Lines Matching refs:in_msg
513 if (con->in_msg) { in ceph_con_reset_protocol()
514 WARN_ON(con->in_msg->con != con); in ceph_con_reset_protocol()
515 ceph_msg_put(con->in_msg); in ceph_con_reset_protocol()
516 con->in_msg = NULL; in ceph_con_reset_protocol()
558 WARN_ON(con->in_msg); in ceph_con_reset_session()
1403 struct ceph_msg *msg = con->in_msg; in ceph_con_process_message()
1405 BUG_ON(con->in_msg->con != con); in ceph_con_process_message()
1406 con->in_msg = NULL; in ceph_con_process_message()
1820 if (con->in_msg == msg) { in ceph_msg_revoke_incoming()
1827 ceph_msg_put(con->in_msg); in ceph_msg_revoke_incoming()
1828 con->in_msg = NULL; in ceph_msg_revoke_incoming()
1831 con, msg, con->in_msg); in ceph_msg_revoke_incoming()
2072 BUG_ON(con->in_msg != NULL); in ceph_con_in_msg_alloc()
2086 con->in_msg = msg; in ceph_con_in_msg_alloc()
2099 memcpy(&con->in_msg->hdr, hdr, sizeof(*hdr)); in ceph_con_in_msg_alloc()
2101 if (middle_len && !con->in_msg->middle) { in ceph_con_in_msg_alloc()
2102 ret = ceph_alloc_middle(con, con->in_msg); in ceph_con_in_msg_alloc()
2104 ceph_msg_put(con->in_msg); in ceph_con_in_msg_alloc()
2105 con->in_msg = NULL; in ceph_con_in_msg_alloc()