Lines Matching refs:ceph_msg
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 *msg, size_t length)
1403 struct ceph_msg *msg = con->in_msg;
1704 static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con)
1730 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg)
1770 void ceph_msg_revoke(struct ceph_msg *msg)
1810 void ceph_msg_revoke_incoming(struct ceph_msg *msg)
1867 static struct ceph_msg_data *ceph_msg_data_add(struct ceph_msg *msg)
1883 void ceph_msg_data_add_pages(struct ceph_msg *msg, struct page **pages,
1902 void ceph_msg_data_add_pagelist(struct ceph_msg *msg,
1920 void ceph_msg_data_add_bio(struct ceph_msg *msg, struct ceph_bio_iter *bio_pos,
1935 void ceph_msg_data_add_bvecs(struct ceph_msg *msg,
1948 void ceph_msg_data_add_iter(struct ceph_msg *msg,
1964 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items,
1967 struct ceph_msg *m;
2020 struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
2034 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg)
2069 struct ceph_msg *msg;
2114 struct ceph_msg *msg;
2117 msg = list_first_entry(&con->out_queue, struct ceph_msg, list_head);
2149 static void ceph_msg_free(struct ceph_msg *m)
2159 struct ceph_msg *m = container_of(kref, struct ceph_msg, kref);
2182 struct ceph_msg *ceph_msg_get(struct ceph_msg *msg)
2191 void ceph_msg_put(struct ceph_msg *msg)
2199 void ceph_msg_dump(struct ceph_msg *msg)