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

/linux-master/include/linux/ceph/
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 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)
154 struct ceph_msg *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);
H A Dlibceph.h127 int (*extra_mon_dispatch)(struct ceph_client *, struct ceph_msg *);
/linux-master/net/ceph/
H A Dmsgpool.c15 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 Dmessenger.c30 * 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 Dmon_client.c334 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 Dosd_client.c609 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 Dmessenger_v1.c160 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 Dauth_x.c962 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 Dmessenger_v2.c359 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 Dmds_client.h323 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 Dmds_client.c747 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 Dsuper.h997 struct ceph_msg *msg);
1224 struct ceph_msg *msg);
1424 struct ceph_msg *msg);
H A Dmetric.c35 struct ceph_msg *msg;
H A Dquota.c42 struct ceph_msg *msg)
H A Dsnap.c1018 struct ceph_msg *msg)
H A Dsuper.c784 static int extra_mon_dispatch(struct ceph_client *client, struct ceph_msg *msg)
H A Dcaps.c1256 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