Synchronize mempool before starting server interfaces
parent
d1c4c66c5f
commit
98d91d4ce1
|
@ -151,6 +151,10 @@ func main() {
|
||||||
glog.Error("resyncIndex ", err)
|
glog.Error("resyncIndex ", err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
if err = mempool.Resync(nil); err != nil {
|
||||||
|
glog.Error("resyncIndex ", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if txCache, err = db.NewTxCache(index, chain); err != nil {
|
if txCache, err = db.NewTxCache(index, chain); err != nil {
|
||||||
|
@ -204,8 +208,6 @@ func main() {
|
||||||
// start the synchronization loops after the server interfaces are started
|
// start the synchronization loops after the server interfaces are started
|
||||||
go syncIndexLoop()
|
go syncIndexLoop()
|
||||||
go syncMempoolLoop()
|
go syncMempoolLoop()
|
||||||
// sync mempool immediately
|
|
||||||
chanSyncMempool <- struct{}{}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
var mq *bchain.MQ
|
var mq *bchain.MQ
|
||||||
|
|
Loading…
Reference in New Issue