Lines Matching refs:in_msg
508 if (con->in_msg) { in ceph_con_reset_protocol()
509 WARN_ON(con->in_msg->con != con); in ceph_con_reset_protocol()
510 ceph_msg_put(con->in_msg); in ceph_con_reset_protocol()
511 con->in_msg = NULL; in ceph_con_reset_protocol()
549 WARN_ON(con->in_msg); in ceph_con_reset_session()
1356 struct ceph_msg *msg = con->in_msg; in ceph_con_process_message()
1358 BUG_ON(con->in_msg->con != con); in ceph_con_process_message()
1359 con->in_msg = NULL; in ceph_con_process_message()
1773 if (con->in_msg == msg) { in ceph_msg_revoke_incoming()
1780 ceph_msg_put(con->in_msg); in ceph_msg_revoke_incoming()
1781 con->in_msg = NULL; in ceph_msg_revoke_incoming()
1784 con, msg, con->in_msg); in ceph_msg_revoke_incoming()
2013 BUG_ON(con->in_msg != NULL); in ceph_con_in_msg_alloc()
2027 con->in_msg = msg; in ceph_con_in_msg_alloc()
2040 memcpy(&con->in_msg->hdr, hdr, sizeof(*hdr)); in ceph_con_in_msg_alloc()
2042 if (middle_len && !con->in_msg->middle) { in ceph_con_in_msg_alloc()
2043 ret = ceph_alloc_middle(con, con->in_msg); in ceph_con_in_msg_alloc()
2045 ceph_msg_put(con->in_msg); in ceph_con_in_msg_alloc()
2046 con->in_msg = NULL; in ceph_con_in_msg_alloc()