Commit d55fddd6 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent e32e463b
...@@ -214,9 +214,9 @@ error _Conn::__pinner(context::Context ctx) { ...@@ -214,9 +214,9 @@ error _Conn::__pinner(context::Context ctx) {
while (1) { while (1) {
err = wconn._wlink->recvReq(ctx, &req); err = wconn._wlink->recvReq(ctx, &req);
if (err != nil) { if (err != nil) {
// it is ok if we receive EOF due to us closing the connection // it is ok if we receive EOF due to us (client) closing the connection
if (err == io::EOF_) { if (err == io::EOF_) {
wconn._mu.lock(); // <- XXX wconn._mu.lock();
err = (wconn._downErr == errConnClosed) ? nil : io::ErrUnexpectedEOF; err = (wconn._downErr == errConnClosed) ? nil : io::ErrUnexpectedEOF;
wconn._mu.unlock(); wconn._mu.unlock();
} }
......
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