Allow context cancelations for backlogged sequencer txs

OffchainLabs · Apr 7, 2022 · 0b690fb · 0b690fb
1 parent 98754a4
commit 0b690fb
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/arbnode/sequencer.go b/arbnode/sequencer.go
@@ -67,12 +67,17 @@ func NewSequencer(txStreamer *TransactionStreamer, l1Client arbutil.L1Interface,
 
 func (s *Sequencer) PublishTransaction(ctx context.Context, tx *types.Transaction) error {
 	resultChan := make(chan error, 1)
-	s.txQueue <- txQueueItem{
+	queueItem := txQueueItem{
 		tx,
 		resultChan,
 		ctx,
 	}
 	select {
+	case s.txQueue <- queueItem:
+	case <-ctx.Done():
+		return ctx.Err()
+	}
+	select {
 	case res := <-resultChan:
 		return res
 	case <-ctx.Done():