Lines Matching refs:in_msg

671 	if (con->in_msg) {  in reset_connection()
672 BUG_ON(con->in_msg->con != con); in reset_connection()
673 ceph_msg_put(con->in_msg); in reset_connection()
674 con->in_msg = NULL; in reset_connection()
1713 BUG_ON(con->in_msg != NULL); in prepare_read_message()
2341 struct ceph_msg *msg = con->in_msg; in read_partial_msg_data()
2388 struct ceph_msg *m = con->in_msg; in read_partial_message()
2443 if (!con->in_msg) { in read_partial_message()
2452 BUG_ON(!con->in_msg ^ skip); in read_partial_message()
2463 BUG_ON(!con->in_msg); in read_partial_message()
2464 BUG_ON(con->in_msg->con != con); in read_partial_message()
2465 m = con->in_msg; in read_partial_message()
2473 prepare_message_data(con->in_msg, data_len); in read_partial_message()
2549 struct ceph_msg *msg = con->in_msg; in process_message()
2551 BUG_ON(con->in_msg->con != con); in process_message()
2552 con->in_msg = NULL; in process_message()
2610 BUG_ON(con->in_msg); in try_write()
3026 if (con->in_msg) { in con_fault()
3027 BUG_ON(con->in_msg->con != con); in con_fault()
3028 ceph_msg_put(con->in_msg); in con_fault()
3029 con->in_msg = NULL; in con_fault()
3205 if (con->in_msg == msg) { in ceph_msg_revoke_incoming()
3218 ceph_msg_put(con->in_msg); in ceph_msg_revoke_incoming()
3219 con->in_msg = NULL; in ceph_msg_revoke_incoming()
3224 __func__, con, con->in_msg, msg); in ceph_msg_revoke_incoming()
3451 BUG_ON(con->in_msg != NULL); in ceph_con_in_msg_alloc()
3465 con->in_msg = msg; in ceph_con_in_msg_alloc()
3478 memcpy(&con->in_msg->hdr, &con->in_hdr, sizeof(con->in_hdr)); in ceph_con_in_msg_alloc()
3480 if (middle_len && !con->in_msg->middle) { in ceph_con_in_msg_alloc()
3481 ret = ceph_alloc_middle(con, con->in_msg); in ceph_con_in_msg_alloc()
3483 ceph_msg_put(con->in_msg); in ceph_con_in_msg_alloc()
3484 con->in_msg = NULL; in ceph_con_in_msg_alloc()