RanchiMall/blockbook
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Move start of http interface before initial sync

Browse Source 
This allows to collect metrics during initial sync
This commit is contained in:
Martin Boehm 2018-03-13 16:10:38 +01:00
parent a86e948e78
commit b412b60c9c
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
blockbook.go
View File

@ -143,22 +143,6 @@ func main() {
return return
} }
syncWorker, err = db.NewSyncWorker(index, chain, *syncWorkers, *syncChunk, *blockFrom, *dryRun, chanOsSignal, metrics)
if err != nil {
glog.Fatalf("NewSyncWorker %v", err)
}
if *synchronize {
if err := syncWorker.ResyncIndex(nil); err != nil {
glog.Error("resyncIndex ", err)
return
}
if err = chain.ResyncMempool(nil); err != nil {
glog.Error("resyncMempool ", err)
return
}
}
if txCache, err = db.NewTxCache(index, chain, metrics); err != nil { if txCache, err = db.NewTxCache(index, chain, metrics); err != nil {
glog.Error("txCache ", err) glog.Error("txCache ", err)
return return
@ -184,6 +168,22 @@ func main() {
}() }()
} }
syncWorker, err = db.NewSyncWorker(index, chain, *syncWorkers, *syncChunk, *blockFrom, *dryRun, chanOsSignal, metrics)
if err != nil {
glog.Fatalf("NewSyncWorker %v", err)
}
if *synchronize {
if err := syncWorker.ResyncIndex(nil); err != nil {
glog.Error("resyncIndex ", err)
return
}
if err = chain.ResyncMempool(nil); err != nil {
glog.Error("resyncMempool ", err)
return
}
}
var socketIoServer *server.SocketIoServer var socketIoServer *server.SocketIoServer
if *socketIoBinding != "" { if *socketIoBinding != "" {
socketIoServer, err = server.NewSocketIoServer( socketIoServer, err = server.NewSocketIoServer(