cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

fix stats tool

Browse Source
This commit is contained in:
whyrusleeping 2019-11-17 15:29:56 -06:00
parent 86221f3569
commit 0ccaa71545
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tools/stats/rpc.go
View File

@ -6,13 +6,13 @@ import (
"net/http" "net/http"
"time" "time"
"github.com/multiformats/go-multiaddr-net" manet "github.com/multiformats/go-multiaddr-net"
"golang.org/x/xerrors" "golang.org/x/xerrors"
"github.com/filecoin-project/lotus/api" "github.com/filecoin-project/lotus/api"
"github.com/filecoin-project/lotus/api/client" "github.com/filecoin-project/lotus/api/client"
"github.com/filecoin-project/lotus/chain" "github.com/filecoin-project/lotus/build"
"github.com/filecoin-project/lotus/chain/store" "github.com/filecoin-project/lotus/chain/store"
"github.com/filecoin-project/lotus/chain/types" "github.com/filecoin-project/lotus/chain/types"
"github.com/filecoin-project/lotus/lib/jsonrpc" "github.com/filecoin-project/lotus/lib/jsonrpc"
@ -50,15 +50,15 @@ func WaitForSyncComplete(ctx context.Context, napi api.FullNode) error {
select { select {
case <-ctx.Done(): case <-ctx.Done():
return ctx.Err() return ctx.Err()
case <-time.After(30 * time.Second): case <-time.After(3 * time.Second):
state, err := napi.SyncState(ctx) head, err := napi.ChainHead(ctx)
if err != nil { if err != nil {
return err return err
} }
log.Printf("Stage %s, Height %d", chain.SyncStageString(state.Stage), state.Height) log.Printf("Height %d", head.Height())
if state.Stage == api.StageSyncComplete { if time.Now().Unix()-int64(head.MinTimestamp()) < build.BlockDelay {
return nil return nil
} }
} }