Skip to content

Commit 737ab9e

Browse files
committed
fix: prover too late
1 parent bed98b1 commit 737ab9e

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

packages/taiko-client/driver/chain_syncer/blob/syncer.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -542,7 +542,7 @@ func (s *Syncer) checkLastVerifiedBlockMismatch(ctx context.Context) (*rpc.Reorg
542542
if err != nil {
543543
return nil, err
544544
}
545-
if s.state.GetL2Head().Number.Uint64() < stateVars.B.LastVerifiedBlockId || s.state.GetL2Head().Number.Uint64() >= s.state.OnTakeForkHeight.Uint64() {
545+
if s.state.GetL2Head().Number.Uint64() < stateVars.B.LastVerifiedBlockId || s.state.GetL2Head().Number.Uint64() <= s.state.OnTakeForkHeight.Uint64() {
546546
return reorgCheckResult, nil
547547
}
548548

packages/taiko-client/prover/event_handler/block_proposed.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,11 @@ func (h *BlockProposedEventHandler) Handle(
9494
end()
9595
return nil
9696
}
97+
if len(h.proofSubmissionCh) == cap(h.proofSubmissionCh) {
98+
log.Info("onBlockProposed callback early return", "proofSubmissionChannelLength", len(h.proofSubmissionCh))
99+
end()
100+
return nil
101+
}
97102

98103
// Wait for the corresponding L2 block being mined in node.
99104
if _, err := h.rpc.WaitL2Header(ctx, meta.GetBlockID()); err != nil {

0 commit comments

Comments
 (0)