front_len
msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);
msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);
msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);
msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);
msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);
int front_len = (int) le32_to_cpu(hdr->front_len);
msg = ceph_msg_new(type, front_len, GFP_NOFS, false);
type, front_len);
msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);
struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items,
extern struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
int front_len; /* preallocated payload size */
int front_len, int max_data_items, int size,
struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len,
__le32 front_len; /* bytes in main payload */
__le32 front_len; /* bytes in main payload */
__le32 front_len;
sigblock->front_len = msg->hdr.front_len;
le32_to_cpu(msg->hdr.front_len),
BUG_ON(msg->front.iov_len != le32_to_cpu(msg->hdr.front_len));
le32_to_cpu(msg->hdr.front_len),
struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items,
m->hdr.front_len = cpu_to_le32(front_len);
if (front_len) {
m->front.iov_base = kvmalloc(front_len, flags);
front_len);
m->front_alloc_len = m->front.iov_len = front_len;
dout("ceph_msg_new %p front %d\n", m, front_len);
front_len);
front_len);
struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
return ceph_msg_new2(type, front_len, 0, flags, can_fail);
unsigned int front_len, middle_len, data_len;
front_len = le32_to_cpu(con->v1.in_hdr.front_len);
if (front_len > CEPH_MSG_MAX_FRONT_LEN)
con->v1.in_base_pos = -front_len - middle_len - data_len -
front_len, data_len);
con->v1.in_base_pos = -front_len - middle_len -
ret = read_partial_message_section(con, &m->front, front_len,
m, front_len, m->footer.front_crc, middle_len,
unsigned int front_len = le32_to_cpu(con->v1.in_hdr.front_len);
front_len -
le32_to_cpu(m->hdr.front_len), le32_to_cpu(m->hdr.middle_len),
WARN_ON(m->front.iov_len != le32_to_cpu(m->hdr.front_len));
if (front_len(msg))
init_sgs(&cur_sg, msg->front.iov_base, front_len(msg),
dpos = padded_len(front_len(con->in_msg) + padded_len(middle_len(con->in_msg)));
if (!front_len(msg) && !middle_len(msg)) {
if (front_len(msg)) {
front_len(msg));
add_out_kvec(con, msg->front.iov_base, front_len(msg));
front_len(msg),
if (!front_len(msg) && !middle_len(msg)) {
if (front_len(msg)) {
add_in_kvec(con, msg->front.iov_base, front_len(msg));
WARN_ON(msg->front.iov_len != front_len(msg));
if (front_len(msg)) {
WARN_ON(front_len(msg) > msg->front_alloc_len);
msg->front.iov_len = front_len(msg);
if (!front_len(msg) && !middle_len(msg) && !data_len(msg))
WARN_ON(!resid || resid > front_len(msg));
sent = front_len(msg) - resid;
boundary = front_len(msg) + middle_len(msg);
if (front_len(msg))
prepare_zero_front(con, msg, front_len(msg));
if (!front_len(msg) && !middle_len(msg) &&
boundary = front_len(msg) + middle_len(msg) +
if (front_len(msg))
prepare_zero_front(con, msg, front_len(msg));
return le32_to_cpu(msg->hdr.front_len);
static int __tail_onwire_len(int front_len, int middle_len, int data_len,
BUG_ON(front_len < 0 || front_len > CEPH_MSG_MAX_FRONT_LEN ||
if (!front_len && !middle_len && !data_len)
return front_len + middle_len + data_len +
return padded_len(front_len) + padded_len(middle_len) +
return __tail_onwire_len(front_len(msg), middle_len(msg),
int front_len, int middle_len, int data_len,
hdr->front_len = cpu_to_le32(front_len);
if (front_len(con->in_msg)) {
front_len(con->in_msg));
if (!front_len(msg) && !middle_len(msg) && !data_len(msg))
if (front_len(msg))
front_len(msg));
int front_len = le32_to_cpu(hdr->front_len);
m = ceph_msg_new(type, front_len, GFP_NOFS, false);
} else if (front_len > m->front_alloc_len) {
front_len, m->front_alloc_len,
m = ceph_msg_new(type, front_len, GFP_NOFS, false);
monc->m_auth->hdr.front_len = cpu_to_le32(len);
msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);
msg = ceph_msg_new2(pool->type, pool->front_len, pool->max_data_items,
int front_len, int max_data_items, int size,
pool->front_len = front_len;
struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len,
if (front_len > pool->front_len ||
__func__, front_len, max_data_items, pool->name,
pool->front_len, pool->max_data_items);
return ceph_msg_new2(pool->type, front_len, max_data_items,
msg->front.iov_len = pool->front_len;
msg->hdr.front_len = cpu_to_le32(pool->front_len);
msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);
msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);
le64_to_cpu(msg->hdr.tid), le32_to_cpu(msg->hdr.front_len),
msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);
int front_len = le32_to_cpu(hdr->front_len);
if (front_len > req->r_reply->front_alloc_len) {
__func__, osd->o_osd, req->r_tid, front_len,
m = ceph_msg_new(CEPH_MSG_OSD_OPREPLY, front_len, GFP_NOFS,
u32 front_len = le32_to_cpu(hdr->front_len);
m = ceph_msg_new2(type, front_len, 1, GFP_NOIO, false);