fix

taikoxyz · Oct 9, 2024 · 2328487 · 2328487
1 parent a2fe08d
commit 2328487
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/packages/taiko-client/prover/proof_submitter/proof_submitter.go b/packages/taiko-client/prover/proof_submitter/proof_submitter.go
@@ -159,6 +159,12 @@ func (s *ProofSubmitter) RequestProof(ctx context.Context, meta metadata.TaikoBl
 				log.Error("Failed to request proof, context is canceled", "blockID", opts.BlockID, "error", ctx.Err())
 				return nil
 			}
+			// Check if there is full buffer
+			if s.proofBuffer.MaxLength == uint64(s.proofBuffer.Len()) {
+				log.Debug("Buffer is full now, try to aggregate firstly", "blockID", meta.GetBlockID())
+				s.aggregationNotify <- s.Tier()
+				return errBufferOverflow
+			}
 			// Check if there is a need to generate proof
 			proofStatus, err := rpc.GetBlockProofStatus(
 				ctx,