Lines Matching refs:ceph_msg
29 * Ceph uses the messenger to exchange ceph_msg messages with other
236 ceph_msg_cache = KMEM_CACHE(ceph_msg, 0);
620 static void ceph_msg_remove(struct ceph_msg *msg)
629 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg,
1116 static void ceph_msg_data_cursor_init(struct ceph_msg *msg, size_t length)
1220 static void prepare_message_data(struct ceph_msg *msg, u32 data_len)
1233 struct ceph_msg *m = con->out_msg;
1256 struct ceph_msg *m;
1273 m = list_first_entry(&con->out_queue, struct ceph_msg, list_head);
1554 struct ceph_msg *msg = con->out_msg;
2259 struct ceph_msg *m;
2271 m = list_first_entry(list, struct ceph_msg, list_head);
2312 struct ceph_msg *msg = con->in_msg;
2358 struct ceph_msg *m = con->in_msg;
2519 struct ceph_msg *msg = con->in_msg;
3066 static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con)
3090 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg)
3130 void ceph_msg_revoke(struct ceph_msg *msg)
3176 void ceph_msg_revoke_incoming(struct ceph_msg *msg)
3241 static struct ceph_msg_data *ceph_msg_data_add(struct ceph_msg *msg)
3257 void ceph_msg_data_add_pages(struct ceph_msg *msg, struct page **pages,
3276 void ceph_msg_data_add_pagelist(struct ceph_msg *msg,
3294 void ceph_msg_data_add_bio(struct ceph_msg *msg, struct ceph_bio_iter *bio_pos,
3309 void ceph_msg_data_add_bvecs(struct ceph_msg *msg,
3326 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items,
3329 struct ceph_msg *m;
3382 struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
3396 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg)
3431 struct ceph_msg *msg;
3478 static void ceph_msg_free(struct ceph_msg *m)
3488 struct ceph_msg *m = container_of(kref, struct ceph_msg, kref);
3511 struct ceph_msg *ceph_msg_get(struct ceph_msg *msg)
3520 void ceph_msg_put(struct ceph_msg *msg)
3528 void ceph_msg_dump(struct ceph_msg *msg)