From 2ba7a90e526667e381330a6044199fa6de487bef Mon Sep 17 00:00:00 2001 From: Lee Bousfield Date: Wed, 31 Jul 2024 10:45:50 -0500 Subject: [PATCH] Wait for the insertion mutex in WriteMessageFromSequencer --- arbnode/transaction_streamer.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/arbnode/transaction_streamer.go b/arbnode/transaction_streamer.go index 90e7feddc6..dd87b5e662 100644 --- a/arbnode/transaction_streamer.go +++ b/arbnode/transaction_streamer.go @@ -952,9 +952,7 @@ func (s *TransactionStreamer) WriteMessageFromSequencer( if err := s.ExpectChosenSequencer(); err != nil { return err } - if !s.insertionMutex.TryLock() { - return execution.ErrSequencerInsertLockTaken - } + s.insertionMutex.Lock() defer s.insertionMutex.Unlock() msgCount, err := s.GetMessageCount()