Skip to content

Commit 3401804

Browse files
authored
perf: use pipelining in chainsync input (#444)
Fixes #443 Signed-off-by: Aurora Gaffney <[email protected]>
1 parent 2382639 commit 3401804

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

input/chainsync/chainsync.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -217,6 +217,8 @@ func (c *ChainSync) setupConnection() error {
217217
ochainsync.NewConfig(
218218
ochainsync.WithRollForwardFunc(c.handleRollForward),
219219
ochainsync.WithRollBackwardFunc(c.handleRollBackward),
220+
// Enable pipelining of RequestNext messages to speed up chainsync
221+
ochainsync.WithPipelineLimit(50),
220222
),
221223
),
222224
ouroboros.WithBlockFetchConfig(

0 commit comments

Comments
 (0)