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()
1336 struct ceph_msg *msg = con->in_msg; in ceph_con_process_message()
1338 BUG_ON(con->in_msg->con != con); in ceph_con_process_message()
1339 con->in_msg = NULL; in ceph_con_process_message()
1753 if (con->in_msg == msg) { in ceph_msg_revoke_incoming()
1760 ceph_msg_put(con->in_msg); in ceph_msg_revoke_incoming()
1761 con->in_msg = NULL; in ceph_msg_revoke_incoming()
1764 con, msg, con->in_msg); in ceph_msg_revoke_incoming()
1993 BUG_ON(con->in_msg != NULL); in ceph_con_in_msg_alloc()
2007 con->in_msg = msg; in ceph_con_in_msg_alloc()
2020 memcpy(&con->in_msg->hdr, hdr, sizeof(*hdr)); in ceph_con_in_msg_alloc()
2022 if (middle_len && !con->in_msg->middle) { in ceph_con_in_msg_alloc()
2023 ret = ceph_alloc_middle(con, con->in_msg); in ceph_con_in_msg_alloc()
2025 ceph_msg_put(con->in_msg); in ceph_con_in_msg_alloc()
2026 con->in_msg = NULL; in ceph_con_in_msg_alloc()