Refresh of shut_wr

diff --git a/src/rsocket.c b/src/rsocket.c
index 5fc54046f2f2932d181e0eb0572cab3cf81f2de2..4eb1ce1eab18bbca2780648911ca35b1741f8fc5 100644 (file)
--- a/src/rsocket.c
+++ b/src/rsocket.c
@@ -888,6 +888,8 @@ static int rs_poll_cq(struct rsocket *rs)
                                if (rs_msg_data(imm_data) == RS_CTRL_DISCONNECT) {
                                        rs->state = rs_disconnected;
                                        return ERR(ECONNRESET);
+                               } else if (rs_msg_data(imm_data) == RS_CTRL_SHUTDOWN) {
+                                       rs->state &= ~rs_connect_rd;
                                }
                                break;
                        default: