Commit fad6baf1 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 9ae505ad
...@@ -110,7 +110,7 @@ func _handshakeClient(ctx context.Context, conn net.Conn, version uint32, encPre ...@@ -110,7 +110,7 @@ func _handshakeClient(ctx context.Context, conn net.Conn, version uint32, encPre
} }
}() }()
rxbuf = newXBufReader(conn, /*any non-small*/1024) rxbuf = newXBufReader(conn, /*any non-small limit*/1024)
var peerEnc proto.Encoding var peerEnc proto.Encoding
err = xcontext.WithCloseOnErrCancel(ctx, conn, func() error { err = xcontext.WithCloseOnErrCancel(ctx, conn, func() error {
...@@ -150,7 +150,7 @@ func _handshakeServer(ctx context.Context, conn net.Conn, version uint32) (enc p ...@@ -150,7 +150,7 @@ func _handshakeServer(ctx context.Context, conn net.Conn, version uint32) (enc p
} }
}() }()
rxbuf = newXBufReader(conn, /*any non-small*/1024) rxbuf = newXBufReader(conn, /*any non-small limit*/1024)
var peerEnc proto.Encoding var peerEnc proto.Encoding
err = xcontext.WithCloseOnErrCancel(ctx, conn, func() error { err = xcontext.WithCloseOnErrCancel(ctx, conn, func() error {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment