#include <linux/ceph/ceph_debug.h>

#include <linux/err.h>
#include <linux/sched.h>
#include <linux/types.h>
#include <linux/vmalloc.h>

#include <linux/ceph/messenger.h>
#include <linux/ceph/msgpool.h>

static void *msgpool_alloc(gfp_t gfp_mask, void *arg)
{
	struct ceph_msgpool *pool = arg;
	struct ceph_msg *msg;

	msg = ceph_msg_new(pool->type, pool->front_len, gfp_mask, true);
	if (!msg) {
		dout("msgpool_alloc %s failed\n", pool->name);
	} else {
		dout("msgpool_alloc %s %p\n", pool->name, msg);
		msg->pool = pool;
	}
	return msg;
}

static void msgpool_free(void *element, void *arg)
{
	struct ceph_msgpool *pool = arg;
	struct ceph_msg *msg = element;

	dout("msgpool_release %s %p\n", pool->name, msg);
	msg->pool = NULL;
	ceph_msg_put(msg);
}

int ceph_msgpool_init(struct ceph_msgpool *pool, int type,
		      int front_len, int size, bool blocking, const char *name)
{
	dout("msgpool %s init\n", name);
	pool->type = type;
	pool->front_len = front_len;
	pool->pool = mempool_create(size, msgpool_alloc, msgpool_free, pool);
	if (!pool->pool)
		return -ENOMEM;
	pool->name = name;
	return 0;
}

void ceph_msgpool_destroy(struct ceph_msgpool *pool)
{
	dout("msgpool %s destroy\n", pool->name);
	mempool_destroy(pool->pool);
}

struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool,
				  int front_len)
{
	struct ceph_msg *msg;

	if (front_len > pool->front_len) {
		dout("msgpool_get %s need front %d, pool size is %d\n",
		       pool->name, front_len, pool->front_len);
		WARN_ON(1);

		/* try to alloc a fresh message */
		return ceph_msg_new(pool->type, front_len, GFP_NOFS, false);
	}

	msg = mempool_alloc(pool->pool, GFP_NOFS);
	dout("msgpool_get %s %p\n", pool->name, msg);
	return msg;
}

