egor3f/kittenipc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

larger buffer

Browse Source
This commit is contained in:
Egor Aristov 2025-11-06 10:47:32 +03:00
parent 9a7ee9f284
commit b5b97c4b8d
Signed by: egor3f
GPG Key ID: 40482A264AAEC85F
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/golang/lib.go
View File

@ -22,6 +22,7 @@ import (
) )
const ipcSocketArg = "--ipc-socket" const ipcSocketArg = "--ipc-socket"
const maxMessageLength = 1 * 1024 * 1024 * 1024 // 1 gigabyte
type StdioMode int type StdioMode int
@ -61,6 +62,7 @@ type ipcCommon struct {
func (ipc *ipcCommon) readConn() { func (ipc *ipcCommon) readConn() {
scn := bufio.NewScanner(ipc.conn) scn := bufio.NewScanner(ipc.conn)
scn.Buffer(nil, maxMessageLength)
for scn.Scan() { for scn.Scan() {
var msg Message var msg Message
if err := json.Unmarshal(scn.Bytes(), &msg); err != nil { if err := json.Unmarshal(scn.Bytes(), &msg); err != nil {