Skip to content

Commit

Permalink
Merge branch 'master' into recognize-batch-poster-backlog
Browse files Browse the repository at this point in the history
  • Loading branch information
PlasmaPower authored Dec 16, 2023
2 parents 21b8a20 + 9b19f6c commit 25b7099
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 5 deletions.
4 changes: 2 additions & 2 deletions arbnode/dataposter/data_poster.go
Original file line number Diff line number Diff line change
Expand Up @@ -907,7 +907,7 @@ var DefaultDataPosterConfig = DataPosterConfig{
WaitForL1Finality: true,
TargetPriceGwei: 60.,
UrgencyGwei: 2.,
MaxMempoolTransactions: 10,
MaxMempoolTransactions: 20,
MinTipCapGwei: 0.05,
MaxTipCapGwei: 5,
NonceRbfSoftConfs: 1,
Expand All @@ -934,7 +934,7 @@ var TestDataPosterConfig = DataPosterConfig{
WaitForL1Finality: false,
TargetPriceGwei: 60.,
UrgencyGwei: 2.,
MaxMempoolTransactions: 10,
MaxMempoolTransactions: 20,
MinTipCapGwei: 0.05,
MaxTipCapGwei: 5,
NonceRbfSoftConfs: 1,
Expand Down
6 changes: 3 additions & 3 deletions arbnode/node.go
Original file line number Diff line number Diff line change
Expand Up @@ -773,9 +773,9 @@ func (n *Node) Start(ctx context.Context) error {
return fmt.Errorf("error initializing feed broadcast server: %w", err)
}
}
if n.InboxTracker != nil && n.BroadcastServer != nil && config.Sequencer && !config.SeqCoordinator.Enable {
// Normally, the sequencer would populate the feed backlog when it acquires the lockout.
// However, if the sequencer coordinator is not enabled, we must populate the backlog on startup.
if n.InboxTracker != nil && n.BroadcastServer != nil && config.Sequencer {
// Even if the sequencer coordinator will populate this backlog,
// we want to make sure it's populated before any clients connect.
err = n.InboxTracker.PopulateFeedBacklog(n.BroadcastServer)
if err != nil {
return fmt.Errorf("error populating feed backlog on startup: %w", err)
Expand Down
1 change: 1 addition & 0 deletions broadcaster/backlog/backlog.go
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,7 @@ func (b *backlog) Append(bm *m.BroadcastMessage) error {
segment = newBacklogSegment()
b.head.Store(segment)
b.tail.Store(segment)
confirmedSequenceNumberGauge.Update(int64(msg.SequenceNumber))
}

prevMsgIdx := segment.End()
Expand Down

0 comments on commit 25b7099

Please sign in to comment.