Refresh of shut_wr

diff --git a/src/rsocket.c b/src/rsocket.c
index 581ecd8a2aad206ef1901c9e9c77fda64b917a9e..4ecb4258b0f0ca5194d9ef012afb07b7a8257c1a 100644 (file)
--- a/src/rsocket.c
+++ b/src/rsocket.c
@@ -1741,7 +1741,7 @@ int rshutdown(int socket, int how)
        if (!rs_all_sends_done(rs) && !(rs->state & rs_error))
                rs_process_cq(rs, 0, rs_all_sends_done);
 
-       if ((rs->fd_flags & O_NONBLOCK) && (how == SHUT_WR))
+       if ((rs->fd_flags & O_NONBLOCK) && (rs->state & rs_connected))
                rs_set_nonblocking(rs, 1);
 
        return 0;