From 79b1234e3f08e35b0b4cbecca02b6c451cab5dbf Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Thu, 27 Aug 2009 11:36:27 -0700 Subject: [PATCH] kclient: msgr cleanup --- src/kernel/messenger.c | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/src/kernel/messenger.c b/src/kernel/messenger.c index ddcd8b7b2022a..e16c8aa89f9bd 100644 --- a/src/kernel/messenger.c +++ b/src/kernel/messenger.c @@ -232,6 +232,16 @@ static int con_close_socket(struct ceph_connection *con) return rc; } +/* + * mark a peer down. drop any open connections. + */ +void ceph_con_close(struct ceph_connection *con) +{ + dout("close %p peer %u.%u.%u.%u:%u\n", con, + IPQUADPORT(con->peer_addr.ipaddr)); + set_bit(CLOSED, &con->state); /* in case there's queued work */ +} + /* * clean up connection state */ @@ -1558,16 +1568,6 @@ void ceph_messenger_destroy(struct ceph_messenger *msgr) dout("destroyed messenger %p\n", msgr); } -/* - * mark a peer down. drop any open connections. - */ -void ceph_con_close(struct ceph_connection *con) -{ - dout("close %p peer %u.%u.%u.%u:%u\n", con, - IPQUADPORT(con->peer_addr.ipaddr)); - set_bit(CLOSED, &con->state); /* in case there's queued work */ -} - /* * A single ceph_msg can't be queued for send twice, unless it's * already been delivered (i.e. we have the only remaining reference), -- 2.39.5