aboutsummaryrefslogtreecommitdiffstats
path: root/eth/backend.go
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2015-04-24 16:19:33 +0800
committerPéter Szilágyi <peterke@gmail.com>2015-04-24 16:33:55 +0800
commit6def110c37d4d43402c4b658ce6b291400f840e5 (patch)
treefc1dbd81120ba8a51599bfb3dbc41f0eed9a2005 /eth/backend.go
parent971702e7a1a5e698721fa6147c444abad9c20141 (diff)
downloadgo-tangerine-6def110c37d4d43402c4b658ce6b291400f840e5.tar.gz
go-tangerine-6def110c37d4d43402c4b658ce6b291400f840e5.tar.zst
go-tangerine-6def110c37d4d43402c4b658ce6b291400f840e5.zip
cmd/bootnode, eth, p2p, p2p/discover: clean up the seeder and mesh into eth.
Diffstat (limited to 'eth/backend.go')
-rw-r--r--eth/backend.go13
1 files changed, 10 insertions, 3 deletions
diff --git a/eth/backend.go b/eth/backend.go
index 382cfc832..039f730f1 100644
--- a/eth/backend.go
+++ b/eth/backend.go
@@ -125,6 +125,8 @@ type Ethereum struct {
blockDb common.Database // Block chain database
stateDb common.Database // State changes database
extraDb common.Database // Extra database (txs, etc)
+ seedDb *discover.Cache // Peer database seeding the bootstrap
+
// Closed when databases are flushed and closed
databasesClosed chan bool
@@ -179,7 +181,10 @@ func New(config *Config) (*Ethereum, error) {
if err != nil {
return nil, err
}
- seedDbPath := path.Join(config.DataDir, "seeds")
+ seedDb, err := discover.NewPersistentCache(path.Join(config.DataDir, "seeds"))
+ if err != nil {
+ return nil, err
+ }
// Perform database sanity checks
d, _ := blockDb.Get([]byte("ProtocolVersion"))
@@ -207,6 +212,7 @@ func New(config *Config) (*Ethereum, error) {
blockDb: blockDb,
stateDb: stateDb,
extraDb: extraDb,
+ seedDb: seedDb,
eventMux: &event.TypeMux{},
accountManager: config.AccountManager,
DataDir: config.DataDir,
@@ -244,7 +250,7 @@ func New(config *Config) (*Ethereum, error) {
NAT: config.NAT,
NoDial: !config.Dial,
BootstrapNodes: config.parseBootNodes(),
- SeedCache: seedDbPath,
+ SeedCache: seedDb,
}
if len(config.Port) > 0 {
eth.net.ListenAddr = ":" + config.Port
@@ -423,6 +429,7 @@ done:
}
}
+ s.seedDb.Close()
s.blockDb.Close()
s.stateDb.Close()
s.extraDb.Close()
@@ -450,7 +457,7 @@ func (self *Ethereum) SuggestPeer(nodeURL string) error {
}
func (s *Ethereum) Stop() {
- s.txSub.Unsubscribe() // quits txBroadcastLoop
+ s.txSub.Unsubscribe() // quits txBroadcastLoop
s.protocolManager.Stop()
s.txPool.Stop()