]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
kclient: msgr cleanup
authorSage Weil <sage@newdream.net>
Thu, 27 Aug 2009 18:36:27 +0000 (11:36 -0700)
committerSage Weil <sage@newdream.net>
Thu, 27 Aug 2009 18:36:27 +0000 (11:36 -0700)
src/kernel/messenger.c

index ddcd8b7b2022a062c0bf09fcfe0157766beba555..e16c8aa89f9bd4fc1062caf4d05a8d98e24e0202 100644 (file)
@@ -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),