Lines Matching refs:msg
747 static int parse_reply_info(struct ceph_mds_session *s, struct ceph_msg *msg, in parse_reply_info() argument
756 info->head = msg->front.iov_base; in parse_reply_info()
757 p = msg->front.iov_base + sizeof(struct ceph_mds_reply_head); in parse_reply_info()
758 end = p + msg->front.iov_len - sizeof(struct ceph_mds_reply_head); in parse_reply_info()
792 ceph_msg_dump(msg); in parse_reply_info()
1443 struct ceph_msg *msg; in ceph_create_session_msg() local
1446 msg = ceph_msg_new(CEPH_MSG_CLIENT_SESSION, sizeof(*h), GFP_NOFS, in ceph_create_session_msg()
1448 if (!msg) { in ceph_create_session_msg()
1453 h = msg->front.iov_base; in ceph_create_session_msg()
1457 return msg; in ceph_create_session_msg()
1540 struct ceph_msg *msg; in create_session_full_msg() local
1586 msg = ceph_msg_new(CEPH_MSG_CLIENT_SESSION, sizeof(*h) + extra_bytes, in create_session_full_msg()
1588 if (!msg) { in create_session_full_msg()
1592 p = msg->front.iov_base; in create_session_full_msg()
1593 end = p + msg->front.iov_len; in create_session_full_msg()
1605 msg->hdr.version = cpu_to_le16(7); in create_session_full_msg()
1606 msg->hdr.compat_version = cpu_to_le16(1); in create_session_full_msg()
1630 ceph_msg_put(msg); in create_session_full_msg()
1637 ceph_msg_put(msg); in create_session_full_msg()
1650 msg->front.iov_len = p - msg->front.iov_base; in create_session_full_msg()
1651 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_session_full_msg()
1653 return msg; in create_session_full_msg()
1664 struct ceph_msg *msg; in __open_session() local
1679 msg = create_session_full_msg(mdsc, CEPH_SESSION_REQUEST_OPEN, in __open_session()
1681 if (IS_ERR(msg)) in __open_session()
1682 return PTR_ERR(msg); in __open_session()
1683 ceph_con_send(&session->s_con, msg); in __open_session()
2018 struct ceph_msg *msg; in send_renew_caps() local
2037 msg = create_session_full_msg(mdsc, CEPH_SESSION_REQUEST_RENEWCAPS, in send_renew_caps()
2039 if (IS_ERR(msg)) in send_renew_caps()
2040 return PTR_ERR(msg); in send_renew_caps()
2041 ceph_con_send(&session->s_con, msg); in send_renew_caps()
2049 struct ceph_msg *msg; in send_flushmsg_ack() local
2053 msg = ceph_create_session_msg(CEPH_SESSION_FLUSHMSG_ACK, seq); in send_flushmsg_ack()
2054 if (!msg) in send_flushmsg_ack()
2056 ceph_con_send(&session->s_con, msg); in send_flushmsg_ack()
2104 struct ceph_msg *msg; in request_close_session() local
2108 msg = ceph_create_session_msg(CEPH_SESSION_REQUEST_CLOSE, in request_close_session()
2110 if (!msg) in request_close_session()
2112 ceph_con_send(&session->s_con, msg); in request_close_session()
2311 struct ceph_msg *msg = NULL; in ceph_send_cap_releases() local
2332 if (!msg) { in ceph_send_cap_releases()
2333 msg = ceph_msg_new(CEPH_MSG_CLIENT_CAPRELEASE, in ceph_send_cap_releases()
2335 if (!msg) in ceph_send_cap_releases()
2337 head = msg->front.iov_base; in ceph_send_cap_releases()
2339 msg->front.iov_len = sizeof(*head); in ceph_send_cap_releases()
2341 msg->hdr.version = cpu_to_le16(2); in ceph_send_cap_releases()
2342 msg->hdr.compat_version = cpu_to_le16(1); in ceph_send_cap_releases()
2350 head = msg->front.iov_base; in ceph_send_cap_releases()
2353 item = msg->front.iov_base + msg->front.iov_len; in ceph_send_cap_releases()
2358 msg->front.iov_len += sizeof(*item); in ceph_send_cap_releases()
2364 cap_barrier = msg->front.iov_base + msg->front.iov_len; in ceph_send_cap_releases()
2366 msg->front.iov_len += sizeof(*cap_barrier); in ceph_send_cap_releases()
2368 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_send_cap_releases()
2369 doutc(cl, "mds%d %p\n", session->s_mds, msg); in ceph_send_cap_releases()
2370 ceph_con_send(&session->s_con, msg); in ceph_send_cap_releases()
2371 msg = NULL; in ceph_send_cap_releases()
2382 if (msg) { in ceph_send_cap_releases()
2384 cap_barrier = msg->front.iov_base + msg->front.iov_len; in ceph_send_cap_releases()
2386 msg->front.iov_len += sizeof(*cap_barrier); in ceph_send_cap_releases()
2388 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_send_cap_releases()
2389 doutc(cl, "mds%d %p\n", session->s_mds, msg); in ceph_send_cap_releases()
2390 ceph_con_send(&session->s_con, msg); in ceph_send_cap_releases()
2969 struct ceph_msg *msg; in create_request_message() local
2992 msg = ERR_PTR(ret); in create_request_message()
3005 msg = ERR_PTR(ret); in create_request_message()
3011 msg = ERR_CAST(req->r_altname); in create_request_message()
3067 msg = ceph_msg_new2(CEPH_MSG_CLIENT_REQUEST, len, 1, GFP_NOFS, false); in create_request_message()
3068 if (!msg) { in create_request_message()
3069 msg = ERR_PTR(-ENOMEM); in create_request_message()
3073 msg->hdr.tid = cpu_to_le64(req->r_tid); in create_request_message()
3075 lhead = find_legacy_request_head(msg->front.iov_base, in create_request_message()
3107 msg->hdr.version = cpu_to_le16(3); in create_request_message()
3108 p = msg->front.iov_base + sizeof(*lhead); in create_request_message()
3110 struct ceph_mds_request_head *nhead = msg->front.iov_base; in create_request_message()
3112 msg->hdr.version = cpu_to_le16(4); in create_request_message()
3114 p = msg->front.iov_base + offsetofend(struct ceph_mds_request_head, args); in create_request_message()
3116 struct ceph_mds_request_head *nhead = msg->front.iov_base; in create_request_message()
3118 msg->hdr.version = cpu_to_le16(6); in create_request_message()
3121 p = msg->front.iov_base + offsetofend(struct ceph_mds_request_head, ext_num_fwd); in create_request_message()
3123 struct ceph_mds_request_head *nhead = msg->front.iov_base; in create_request_message()
3127 msg->hdr.version = cpu_to_le16(6); in create_request_message()
3143 p = msg->front.iov_base + sizeof(*nhead); in create_request_message()
3146 end = msg->front.iov_base + msg->front.iov_len; in create_request_message()
3161 req->r_request_release_offset = p - msg->front.iov_base; in create_request_message()
3194 p = msg->front.iov_base + req->r_request_release_offset; in create_request_message()
3202 ceph_msg_put(msg); in create_request_message()
3203 msg = ERR_PTR(-ERANGE); in create_request_message()
3207 msg->front.iov_len = p - msg->front.iov_base; in create_request_message()
3208 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_request_message()
3212 ceph_msg_data_add_pagelist(msg, pagelist); in create_request_message()
3213 msg->hdr.data_len = cpu_to_le32(pagelist->length); in create_request_message()
3215 msg->hdr.data_len = 0; in create_request_message()
3218 msg->hdr.data_off = cpu_to_le16(0); in create_request_message()
3227 return msg; in create_request_message()
3229 ceph_msg_put(msg); in create_request_message()
3230 msg = ERR_PTR(ret); in create_request_message()
3260 struct ceph_msg *msg; in __prepare_send_request() local
3304 msg = req->r_request; in __prepare_send_request()
3305 lhead = find_legacy_request_head(msg->front.iov_base, in __prepare_send_request()
3317 nhead = (struct ceph_mds_request_head*)msg->front.iov_base; in __prepare_send_request()
3324 p = msg->front.iov_base + req->r_request_release_offset; in __prepare_send_request()
3327 msg->front.iov_len = p - msg->front.iov_base; in __prepare_send_request()
3328 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in __prepare_send_request()
3336 msg = create_request_message(session, req, drop_cap_releases); in __prepare_send_request()
3337 if (IS_ERR(msg)) { in __prepare_send_request()
3338 req->r_err = PTR_ERR(msg); in __prepare_send_request()
3339 return PTR_ERR(msg); in __prepare_send_request()
3341 req->r_request = msg; in __prepare_send_request()
3343 lhead = find_legacy_request_head(msg->front.iov_base, in __prepare_send_request()
3356 nhead = (struct ceph_mds_request_head*)msg->front.iov_base; in __prepare_send_request()
3787 static void handle_reply(struct ceph_mds_session *session, struct ceph_msg *msg) in handle_reply() argument
3792 struct ceph_mds_reply_head *head = msg->front.iov_base; in handle_reply()
3800 if (msg->front.iov_len < sizeof(*head)) { in handle_reply()
3802 ceph_msg_dump(msg); in handle_reply()
3807 tid = le64_to_cpu(msg->hdr.tid); in handle_reply()
3871 err = parse_reply_info(session, msg, req, (u64)-1); in handle_reply()
3873 err = parse_reply_info(session, msg, req, in handle_reply()
3911 ceph_msg_dump(msg); in handle_reply()
3927 ceph_msg_dump(msg); in handle_reply()
3970 req->r_reply = ceph_msg_get(msg); in handle_reply()
4001 struct ceph_msg *msg) in handle_forward() argument
4005 u64 tid = le64_to_cpu(msg->hdr.tid); in handle_forward()
4009 void *p = msg->front.iov_base; in handle_forward()
4010 void *end = p + msg->front.iov_len; in handle_forward()
4065 ceph_msg_dump(msg); in handle_forward()
4100 struct ceph_msg *msg) in handle_session() argument
4105 int msg_version = le16_to_cpu(msg->hdr.version); in handle_session()
4106 void *p = msg->front.iov_base; in handle_session()
4107 void *end = p + msg->front.iov_len; in handle_session()
4382 (int)msg->front.iov_len); in handle_session()
4383 ceph_msg_dump(msg); in handle_session()
5182 struct ceph_msg *msg) in handle_lease() argument
5190 struct ceph_mds_lease *h = msg->front.iov_base; in handle_lease()
5202 if (msg->front.iov_len < sizeof(*h) + sizeof(u32)) in handle_lease()
5208 if (msg->front.iov_len < sizeof(*h) + sizeof(u32) + dname.len) in handle_lease()
5273 ceph_msg_get(msg); in handle_lease()
5274 ceph_con_send(&session->s_con, msg); in handle_lease()
5287 ceph_msg_dump(msg); in handle_lease()
5295 struct ceph_msg *msg; in ceph_mdsc_lease_send_msg() local
5303 msg = ceph_msg_new(CEPH_MSG_CLIENT_LEASE, len, GFP_NOFS, false); in ceph_mdsc_lease_send_msg()
5304 if (!msg) in ceph_mdsc_lease_send_msg()
5306 lease = msg->front.iov_base; in ceph_mdsc_lease_send_msg()
5320 ceph_con_send(&session->s_con, msg); in ceph_mdsc_lease_send_msg()
5584 struct ceph_msg *msg; in send_flush_mdlog() local
5595 msg = ceph_create_session_msg(CEPH_SESSION_REQUEST_FLUSH_MDLOG, in send_flush_mdlog()
5597 if (!msg) { in send_flush_mdlog()
5601 ceph_con_send(&s->s_con, msg); in send_flush_mdlog()
6053 void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) in ceph_mdsc_handle_fsmap() argument
6058 void *p = msg->front.iov_base; in ceph_mdsc_handle_fsmap()
6059 void *end = p + msg->front.iov_len; in ceph_mdsc_handle_fsmap()
6116 ceph_msg_dump(msg); in ceph_mdsc_handle_fsmap()
6127 void ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) in ceph_mdsc_handle_mdsmap() argument
6132 void *p = msg->front.iov_base; in ceph_mdsc_handle_mdsmap()
6133 void *end = p + msg->front.iov_len; in ceph_mdsc_handle_mdsmap()
6186 ceph_msg_dump(msg); in ceph_mdsc_handle_mdsmap()
6222 static void mds_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in mds_dispatch() argument
6227 int type = le16_to_cpu(msg->hdr.type); in mds_dispatch()
6238 ceph_mdsc_handle_mdsmap(mdsc, msg); in mds_dispatch()
6241 ceph_mdsc_handle_fsmap(mdsc, msg); in mds_dispatch()
6244 handle_session(s, msg); in mds_dispatch()
6247 handle_reply(s, msg); in mds_dispatch()
6250 handle_forward(mdsc, s, msg); in mds_dispatch()
6253 ceph_handle_caps(s, msg); in mds_dispatch()
6256 ceph_handle_snap(mdsc, s, msg); in mds_dispatch()
6259 handle_lease(mdsc, s, msg); in mds_dispatch()
6262 ceph_handle_quota(mdsc, s, msg); in mds_dispatch()
6270 ceph_msg_put(msg); in mds_dispatch()
6409 struct ceph_msg *msg; in mds_alloc_msg() local
6417 msg = ceph_msg_new(type, front_len, GFP_NOFS, false); in mds_alloc_msg()
6418 if (!msg) { in mds_alloc_msg()
6424 return msg; in mds_alloc_msg()
6427 static int mds_sign_message(struct ceph_msg *msg) in mds_sign_message() argument
6429 struct ceph_mds_session *s = msg->con->private; in mds_sign_message()
6432 return ceph_auth_sign_message(auth, msg); in mds_sign_message()
6435 static int mds_check_message_signature(struct ceph_msg *msg) in mds_check_message_signature() argument
6437 struct ceph_mds_session *s = msg->con->private; in mds_check_message_signature()
6440 return ceph_auth_check_message_signature(auth, msg); in mds_check_message_signature()