Lines Matching refs:in_msg

650 	if (con->in_msg) {  in reset_connection()
651 BUG_ON(con->in_msg->con != con); in reset_connection()
652 ceph_msg_put(con->in_msg); in reset_connection()
653 con->in_msg = NULL; in reset_connection()
1692 BUG_ON(con->in_msg != NULL); in prepare_read_message()
2321 struct ceph_msg *msg = con->in_msg; in read_partial_msg_data()
2367 struct ceph_msg *m = con->in_msg; in read_partial_message()
2422 if (!con->in_msg) { in read_partial_message()
2431 BUG_ON(!con->in_msg ^ skip); in read_partial_message()
2442 BUG_ON(!con->in_msg); in read_partial_message()
2443 BUG_ON(con->in_msg->con != con); in read_partial_message()
2444 m = con->in_msg; in read_partial_message()
2452 prepare_message_data(con->in_msg, data_len); in read_partial_message()
2528 struct ceph_msg *msg = con->in_msg; in process_message()
2530 BUG_ON(con->in_msg->con != con); in process_message()
2531 con->in_msg = NULL; in process_message()
2589 BUG_ON(con->in_msg); in try_write()
3005 if (con->in_msg) { in con_fault()
3006 BUG_ON(con->in_msg->con != con); in con_fault()
3007 ceph_msg_put(con->in_msg); in con_fault()
3008 con->in_msg = NULL; in con_fault()
3190 if (con->in_msg == msg) { in ceph_msg_revoke_incoming()
3203 ceph_msg_put(con->in_msg); in ceph_msg_revoke_incoming()
3204 con->in_msg = NULL; in ceph_msg_revoke_incoming()
3209 __func__, con, con->in_msg, msg); in ceph_msg_revoke_incoming()
3433 BUG_ON(con->in_msg != NULL); in ceph_con_in_msg_alloc()
3447 con->in_msg = msg; in ceph_con_in_msg_alloc()
3460 memcpy(&con->in_msg->hdr, &con->in_hdr, sizeof(con->in_hdr)); in ceph_con_in_msg_alloc()
3462 if (middle_len && !con->in_msg->middle) { in ceph_con_in_msg_alloc()
3463 ret = ceph_alloc_middle(con, con->in_msg); in ceph_con_in_msg_alloc()
3465 ceph_msg_put(con->in_msg); in ceph_con_in_msg_alloc()
3466 con->in_msg = NULL; in ceph_con_in_msg_alloc()