Symbol: ceph_msg
fs/ceph/caps.c
1244
static void encode_cap_msg(struct ceph_msg *msg, struct cap_msg_args *arg)
fs/ceph/caps.c
1523
struct ceph_msg *msg;
fs/ceph/caps.c
1555
struct ceph_msg *msg;
fs/ceph/caps.c
4329
struct ceph_msg *msg)
fs/ceph/mds_client.c
1443
struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq)
fs/ceph/mds_client.c
1445
struct ceph_msg *msg;
fs/ceph/mds_client.c
1539
static struct ceph_msg *
fs/ceph/mds_client.c
1542
struct ceph_msg *msg;
fs/ceph/mds_client.c
1666
struct ceph_msg *msg;
fs/ceph/mds_client.c
2020
struct ceph_msg *msg;
fs/ceph/mds_client.c
2051
struct ceph_msg *msg;
fs/ceph/mds_client.c
2106
struct ceph_msg *msg;
fs/ceph/mds_client.c
2313
struct ceph_msg *msg = NULL;
fs/ceph/mds_client.c
2995
static struct ceph_msg *create_request_message(struct ceph_mds_session *session,
fs/ceph/mds_client.c
3002
struct ceph_msg *msg;
fs/ceph/mds_client.c
3314
struct ceph_msg *msg;
fs/ceph/mds_client.c
3854
static void handle_reply(struct ceph_mds_session *session, struct ceph_msg *msg)
fs/ceph/mds_client.c
4068
struct ceph_msg *msg)
fs/ceph/mds_client.c
4167
struct ceph_msg *msg)
fs/ceph/mds_client.c
4525
struct ceph_msg *reply;
fs/ceph/mds_client.c
4897
struct ceph_msg *reply;
fs/ceph/mds_client.c
5244
struct ceph_msg *msg)
fs/ceph/mds_client.c
5357
struct ceph_msg *msg;
fs/ceph/mds_client.c
5646
struct ceph_msg *msg;
fs/ceph/mds_client.c
6124
void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
fs/ceph/mds_client.c
6198
void ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
fs/ceph/mds_client.c
6293
static void mds_dispatch(struct ceph_connection *con, struct ceph_msg *msg)
fs/ceph/mds_client.c
6477
static struct ceph_msg *mds_alloc_msg(struct ceph_connection *con,
fs/ceph/mds_client.c
6480
struct ceph_msg *msg;
fs/ceph/mds_client.c
6498
static int mds_sign_message(struct ceph_msg *msg)
fs/ceph/mds_client.c
6506
static int mds_check_message_signature(struct ceph_msg *msg)
fs/ceph/mds_client.c
748
static int parse_reply_info(struct ceph_mds_session *s, struct ceph_msg *msg,
fs/ceph/mds_client.h
345
struct ceph_msg *r_request; /* original request */
fs/ceph/mds_client.h
346
struct ceph_msg *r_reply;
fs/ceph/mds_client.h
604
extern struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq);
fs/ceph/mds_client.h
646
struct ceph_msg *msg);
fs/ceph/mds_client.h
648
struct ceph_msg *msg);
fs/ceph/metric.c
35
struct ceph_msg *msg;
fs/ceph/quota.c
42
struct ceph_msg *msg)
fs/ceph/snap.c
1018
struct ceph_msg *msg)
fs/ceph/super.c
784
static int extra_mon_dispatch(struct ceph_client *client, struct ceph_msg *msg)
fs/ceph/super.h
1025
struct ceph_msg *msg);
fs/ceph/super.h
1245
struct ceph_msg *msg);
fs/ceph/super.h
1446
struct ceph_msg *msg);
include/linux/ceph/auth.h
145
struct ceph_msg *msg)
include/linux/ceph/auth.h
154
struct ceph_msg *msg)
include/linux/ceph/auth.h
16
struct ceph_msg;
include/linux/ceph/auth.h
29
struct ceph_msg *msg);
include/linux/ceph/auth.h
31
struct ceph_msg *msg);
include/linux/ceph/auth.h
85
struct ceph_msg *msg);
include/linux/ceph/auth.h
87
struct ceph_msg *msg);
include/linux/ceph/libceph.h
127
int (*extra_mon_dispatch)(struct ceph_client *, struct ceph_msg *);
include/linux/ceph/messenger.h
19
struct ceph_msg;
include/linux/ceph/messenger.h
31
void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
include/linux/ceph/messenger.h
499
struct ceph_msg *in_msg;
include/linux/ceph/messenger.h
50
struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
include/linux/ceph/messenger.h
500
struct ceph_msg *out_msg; /* sending message (== tail of
include/linux/ceph/messenger.h
538
struct ceph_msg *msg, size_t length);
include/linux/ceph/messenger.h
54
void (*reencode_message) (struct ceph_msg *msg);
include/linux/ceph/messenger.h
553
struct ceph_msg *ceph_con_get_out_msg(struct ceph_connection *con);
include/linux/ceph/messenger.h
558
void ceph_con_v1_revoke(struct ceph_connection *con, struct ceph_msg *msg);
include/linux/ceph/messenger.h
56
int (*sign_message) (struct ceph_msg *msg);
include/linux/ceph/messenger.h
567
void ceph_con_v2_revoke(struct ceph_connection *con, struct ceph_msg *msg);
include/linux/ceph/messenger.h
57
int (*check_message_signature) (struct ceph_msg *msg);
include/linux/ceph/messenger.h
597
extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg);
include/linux/ceph/messenger.h
599
extern void ceph_msg_revoke(struct ceph_msg *msg);
include/linux/ceph/messenger.h
600
extern void ceph_msg_revoke_incoming(struct ceph_msg *msg);
include/linux/ceph/messenger.h
606
void ceph_msg_data_add_pages(struct ceph_msg *msg, struct page **pages,
include/linux/ceph/messenger.h
608
extern void ceph_msg_data_add_pagelist(struct ceph_msg *msg,
include/linux/ceph/messenger.h
611
void ceph_msg_data_add_bio(struct ceph_msg *msg, struct ceph_bio_iter *bio_pos,
include/linux/ceph/messenger.h
614
void ceph_msg_data_add_bvecs(struct ceph_msg *msg,
include/linux/ceph/messenger.h
616
void ceph_msg_data_add_iter(struct ceph_msg *msg,
include/linux/ceph/messenger.h
619
struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items,
include/linux/ceph/messenger.h
621
extern struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
include/linux/ceph/messenger.h
624
extern struct ceph_msg *ceph_msg_get(struct ceph_msg *msg);
include/linux/ceph/messenger.h
625
extern void ceph_msg_put(struct ceph_msg *msg);
include/linux/ceph/messenger.h
627
extern void ceph_msg_dump(struct ceph_msg *msg);
include/linux/ceph/mon_client.h
61
struct ceph_msg *request; /* original request */
include/linux/ceph/mon_client.h
62
struct ceph_msg *reply; /* and reply */
include/linux/ceph/mon_client.h
78
struct ceph_msg *m_auth, *m_auth_reply, *m_subscribe, *m_subscribe_ack;
include/linux/ceph/msgpool.h
23
struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len,
include/linux/ceph/msgpool.h
25
extern void ceph_msgpool_put(struct ceph_msgpool *, struct ceph_msg *);
include/linux/ceph/osd_client.h
20
struct ceph_msg;
include/linux/ceph/osd_client.h
248
struct ceph_msg *r_request, *r_reply;
include/linux/ceph/osd_client.h
453
struct ceph_msg *msg);
net/ceph/auth_x.c
1030
static int calc_signature(struct ceph_x_authorizer *au, struct ceph_msg *msg,
net/ceph/auth_x.c
1112
struct ceph_msg *msg)
net/ceph/auth_x.c
1131
struct ceph_msg *msg)
net/ceph/messenger.c
1068
struct ceph_msg *msg, size_t length)
net/ceph/messenger.c
1404
struct ceph_msg *msg = con->in_msg;
net/ceph/messenger.c
1705
static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con)
net/ceph/messenger.c
1732
void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg)
net/ceph/messenger.c
1772
void ceph_msg_revoke(struct ceph_msg *msg)
net/ceph/messenger.c
1812
void ceph_msg_revoke_incoming(struct ceph_msg *msg)
net/ceph/messenger.c
1869
static struct ceph_msg_data *ceph_msg_data_add(struct ceph_msg *msg)
net/ceph/messenger.c
1885
void ceph_msg_data_add_pages(struct ceph_msg *msg, struct page **pages,
net/ceph/messenger.c
1904
void ceph_msg_data_add_pagelist(struct ceph_msg *msg,
net/ceph/messenger.c
1922
void ceph_msg_data_add_bio(struct ceph_msg *msg, struct ceph_bio_iter *bio_pos,
net/ceph/messenger.c
1937
void ceph_msg_data_add_bvecs(struct ceph_msg *msg,
net/ceph/messenger.c
1950
void ceph_msg_data_add_iter(struct ceph_msg *msg,
net/ceph/messenger.c
1966
struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items,
net/ceph/messenger.c
1969
struct ceph_msg *m;
net/ceph/messenger.c
2021
struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
net/ceph/messenger.c
2035
static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg)
net/ceph/messenger.c
2070
struct ceph_msg *msg;
net/ceph/messenger.c
2113
struct ceph_msg *ceph_con_get_out_msg(struct ceph_connection *con)
net/ceph/messenger.c
2115
struct ceph_msg *msg;
net/ceph/messenger.c
2120
msg = list_first_entry(&con->out_queue, struct ceph_msg, list_head);
net/ceph/messenger.c
214
ceph_msg_cache = KMEM_CACHE(ceph_msg, 0);
net/ceph/messenger.c
2152
static void ceph_msg_free(struct ceph_msg *m)
net/ceph/messenger.c
2162
struct ceph_msg *m = container_of(kref, struct ceph_msg, kref);
net/ceph/messenger.c
2185
struct ceph_msg *ceph_msg_get(struct ceph_msg *msg)
net/ceph/messenger.c
2194
void ceph_msg_put(struct ceph_msg *msg)
net/ceph/messenger.c
2202
void ceph_msg_dump(struct ceph_msg *msg)
net/ceph/messenger.c
539
static void ceph_msg_remove(struct ceph_msg *msg)
net/ceph/messenger.c
549
struct ceph_msg *msg = list_first_entry(head, struct ceph_msg,
net/ceph/messenger.c
674
struct ceph_msg *msg;
net/ceph/messenger.c
679
msg = list_first_entry(&con->out_sent, struct ceph_msg,
net/ceph/messenger.c
699
struct ceph_msg *msg;
net/ceph/messenger.c
704
msg = list_first_entry(&con->out_queue, struct ceph_msg,
net/ceph/messenger_v1.c
1145
struct ceph_msg *m = con->in_msg;
net/ceph/messenger_v1.c
1471
struct ceph_msg *msg;
net/ceph/messenger_v1.c
1565
void ceph_con_v1_revoke(struct ceph_connection *con, struct ceph_msg *msg)
net/ceph/messenger_v1.c
160
static void prepare_message_data(struct ceph_msg *msg, u32 data_len)
net/ceph/messenger_v1.c
173
struct ceph_msg *m)
net/ceph/messenger_v1.c
195
struct ceph_msg *m)
net/ceph/messenger_v1.c
462
struct ceph_msg *msg)
net/ceph/messenger_v2.c
1565
struct ceph_msg *msg, bool aborted)
net/ceph/messenger_v2.c
1580
struct ceph_msg *msg)
net/ceph/messenger_v2.c
1635
struct ceph_msg *msg)
net/ceph/messenger_v2.c
1699
static int prepare_message(struct ceph_connection *con, struct ceph_msg *msg)
net/ceph/messenger_v2.c
2000
struct ceph_msg *msg = con->in_msg;
net/ceph/messenger_v2.c
2021
struct ceph_msg *msg = con->in_msg;
net/ceph/messenger_v2.c
2901
struct ceph_msg *msg;
net/ceph/messenger_v2.c
3171
static void queue_data(struct ceph_connection *con, struct ceph_msg *msg)
net/ceph/messenger_v2.c
3184
static void queue_data_cont(struct ceph_connection *con, struct ceph_msg *msg)
net/ceph/messenger_v2.c
3237
static void queue_zeros(struct ceph_connection *con, struct ceph_msg *msg)
net/ceph/messenger_v2.c
3281
struct ceph_msg *msg;
net/ceph/messenger_v2.c
3441
struct ceph_msg *msg, int resid)
net/ceph/messenger_v2.c
3463
struct ceph_msg *msg, int resid)
net/ceph/messenger_v2.c
3485
struct ceph_msg *msg)
net/ceph/messenger_v2.c
3493
struct ceph_msg *msg)
net/ceph/messenger_v2.c
3537
struct ceph_msg *msg)
net/ceph/messenger_v2.c
3564
struct ceph_msg *msg)
net/ceph/messenger_v2.c
359
static int front_len(const struct ceph_msg *msg)
net/ceph/messenger_v2.c
3622
void ceph_con_v2_revoke(struct ceph_connection *con, struct ceph_msg *msg)
net/ceph/messenger_v2.c
364
static int middle_len(const struct ceph_msg *msg)
net/ceph/messenger_v2.c
369
static int data_len(const struct ceph_msg *msg)
net/ceph/messenger_v2.c
428
static int tail_onwire_len(const struct ceph_msg *msg, bool secure)
net/ceph/messenger_v2.c
975
static int setup_message_sgs(struct sg_table *sgt, struct ceph_msg *msg,
net/ceph/mon_client.c
1313
struct ceph_msg *msg)
net/ceph/mon_client.c
1444
static void mon_dispatch(struct ceph_connection *con, struct ceph_msg *msg)
net/ceph/mon_client.c
1493
static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con,
net/ceph/mon_client.c
1500
struct ceph_msg *m = NULL;
net/ceph/mon_client.c
334
struct ceph_msg *msg = monc->m_subscribe;
net/ceph/mon_client.c
383
struct ceph_msg *msg)
net/ceph/mon_client.c
540
struct ceph_msg *msg)
net/ceph/mon_client.c
706
static struct ceph_msg *get_generic_reply(struct ceph_connection *con,
net/ceph/mon_client.c
713
struct ceph_msg *m;
net/ceph/mon_client.c
739
struct ceph_msg *msg)
net/ceph/mon_client.c
817
struct ceph_msg *msg)
net/ceph/mon_client.c
940
struct ceph_msg *msg)
net/ceph/msgpool.c
15
struct ceph_msg *msg;
net/ceph/msgpool.c
31
struct ceph_msg *msg = element;
net/ceph/msgpool.c
59
struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len,
net/ceph/msgpool.c
62
struct ceph_msg *msg;
net/ceph/msgpool.c
81
void ceph_msgpool_put(struct ceph_msgpool *pool, struct ceph_msg *msg)
net/ceph/osd_client.c
2043
struct ceph_msg *request_msg = req->r_request;
net/ceph/osd_client.c
2044
struct ceph_msg *reply_msg = req->r_reply;
net/ceph/osd_client.c
2145
struct ceph_msg *msg)
net/ceph/osd_client.c
2221
static void encode_request_finish(struct ceph_msg *msg)
net/ceph/osd_client.c
2937
struct ceph_msg *msg; /* for ceph_msg_put() */
net/ceph/osd_client.c
3669
static int decode_MOSDOpReply(const struct ceph_msg *msg, struct MOSDOpReply *m)
net/ceph/osd_client.c
3749
static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg)
net/ceph/osd_client.c
4134
void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg)
net/ceph/osd_client.c
4310
static int decode_MOSDBackoff(const struct ceph_msg *msg, struct MOSDBackoff *m)
net/ceph/osd_client.c
4360
static struct ceph_msg *create_backoff_message(
net/ceph/osd_client.c
4364
struct ceph_msg *msg;
net/ceph/osd_client.c
4402
struct ceph_msg *msg;
net/ceph/osd_client.c
4515
static void handle_backoff(struct ceph_osd *osd, struct ceph_msg *msg)
net/ceph/osd_client.c
4560
struct ceph_msg *msg)
net/ceph/osd_client.c
5359
static void osd_dispatch(struct ceph_connection *con, struct ceph_msg *msg)
net/ceph/osd_client.c
5410
static struct ceph_msg *get_reply(struct ceph_connection *con,
net/ceph/osd_client.c
5416
struct ceph_msg *m = NULL;
net/ceph/osd_client.c
5476
static struct ceph_msg *alloc_msg_with_page_vector(struct ceph_msg_header *hdr)
net/ceph/osd_client.c
5478
struct ceph_msg *m;
net/ceph/osd_client.c
5503
static struct ceph_msg *osd_alloc_msg(struct ceph_connection *con,
net/ceph/osd_client.c
5675
static void osd_reencode_message(struct ceph_msg *msg)
net/ceph/osd_client.c
5683
static int osd_sign_message(struct ceph_msg *msg)
net/ceph/osd_client.c
5691
static int osd_check_message_signature(struct ceph_msg *msg)
net/ceph/osd_client.c
586
struct ceph_msg *msg;
net/ceph/osd_client.c
940
static void ceph_osdc_msg_data_add(struct ceph_msg *msg,