~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

TOMOYO Linux Cross Reference
Linux/net/ceph/msgpool.c

Version: ~ [ linux-5.17-rc1 ] ~ [ linux-5.16.2 ] ~ [ linux-5.15.16 ] ~ [ linux-5.14.21 ] ~ [ linux-5.13.19 ] ~ [ linux-5.12.19 ] ~ [ linux-5.11.22 ] ~ [ linux-5.10.93 ] ~ [ linux-5.9.16 ] ~ [ linux-5.8.18 ] ~ [ linux-5.7.19 ] ~ [ linux-5.6.19 ] ~ [ linux-5.5.19 ] ~ [ linux-5.4.173 ] ~ [ linux-5.3.18 ] ~ [ linux-5.2.21 ] ~ [ linux-5.1.21 ] ~ [ linux-5.0.21 ] ~ [ linux-4.20.17 ] ~ [ linux-4.19.225 ] ~ [ linux-4.18.20 ] ~ [ linux-4.17.19 ] ~ [ linux-4.16.18 ] ~ [ linux-4.15.18 ] ~ [ linux-4.14.262 ] ~ [ linux-4.13.16 ] ~ [ linux-4.12.14 ] ~ [ linux-4.11.12 ] ~ [ linux-4.10.17 ] ~ [ linux-4.9.297 ] ~ [ linux-4.8.17 ] ~ [ linux-4.7.10 ] ~ [ linux-4.6.7 ] ~ [ linux-4.5.7 ] ~ [ linux-4.4.299 ] ~ [ linux-4.3.6 ] ~ [ linux-4.2.8 ] ~ [ linux-4.1.52 ] ~ [ linux-4.0.9 ] ~ [ linux-3.18.140 ] ~ [ linux-3.16.85 ] ~ [ linux-3.14.79 ] ~ [ linux-3.12.74 ] ~ [ linux-3.10.108 ] ~ [ linux-2.6.32.71 ] ~ [ linux-2.6.0 ] ~ [ linux-2.4.37.11 ] ~ [ unix-v6-master ] ~ [ ccs-tools-1.8.5 ] ~ [ policy-sample ] ~
Architecture: ~ [ i386 ] ~ [ alpha ] ~ [ m68k ] ~ [ mips ] ~ [ ppc ] ~ [ sparc ] ~ [ sparc64 ] ~

  1 #include <linux/ceph/ceph_debug.h>
  2 
  3 #include <linux/err.h>
  4 #include <linux/sched.h>
  5 #include <linux/types.h>
  6 #include <linux/vmalloc.h>
  7 
  8 #include <linux/ceph/msgpool.h>
  9 
 10 static void *msgpool_alloc(gfp_t gfp_mask, void *arg)
 11 {
 12         struct ceph_msgpool *pool = arg;
 13         struct ceph_msg *msg;
 14 
 15         msg = ceph_msg_new(pool->type, pool->front_len, gfp_mask, true);
 16         if (!msg) {
 17                 dout("msgpool_alloc %s failed\n", pool->name);
 18         } else {
 19                 dout("msgpool_alloc %s %p\n", pool->name, msg);
 20                 msg->pool = pool;
 21         }
 22         return msg;
 23 }
 24 
 25 static void msgpool_free(void *element, void *arg)
 26 {
 27         struct ceph_msgpool *pool = arg;
 28         struct ceph_msg *msg = element;
 29 
 30         dout("msgpool_release %s %p\n", pool->name, msg);
 31         msg->pool = NULL;
 32         ceph_msg_put(msg);
 33 }
 34 
 35 int ceph_msgpool_init(struct ceph_msgpool *pool, int type,
 36                       int front_len, int size, bool blocking, const char *name)
 37 {
 38         dout("msgpool %s init\n", name);
 39         pool->type = type;
 40         pool->front_len = front_len;
 41         pool->pool = mempool_create(size, msgpool_alloc, msgpool_free, pool);
 42         if (!pool->pool)
 43                 return -ENOMEM;
 44         pool->name = name;
 45         return 0;
 46 }
 47 
 48 void ceph_msgpool_destroy(struct ceph_msgpool *pool)
 49 {
 50         dout("msgpool %s destroy\n", pool->name);
 51         mempool_destroy(pool->pool);
 52 }
 53 
 54 struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool,
 55                                   int front_len)
 56 {
 57         struct ceph_msg *msg;
 58 
 59         if (front_len > pool->front_len) {
 60                 dout("msgpool_get %s need front %d, pool size is %d\n",
 61                        pool->name, front_len, pool->front_len);
 62                 WARN_ON(1);
 63 
 64                 /* try to alloc a fresh message */
 65                 return ceph_msg_new(pool->type, front_len, GFP_NOFS, false);
 66         }
 67 
 68         msg = mempool_alloc(pool->pool, GFP_NOFS);
 69         dout("msgpool_get %s %p\n", pool->name, msg);
 70         return msg;
 71 }
 72 
 73 void ceph_msgpool_put(struct ceph_msgpool *pool, struct ceph_msg *msg)
 74 {
 75         dout("msgpool_put %s %p\n", pool->name, msg);
 76 
 77         /* reset msg front_len; user may have changed it */
 78         msg->front.iov_len = pool->front_len;
 79         msg->hdr.front_len = cpu_to_le32(pool->front_len);
 80 
 81         kref_init(&msg->kref);  /* retake single ref */
 82         mempool_free(msg, pool->pool);
 83 }
 84 

~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

kernel.org | git.kernel.org | LWN.net | Project Home | Wiki (Japanese) | Wiki (English) | SVN repository | Mail admin

Linux® is a registered trademark of Linus Torvalds in the United States and other countries.
TOMOYO® is a registered trademark of NTT DATA CORPORATION.

osdn.jp