Lines Matching refs:out_msg
651 if (con->out_msg) { in reset_connection()
652 BUG_ON(con->out_msg->con != con); in reset_connection()
653 ceph_msg_put(con->out_msg); in reset_connection()
654 con->out_msg = NULL; in reset_connection()
1233 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
1274 con->out_msg = m; in prepare_write_message()
1311 con->out_msg->hdr.crc = cpu_to_le32(crc); in prepare_write_message()
1312 memcpy(&con->out_hdr, &con->out_msg->hdr, sizeof(con->out_hdr)); in prepare_write_message()
1316 con->out_msg->footer.front_crc = cpu_to_le32(crc); in prepare_write_message()
1320 con->out_msg->footer.middle_crc = cpu_to_le32(crc); in prepare_write_message()
1322 con->out_msg->footer.middle_crc = 0; in prepare_write_message()
1324 le32_to_cpu(con->out_msg->footer.front_crc), in prepare_write_message()
1325 le32_to_cpu(con->out_msg->footer.middle_crc)); in prepare_write_message()
1326 con->out_msg->footer.flags = 0; in prepare_write_message()
1329 con->out_msg->footer.data_crc = 0; in prepare_write_message()
1331 prepare_message_data(con->out_msg, m->data_length); in prepare_write_message()
1554 struct ceph_msg *msg = con->out_msg; in write_partial_message_data()
2608 if (con->out_msg) { in try_write()
2610 ceph_msg_put(con->out_msg); in try_write()
2611 con->out_msg = NULL; /* we're done with this one */ in try_write()
3001 if (con->out_msg) { in con_fault()
3002 BUG_ON(con->out_msg->con != con); in con_fault()
3003 ceph_msg_put(con->out_msg); in con_fault()
3004 con->out_msg = NULL; in con_fault()
3147 if (con->out_msg == msg) { in ceph_msg_revoke()
3166 con->out_msg = NULL; in ceph_msg_revoke()