opencode/picoclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(bus): increase message bus buffer size from 16 to 64

Browse source 
Prevents potential backpressure under load when multiple channels
publish concurrently in gateway mode, where SDK callbacks blocking
on a full buffer can cause message loss or timeouts.
This commit is contained in:
Hoshina 2026-02-26 22:46:57 +08:00
parent 0a7c929905
commit 1d4fe4652a
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pkg/bus/bus.go
View file

@ -11,7 +11,7 @@ import (
// ErrBusClosed is returned when publishing to a closed MessageBus. // ErrBusClosed is returned when publishing to a closed MessageBus.
var ErrBusClosed = errors.New("message bus closed") var ErrBusClosed = errors.New("message bus closed")
const defaultBusBufferSize = 16 const defaultBusBufferSize = 64
type MessageBus struct { type MessageBus struct {
inbound chan InboundMessage inbound chan InboundMessage