Lines Matching refs:in_msg
660 if (con->in_msg) { in reset_connection()
661 BUG_ON(con->in_msg->con != con); in reset_connection()
662 ceph_msg_put(con->in_msg); in reset_connection()
663 con->in_msg = NULL; in reset_connection()
1679 BUG_ON(con->in_msg != NULL); in prepare_read_message()
2262 struct ceph_msg *msg = con->in_msg; in read_partial_msg_data()
2304 struct ceph_msg *m = con->in_msg; in read_partial_message()
2359 if (!con->in_msg) { in read_partial_message()
2368 BUG_ON(!con->in_msg ^ skip); in read_partial_message()
2379 BUG_ON(!con->in_msg); in read_partial_message()
2380 BUG_ON(con->in_msg->con != con); in read_partial_message()
2381 m = con->in_msg; in read_partial_message()
2389 prepare_message_data(con->in_msg, data_len); in read_partial_message()
2469 struct ceph_msg *msg = con->in_msg; in process_message()
2471 BUG_ON(con->in_msg->con != con); in process_message()
2472 con->in_msg = NULL; in process_message()
2528 BUG_ON(con->in_msg); in try_write()
2944 if (con->in_msg) { in con_fault()
2945 BUG_ON(con->in_msg->con != con); in con_fault()
2946 ceph_msg_put(con->in_msg); in con_fault()
2947 con->in_msg = NULL; in con_fault()
3126 if (con->in_msg == msg) { in ceph_msg_revoke_incoming()
3139 ceph_msg_put(con->in_msg); in ceph_msg_revoke_incoming()
3140 con->in_msg = NULL; in ceph_msg_revoke_incoming()
3145 __func__, con, con->in_msg, msg); in ceph_msg_revoke_incoming()
3357 BUG_ON(con->in_msg != NULL); in ceph_con_in_msg_alloc()
3371 con->in_msg = msg; in ceph_con_in_msg_alloc()
3384 memcpy(&con->in_msg->hdr, &con->in_hdr, sizeof(con->in_hdr)); in ceph_con_in_msg_alloc()
3386 if (middle_len && !con->in_msg->middle) { in ceph_con_in_msg_alloc()
3387 ret = ceph_alloc_middle(con, con->in_msg); in ceph_con_in_msg_alloc()
3389 ceph_msg_put(con->in_msg); in ceph_con_in_msg_alloc()
3390 con->in_msg = NULL; in ceph_con_in_msg_alloc()