Searched refs:ceph_msg (Results 1 – 18 of 18) sorted by relevance
| /Linux-v5.4/include/linux/ceph/ |
| D | messenger.h | 17 struct ceph_msg;
28 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
47 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
51 void (*reencode_message) (struct ceph_msg *msg);
53 int (*sign_message) (struct ceph_msg *msg);
54 int (*check_message_signature) (struct ceph_msg *msg);
215 struct ceph_msg { struct
296 struct ceph_msg *out_msg; /* sending message (== tail of
312 struct ceph_msg *in_msg;
350 extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg);
[all …]
|
| D | auth.h | 16 struct ceph_msg;
29 struct ceph_msg *msg);
31 struct ceph_msg *msg);
82 struct ceph_msg *msg);
84 struct ceph_msg *msg);
135 struct ceph_msg *msg) in ceph_auth_sign_message()
144 struct ceph_msg *msg) in ceph_auth_check_message_signature()
|
| D | msgpool.h | 23 struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len,
25 extern void ceph_msgpool_put(struct ceph_msgpool *, struct ceph_msg *);
|
| D | mon_client.h | 61 struct ceph_msg *request; /* original request */
62 struct ceph_msg *reply; /* and reply */
78 struct ceph_msg *m_auth, *m_auth_reply, *m_subscribe, *m_subscribe_ack;
|
| D | osd_client.h | 19 struct ceph_msg;
188 struct ceph_msg *r_request, *r_reply;
387 struct ceph_msg *msg);
389 struct ceph_msg *msg);
|
| D | libceph.h | 131 int (*extra_mon_dispatch)(struct ceph_client *, struct ceph_msg *);
|
| /Linux-v5.4/net/ceph/ |
| D | msgpool.c | 15 struct ceph_msg *msg; in msgpool_alloc()
31 struct ceph_msg *msg = element; in msgpool_free()
59 struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len, in ceph_msgpool_get()
62 struct ceph_msg *msg; in ceph_msgpool_get()
81 void ceph_msgpool_put(struct ceph_msgpool *pool, struct ceph_msg *msg) in ceph_msgpool_put()
|
| D | messenger.c | 236 ceph_msg_cache = KMEM_CACHE(ceph_msg, 0); in ceph_msgr_slab_init()
627 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
636 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
1123 static void ceph_msg_data_cursor_init(struct ceph_msg *msg, size_t length) in ceph_msg_data_cursor_init()
1227 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
1240 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
1263 struct ceph_msg *m; in prepare_write_message()
1280 m = list_first_entry(&con->out_queue, struct ceph_msg, list_head); in prepare_write_message()
1561 struct ceph_msg *msg = con->out_msg; in write_partial_message_data()
2268 struct ceph_msg *m; in process_ack()
[all …]
|
| D | mon_client.c | 261 struct ceph_msg *msg = monc->m_subscribe; in __send_subscribe()
310 struct ceph_msg *msg) in handle_subscribe_ack()
467 struct ceph_msg *msg) in ceph_monc_handle_map()
633 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply()
640 struct ceph_msg *m; in get_generic_reply()
666 struct ceph_msg *msg) in handle_statfs_reply()
744 struct ceph_msg *msg) in handle_get_version_reply()
867 struct ceph_msg *msg) in handle_command_ack()
1161 struct ceph_msg *msg) in handle_auth_reply()
1231 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) in dispatch()
[all …]
|
| D | osd_client.c | 553 struct ceph_msg *request_msg = req->r_request; in request_reinit()
554 struct ceph_msg *reply_msg = req->r_reply; in request_reinit()
617 struct ceph_msg *msg; in __ceph_osdc_alloc_messages()
956 static void ceph_osdc_msg_data_add(struct ceph_msg *msg, in ceph_osdc_msg_data_add()
1941 struct ceph_msg *request_msg = req->r_request; in setup_request_data()
1942 struct ceph_msg *reply_msg = req->r_reply; in setup_request_data()
2042 struct ceph_msg *msg) in encode_request_partial()
2118 static void encode_request_finish(struct ceph_msg *msg) in encode_request_finish()
2822 struct ceph_msg *msg; /* for ceph_msg_put() */
3513 static int decode_MOSDOpReply(const struct ceph_msg *msg, struct MOSDOpReply *m) in decode_MOSDOpReply()
[all …]
|
| D | auth_x.c | 805 static int calc_signature(struct ceph_x_authorizer *au, struct ceph_msg *msg, in calc_signature()
871 struct ceph_msg *msg) in ceph_x_sign_message()
890 struct ceph_msg *msg) in ceph_x_check_message_signature()
|
| /Linux-v5.4/fs/ceph/ |
| D | mds_client.h | 271 struct ceph_msg *r_request; /* original request */
273 struct ceph_msg *r_reply;
457 struct ceph_msg *msg, int mds);
514 struct ceph_msg *msg);
516 struct ceph_msg *msg);
|
| D | mds_client.c | 467 static int parse_reply_info(struct ceph_msg *msg, in parse_reply_info()
1028 static struct ceph_msg *create_session_msg(u32 op, u64 seq) in create_session_msg()
1030 struct ceph_msg *msg; in create_session_msg()
1071 static struct ceph_msg *create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq) in create_session_open_msg()
1073 struct ceph_msg *msg; in create_session_open_msg()
1157 struct ceph_msg *msg; in __open_session()
1584 struct ceph_msg *msg; in send_renew_caps()
1614 struct ceph_msg *msg; in send_flushmsg_ack()
1666 struct ceph_msg *msg; in request_close_session()
1858 struct ceph_msg *msg = NULL; in ceph_send_cap_releases()
[all …]
|
| D | super.h | 871 struct ceph_msg *msg);
1035 struct ceph_msg *msg);
1171 struct ceph_msg *msg);
|
| D | quota.c | 39 struct ceph_msg *msg) in ceph_handle_quota()
|
| D | super.c | 635 static int extra_mon_dispatch(struct ceph_client *client, struct ceph_msg *msg) in extra_mon_dispatch()
|
| D | snap.c | 844 struct ceph_msg *msg) in ceph_handle_snap()
|
| D | caps.c | 1138 struct ceph_msg *msg; in send_cap_msg()
3797 struct ceph_msg *msg) in ceph_handle_caps()
|
