Searched refs:ceph_msg (Results 1 - 21 of 21) sorted by relevance
/linux-master/include/linux/ceph/ |
H A D | msgpool.h | 23 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 D | messenger.h | 18 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 D | auth.h | 16 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) 154 struct ceph_msg *msg)
|
H A D | mon_client.h | 61 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 D | osd_client.h | 20 struct ceph_msg; 248 struct ceph_msg *r_request, *r_reply; 453 struct ceph_msg *msg); 455 struct ceph_msg *msg);
|
H A D | libceph.h | 127 int (*extra_mon_dispatch)(struct ceph_client *, struct ceph_msg *);
|
/linux-master/net/ceph/ |
H A D | msgpool.c | 15 struct ceph_msg *msg; 31 struct ceph_msg *msg = element; 59 struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len, 62 struct ceph_msg *msg; 81 void ceph_msgpool_put(struct ceph_msgpool *pool, struct ceph_msg *msg)
|
H A D | messenger.c | 30 * Ceph uses the messenger to exchange ceph_msg messages with other 214 ceph_msg_cache = KMEM_CACHE(ceph_msg, 0); 538 static void ceph_msg_remove(struct ceph_msg *msg) 548 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, 673 struct ceph_msg *msg; 678 msg = list_first_entry(&con->out_sent, struct ceph_msg, 698 struct ceph_msg *msg; 703 msg = list_first_entry(&con->out_queue, struct ceph_msg, 1067 struct ceph_msg *ms [all...] |
H A D | mon_client.c | 334 struct ceph_msg *msg = monc->m_subscribe; 383 struct ceph_msg *msg) 540 struct ceph_msg *msg) 706 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, 713 struct ceph_msg *m; 739 struct ceph_msg *msg) 817 struct ceph_msg *msg) 940 struct ceph_msg *msg) 1304 struct ceph_msg *msg) 1435 static void mon_dispatch(struct ceph_connection *con, struct ceph_msg *ms [all...] |
H A D | osd_client.c | 609 struct ceph_msg *msg; 963 static void ceph_osdc_msg_data_add(struct ceph_msg *msg, 2060 struct ceph_msg *request_msg = req->r_request; 2061 struct ceph_msg *reply_msg = req->r_reply; 2162 struct ceph_msg *msg) 2238 static void encode_request_finish(struct ceph_msg *msg) 2954 struct ceph_msg *msg; /* for ceph_msg_put() */ 3686 static int decode_MOSDOpReply(const struct ceph_msg *msg, struct MOSDOpReply *m) 3766 static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg) 4151 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *ms [all...] |
H A D | messenger_v1.c | 160 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) 174 struct ceph_msg *m = con->out_msg; 197 struct ceph_msg *m; 467 struct ceph_msg *msg = con->out_msg; 1149 struct ceph_msg *m = con->in_msg; 1569 struct ceph_msg *msg = con->out_msg;
|
H A D | auth_x.c | 962 static int calc_signature(struct ceph_x_authorizer *au, struct ceph_msg *msg, 1028 struct ceph_msg *msg) 1047 struct ceph_msg *msg)
|
H A D | messenger_v2.c | 359 static int front_len(const struct ceph_msg *msg) 364 static int middle_len(const struct ceph_msg *msg) 369 static int data_len(const struct ceph_msg *msg) 430 static int tail_onwire_len(const struct ceph_msg *msg, bool secure) 1002 static int setup_message_sgs(struct sg_table *sgt, struct ceph_msg *msg, 1608 struct ceph_msg *msg = con->out_msg; 2027 struct ceph_msg *msg = con->in_msg; 2048 struct ceph_msg *msg = con->in_msg; 2922 struct ceph_msg *msg;
|
/linux-master/fs/ceph/ |
H A D | mds_client.h | 323 struct ceph_msg *r_request; /* original request */ 324 struct ceph_msg *r_reply; 534 struct ceph_msg *msg, int mds); 573 extern struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq); 602 struct ceph_msg *msg); 604 struct ceph_msg *msg);
|
H A D | mds_client.c | 747 static int parse_reply_info(struct ceph_mds_session *s, struct ceph_msg *msg, 1441 struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq) 1443 struct ceph_msg *msg; 1537 static struct ceph_msg * 1540 struct ceph_msg *msg; 1664 struct ceph_msg *msg; 2026 struct ceph_msg *msg; 2057 struct ceph_msg *msg; 2112 struct ceph_msg *msg; 2319 struct ceph_msg *ms [all...] |
H A D | super.h | 997 struct ceph_msg *msg); 1224 struct ceph_msg *msg); 1424 struct ceph_msg *msg);
|
H A D | metric.c | 35 struct ceph_msg *msg;
|
H A D | quota.c | 42 struct ceph_msg *msg)
|
H A D | snap.c | 1018 struct ceph_msg *msg)
|
H A D | super.c | 784 static int extra_mon_dispatch(struct ceph_client *client, struct ceph_msg *msg)
|
H A D | caps.c | 1256 static void encode_cap_msg(struct ceph_msg *msg, struct cap_msg_args *arg) 1535 struct ceph_msg *msg; 1567 struct ceph_msg *msg; 4321 struct ceph_msg *msg)
|
Completed in 219 milliseconds