Increase buffer size for raft msgs

alpe · alpe · commit b34d7a054ddb · 2025-11-19T11:10:43.000+01:00
diff --git a/block/internal/syncing/raft_retriever.go b/block/internal/syncing/raft_retriever.go
@@ -55,7 +55,7 @@ func (r *raftRetriever) Start(ctx context.Context) error {
 		return errors.New("syncer already started")
 	}
 	ctx, r.cancel = context.WithCancel(ctx)
-	applyCh := make(chan raft.RaftApplyMsg)
+	applyCh := make(chan raft.RaftApplyMsg, 1)
 	r.raftNode.SetApplyCallback(applyCh)
 
 	r.wg.Add(1)

Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ func (r *raftRetriever) Start(ctx context.Context) error {`
`55`	`55`	`return errors.New("syncer already started")`
`56`	`56`	`}`
`57`	`57`	`ctx, r.cancel = context.WithCancel(ctx)`
`58`		`- applyCh := make(chan raft.RaftApplyMsg)`
	`58`	`+ applyCh := make(chan raft.RaftApplyMsg, 1)`
`59`	`59`	`r.raftNode.SetApplyCallback(applyCh)`
`60`	`60`
`61`	`61`	`r.wg.Add(1)`