diff --git a/synchronizer/synchronizer.go b/synchronizer/synchronizer.go index c8005f8..3a7e009 100644 --- a/synchronizer/synchronizer.go +++ b/synchronizer/synchronizer.go @@ -335,7 +335,7 @@ func (s *Synchronizer) updateCurrentSlot(slot *common.Slot, reset bool, hasBatch // We want the next block because the current one is already mined blockNum := s.stats.Sync.LastBlock.Num + 1 slotNum := s.consts.Auction.SlotNum(blockNum) - firstBatchBlockNum := s.stats.Sync.LastBlock.Num + syncLastBlockNum := s.stats.Sync.LastBlock.Num if reset { // Using this query only to know if there dbFirstBatchBlockNum, err := s.historyDB.GetFirstBatchBlockNumBySlot(slotNum) @@ -345,7 +345,7 @@ func (s *Synchronizer) updateCurrentSlot(slot *common.Slot, reset bool, hasBatch hasBatch = false } else { hasBatch = true - firstBatchBlockNum = dbFirstBatchBlockNum + syncLastBlockNum = dbFirstBatchBlockNum } slot.ForgerCommitment = false } else if slotNum > slot.SlotNum { @@ -354,16 +354,14 @@ func (s *Synchronizer) updateCurrentSlot(slot *common.Slot, reset bool, hasBatch } slot.SlotNum = slotNum slot.StartBlock, slot.EndBlock = s.consts.Auction.SlotBlocks(slot.SlotNum) + if hasBatch && s.consts.Auction.RelativeBlock(syncLastBlockNum) < int64(s.vars.Auction.SlotDeadline) { + slot.ForgerCommitment = true + } // If Synced, update the current coordinator if s.stats.Synced() && blockNum >= s.consts.Auction.GenesisBlockNum { if err := s.setSlotCoordinator(slot); err != nil { return tracerr.Wrap(err) } - if hasBatch && - s.consts.Auction.RelativeBlock(firstBatchBlockNum) < - int64(s.vars.Auction.SlotDeadline) { - slot.ForgerCommitment = true - } // TODO: Remove this SANITY CHECK once this code is tested enough // BEGIN SANITY CHECK