Merge pull request #63 from mark4z/merge/grpc

AlexStocks · web-flow · commit df20316cdac5 · 2023-03-03T21:15:43.000+08:00
fix max message size
diff --git a/pkg/triple/dubbo3_server.go b/pkg/triple/dubbo3_server.go
@@ -212,10 +212,10 @@ func newGrpcServerWithCodec(opt *config.Option) *grpc.Server {
 	}
 
 	if opt.GRPCMaxServerRecvMsgSize != 0 {
-		serverOpts = append(serverOpts, grpc.MaxRecvMsgSize(opt.GRPCMaxServerSendMsgSize))
+		serverOpts = append(serverOpts, grpc.MaxRecvMsgSize(opt.GRPCMaxServerRecvMsgSize))
 	}
 	if opt.GRPCMaxCallSendMsgSize != 0 {
-		serverOpts = append(serverOpts, grpc.MaxSendMsgSize(opt.GRPCMaxServerRecvMsgSize))
+		serverOpts = append(serverOpts, grpc.MaxSendMsgSize(opt.GRPCMaxCallSendMsgSize))
 	}
 
 	if opt.ProxyModeEnable {

Original file line number	Diff line number	Diff line change
`@@ -212,10 +212,10 @@ func newGrpcServerWithCodec(opt config.Option) grpc.Server {`
`212`	`212`	`}`
`213`	`213`
`214`	`214`	`if opt.GRPCMaxServerRecvMsgSize != 0 {`
`215`		`- serverOpts = append(serverOpts, grpc.MaxRecvMsgSize(opt.GRPCMaxServerSendMsgSize))`
	`215`	`+ serverOpts = append(serverOpts, grpc.MaxRecvMsgSize(opt.GRPCMaxServerRecvMsgSize))`
`216`	`216`	`}`
`217`	`217`	`if opt.GRPCMaxCallSendMsgSize != 0 {`
`218`		`- serverOpts = append(serverOpts, grpc.MaxSendMsgSize(opt.GRPCMaxServerRecvMsgSize))`
	`218`	`+ serverOpts = append(serverOpts, grpc.MaxSendMsgSize(opt.GRPCMaxCallSendMsgSize))`
`219`	`219`	`}`
`220`	`220`
`221`	`221`	`if opt.ProxyModeEnable {`