Lines Matching refs:in_msg
643 if (con->in_msg) { in reset_connection()
644 BUG_ON(con->in_msg->con != con); in reset_connection()
645 ceph_msg_put(con->in_msg); in reset_connection()
646 con->in_msg = NULL; in reset_connection()
1685 BUG_ON(con->in_msg != NULL); in prepare_read_message()
2312 struct ceph_msg *msg = con->in_msg; in read_partial_msg_data()
2358 struct ceph_msg *m = con->in_msg; in read_partial_message()
2413 if (!con->in_msg) { in read_partial_message()
2422 BUG_ON(!con->in_msg ^ skip); in read_partial_message()
2433 BUG_ON(!con->in_msg); in read_partial_message()
2434 BUG_ON(con->in_msg->con != con); in read_partial_message()
2435 m = con->in_msg; in read_partial_message()
2443 prepare_message_data(con->in_msg, data_len); in read_partial_message()
2519 struct ceph_msg *msg = con->in_msg; in process_message()
2521 BUG_ON(con->in_msg->con != con); in process_message()
2522 con->in_msg = NULL; in process_message()
2580 BUG_ON(con->in_msg); in try_write()
2996 if (con->in_msg) { in con_fault()
2997 BUG_ON(con->in_msg->con != con); in con_fault()
2998 ceph_msg_put(con->in_msg); in con_fault()
2999 con->in_msg = NULL; in con_fault()
3186 if (con->in_msg == msg) { in ceph_msg_revoke_incoming()
3199 ceph_msg_put(con->in_msg); in ceph_msg_revoke_incoming()
3200 con->in_msg = NULL; in ceph_msg_revoke_incoming()
3205 __func__, con, con->in_msg, msg); in ceph_msg_revoke_incoming()
3434 BUG_ON(con->in_msg != NULL); in ceph_con_in_msg_alloc()
3448 con->in_msg = msg; in ceph_con_in_msg_alloc()
3461 memcpy(&con->in_msg->hdr, &con->in_hdr, sizeof(con->in_hdr)); in ceph_con_in_msg_alloc()
3463 if (middle_len && !con->in_msg->middle) { in ceph_con_in_msg_alloc()
3464 ret = ceph_alloc_middle(con, con->in_msg); in ceph_con_in_msg_alloc()
3466 ceph_msg_put(con->in_msg); in ceph_con_in_msg_alloc()
3467 con->in_msg = NULL; in ceph_con_in_msg_alloc()