Lines Matching refs:msg
1227 static void encode_cap_msg(struct ceph_msg *msg, struct cap_msg_args *arg) in encode_cap_msg() argument
1241 msg->hdr.version = cpu_to_le16(12); in encode_cap_msg()
1242 msg->hdr.tid = cpu_to_le64(arg->flush_tid); in encode_cap_msg()
1244 fc = msg->front.iov_base; in encode_cap_msg()
1277 msg->middle = ceph_buffer_get(arg->xattr_buf); in encode_cap_msg()
1279 msg->hdr.middle_len = cpu_to_le32(arg->xattr_buf->vec.iov_len); in encode_cap_msg()
1501 struct ceph_msg *msg; in __send_cap() local
1504 msg = ceph_msg_new(CEPH_MSG_CLIENT_CAPS, cap_msg_size(arg), GFP_NOFS, in __send_cap()
1506 if (!msg) { in __send_cap()
1516 encode_cap_msg(msg, arg); in __send_cap()
1517 ceph_con_send(&arg->session->s_con, msg); in __send_cap()
1530 struct ceph_msg *msg; in __send_flush_snap() local
1573 msg = ceph_msg_new(CEPH_MSG_CLIENT_CAPS, cap_msg_size(&arg), in __send_flush_snap()
1575 if (!msg) in __send_flush_snap()
1578 encode_cap_msg(msg, &arg); in __send_flush_snap()
1579 ceph_con_send(&arg.session->s_con, msg); in __send_flush_snap()
4231 struct ceph_msg *msg) in ceph_handle_caps() argument
4241 int msg_version = le16_to_cpu(msg->hdr.version); in ceph_handle_caps()
4258 end = msg->front.iov_base + msg->front.iov_len; in ceph_handle_caps()
4259 if (msg->front.iov_len < sizeof(*h)) in ceph_handle_caps()
4261 h = msg->front.iov_base; in ceph_handle_caps()
4380 handle_cap_flushsnap_ack(inode, le64_to_cpu(msg->hdr.tid), in ceph_handle_caps()
4407 h, msg->middle, &extra_info); in ceph_handle_caps()
4439 h, msg->middle, &extra_info); in ceph_handle_caps()
4443 handle_cap_flush_ack(inode, le64_to_cpu(msg->hdr.tid), in ceph_handle_caps()
4500 ceph_msg_dump(msg); in ceph_handle_caps()