From ba43364f36db690528cc62196969414ef5e98833 Mon Sep 17 00:00:00 2001 From: obscuren Date: Wed, 24 Sep 2014 11:41:57 +0200 Subject: tmp --- ethereum.go | 1 - 1 file changed, 1 deletion(-) (limited to 'ethereum.go') diff --git a/ethereum.go b/ethereum.go index 09665336c..8f667b786 100644 --- a/ethereum.go +++ b/ethereum.go @@ -383,7 +383,6 @@ func (s *Ethereum) ReapDeadPeerHandler() { // Start the ethereum func (s *Ethereum) Start(seed bool) { s.reactor.Start() - s.blockPool.Start() // Bind to addr and port ln, err := net.Listen("tcp", ":"+s.Port) if err != nil { -- cgit From cba2f6c2c472d5818541f6eabf3e18196d0c477d Mon Sep 17 00:00:00 2001 From: obscuren Date: Wed, 24 Sep 2014 19:56:21 +0200 Subject: Block pool stop / start --- ethereum.go | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'ethereum.go') diff --git a/ethereum.go b/ethereum.go index 8f667b786..d04b08960 100644 --- a/ethereum.go +++ b/ethereum.go @@ -158,6 +158,9 @@ func (s *Ethereum) StateManager() *ethchain.StateManager { func (s *Ethereum) TxPool() *ethchain.TxPool { return s.txPool } +func (s *Ethereum) BlockPool() *BlockPool { + return s.blockPool +} func (self *Ethereum) Db() ethutil.Database { return self.db } @@ -383,6 +386,7 @@ func (s *Ethereum) ReapDeadPeerHandler() { // Start the ethereum func (s *Ethereum) Start(seed bool) { s.reactor.Start() + s.blockPool.Start() // Bind to addr and port ln, err := net.Listen("tcp", ":"+s.Port) if err != nil { @@ -503,6 +507,7 @@ func (s *Ethereum) Stop() { s.stateManager.Stop() s.reactor.Flush() s.reactor.Stop() + s.blockPool.Stop() ethlogger.Infoln("Server stopped") close(s.shutdownChan) -- cgit