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
*/
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),