Lines Matching defs:msg
15 struct ceph_msg *msg;
17 msg = ceph_msg_new2(pool->type, pool->front_len, pool->max_data_items,
19 if (!msg) {
22 dout("msgpool_alloc %s %p\n", pool->name, msg);
23 msg->pool = pool;
25 return msg;
31 struct ceph_msg *msg = element;
33 dout("msgpool_release %s %p\n", pool->name, msg);
34 msg->pool = NULL;
35 ceph_msg_put(msg);
62 struct ceph_msg *msg;
76 msg = mempool_alloc(pool->pool, GFP_NOFS);
77 dout("msgpool_get %s %p\n", pool->name, msg);
78 return msg;
81 void ceph_msgpool_put(struct ceph_msgpool *pool, struct ceph_msg *msg)
83 dout("msgpool_put %s %p\n", pool->name, msg);
85 /* reset msg front_len; user may have changed it */
86 msg->front.iov_len = pool->front_len;
87 msg->hdr.front_len = cpu_to_le32(pool->front_len);
89 msg->data_length = 0;
90 msg->num_data_items = 0;
92 kref_init(&msg->kref); /* retake single ref */
93 mempool_free(msg, pool->pool);