Lines Matching refs:in_msg

662 	if (con->in_msg) {  in reset_connection()
663 BUG_ON(con->in_msg->con != con); in reset_connection()
664 con->in_msg->con = NULL; in reset_connection()
665 ceph_msg_put(con->in_msg); in reset_connection()
666 con->in_msg = NULL; in reset_connection()
1666 BUG_ON(con->in_msg != NULL); in prepare_read_message()
2249 struct ceph_msg *msg = con->in_msg; in read_partial_msg_data()
2292 struct ceph_msg *m = con->in_msg; in read_partial_message()
2347 if (!con->in_msg) { in read_partial_message()
2356 BUG_ON(!con->in_msg ^ skip); in read_partial_message()
2357 if (con->in_msg && data_len > con->in_msg->data_length) { in read_partial_message()
2359 __func__, data_len, con->in_msg->data_length); in read_partial_message()
2360 ceph_msg_put(con->in_msg); in read_partial_message()
2361 con->in_msg = NULL; in read_partial_message()
2374 BUG_ON(!con->in_msg); in read_partial_message()
2375 BUG_ON(con->in_msg->con != con); in read_partial_message()
2376 m = con->in_msg; in read_partial_message()
2384 prepare_message_data(con->in_msg, data_len); in read_partial_message()
2466 BUG_ON(con->in_msg->con != con); in process_message()
2467 con->in_msg->con = NULL; in process_message()
2468 msg = con->in_msg; in process_message()
2469 con->in_msg = NULL; in process_message()
2515 BUG_ON(con->in_msg); in try_write()
2922 if (con->in_msg) { in con_fault()
2923 BUG_ON(con->in_msg->con != con); in con_fault()
2924 con->in_msg->con = NULL; in con_fault()
2925 ceph_msg_put(con->in_msg); in con_fault()
2926 con->in_msg = NULL; in con_fault()
3105 if (con->in_msg == msg) { in ceph_msg_revoke_incoming()
3118 ceph_msg_put(con->in_msg); in ceph_msg_revoke_incoming()
3119 con->in_msg = NULL; in ceph_msg_revoke_incoming()
3124 __func__, con, con->in_msg, msg); in ceph_msg_revoke_incoming()
3322 BUG_ON(con->in_msg != NULL); in ceph_con_in_msg_alloc()
3335 con->in_msg = msg; in ceph_con_in_msg_alloc()
3336 con->in_msg->con = con->ops->get(con); in ceph_con_in_msg_alloc()
3337 BUG_ON(con->in_msg->con == NULL); in ceph_con_in_msg_alloc()
3350 memcpy(&con->in_msg->hdr, &con->in_hdr, sizeof(con->in_hdr)); in ceph_con_in_msg_alloc()
3352 if (middle_len && !con->in_msg->middle) { in ceph_con_in_msg_alloc()
3353 ret = ceph_alloc_middle(con, con->in_msg); in ceph_con_in_msg_alloc()
3355 ceph_msg_put(con->in_msg); in ceph_con_in_msg_alloc()
3356 con->in_msg = NULL; in ceph_con_in_msg_alloc()