Browse Source

Fixed chain event issue

obscuren 10 years ago
parent
commit
66d5559866
2 changed files with 3 additions and 7 deletions
  1. 1 3
      core/chain_manager.go
  2. 2 4
      rpc/packages.go

+ 1 - 3
core/chain_manager.go

@@ -396,9 +396,7 @@ func (self *ChainManager) InsertChain(chain types.Blocks) error {
 		self.mu.Unlock()
 
 		if chain {
-			fmt.Println("POST START")
-			self.eventMux.Post(ChainEvent{block, td})
-			fmt.Println("POST END")
+			go self.eventMux.Post(ChainEvent{block, td})
 		}
 
 		if split {

+ 2 - 4
rpc/packages.go

@@ -101,13 +101,11 @@ func (self *EthereumApi) NewFilter(args *FilterOptions, reply *interface{}) erro
 		self.logMut.Lock()
 		defer self.logMut.Unlock()
 
-		if self.logs[id] == nil {
-			self.logs[id] = &logFilter{timeout: time.Now()}
-		}
-
 		self.logs[id].add(logs...)
 	}
 	id = self.filterManager.InstallFilter(filter)
+	self.logs[id] = &logFilter{timeout: time.Now()}
+
 	*reply = id
 
 	return nil