aboutsummaryrefslogtreecommitdiffstats
path: root/xeth
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2015-07-20 19:02:02 +0800
committerPéter Szilágyi <peterke@gmail.com>2015-07-20 19:02:02 +0800
commit3642441ca3a0afe94e581612ff99aef7f0e66a44 (patch)
tree318bfae73e0e3b392381e7bf2a50019f79fb8fa4 /xeth
parent12bb743b3541c3ce038d26a7f2fc4e28208e5c1f (diff)
downloaddexon-3642441ca3a0afe94e581612ff99aef7f0e66a44.tar.gz
dexon-3642441ca3a0afe94e581612ff99aef7f0e66a44.tar.zst
dexon-3642441ca3a0afe94e581612ff99aef7f0e66a44.zip
xeth: fix #1485, data race in fiilter creation and event firing
Diffstat (limited to 'xeth')
-rw-r--r--xeth/xeth.go9
1 files changed, 9 insertions, 0 deletions
diff --git a/xeth/xeth.go b/xeth/xeth.go
index 19d9c0ad4..34409a148 100644
--- a/xeth/xeth.go
+++ b/xeth/xeth.go
@@ -518,6 +518,9 @@ func (self *XEth) UninstallFilter(id int) bool {
}
func (self *XEth) NewLogFilter(earliest, latest int64, skip, max int, address []string, topics [][]string) int {
+ self.logMu.Lock()
+ defer self.logMu.Unlock()
+
var id int
filter := core.NewFilter(self.backend)
filter.SetEarliestBlock(earliest)
@@ -539,6 +542,9 @@ func (self *XEth) NewLogFilter(earliest, latest int64, skip, max int, address []
}
func (self *XEth) NewTransactionFilter() int {
+ self.transactionMu.Lock()
+ defer self.transactionMu.Unlock()
+
var id int
filter := core.NewFilter(self.backend)
filter.TransactionCallback = func(tx *types.Transaction) {
@@ -553,6 +559,9 @@ func (self *XEth) NewTransactionFilter() int {
}
func (self *XEth) NewBlockFilter() int {
+ self.blockMu.Lock()
+ defer self.blockMu.Unlock()
+
var id int
filter := core.NewFilter(self.backend)
filter.BlockCallback = func(block *types.Block, logs state.Logs) {