Skip to content

Commit

Permalink
fix: increase chan length
Browse files Browse the repository at this point in the history
  • Loading branch information
Alok committed Jul 9, 2024
1 parent 37e6b3a commit 14abe88
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 8 deletions.
2 changes: 1 addition & 1 deletion p2p/integrationtest/real-bidder/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ var (
)
bidWorkers = flag.Int(
"bid-workers",
3,
2,
"Number of workers to send bids",
)
)
Expand Down
14 changes: 7 additions & 7 deletions p2p/pkg/preconfirmation/tracker/tracker.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,9 +32,9 @@ type Tracker struct {
newL1Blocks chan *blocktracker.BlocktrackerNewL1Block
enryptedCmts chan *preconfcommstore.PreconfcommitmentstoreEncryptedCommitmentStored
commitments chan *preconfcommstore.PreconfcommitmentstoreCommitmentStored
winners map[int64]*blocktracker.BlocktrackerNewL1Block
metrics *metrics
logger *slog.Logger
winners map[int64]*blocktracker.BlocktrackerNewL1Block
metrics *metrics
logger *slog.Logger
}

type OptsGetter func(context.Context) (*bind.TransactOpts, error)
Expand Down Expand Up @@ -86,12 +86,12 @@ func NewTracker(
preconfContract: preconfContract,
receiptGetter: receiptGetter,
optsGetter: optsGetter,
newL1Blocks: make(chan *blocktracker.BlocktrackerNewL1Block),
newL1Blocks: make(chan *blocktracker.BlocktrackerNewL1Block, 10),
enryptedCmts: make(chan *preconfcommstore.PreconfcommitmentstoreEncryptedCommitmentStored),
commitments: make(chan *preconfcommstore.PreconfcommitmentstoreCommitmentStored),
winners: make(map[int64]*blocktracker.BlocktrackerNewL1Block),
metrics: newMetrics(),
logger: logger,
winners: make(map[int64]*blocktracker.BlocktrackerNewL1Block),
metrics: newMetrics(),
logger: logger,
}
}

Expand Down

0 comments on commit 14abe88

Please sign in to comment.