Lines Matching refs:in_msg
649 if (front_len(con->in_msg)) { in verify_epilogue_crcs()
650 con->in_front_crc = crc32c(-1, con->in_msg->front.iov_base, in verify_epilogue_crcs()
651 front_len(con->in_msg)); in verify_epilogue_crcs()
653 WARN_ON(!middle_len(con->in_msg) && !data_len(con->in_msg)); in verify_epilogue_crcs()
657 if (middle_len(con->in_msg)) in verify_epilogue_crcs()
659 con->in_msg->middle->vec.iov_base, in verify_epilogue_crcs()
660 middle_len(con->in_msg)); in verify_epilogue_crcs()
661 else if (data_len(con->in_msg)) in verify_epilogue_crcs()
666 if (!data_len(con->in_msg)) in verify_epilogue_crcs()
669 dout("%s con %p msg %p crcs %u %u %u\n", __func__, con, con->in_msg, in verify_epilogue_crcs()
1039 tail_len = tail_onwire_len(con->in_msg, true); in decrypt_tail()
1046 ret = setup_message_sgs(&sgt, con->in_msg, FRONT_PAD(con->v2.in_buf), in decrypt_tail()
1053 con->in_msg, con->v2.in_enc_page_cnt, sgt.orig_nents); in decrypt_tail()
1757 ceph_msg_data_cursor_init(&con->v2.in_cursor, con->in_msg, in prepare_read_data()
1758 data_len(con->in_msg)); in prepare_read_data()
1820 struct ceph_msg *msg = con->in_msg; in prepare_read_tail_plain()
1880 tail_len = tail_onwire_len(con->in_msg, true); in prepare_read_tail_secure()
2661 WARN_ON(!con->in_msg ^ skip); in process_message_header()
2665 WARN_ON(!con->in_msg); in process_message_header()
2666 WARN_ON(con->in_msg->con != con); in process_message_header()
2705 msg = con->in_msg; /* set in process_message_header() */ in __handle_control()
3428 WARN_ON(!data_len(con->in_msg)); in revoke_at_prepare_read_data()
3433 remaining = data_len(con->in_msg) + CEPH_EPILOGUE_PLAIN_LEN; in revoke_at_prepare_read_data()
3447 WARN_ON(!data_len(con->in_msg)); in revoke_at_prepare_read_data_cont()