| /linux-4.1.27/include/linux/ceph/ |
| D | messenger.h | 15 struct ceph_msg;
26 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
42 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
45 int (*sign_message) (struct ceph_connection *con, struct ceph_msg *msg);
48 struct ceph_msg *msg);
148 struct ceph_msg { struct
228 struct ceph_msg *out_msg; /* sending message (== tail of
242 struct ceph_msg *in_msg;
279 extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg);
281 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 | 125 int (*extra_mon_dispatch)(struct ceph_client *, struct ceph_msg *);
|
| /linux-4.1.27/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 | 240 sizeof (struct ceph_msg), in ceph_msgr_slab_init()
241 __alignof__(struct ceph_msg), 0, NULL); in ceph_msgr_slab_init()
636 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
648 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
1111 static void ceph_msg_data_cursor_init(struct ceph_msg *msg, size_t length) in ceph_msg_data_cursor_init()
1213 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
1229 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
1258 struct ceph_msg *m; in prepare_write_message()
1275 m = list_first_entry(&con->out_queue, struct ceph_msg, list_head); in prepare_write_message()
1549 struct ceph_msg *msg = con->out_msg; in write_partial_message_data()
[all …]
|
| D | mon_client.c | 193 struct ceph_msg *msg = monc->m_subscribe; in __send_subscribe()
239 struct ceph_msg *msg) in handle_subscribe_ack()
356 struct ceph_msg *msg) in ceph_monc_handle_map()
478 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply()
485 struct ceph_msg *m; in get_generic_reply()
547 struct ceph_msg *msg) in handle_statfs_reply()
619 struct ceph_msg *msg) in handle_get_version_reply()
890 struct ceph_msg *msg) in handle_auth_reply()
966 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) in dispatch()
1014 static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con, in mon_alloc_msg()
[all …]
|
| D | osd_client.c | 363 struct ceph_msg *msg; in ceph_osdc_alloc_request()
619 static void ceph_osdc_msg_data_add(struct ceph_msg *msg, in ceph_osdc_msg_data_add()
1740 static void handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg, in handle_reply()
2059 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) in ceph_osdc_handle_map()
2335 struct ceph_msg *msg) in handle_watch_notify()
2392 struct ceph_msg *msg = req->r_request; in ceph_osdc_build_request()
2782 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) in dispatch()
2815 static struct ceph_msg *get_reply(struct ceph_connection *con, in get_reply()
2821 struct ceph_msg *m; in get_reply()
2888 static struct ceph_msg *alloc_msg(struct ceph_connection *con, in alloc_msg()
[all …]
|
| D | auth_x.c | 674 struct ceph_msg *msg, __le64 *sig) in calcu_signature()
691 struct ceph_msg *msg) in ceph_x_sign_message()
705 struct ceph_msg *msg) in ceph_x_check_message_signature()
|
| /linux-4.1.27/fs/ceph/ |
| D | mds_client.h | 223 struct ceph_msg *r_request; /* original request */
225 struct ceph_msg *r_reply;
350 struct ceph_msg *msg, int mds);
399 struct ceph_msg *msg);
|
| D | mds_client.c | 290 static int parse_reply_info(struct ceph_msg *msg, in parse_reply_info()
815 static struct ceph_msg *create_session_msg(u32 op, u64 seq) in create_session_msg()
817 struct ceph_msg *msg; in create_session_msg()
837 static struct ceph_msg *create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq) in create_session_open_msg()
839 struct ceph_msg *msg; in create_session_open_msg()
912 struct ceph_msg *msg; in __open_session()
1006 struct ceph_msg *msg; in cleanup_cap_releases()
1011 struct ceph_msg, list_head); in cleanup_cap_releases()
1017 struct ceph_msg, list_head); in cleanup_cap_releases()
1239 struct ceph_msg *msg; in send_renew_caps()
[all …]
|
| D | super.h | 701 struct ceph_msg *msg);
828 struct ceph_msg *msg);
|
| D | addr.c | 256 static void finish_read(struct ceph_osd_request *req, struct ceph_msg *msg) in finish_read()
599 struct ceph_msg *msg) in writepages_finish()
|
| D | caps.c | 990 struct ceph_msg *msg; in send_cap_msg()
1060 struct ceph_msg *msg; in __queue_cap_release()
1066 struct ceph_msg, list_head); in __queue_cap_release()
3085 struct ceph_msg *msg) in ceph_handle_caps()
|
| D | super.c | 478 static int extra_mon_dispatch(struct ceph_client *client, struct ceph_msg *msg) in extra_mon_dispatch()
|
| D | snap.c | 807 struct ceph_msg *msg) in ceph_handle_snap()
|
| /linux-4.1.27/drivers/block/ |
| D | rbd.c | 1814 struct ceph_msg *msg) in rbd_osd_req_callback()
|