fix: validate the grpc buffer size setting by option (#441)

cloudwego · May 6, 2022 · 021b894 · 021b894
1 parent 5c30cb1
commit 021b894
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/pkg/remote/trans/nphttp2/grpc/http2_client.go b/pkg/remote/trans/nphttp2/grpc/http2_client.go
@@ -137,8 +137,14 @@ func newHTTP2Client(ctx context.Context, conn net.Conn, opts ConnectOptions,
 		dynamicWindow = false
 	}
 
-	writeBufSize := opts.WriteBufferSize
-	readBufSize := opts.ReadBufferSize
+	writeBufSize := defaultWriteBufferSize
+	readBufSize := defaultReadBufferSize
+	if opts.WriteBufferSize > 0 {
+		writeBufSize = opts.WriteBufferSize
+	}
+	if opts.ReadBufferSize > 0 {
+		readBufSize = opts.ReadBufferSize
+	}
 	maxHeaderListSize := defaultClientMaxHeaderListSize
 	if opts.MaxHeaderListSize != nil {
 		maxHeaderListSize = *opts.MaxHeaderListSize

diff --git a/version.go b/version.go
@@ -19,5 +19,5 @@ package kitex
 // Name and Version info of this framework, used for statistics and debug
 const (
 	Name    = "Kitex"
-	Version = "v0.3.0"
+	Version = "v0.3.1"
 )