kmsgr: close connection on rx of CLOSED tag

diff --git a/src/kernel/messenger.c b/src/kernel/messenger.c
index 1dcaa09d57e1b3234ecc3e58a467a913c3d7a31f..a4f02fa756c5b9508015ce3a2d08a620293d3487 100644 (file)
--- a/src/kernel/messenger.c
+++ b/src/kernel/messenger.c
@@ -1061,7 +1061,10 @@ more:
                        prepare_read_message(con);
                else if (con->in_tag == CEPH_MSGR_TAG_ACK)
                        prepare_read_ack(con);
-               else {
+               else if (con->in_tag == CEPH_MSGR_TAG_CLOSE) {
+                       set_bit(CLOSED, &con->state);   /* fixme */
+                       goto done;
+               } else {
                        derr(2, "try_read got bad tag %d\n", (int)con->in_tag);
                        ret = -EINVAL;
                        goto bad;