void ceph_msgpool_put(struct ceph_msgpool *pool, struct ceph_msg *msg)
{
	dout("msgpool_put %s %p\n", pool->name, msg);

	/* reset msg front_len; user may have changed it */
	msg->front.iov_len = pool->front_len;
	msg->hdr.front_len = cpu_to_le32(pool->front_len);

	kref_init(&msg->kref);  /* retake single ref */
	mempool_free(msg, pool->pool);
}
.cgi/linux/net-next.git/log/include'>
<input type='hidden' name='id' value='e158e5ef24d191462428ff1be6b5048c0168fd14'/><select name='qt'>
<option value='grep'>log msg</option>
<option value='author'>author</option>
<option value='committer'>committer</option>
<option value='range'>range</option>
</select>
<input class='txt' type='search' size='10' name='q' value=''/>
<input type='submit' value='search'/>
</form>
</td></tr></table>
<div class='path'>path: <a href='/cgit.cgi/linux/net-next.git/log/?id=e158e5ef24d191462428ff1be6b5048c0168fd14'>root</a>/<a href='/cgit.cgi/linux/net-next.git/log/include?id=e158e5ef24d191462428ff1be6b5048c0168fd14'>include</a></div><div class='content'><table class='list nowrap'><tr class='nohover'><th class='left'>Age</th><th class='left'>Commit message (<a href='/cgit.cgi/linux/net-next.git/log/include?id=e158e5ef24d191462428ff1be6b5048c0168fd14&amp;showmsg=1'>Expand</a>)</th><th class='left'>Author</th><th class='left'>Files</th><th class='left'>Lines</th></tr>
<tr><td><span title='2017-02-05 16:11:57 -0500'>2017-02-05</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=02c1602ee7b3e3d062c3eacd374d6a6e3a2ebb73'>net: remove __napi_complete()</a></td><td>Eric Dumazet</td><td>1</td><td><span class='deletions'>-1</span>/<span class='insertions'>+0</span></td></tr>
<tr><td><span title='2017-02-04 19:58:14 -0500'>2017-02-04</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=3b1137fe74829e021f483756a648cbb87c8a1b4a'>net: ipv6: Change notifications for multipath add to RTA_MULTIPATH</a></td><td>David Ahern</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+1</span></td></tr>
<tr><td><span title='2017-02-04 19:58:14 -0500'>2017-02-04</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=0ae8133586ad1c9be894411aaf8b17bb58c8efe5'>net: ipv6: Allow shorthand delete of all nexthops in multipath route</a></td><td>David Ahern</td><td>1</td><td><span class='deletions'>-1</span>/<span class='insertions'>+3</span></td></tr>
<tr><td><span title='2017-02-03 17:28:29 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=79e7fff47b7bb4124ef970a13eac4fdeddd1fc25'>net: remove support for per driver ndo_busy_poll()</a></td><td>Eric Dumazet</td><td>2</td><td><span class='deletions'>-5</span>/<span class='insertions'>+0</span></td></tr>
<tr><td><span title='2017-02-03 16:58:20 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=52e01b84a244473074fc0612c169e2e043d58b01'>Merge git://git.kernel.org/pub/scm/linux/kernel/git/pablo/nf-next</a></td><td>David S. Miller</td><td>11</td><td><span class='deletions'>-40</span>/<span class='insertions'>+60</span></td></tr>
<tr><td><span title='2017-02-03 16:35:43 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=69ca05ce9dec2cc95070df7f1f10ea6c9c12d237'>sched: cls_flower: expose priority to offloading netdevice</a></td><td>Jiri Pirko</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+1</span></td></tr>
<tr><td><span title='2017-02-03 16:35:42 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=44091d29f2075972aede47ef17e1e70db3d51190'>lib: Introduce priority array area manager</a></td><td>Jiri Pirko</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+76</span></td></tr>
<tr><td><span title='2017-02-03 16:35:42 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=b862815c3ee7b49ec20a9ab25da55a5f0bcbb95e'>list: introduce list_for_each_entry_from_reverse helper</a></td><td>Jiri Pirko</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+13</span></td></tr>
<tr><td><span title='2017-02-03 15:50:18 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=3898fac1f488c76e0eef5b5267b4ba8112a82ac4'>trace: rename trace_print_hex_seq arg and add kdoc</a></td><td>Daniel Borkmann</td><td>2</td><td><span class='deletions'>-3</span>/<span class='insertions'>+3</span></td></tr>
<tr><td><span title='2017-02-03 15:21:21 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=b3c7ef0adadc5768e0baa786213c6bd1ce521a77'>bridge: uapi: add per vlan tunnel info</a></td><td>Roopa Prabhu</td><td>3</td><td><span class='deletions'>-0</span>/<span class='insertions'>+13</span></td></tr>
<tr><td><span title='2017-02-03 15:21:21 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=3ad7a4b141ebd6091494913672d7166d5c2764e4'>vxlan: support fdb and learning in COLLECT_METADATA mode</a></td><td>Roopa Prabhu</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+1</span></td></tr>
<tr><td><span title='2017-02-03 15:21:21 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=f35581d64e55fc65753a62957b3b98127d560d07'>ip_tunnels: new IP_TUNNEL_INFO_BRIDGE flag for ip_tunnel_info mode</a></td><td>Roopa Prabhu</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+1</span></td></tr>
<tr><td><span title='2017-02-03 15:16:46 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=295a6e06d21e1f469c9f38b00125a13b60ad4e7c'>net/sched: act_ife: Change to use ife module</a></td><td>Yotam Gigi</td><td>2</td><td><span class='deletions'>-10</span>/<span class='insertions'>+1</span></td></tr>
<tr><td><span title='2017-02-03 15:16:45 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=1ce8460496c05379c66edc178c3c55ca4e953044'>net: Introduce ife encapsulation module</a></td><td>Yotam Gigi</td><td>3</td><td><span class='deletions'>-0</span>/<span class='insertions'>+70</span></td></tr>
<tr><td><span title='2017-02-03 15:16:45 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=1d5e7c859e81a66674d194c346119d154d31e9dc'>net/sched: act_ife: Unexport ife_tlv_meta_encode</a></td><td>Yotam Gigi</td><td>1</td><td><span class='deletions'>-2</span>/<span class='insertions'>+0</span></td></tr>
<tr><td><span title='2017-02-03 11:19:34 -0500'>2017-02-03</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=3541f9e8bdebce02458882b66b638d7302c1f616'>tcp: add tcp_mss_clamp() helper</a></td><td>Eric Dumazet</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+9</span></td></tr>
<tr><td><span title='2017-02-02 23:34:19 -0500'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=8fe809a992639b2013c0d8da2ba55cdea28a959a'>net: add LINUX_MIB_PFMEMALLOCDROP counter</a></td><td>Eric Dumazet</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+1</span></td></tr>
<tr><td><span title='2017-02-02 22:05:28 -0500'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=60f06fde4cff6f6134decbf09199b5e047bc3355'>net: phy: marvell: Add support for 88e1545 PHY</a></td><td>Andrew Lunn</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+1</span></td></tr>
<tr><td><span title='2017-02-02 21:58:02 -0500'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=ba94f3088b792b16ea576a256a6030feddc87f24'>unix: add ioctl to open a unix socket file with O_PATH</a></td><td>Andrey Vagin</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+2</span></td></tr>
<tr><td><span title='2017-02-02 21:50:51 -0500'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=e4cf8a38fc0d257b4070066e46a678f4777fecaa'>net: phy: Marvell: Add mv88e6390 internal PHY</a></td><td>Andrew Lunn</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+6</span></td></tr>
<tr><td><span title='2017-02-02 16:54:00 -0500'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=e2160156bf2a7d5018e99a9993fbcdda0abac09b'>Merge git://git.kernel.org/pub/scm/linux/kernel/git/davem/net</a></td><td>David S. Miller</td><td>9</td><td><span class='deletions'>-30</span>/<span class='insertions'>+40</span></td></tr>
<tr><td><span title='2017-02-02 14:31:58 +0100'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=2851940ffee313e0ff12540a8e11a8c54dea9c65'>netfilter: allow logging from non-init namespaces</a></td><td>Michal Kubeček</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+3</span></td></tr>
<tr><td><span title='2017-02-02 14:31:57 +0100'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=90c1aff702d449a1a248c4829d51c0bc677f968e'>ipvs: free ip_vs_dest structs when refcnt=0</a></td><td>David Windsor</td><td>1</td><td><span class='deletions'>-1</span>/<span class='insertions'>+1</span></td></tr>
<tr><td><span title='2017-02-02 14:31:56 +0100'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=a9e419dc7be6997409dca6d1b9daf3cc7046902f'>netfilter: merge ctinfo into nfct pointer storage area</a></td><td>Florian Westphal</td><td>2</td><td><span class='deletions'>-17</span>/<span class='insertions'>+15</span></td></tr>
<tr><td><span title='2017-02-02 14:31:55 +0100'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=303223092081963513494b4377fa1ac9e362ed4b'>netfilter: guarantee 8 byte minalign for template addresses</a></td><td>Florian Westphal</td><td>1</td><td><span class='deletions'>-0</span>/<span class='insertions'>+2</span></td></tr>
<tr><td><span title='2017-02-02 14:31:54 +0100'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=c74454fadd5ea6fc866ffe2c417a0dba56b2bf1c'>netfilter: add and use nf_ct_set helper</a></td><td>Florian Westphal</td><td>2</td><td><span class='deletions'>-2</span>/<span class='insertions'>+9</span></td></tr>
<tr><td><span title='2017-02-02 14:31:53 +0100'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=cb9c68363efb6d1f950ec55fb06e031ee70db5fc'>skbuff: add and use skb_nfct helper</a></td><td>Florian Westphal</td><td>2</td><td><span class='deletions'>-4</span>/<span class='insertions'>+11</span></td></tr>
<tr><td><span title='2017-02-02 14:31:52 +0100'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=97a6ad13decc16c5adbf181283932daba7e17faf'>netfilter: reduce direct skb-&gt;nfct usage</a></td><td>Florian Westphal</td><td>1</td><td><span class='deletions'>-3</span>/<span class='insertions'>+6</span></td></tr>
<tr><td><span title='2017-02-02 14:31:51 +0100'>2017-02-02</span></td><td><a href='/cgit.cgi/linux/net-next.git/commit/include?id=11df4b760f11ca7528c62b1c4b870735d1c62116'>netfilter: conntrack: no need to pass ctinfo to error handler</a></td><td>Florian Westphal</td><td>1</td><td><span class='deletions'>-1</span>/<span class='insertions'>+1</span></td></tr>