From 0ccaa7154599049a30eb68e809a261b4aa455823 Mon Sep 17 00:00:00 2001 From: whyrusleeping Date: Sun, 17 Nov 2019 15:29:56 -0600 Subject: [PATCH] fix stats tool --- tools/stats/rpc.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/tools/stats/rpc.go b/tools/stats/rpc.go index 32943c16f..c2131b480 100644 --- a/tools/stats/rpc.go +++ b/tools/stats/rpc.go @@ -6,13 +6,13 @@ import ( "net/http" "time" - "github.com/multiformats/go-multiaddr-net" + manet "github.com/multiformats/go-multiaddr-net" "golang.org/x/xerrors" "github.com/filecoin-project/lotus/api" "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/types" "github.com/filecoin-project/lotus/lib/jsonrpc" @@ -50,15 +50,15 @@ func WaitForSyncComplete(ctx context.Context, napi api.FullNode) error { select { case <-ctx.Done(): return ctx.Err() - case <-time.After(30 * time.Second): - state, err := napi.SyncState(ctx) + case <-time.After(3 * time.Second): + head, err := napi.ChainHead(ctx) if err != nil { 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 } }