Lines Matching refs:out_msg

1491 	     con->out_msg, aborted, con->v2.out_epil.front_crc,  in prepare_epilogue_plain()
1504 struct ceph_msg *msg = con->out_msg; in prepare_message_plain()
1573 tail_len = tail_onwire_len(con->out_msg, true); in prepare_message_secure()
1584 ret = setup_message_sgs(&sgt, con->out_msg, zerop, zerop, zerop, in prepare_message_secure()
1613 con->out_msg, sgt.orig_nents, enc_page_cnt); in prepare_message_secure()
1626 front_len(con->out_msg), in prepare_message()
1627 middle_len(con->out_msg), in prepare_message()
1628 data_len(con->out_msg) in prepare_message()
1634 con->out_msg, lens[0], lens[1], lens[2], lens[3]); in prepare_message()
1645 fill_header2(CTRL_BODY(con->v2.out_buf), &con->out_msg->hdr, in prepare_message()
2960 ceph_msg_data_cursor_init(&con->v2.out_cursor, con->out_msg, in queue_data()
2961 data_len(con->out_msg)); in queue_data()
3045 dout("%s con %p msg %p\n", __func__, con, con->out_msg); in finish_message()
3056 if (con->out_msg) { in finish_message()
3057 ceph_msg_put(con->out_msg); in finish_message()
3058 con->out_msg = NULL; in finish_message()
3080 WARN_ON(!con->out_msg); in populate_out_iter()
3084 WARN_ON(!con->out_msg); in populate_out_iter()
3091 WARN_ON(con->out_msg); /* revoked */ in populate_out_iter()
3229 WARN_ON(!resid || resid > front_len(con->out_msg)); in prepare_zero_front()
3230 sent = front_len(con->out_msg) - resid; in prepare_zero_front()
3235 crc32c(-1, con->out_msg->front.iov_base, sent); in prepare_zero_front()
3250 WARN_ON(!resid || resid > middle_len(con->out_msg)); in prepare_zero_middle()
3251 sent = middle_len(con->out_msg) - resid; in prepare_zero_middle()
3256 crc32c(-1, con->out_msg->middle->vec.iov_base, sent); in prepare_zero_middle()
3270 con->v2.out_epil.data_crc = crc32c_zeros(-1, data_len(con->out_msg)); in prepare_zero_data()
3271 out_zero_add(con, data_len(con->out_msg)); in prepare_zero_data()
3279 WARN_ON(!data_len(con->out_msg)); in revoke_at_queue_data()
3283 boundary = front_len(con->out_msg) + middle_len(con->out_msg); in revoke_at_queue_data()
3288 if (front_len(con->out_msg)) in revoke_at_queue_data()
3289 prepare_zero_front(con, front_len(con->out_msg)); in revoke_at_queue_data()
3290 if (middle_len(con->out_msg)) in revoke_at_queue_data()
3291 prepare_zero_middle(con, middle_len(con->out_msg)); in revoke_at_queue_data()
3298 boundary = middle_len(con->out_msg); in revoke_at_queue_data()
3303 if (middle_len(con->out_msg)) in revoke_at_queue_data()
3304 prepare_zero_middle(con, middle_len(con->out_msg)); in revoke_at_queue_data()
3321 WARN_ON(!data_len(con->out_msg)); in revoke_at_queue_data_cont()
3351 if (!front_len(con->out_msg) && !middle_len(con->out_msg) && in revoke_at_finish_message()
3352 !data_len(con->out_msg)) { in revoke_at_finish_message()
3359 boundary = front_len(con->out_msg) + middle_len(con->out_msg) + in revoke_at_finish_message()
3365 if (front_len(con->out_msg)) in revoke_at_finish_message()
3366 prepare_zero_front(con, front_len(con->out_msg)); in revoke_at_finish_message()
3367 if (middle_len(con->out_msg)) in revoke_at_finish_message()
3368 prepare_zero_middle(con, middle_len(con->out_msg)); in revoke_at_finish_message()
3375 boundary = middle_len(con->out_msg) + CEPH_EPILOGUE_PLAIN_LEN; in revoke_at_finish_message()
3380 if (middle_len(con->out_msg)) in revoke_at_finish_message()
3381 prepare_zero_middle(con, middle_len(con->out_msg)); in revoke_at_finish_message()