Home
last modified time | relevance | path

Searched refs:ceph_msg (Results 1 – 21 of 21) sorted by relevance

/linux-6.15/include/linux/ceph/
H A Dmessenger.h18 struct ceph_msg;
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;
536 struct ceph_msg *msg, size_t length);
614 void ceph_msg_data_add_iter(struct ceph_msg *msg,
622 extern struct ceph_msg *ceph_msg_get(struct ceph_msg *msg);
623 extern void ceph_msg_put(struct ceph_msg *msg);
[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);
H A Dlibceph.h127 int (*extra_mon_dispatch)(struct ceph_client *, struct ceph_msg *);
/linux-6.15/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.c214 ceph_msg_cache = KMEM_CACHE(ceph_msg, 0); in ceph_msgr_slab_init()
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()
698 struct ceph_msg *msg; in ceph_con_discard_requeued()
1403 struct ceph_msg *msg = con->in_msg; in ceph_con_process_message()
1967 struct ceph_msg *m; in ceph_msg_new2()
2069 struct ceph_msg *msg; in ceph_con_in_msg_alloc()
2114 struct ceph_msg *msg; in ceph_con_get_out_msg()
2159 struct ceph_msg *m = container_of(kref, struct ceph_msg, kref); in ceph_msg_release()
2182 struct ceph_msg *ceph_msg_get(struct ceph_msg *msg) in ceph_msg_get()
[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()
1314 struct ceph_msg *msg) in handle_auth_reply()
1494 static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con, in mon_alloc_msg()
[all …]
H A Dosd_client.c586 struct ceph_msg *msg; in __ceph_osdc_alloc_messages()
2039 struct ceph_msg *request_msg = req->r_request; in setup_request_data()
2040 struct ceph_msg *reply_msg = req->r_reply; in setup_request_data()
2141 struct ceph_msg *msg) in encode_request_partial()
2933 struct ceph_msg *msg; /* for ceph_msg_put() */
4353 static struct ceph_msg *create_backoff_message( in create_backoff_message()
4357 struct ceph_msg *msg; in create_backoff_message()
4395 struct ceph_msg *msg; in handle_backoff_block()
4553 struct ceph_msg *msg) in handle_watch_notify()
5409 struct ceph_msg *m = NULL; in get_reply()
[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()
H A Dauth_x.c962 static int calc_signature(struct ceph_x_authorizer *au, struct ceph_msg *msg, in calc_signature()
1028 struct ceph_msg *msg) in ceph_x_sign_message()
1047 struct ceph_msg *msg) in ceph_x_check_message_signature()
H A Dmessenger_v2.c359 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()
1002 static int setup_message_sgs(struct sg_table *sgt, struct ceph_msg *msg, in setup_message_sgs()
1608 struct ceph_msg *msg = con->out_msg; in prepare_message_plain()
2027 struct ceph_msg *msg = con->in_msg; in prepare_sparse_read_data()
2048 struct ceph_msg *msg = con->in_msg; in prepare_read_tail_plain()
2922 struct ceph_msg *msg; in __handle_control()
/linux-6.15/fs/ceph/
H A Dmds_client.h345 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);
636 struct ceph_msg *msg);
638 struct ceph_msg *msg);
H A Dmds_client.c1443 struct ceph_msg *msg; in ceph_create_session_msg()
1540 struct ceph_msg *msg; in create_session_full_msg()
1664 struct ceph_msg *msg; in __open_session()
2018 struct ceph_msg *msg; in send_renew_caps()
2049 struct ceph_msg *msg; in send_flushmsg_ack()
2104 struct ceph_msg *msg; in request_close_session()
2969 struct ceph_msg *msg; in create_request_message()
3260 struct ceph_msg *msg; in __prepare_send_request()
5295 struct ceph_msg *msg; in ceph_mdsc_lease_send_msg()
5584 struct ceph_msg *msg; in send_flush_mdlog()
[all …]
H A Dsuper.h997 struct ceph_msg *msg);
1217 struct ceph_msg *msg);
1418 struct ceph_msg *msg);
H A Dmetric.c35 struct ceph_msg *msg; in ceph_mdsc_send_metrics()
H A Dquota.c42 struct ceph_msg *msg) in ceph_handle_quota()
H A Dcaps.c1243 static void encode_cap_msg(struct ceph_msg *msg, struct cap_msg_args *arg) in encode_cap_msg()
1522 struct ceph_msg *msg; in __send_cap()
1554 struct ceph_msg *msg; in __send_flush_snap()
4328 struct ceph_msg *msg) in ceph_handle_caps()
H A Dsnap.c1018 struct ceph_msg *msg) in ceph_handle_snap()
H A Dsuper.c795 static int extra_mon_dispatch(struct ceph_client *client, struct ceph_msg *msg) in extra_mon_dispatch()