Lines Matching refs:msg
13 struct ceph_msg *msg; in msgpool_alloc() local
15 msg = ceph_msg_new(pool->type, pool->front_len, gfp_mask, true); in msgpool_alloc()
16 if (!msg) { in msgpool_alloc()
19 dout("msgpool_alloc %s %p\n", pool->name, msg); in msgpool_alloc()
20 msg->pool = pool; in msgpool_alloc()
22 return msg; in msgpool_alloc()
28 struct ceph_msg *msg = element; in msgpool_free() local
30 dout("msgpool_release %s %p\n", pool->name, msg); in msgpool_free()
31 msg->pool = NULL; in msgpool_free()
32 ceph_msg_put(msg); in msgpool_free()
57 struct ceph_msg *msg; in ceph_msgpool_get() local
68 msg = mempool_alloc(pool->pool, GFP_NOFS); in ceph_msgpool_get()
69 dout("msgpool_get %s %p\n", pool->name, msg); in ceph_msgpool_get()
70 return msg; in ceph_msgpool_get()
73 void ceph_msgpool_put(struct ceph_msgpool *pool, struct ceph_msg *msg) in ceph_msgpool_put() argument
75 dout("msgpool_put %s %p\n", pool->name, msg); in ceph_msgpool_put()
78 msg->front.iov_len = pool->front_len; in ceph_msgpool_put()
79 msg->hdr.front_len = cpu_to_le32(pool->front_len); in ceph_msgpool_put()
81 kref_init(&msg->kref); /* retake single ref */ in ceph_msgpool_put()
82 mempool_free(msg, pool->pool); in ceph_msgpool_put()