diff --git a/pkg/innerring/blocktimer.go b/pkg/innerring/blocktimer.go index 0fe4daed34..38d58edcf6 100644 --- a/pkg/innerring/blocktimer.go +++ b/pkg/innerring/blocktimer.go @@ -95,8 +95,11 @@ func newEpochTimer(args *epochTimerArgs) *timer.BlockTimer { return } + estimationEpoch := epochN - 1 + args.l.Info("stop estimation collections", zap.Uint64("epoch", estimationEpoch)) + prm := container.StopEstimationPrm{} - prm.SetEpoch(epochN - 1) + prm.SetEpoch(estimationEpoch) err := args.cnrWrapper.StopEstimation(prm) if err != nil { diff --git a/pkg/innerring/processors/netmap/process_epoch.go b/pkg/innerring/processors/netmap/process_epoch.go index 7314e0e896..745766c412 100644 --- a/pkg/innerring/processors/netmap/process_epoch.go +++ b/pkg/innerring/processors/netmap/process_epoch.go @@ -45,12 +45,16 @@ func (np *Processor) processNewEpoch(ev netmapEvent.NewEpoch) { return } + estimationEpoch := epoch - 1 + prm := cntClient.StartEstimationPrm{} - prm.SetEpoch(epoch - 1) + prm.SetEpoch(estimationEpoch) prm.SetHash(ev.TxHash()) if epoch > 0 { // estimates are invalid in genesis epoch + np.log.Info("start estimation collection", zap.Uint64("epoch", estimationEpoch)) + err = np.containerWrp.StartEstimation(prm) if err != nil {