(incubator-devlake) branch main updated: fix(ipc): increase scanner buffer size to 5MB to handle large outputs (#8841)

[klesh]

This is an automated email from the ASF dual-hosted git repository.

klesh pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git


The following commit(s) were added to refs/heads/main by this push:
     new 78cb8d79b fix(ipc): increase scanner buffer size to 5MB to handle 
large outputs (#8841)
78cb8d79b is described below

commit 78cb8d79b77b6d496f7a953f036791f79b62b876
Author: rohit singh gulia <rg...@njit.edu>
AuthorDate: Mon May 4 21:53:45 2026 -0400

    fix(ipc): increase scanner buffer size to 5MB to handle large outputs 
(#8841)
---
 backend/core/utils/ipc.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/backend/core/utils/ipc.go b/backend/core/utils/ipc.go
index 4a0f814bf..f8bb156f0 100644
--- a/backend/core/utils/ipc.go
+++ b/backend/core/utils/ipc.go
@@ -238,6 +238,7 @@ func scanOutputPipe(pipe io.ReadCloser, wg *sync.WaitGroup, 
onReceive func([]byt
        responseCreator func([]byte) *ProcessResponse, outboundChannel chan<- 
*ProcessResponse) func() {
        return func() {
                scanner := bufio.NewScanner(pipe)
+               scanner.Buffer(make([]byte, 5*1024*1024), 5*1024*1024)
                scanner.Split(bufio.ScanLines)
                for scanner.Scan() {
                        src := scanner.Bytes()
@@ -256,6 +257,7 @@ func scanErrorPipe(pipe io.ReadCloser, onReceive 
func([]byte), outboundChannel c
        remoteErrorMsg := &strings.Builder{}
        return func() {
                scanner := bufio.NewScanner(pipe)
+               scanner.Buffer(make([]byte, 5*1024*1024), 5*1024*1024)
                scanner.Split(bufio.ScanLines)
                for scanner.Scan() {
                        src := scanner.Bytes()