| /linux/include/linux/ceph/ |
| H A D | messenger.h | 19 struct ceph_msg;
31 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
50 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
54 void (*reencode_message) (struct ceph_msg *msg);
56 int (*sign_message) (struct ceph_msg *msg);
57 int (*check_message_signature) (struct ceph_msg *msg);
266 struct ceph_msg { struct
499 struct ceph_msg *in_msg;
500 struct ceph_msg *out_msg; /* sending message (== tail of
538 struct ceph_msg *msg, size_t length);
[all …]
|
| H A D | auth.h | 16 struct ceph_msg;
29 struct ceph_msg *msg);
31 struct ceph_msg *msg);
85 struct ceph_msg *msg);
87 struct ceph_msg *msg);
145 struct ceph_msg *msg) in ceph_auth_sign_message()
154 struct ceph_msg *msg) in ceph_auth_check_message_signature()
|
| H A 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 *);
|
| H A 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;
|
| H A D | osd_client.h | 20 struct ceph_msg;
248 struct ceph_msg *r_request, *r_reply;
453 struct ceph_msg *msg);
|
| H A D | libceph.h | 127 int (*extra_mon_dispatch)(struct ceph_client *, struct ceph_msg *);
|
| /linux/net/ceph/ |
| H A 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()
|
| H A D | messenger.c | 30 * Ceph uses the messenger to exchange ceph_msg messages with other
214 ceph_msg_cache = KMEM_CACHE(ceph_msg, 0); in ceph_msgr_slab_init()
539 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
549 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
674 struct ceph_msg *msg; in ceph_con_discard_sent()
679 msg = list_first_entry(&con->out_sent, struct ceph_msg, in ceph_con_discard_sent()
699 struct ceph_msg *msg; in ceph_con_discard_requeued()
704 msg = list_first_entry(&con->out_queue, struct ceph_msg, in ceph_con_discard_requeued()
1068 struct ceph_msg *ms in ceph_msg_data_cursor_init()
[all...] |
| H A D | mon_client.c | 334 struct ceph_msg *msg = monc->m_subscribe; in __send_subscribe()
383 struct ceph_msg *msg) in handle_subscribe_ack()
540 struct ceph_msg *msg) in ceph_monc_handle_map()
706 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply()
713 struct ceph_msg *m; in get_generic_reply()
739 struct ceph_msg *msg) in handle_statfs_reply()
817 struct ceph_msg *msg) in handle_get_version_reply()
940 struct ceph_msg *msg) in handle_command_ack()
1314 struct ceph_msg *msg) in handle_auth_reply()
1445 static void mon_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in mon_dispatch()
[all …]
|
| H A D | messenger_v2.c | 359 static int front_len(const struct ceph_msg *msg) in front_len()
364 static int middle_len(const struct ceph_msg *msg) in middle_len()
369 static int data_len(const struct ceph_msg *msg) in data_len()
430 static int tail_onwire_len(const struct ceph_msg *msg, bool secure) in tail_onwire_len()
976 static int setup_message_sgs(struct sg_table *sgt, struct ceph_msg *msg, in setup_message_sgs()
1566 struct ceph_msg *msg, bool aborted) in prepare_epilogue_plain()
1581 struct ceph_msg *msg) in prepare_message_plain()
1636 struct ceph_msg *msg) in prepare_message_secure()
1700 static int prepare_message(struct ceph_connection *con, struct ceph_msg *msg) in prepare_message()
2001 struct ceph_msg *msg = con->in_msg; in prepare_sparse_read_data()
[all …]
|
| H A D | osd_client.c | 586 struct ceph_msg *msg; in __ceph_osdc_alloc_messages()
940 static void ceph_osdc_msg_data_add(struct ceph_msg *msg, in ceph_osdc_msg_data_add()
2044 struct ceph_msg *request_msg = req->r_request; in setup_request_data()
2045 struct ceph_msg *reply_msg = req->r_reply; in setup_request_data()
2146 struct ceph_msg *msg) in encode_request_partial()
2222 static void encode_request_finish(struct ceph_msg *msg) in encode_request_finish()
2938 struct ceph_msg *msg; /* for ceph_msg_put() */
3670 static int decode_MOSDOpReply(const struct ceph_msg *msg, struct MOSDOpReply *m) in decode_MOSDOpReply()
3750 static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg) in handle_reply()
4135 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) in ceph_osdc_handle_map()
[all …]
|
| H A D | messenger_v1.c | 160 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
173 struct ceph_msg *m) in prepare_write_message_footer()
195 struct ceph_msg *m) in prepare_write_message()
462 struct ceph_msg *msg) in write_partial_message_data()
1145 struct ceph_msg *m = con->in_msg; in read_partial_message()
1471 struct ceph_msg *msg; in ceph_con_v1_try_write()
1565 void ceph_con_v1_revoke(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_v1_revoke()
|
| H A D | auth_x.c | 964 static int calc_signature(struct ceph_x_authorizer *au, struct ceph_msg *msg, in calc_signature()
1030 struct ceph_msg *msg) in ceph_x_sign_message()
1049 struct ceph_msg *msg) in ceph_x_check_message_signature()
|
| /linux/fs/ceph/ |
| H A D | mds_client.h | 345 struct ceph_msg *r_request; /* original request */
346 struct ceph_msg *r_reply;
604 extern struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq);
646 struct ceph_msg *msg);
648 struct ceph_msg *msg);
|
| H A D | mds_client.c | 748 static int parse_reply_info(struct ceph_mds_session *s, struct ceph_msg *msg, in parse_reply_info()
1443 struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq) in ceph_create_session_msg()
1445 struct ceph_msg *msg; in ceph_create_session_msg()
1539 static struct ceph_msg *
1542 struct ceph_msg *msg; in create_session_full_msg()
1666 struct ceph_msg *msg; in __open_session()
2020 struct ceph_msg *msg; in send_renew_caps()
2051 struct ceph_msg *msg; in send_flushmsg_ack()
2106 struct ceph_msg *msg; in request_close_session()
2313 struct ceph_msg *msg = NULL; in ceph_send_cap_releases()
[all …]
|
| H A D | super.h | 1013 struct ceph_msg *msg);
1233 struct ceph_msg *msg);
1434 struct ceph_msg *msg);
|
| H A D | metric.c | 35 struct ceph_msg *msg; in ceph_mdsc_send_metrics()
|
| H A D | caps.c | 1244 static void encode_cap_msg(struct ceph_msg *msg, struct cap_msg_args *arg) in encode_cap_msg()
1523 struct ceph_msg *msg; in __send_cap()
1555 struct ceph_msg *msg; in __send_flush_snap()
4329 struct ceph_msg *msg) in ceph_handle_caps()
|
| H A D | snap.c | 1018 struct ceph_msg *msg) in ceph_handle_snap()
|
| H A D | super.c | 784 static int extra_mon_dispatch(struct ceph_client *client, struct ceph_msg *msg) in extra_mon_dispatch()
|