lock

ethmonitor/ethmonitor.go

@@ -311,6 +311,7 @@ func (m *Monitor) monitor() error {
 			// build deterministic set of add/remove events which construct the canonical chain
 			events, err = m.buildCanonicalChain(ctx, nextBlock, nextBlockPayload, events)
 			if err != nil {
+				// TODO: polygon-zkevm stuck here.. retrying to find the block hash for too long.. prob cuz the block is gone..
 				m.log.Warnf("ethmonitor: error reported '%v', failed to build chain for next blockNum:%d blockHash:%s, retrying..",
 					err, nextBlock.NumberU64(), nextBlock.Hash().Hex())
 
@@ -427,7 +428,9 @@ func (m *Monitor) addLogs(ctx context.Context, blocks Blocks) {
 		// do not attempt to get logs for re-org'd blocks as the data
 		// will be inconsistent and may never be available.
 		if block.Event == Removed {
+			m.chain.mu.Lock()
 			block.OK = true
+			m.chain.mu.Unlock()
 			continue
 		}
 
@@ -444,6 +447,7 @@ func (m *Monitor) addLogs(ctx context.Context, blocks Blocks) {
 			// check the logsBloom from the block to check if we should be expecting logs. logsBloom
 			// will be included for any indexed logs.
 			if len(logs) > 0 || block.Bloom() == (types.Bloom{}) {
+				m.chain.mu.Lock()
 				// successful backfill
 				if logs == nil {
 					block.Logs = []types.Log{}
@@ -452,13 +456,16 @@ func (m *Monitor) addLogs(ctx context.Context, blocks Blocks) {
 				}
 				block.LogsPayload = m.setPayload(logsPayload)
 				block.OK = true
+				m.chain.mu.Unlock()
 				continue
 			}
 		}
 
 		// mark for backfilling
+		m.chain.mu.Lock()
 		block.Logs = nil
 		block.OK = false
+		m.chain.mu.Unlock()
 
 		// NOTE: we do not error here as these logs will be backfilled before they are published anyways,
 		// but we log the error anyways.