@@ -36,7 +36,7 @@ import (
3636
3737const (
3838 defaultDownloadDir = ".cq"
39- maxMsgSize = 100 * 1024 * 1024 // 100 MiB
39+ maxGrpcMsgSize = 200 * 1024 * 1024 // 200 MiB
4040
4141 containerPortMappingRetries = 30
4242 containerPortMappingInitialRetryDelay = 100 * time .Millisecond
@@ -579,8 +579,8 @@ func (c *Client) connectUsingTCP(ctx context.Context, path string) error {
579579 c .Conn , err = grpc .DialContext (ctx , path ,
580580 grpc .WithTransportCredentials (insecure .NewCredentials ()),
581581 grpc .WithDefaultCallOptions (
582- grpc .MaxCallRecvMsgSize (maxMsgSize ),
583- grpc .MaxCallSendMsgSize (maxMsgSize ),
582+ grpc .MaxCallRecvMsgSize (maxGrpcMsgSize ),
583+ grpc .MaxCallSendMsgSize (maxGrpcMsgSize ),
584584 ),
585585 )
586586 if err != nil {
@@ -626,8 +626,8 @@ func (c *Client) connectToUnixSocket(ctx context.Context) error {
626626 grpc .WithBlock (),
627627 grpc .WithContextDialer (dialer ),
628628 grpc .WithDefaultCallOptions (
629- grpc .MaxCallRecvMsgSize (maxMsgSize ),
630- grpc .MaxCallSendMsgSize (maxMsgSize ),
629+ grpc .MaxCallRecvMsgSize (maxGrpcMsgSize ),
630+ grpc .MaxCallSendMsgSize (maxGrpcMsgSize ),
631631 ))
632632 return err
633633}
0 commit comments