update

sequencesender/sequencesender.go

@@ -25,6 +25,7 @@ import (
 )
 
 const ten = 10
+const multipleBatchSize = 5
 
 // EthTxManager represents the eth tx manager interface
 type EthTxManager interface {
@@ -176,6 +177,11 @@ func (s *SequenceSender) batchRetrieval(ctx context.Context) error {
 			s.logger.Info("context cancelled, stopping batch retrieval")
 			return ctx.Err()
 		default:
+			if s.checkWait() {
+				<-ticker.C
+				continue
+			}
+
 			// Try to retrieve batch from RPC
 			rpcBatch, err := s.rpcClient.GetBatch(currentBatchNumber)
 			if err != nil {
@@ -206,6 +212,17 @@ func (s *SequenceSender) batchRetrieval(ctx context.Context) error {
 	}
 }
 
+func (s *SequenceSender) checkWait() bool {
+	s.mutexSequence.Lock()
+	defer s.mutexSequence.Unlock()
+
+	if uint64(len(s.sequenceList)) >= s.cfg.MaxBatchesForL1*multipleBatchSize {
+		s.logger.Infof("Sequence list is full: %d, waiting to sync batch from rpc.", len(s.sequenceList))
+		return true
+	}
+	return false
+}
+
 func (s *SequenceSender) populateSequenceData(rpcBatch *types.RPCBatch, batchNumber uint64) error {
 	s.mutexSequence.Lock()
 	defer s.mutexSequence.Unlock()