Skip to content

N
nebula
Commit f33a0a9e authored by George Knee's avatar George Knee Committed by GitHub
Browse files
Options

increase metric properly when blocks are requeued (#12326)

parent d062c1c5
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 0 deletions
op-batcher/batcher/channel_manager.go
View file @ f33a0a9e
...@@ -493,6 +493,11 @@ func (s *channelManager) Requeue(newCfg ChannelConfig) { ...@@ -493,6 +493,11 @@ func (s *channelManager) Requeue(newCfg ChannelConfig) {
// We put the blocks back at the front of the queue: // We put the blocks back at the front of the queue:
s.blocks.Prepend(blocksToRequeue...) s.blocks.Prepend(blocksToRequeue...)
for _, b := range blocksToRequeue {
s.metr.RecordL2BlockInPendingQueue(b)
}
// Channels which where already being submitted are put back // Channels which where already being submitted are put back
s.channelQueue = newChannelQueue s.channelQueue = newChannelQueue
s.currentChannel = nil s.currentChannel = nil
......
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