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

drop a few logs down to debug

Browse Source
This commit is contained in:
whyrusleeping 2020-11-12 11:25:22 -08:00
parent 36b78b1891
commit 7921f8d713
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
chain/sync_manager.go
View File

@ -194,7 +194,7 @@ func (sm *syncManager) scheduler() {
}
func (sm *syncManager) handlePeerHead(head peerHead) {
log.Infof("new peer head: %s %s", head.p, head.ts)
log.Debugf("new peer head: %s %s", head.p, head.ts)
// have we started syncing yet?
if sm.nextWorker == 0 {
@ -410,7 +410,7 @@ func (sm *syncManager) addSyncTarget(ts *types.TipSet) (*types.TipSet, bool, err
// if we have not finished the initial sync or have too many workers, add it to the deferred queue;
// it will be processed once a worker is freed from syncing a chain (or the initial sync finishes)
if !sm.initialSyncDone || len(sm.state) >= MaxSyncWorkers {
log.Infof("deferring sync on %s", ts)
log.Debugf("deferring sync on %s", ts)
sm.deferred.Insert(ts)
return nil, false, nil
}

5
node/hello/hello.go
View File

@ -161,7 +161,8 @@ func (hs *Service) SayHello(ctx context.Context, pid peer.ID) error {
_ = s.SetReadDeadline(build.Clock.Now().Add(10 * time.Second))
err := cborutil.ReadCborRPC(s, lmsg)
if err != nil {
log.Infow("reading latency message", "error", err)
log.Debugw("reading latency message", "error", err)
// TODO: should we just return right here?
}
t3 := build.Clock.Now()
@ -177,7 +178,7 @@ func (hs *Service) SayHello(ctx context.Context, pid peer.ID) error {
t2 := time.Unix(0, lmsg.TSent)
offset := t0.Sub(t1) + t3.Sub(t2)
offset /= 2
log.Infow("time offset", "offset", offset.Seconds(), "peerid", pid.String())
log.Debugw("time offset", "offset", offset.Seconds(), "peerid", pid.String())
}
}
}()