Home
last modified time | relevance | path

Searched refs:ceph_msg (Results 1 - 25 of 40) sorted by relevance

12

/kernel/linux/linux-5.10/include/linux/ceph/
H A Dmessenger.h17 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);
216 struct ceph_msg { struct
297 struct ceph_msg *out_msg; /* sending message (== tail of
313 struct ceph_msg *in_msg;
351 extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *ms
[all...]
H A Dauth.h16 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()
H A Dmsgpool.h23 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 Dmon_client.h61 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 Dosd_client.h20 struct ceph_msg;
191 struct ceph_msg *r_request, *r_reply;
395 struct ceph_msg *msg);
397 struct ceph_msg *msg);
/kernel/linux/linux-6.6/include/linux/ceph/
H A Dmessenger.h18 struct ceph_msg;
30 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
49 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
53 void (*reencode_message) (struct ceph_msg *msg);
55 int (*sign_message) (struct ceph_msg *msg);
56 int (*check_message_signature) (struct ceph_msg *msg);
265 struct ceph_msg { struct
497 struct ceph_msg *in_msg;
498 struct ceph_msg *out_msg; /* sending message (== tail of
536 struct ceph_msg *ms
[all...]
H A Dauth.h16 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 Dmsgpool.h23 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 Dmon_client.h61 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 Dosd_client.h20 struct ceph_msg;
248 struct ceph_msg *r_request, *r_reply;
453 struct ceph_msg *msg);
455 struct ceph_msg *msg);
/kernel/linux/linux-5.10/net/ceph/
H A Dmsgpool.c15 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 Dmessenger.c29 * Ceph uses the messenger to exchange ceph_msg messages with other
236 ceph_msg_cache = KMEM_CACHE(ceph_msg, 0); in ceph_msgr_slab_init()
620 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
629 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
1116 static void ceph_msg_data_cursor_init(struct ceph_msg *msg, size_t length) in ceph_msg_data_cursor_init()
1220 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
1233 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
1256 struct ceph_msg *m; in prepare_write_message()
1273 m = list_first_entry(&con->out_queue, struct ceph_msg, list_hea in prepare_write_message()
[all...]
H A Dmon_client.c263 struct ceph_msg *msg = monc->m_subscribe; in __send_subscribe()
312 struct ceph_msg *msg) in handle_subscribe_ack()
469 struct ceph_msg *msg) in ceph_monc_handle_map()
635 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply()
642 struct ceph_msg *m; in get_generic_reply()
668 struct ceph_msg *msg) in handle_statfs_reply()
746 struct ceph_msg *msg) in handle_get_version_reply()
869 struct ceph_msg *msg) in handle_command_ack()
1210 struct ceph_msg *msg) in handle_auth_reply()
1280 static void dispatch(struct ceph_connection *con, struct ceph_msg *ms
[all...]
H A Dosd_client.c582 struct ceph_msg *msg; in __ceph_osdc_alloc_messages()
935 static void ceph_osdc_msg_data_add(struct ceph_msg *msg, in ceph_osdc_msg_data_add()
1980 struct ceph_msg *request_msg = req->r_request; in setup_request_data()
1981 struct ceph_msg *reply_msg = req->r_reply; in setup_request_data()
2081 struct ceph_msg *msg) in encode_request_partial()
2157 static void encode_request_finish(struct ceph_msg *msg) in encode_request_finish()
2867 struct ceph_msg *msg; /* for ceph_msg_put() */
3599 static int decode_MOSDOpReply(const struct ceph_msg *msg, struct MOSDOpReply *m) in decode_MOSDOpReply()
3679 static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg) in handle_reply()
4061 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *ms
[all...]
H A Dauth_x.c805 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()
/kernel/linux/linux-6.6/net/ceph/
H A Dmsgpool.c15 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 Dmessenger.c30 * 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()
538 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
548 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
673 struct ceph_msg *msg; in ceph_con_discard_sent()
678 msg = list_first_entry(&con->out_sent, struct ceph_msg, in ceph_con_discard_sent()
698 struct ceph_msg *msg; in ceph_con_discard_requeued()
703 msg = list_first_entry(&con->out_queue, struct ceph_msg, in ceph_con_discard_requeued()
1067 struct ceph_msg *ms in ceph_msg_data_cursor_init()
[all...]
H A Dmon_client.c334 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()
1304 struct ceph_msg *msg) in handle_auth_reply()
1435 static void mon_dispatch(struct ceph_connection *con, struct ceph_msg *ms
[all...]
H A Dosd_client.c609 struct ceph_msg *msg; in __ceph_osdc_alloc_messages()
963 static void ceph_osdc_msg_data_add(struct ceph_msg *msg, in ceph_osdc_msg_data_add()
2060 struct ceph_msg *request_msg = req->r_request; in setup_request_data()
2061 struct ceph_msg *reply_msg = req->r_reply; in setup_request_data()
2162 struct ceph_msg *msg) in encode_request_partial()
2238 static void encode_request_finish(struct ceph_msg *msg) in encode_request_finish()
2954 struct ceph_msg *msg; /* for ceph_msg_put() */
3686 static int decode_MOSDOpReply(const struct ceph_msg *msg, struct MOSDOpReply *m) in decode_MOSDOpReply()
3766 static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg) in handle_reply()
4151 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *ms
[all...]
H A Dmessenger_v1.c160 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
174 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
197 struct ceph_msg *m; in prepare_write_message()
467 struct ceph_msg *msg = con->out_msg; in write_partial_message_data()
1149 struct ceph_msg *m = con->in_msg; in read_partial_message()
1569 struct ceph_msg *msg = con->out_msg; in ceph_con_v1_revoke()
/kernel/linux/linux-5.10/fs/ceph/
H A Dmds_client.h291 struct ceph_msg *r_request; /* original request */
292 struct ceph_msg *r_reply;
494 struct ceph_msg *msg, int mds);
530 extern struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq);
558 struct ceph_msg *msg);
560 struct ceph_msg *msg);
H A Dmds_client.c576 static int parse_reply_info(struct ceph_mds_session *s, struct ceph_msg *msg, in parse_reply_info()
1187 struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq) in ceph_create_session_msg()
1189 struct ceph_msg *msg; in ceph_create_session_msg()
1283 static struct ceph_msg *create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq) in create_session_open_msg()
1285 struct ceph_msg *msg; in create_session_open_msg()
1396 struct ceph_msg *msg; in __open_session()
1845 struct ceph_msg *msg; in send_renew_caps()
1875 struct ceph_msg *msg; in send_flushmsg_ack()
1926 struct ceph_msg *msg; in request_close_session()
2120 struct ceph_msg *ms in ceph_send_cap_releases()
[all...]
H A Dsuper.h928 struct ceph_msg *msg);
1100 struct ceph_msg *msg);
1250 struct ceph_msg *msg);
/kernel/linux/linux-6.6/fs/ceph/
H A Dmds_client.h319 struct ceph_msg *r_request; /* original request */
320 struct ceph_msg *r_reply;
527 struct ceph_msg *msg, int mds);
566 extern struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq);
593 struct ceph_msg *msg);
595 struct ceph_msg *msg);
H A Dmds_client.c743 static int parse_reply_info(struct ceph_mds_session *s, struct ceph_msg *msg, in parse_reply_info()
1427 struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq) in ceph_create_session_msg()
1429 struct ceph_msg *msg; in ceph_create_session_msg()
1523 static struct ceph_msg *create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq) in create_session_open_msg()
1525 struct ceph_msg *msg; in create_session_open_msg()
1636 struct ceph_msg *msg; in __open_session()
1988 struct ceph_msg *msg; in send_renew_caps()
2018 struct ceph_msg *msg; in send_flushmsg_ack()
2069 struct ceph_msg *msg; in request_close_session()
2269 struct ceph_msg *ms in ceph_send_cap_releases()
[all...]

Completed in 43 milliseconds

12