| /linux-4.4.14/include/linux/ceph/ |
| D | messenger.h | 16 struct ceph_msg;
27 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
43 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
47 int (*sign_message) (struct ceph_msg *msg);
48 int (*check_message_signature) (struct ceph_msg *msg);
144 struct ceph_msg { struct
224 struct ceph_msg *out_msg; /* sending message (== tail of
240 struct ceph_msg *in_msg;
276 extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg);
278 extern void ceph_msg_revoke(struct ceph_msg *msg);
[all …]
|
| D | auth.h | 16 struct ceph_msg;
25 struct ceph_msg *msg);
27 struct ceph_msg *msg);
76 struct ceph_msg *msg);
78 struct ceph_msg *msg);
127 struct ceph_msg *msg) in ceph_auth_sign_message()
136 struct ceph_msg *msg) in ceph_auth_check_message_signature()
|
| D | mon_client.h | 54 struct ceph_msg *request; /* original request */
55 struct ceph_msg *reply; /* and reply */
66 struct ceph_msg *m_auth, *m_auth_reply, *m_subscribe, *m_subscribe_ack;
|
| D | msgpool.h | 22 extern struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *,
24 extern void ceph_msgpool_put(struct ceph_msgpool *, struct ceph_msg *);
|
| D | osd_client.h | 15 struct ceph_msg;
25 struct ceph_msg *);
133 struct ceph_msg *r_request, *r_reply;
247 struct ceph_msg *msg);
249 struct ceph_msg *msg);
|
| D | libceph.h | 124 int (*extra_mon_dispatch)(struct ceph_client *, struct ceph_msg *);
|
| /linux-4.4.14/net/ceph/ |
| D | msgpool.c | 13 struct ceph_msg *msg; in msgpool_alloc()
28 struct ceph_msg *msg = element; in msgpool_free()
54 struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, in ceph_msgpool_get()
57 struct ceph_msg *msg; in ceph_msgpool_get()
73 void ceph_msgpool_put(struct ceph_msgpool *pool, struct ceph_msg *msg) in ceph_msgpool_put()
|
| D | messenger.c | 242 sizeof (struct ceph_msg), in ceph_msgr_slab_init()
243 __alignof__(struct ceph_msg), 0, NULL); in ceph_msgr_slab_init()
637 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
646 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
1108 static void ceph_msg_data_cursor_init(struct ceph_msg *msg, size_t length) in ceph_msg_data_cursor_init()
1210 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
1226 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
1255 struct ceph_msg *m; in prepare_write_message()
1272 m = list_first_entry(&con->out_queue, struct ceph_msg, list_head); in prepare_write_message()
1556 struct ceph_msg *msg = con->out_msg; in write_partial_message_data()
[all …]
|
| D | mon_client.c | 202 struct ceph_msg *msg = monc->m_subscribe; in __send_subscribe()
248 struct ceph_msg *msg) in handle_subscribe_ack()
372 struct ceph_msg *msg) in ceph_monc_handle_map()
494 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply()
501 struct ceph_msg *m; in get_generic_reply()
563 struct ceph_msg *msg) in handle_statfs_reply()
635 struct ceph_msg *msg) in handle_get_version_reply()
918 struct ceph_msg *msg) in handle_auth_reply()
994 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) in dispatch()
1042 static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con, in mon_alloc_msg()
[all …]
|
| D | osd_client.c | 369 struct ceph_msg *msg; in ceph_osdc_alloc_request()
632 static void ceph_osdc_msg_data_add(struct ceph_msg *msg, in ceph_osdc_msg_data_add()
1755 static void handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg) in handle_reply()
2073 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) in ceph_osdc_handle_map()
2349 struct ceph_msg *msg) in handle_watch_notify()
2406 struct ceph_msg *msg = req->r_request; in ceph_osdc_build_request()
2796 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) in dispatch()
2830 static struct ceph_msg *get_reply(struct ceph_connection *con, in get_reply()
2836 struct ceph_msg *m; in get_reply()
2884 static struct ceph_msg *alloc_msg(struct ceph_connection *con, in alloc_msg()
[all …]
|
| D | auth_x.c | 681 struct ceph_msg *msg, __le64 *sig) in calcu_signature()
698 struct ceph_msg *msg) in ceph_x_sign_message()
714 struct ceph_msg *msg) in ceph_x_check_message_signature()
|
| /linux-4.4.14/fs/ceph/ |
| D | mds_client.h | 222 struct ceph_msg *r_request; /* original request */
224 struct ceph_msg *r_reply;
368 struct ceph_msg *msg, int mds);
416 struct ceph_msg *msg);
|
| D | mds_client.c | 291 static int parse_reply_info(struct ceph_msg *msg, in parse_reply_info()
835 static struct ceph_msg *create_session_msg(u32 op, u64 seq) in create_session_msg()
837 struct ceph_msg *msg; in create_session_msg()
857 static struct ceph_msg *create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq) in create_session_open_msg()
859 struct ceph_msg *msg; in create_session_open_msg()
932 struct ceph_msg *msg; in __open_session()
1294 struct ceph_msg *msg; in send_renew_caps()
1324 struct ceph_msg *msg; in send_flushmsg_ack()
1376 struct ceph_msg *msg; in request_close_session()
1588 struct ceph_msg *msg = NULL; in ceph_send_cap_releases()
[all …]
|
| D | super.h | 735 struct ceph_msg *msg);
862 struct ceph_msg *msg);
|
| D | addr.c | 260 static void finish_read(struct ceph_osd_request *req, struct ceph_msg *msg) in finish_read()
604 struct ceph_msg *msg) in writepages_finish()
|
| D | super.c | 491 static int extra_mon_dispatch(struct ceph_client *client, struct ceph_msg *msg) in extra_mon_dispatch()
|
| D | snap.c | 833 struct ceph_msg *msg) in ceph_handle_snap()
|
| D | caps.c | 1001 struct ceph_msg *msg; in send_cap_msg()
3392 struct ceph_msg *msg) in ceph_handle_caps()
|
| /linux-4.4.14/drivers/block/ |
| D | rbd.c | 1833 struct ceph_msg *msg) in rbd_osd_req_callback()
|