Skip to content

Commit

Permalink
fix: estore default message queue size in PubSub module
Browse files Browse the repository at this point in the history
  • Loading branch information
Ja7ad committed Dec 10, 2024
1 parent c7ab5d8 commit 47772fe
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions network/gossip.go
Original file line number Diff line number Diff line change
Expand Up @@ -35,11 +35,10 @@ func newGossipService(ctx context.Context, host lp2phost.Host, conf *Config,
lp2pps.WithMessageSignaturePolicy(lp2pps.StrictNoSign),
lp2pps.WithNoAuthor(),
lp2pps.WithMessageIdFn(MessageIDFunc),
lp2pps.WithPeerOutboundQueueSize(600),
}

if conf.IsBootstrapper {
// enable Peer eXchange on bootstrappers
// enable Peer exchange on bootstrappers

Check warning on line 41 in network/gossip.go

View check run for this annotation

Codecov / codecov/patch

network/gossip.go#L41

Added line #L41 was not covered by tests
opts = append(opts, lp2pps.WithPeerExchange(true))
}

Expand Down

0 comments on commit 47772fe

Please sign in to comment.