Skip to content
Snippets Groups Projects
Commit 3b9e06e4 authored by Richard T. Carback III's avatar Richard T. Carback III
Browse files

Remove warning (it's not real) and set the read/write buffer sizes to turn off buffering.

parent 717527f3
No related branches found
No related tags found
1 merge request!11Release
...@@ -398,16 +398,16 @@ func (h *Host) connectHelper() (err error) { ...@@ -398,16 +398,16 @@ func (h *Host) connectHelper() (err error) {
grpc.WithBlock(), grpc.WithBlock(),
grpc.WithKeepaliveParams(KaClientOpts), grpc.WithKeepaliveParams(KaClientOpts),
securityDial, securityDial,
grpc.WithReadBufferSize(0),
grpc.WithWriteBufferSize(0),
} }
windowSize := atomic.LoadInt32(h.windowSize) windowSize := atomic.LoadInt32(h.windowSize)
if windowSize != 0 { if windowSize != 0 {
dialOpts = append(dialOpts, grpc.WithInitialWindowSize(windowSize)) dialOpts = append(dialOpts, grpc.WithInitialWindowSize(windowSize))
dialOpts = append(dialOpts, grpc.WithInitialConnWindowSize(windowSize)) dialOpts = append(dialOpts, grpc.WithInitialConnWindowSize(windowSize))
} else {
jww.WARN.Printf("WindowSize not set, this can " +
"cause network performance issues")
} }
// Create the connection // Create the connection
h.connection, err = grpc.DialContext(ctx, h.GetAddress(), h.connection, err = grpc.DialContext(ctx, h.GetAddress(),
dialOpts...) dialOpts...)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment