Skip to content

N
nebula
Commit 29a00c95 authored by Michael de Hoog's avatar Michael de Hoog
Browse files
Options

Return early if channel is full

parent 8366317b
Show whitespace changes
Inline Side-by-side
Showing with 5 additions and 0 deletions
op-batcher/batcher/channel_manager.go
View file @ 29a00c95
...@@ -199,6 +199,11 @@ func (s *channelManager) TxData(l1Head eth.BlockID) (txData, error) { ...@@ -199,6 +199,11 @@ func (s *channelManager) TxData(l1Head eth.BlockID) (txData, error) {
return txData{}, io.EOF return txData{}, io.EOF
} }
// we have blocks, but we cannot add them to the channel right now
if s.pendingChannel != nil && s.pendingChannel.IsFull() {
return txData{}, io.EOF
}
if err := s.ensurePendingChannel(l1Head); err != nil { if err := s.ensurePendingChannel(l1Head); err != nil {
return txData{}, err return txData{}, err
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment