JOJ/JOJ3
24
5
Fork 0
Code Issues 5 Pull Requests Actions Packages Projects Releases Wiki Activity

feat(executor): default 512 MB grpc msg size
All checks were successful
submodules sync / sync (push) Successful in 41s
Details
build / build (push) Successful in 1m17s
Details
build / trigger-build-image (push) Successful in 7s
Details

Browse Source
This commit is contained in:
张泊明518370910136 2024-11-06 07:20:05 -05:00
parent 0cb1a63025
commit adb9dd2a9a
Signed by: 张泊明518370910136
GPG Key ID: D47306D7062CDA9D
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/executor/sandbox/executor.go
View File

@ -59,7 +59,7 @@ func (e *Sandbox) Run(cmds []stage.Cmd) ([]stage.ExecutorResult, error) {
) )
} }
} }
slog.Debug("sandbox execute", "total protobuf cmd size", totalPbCmdSize) slog.Info("sandbox execute", "total protobuf cmd size", totalPbCmdSize)
pbReq := &pb.Request{Cmd: pbCmds} pbReq := &pb.Request{Cmd: pbCmds}
pbRet, err := e.execClient.Exec(context.TODO(), pbReq) pbRet, err := e.execClient.Exec(context.TODO(), pbReq)
if err != nil { if err != nil {

3
internal/executor/sandbox/grpc.go
View File

@ -23,6 +23,9 @@ func createExecClient(execServer, token string) (pb.ExecutorClient, error) {
func createGRPCConnection(addr, token string) (*grpc.ClientConn, error) { func createGRPCConnection(addr, token string) (*grpc.ClientConn, error) {
opts := []grpc.DialOption{ opts := []grpc.DialOption{
grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithTransportCredentials(insecure.NewCredentials()),
grpc.WithDefaultCallOptions(
grpc.MaxCallRecvMsgSize(512 * 1024 * 1024), // 512 MB
),
} }
if token != "" { if token != "" {
opts = append(opts, grpc.WithPerRPCCredentials(newTokenAuth(token))) opts = append(opts, grpc.WithPerRPCCredentials(newTokenAuth(token)))