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