diff --git a/build/params_debug.go b/build/params_debug.go index 7186ee478..644a5d7b5 100644 --- a/build/params_debug.go +++ b/build/params_debug.go @@ -7,6 +7,8 @@ import "os" // Seconds const BlockDelay = 6 +const PropagationDelay = 3 + // FallbackPoStDelay is the number of epochs the miner needs to wait after // ElectionPeriodStart before starting fallback post computation // diff --git a/build/params_devnet.go b/build/params_devnet.go index c2c1c3905..6f53d2704 100644 --- a/build/params_devnet.go +++ b/build/params_devnet.go @@ -5,6 +5,8 @@ package build // Seconds const BlockDelay = 30 +const PropagationDelay = 5 + // FallbackPoStDelay is the number of epochs the miner needs to wait after // ElectionPeriodStart before starting fallback post computation // diff --git a/chain/store/store.go b/chain/store/store.go index 9f977b161..9f20626e8 100644 --- a/chain/store/store.go +++ b/chain/store/store.go @@ -290,7 +290,7 @@ func (cs *ChainStore) takeHeaviestTipSet(ctx context.Context, ts *types.TipSet) span.AddAttributes(trace.BoolAttribute("newHead", true)) - log.Debugf("New heaviest tipset! %s", ts.Cids()) + log.Infof("New heaviest tipset! %s (height=%d)", ts.Cids()) cs.heaviest = ts if err := cs.writeHead(ts); err != nil { diff --git a/chain/sync_manager.go b/chain/sync_manager.go index 0e296d617..104ca674c 100644 --- a/chain/sync_manager.go +++ b/chain/sync_manager.go @@ -71,7 +71,6 @@ func (sm *SyncManager) Stop() { } func (sm *SyncManager) SetPeerHead(ctx context.Context, p peer.ID, ts *types.TipSet) { - log.Info("set peer head!", ts.Height(), ts.Cids()) sm.lk.Lock() defer sm.lk.Unlock() sm.peerHeads[p] = ts @@ -336,7 +335,6 @@ func (sm *SyncManager) syncWorker(id int) { log.Info("sync manager worker shutting down") return } - log.Info("sync worker go time!", ts.Height(), ts.Cids()) ctx := context.WithValue(context.TODO(), syncStateKey{}, ss) err := sm.doSync(ctx, ts) diff --git a/miner/miner.go b/miner/miner.go index ef5ef0b7c..f4e5b9ea8 100644 --- a/miner/miner.go +++ b/miner/miner.go @@ -27,7 +27,7 @@ func NewMiner(api api.FullNode, epp gen.ElectionPoStProver) *Miner { epp: epp, waitFunc: func(ctx context.Context) error { // Wait around for half the block time in case other parents come in - time.Sleep(build.BlockDelay * time.Second / 2) + time.Sleep(build.PropagationDelay * time.Second) return nil }, }