| /linux-3.4.99/include/linux/ceph/ |
| D | messenger.h | 14 struct ceph_msg;
25 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
41 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
72 struct ceph_msg { struct
159 struct ceph_msg *out_msg; /* sending message (== tail of
175 struct ceph_msg *in_msg;
212 extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg);
214 extern void ceph_msg_revoke(struct ceph_msg *msg);
215 extern void ceph_msg_revoke_incoming(struct ceph_msg *msg);
219 extern struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
[all …]
|
| D | mon_client.h | 55 struct ceph_msg *request; /* original request */
56 struct ceph_msg *reply; /* and reply */
67 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 | 20 struct ceph_msg;
31 struct ceph_msg *);
65 struct ceph_msg *r_request, *r_reply;
206 struct ceph_msg *msg);
208 struct ceph_msg *msg);
|
| D | libceph.h | 128 int (*extra_mon_dispatch)(struct ceph_client *, struct ceph_msg *);
|
| /linux-3.4.99/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 | mon_client.c | 193 struct ceph_msg *msg = monc->m_subscribe; in __send_subscribe()
239 struct ceph_msg *msg) in handle_subscribe_ack()
329 struct ceph_msg *msg) in ceph_monc_handle_map()
451 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply()
458 struct ceph_msg *m; in get_generic_reply()
510 struct ceph_msg *msg) in handle_statfs_reply()
602 struct ceph_msg *msg) in handle_poolop_reply()
888 struct ceph_msg *msg) in handle_auth_reply()
964 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) in dispatch()
1012 static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con, in mon_alloc_msg()
[all …]
|
| D | messenger.c | 487 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
499 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
675 struct ceph_msg *msg = con->out_msg; in prepare_write_message_data()
701 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
721 struct ceph_msg *m; in prepare_write_message()
739 m = list_first_entry(&con->out_queue, struct ceph_msg, list_head); in prepare_write_message()
973 struct ceph_msg *msg = con->out_msg; in out_msg_pos_next()
1008 struct ceph_msg *msg = con->out_msg; in write_partial_msg_pages()
1685 struct ceph_msg *m; in process_ack()
1690 m = list_first_entry(&con->out_sent, struct ceph_msg, in process_ack()
[all …]
|
| D | osd_client.c | 202 struct ceph_msg *msg; in ceph_osdc_alloc_request()
373 struct ceph_msg *msg = req->r_request; in ceph_osdc_build_request()
1156 static void handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg, in handle_reply()
1363 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) in ceph_osdc_handle_map()
1636 void handle_watch_notify(struct ceph_osd_client *osdc, struct ceph_msg *msg) in handle_watch_notify()
1987 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) in dispatch()
2020 static struct ceph_msg *get_reply(struct ceph_connection *con, in get_reply()
2026 struct ceph_msg *m; in get_reply()
2091 static struct ceph_msg *alloc_msg(struct ceph_connection *con, in alloc_msg()
|
| /linux-3.4.99/fs/ceph/ |
| D | mds_client.h | 207 struct ceph_msg *r_request; /* original request */
209 struct ceph_msg *r_reply;
329 struct ceph_msg *msg, int mds);
377 struct ceph_msg *msg);
|
| D | mds_client.c | 250 static int parse_reply_info(struct ceph_msg *msg, in parse_reply_info()
765 static struct ceph_msg *create_session_msg(u32 op, u64 seq) in create_session_msg()
767 struct ceph_msg *msg; in create_session_msg()
790 struct ceph_msg *msg; in __open_session()
863 struct ceph_msg *msg; in cleanup_cap_releases()
868 struct ceph_msg, list_head); in cleanup_cap_releases()
874 struct ceph_msg, list_head); in cleanup_cap_releases()
1046 struct ceph_msg *msg; in send_renew_caps()
1113 struct ceph_msg *msg; in request_close_session()
1219 struct ceph_msg *msg, *partial = NULL; in ceph_add_cap_releases()
[all …]
|
| D | super.h | 676 struct ceph_msg *msg);
742 struct ceph_msg *msg);
|
| D | addr.c | 240 static void finish_read(struct ceph_osd_request *req, struct ceph_msg *msg) in finish_read()
558 struct ceph_msg *msg) in writepages_finish()
|
| D | caps.c | 937 struct ceph_msg *msg; in send_cap_msg()
994 struct ceph_msg *msg; in __queue_cap_release()
1001 struct ceph_msg, list_head); in __queue_cap_release()
2764 struct ceph_msg *msg) in ceph_handle_caps()
|
| D | snap.c | 771 struct ceph_msg *msg) in ceph_handle_snap()
|
| D | super.c | 440 static int extra_mon_dispatch(struct ceph_client *client, struct ceph_msg *msg) in extra_mon_dispatch()
|
| D | file.c | 440 struct ceph_msg *msg) in sync_write_commit()
|
| /linux-3.4.99/drivers/block/ |
| D | rbd.c | 883 struct ceph_msg *msg), in rbd_do_request()
982 static void rbd_req_cb(struct ceph_osd_request *req, struct ceph_msg *msg) in rbd_req_cb()
1018 static void rbd_simple_req_cb(struct ceph_osd_request *req, struct ceph_msg *msg) in rbd_simple_req_cb()
|