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

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

Version: ~ [ linux-5.0-rc7 ] ~ [ linux-4.20.12 ] ~ [ linux-4.19.25 ] ~ [ linux-4.18.20 ] ~ [ linux-4.17.19 ] ~ [ linux-4.16.18 ] ~ [ linux-4.15.18 ] ~ [ linux-4.14.103 ] ~ [ linux-4.13.16 ] ~ [ linux-4.12.14 ] ~ [ linux-4.11.12 ] ~ [ linux-4.10.17 ] ~ [ linux-4.9.160 ] ~ [ linux-4.8.17 ] ~ [ linux-4.7.10 ] ~ [ linux-4.6.7 ] ~ [ linux-4.5.7 ] ~ [ linux-4.4.176 ] ~ [ linux-4.3.6 ] ~ [ linux-4.2.8 ] ~ [ linux-4.1.52 ] ~ [ linux-4.0.9 ] ~ [ linux-3.19.8 ] ~ [ linux-3.18.136 ] ~ [ linux-3.17.8 ] ~ [ linux-3.16.63 ] ~ [ linux-3.15.10 ] ~ [ linux-3.14.79 ] ~ [ linux-3.13.11 ] ~ [ linux-3.12.74 ] ~ [ linux-3.11.10 ] ~ [ linux-3.10.108 ] ~ [ linux-3.9.11 ] ~ [ linux-3.8.13 ] ~ [ linux-3.7.10 ] ~ [ linux-3.6.11 ] ~ [ linux-3.5.7 ] ~ [ linux-3.4.113 ] ~ [ linux-3.3.8 ] ~ [ linux-3.2.102 ] ~ [ linux-3.1.10 ] ~ [ linux-3.0.101 ] ~ [ linux-2.6.39.4 ] ~ [ linux-2.6.38.8 ] ~ [ linux-2.6.37.6 ] ~ [ linux-2.6.36.4 ] ~ [ linux-2.6.35.14 ] ~ [ linux-2.6.34.15 ] ~ [ linux-2.6.33.20 ] ~ [ 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 // SPDX-License-Identifier: GPL-2.0
  2 #include <linux/ceph/ceph_debug.h>
  3 
  4 #include <linux/err.h>
  5 #include <linux/sched.h>
  6 #include <linux/types.h>
  7 #include <linux/vmalloc.h>
  8 
  9 #include <linux/ceph/messenger.h>
 10 #include <linux/ceph/msgpool.h>
 11 
 12 static void *msgpool_alloc(gfp_t gfp_mask, void *arg)
 13 {
 14         struct ceph_msgpool *pool = arg;
 15         struct ceph_msg *msg;
 16 
 17         msg = ceph_msg_new2(pool->type, pool->front_len, pool->max_data_items,
 18                             gfp_mask, true);
 19         if (!msg) {
 20                 dout("msgpool_alloc %s failed\n", pool->name);
 21         } else {
 22                 dout("msgpool_alloc %s %p\n", pool->name, msg);
 23                 msg->pool = pool;
 24         }
 25         return msg;
 26 }
 27 
 28 static void msgpool_free(void *element, void *arg)
 29 {
 30         struct ceph_msgpool *pool = arg;
 31         struct ceph_msg *msg = element;
 32 
 33         dout("msgpool_release %s %p\n", pool->name, msg);
 34         msg->pool = NULL;
 35         ceph_msg_put(msg);
 36 }
 37 
 38 int ceph_msgpool_init(struct ceph_msgpool *pool, int type,
 39                       int front_len, int max_data_items, int size,
 40                       const char *name)
 41 {
 42         dout("msgpool %s init\n", name);
 43         pool->type = type;
 44         pool->front_len = front_len;
 45         pool->max_data_items = max_data_items;
 46         pool->pool = mempool_create(size, msgpool_alloc, msgpool_free, pool);
 47         if (!pool->pool)
 48                 return -ENOMEM;
 49         pool->name = name;
 50         return 0;
 51 }
 52 
 53 void ceph_msgpool_destroy(struct ceph_msgpool *pool)
 54 {
 55         dout("msgpool %s destroy\n", pool->name);
 56         mempool_destroy(pool->pool);
 57 }
 58 
 59 struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len,
 60                                   int max_data_items)
 61 {
 62         struct ceph_msg *msg;
 63 
 64         if (front_len > pool->front_len ||
 65             max_data_items > pool->max_data_items) {
 66                 pr_warn_ratelimited("%s need %d/%d, pool %s has %d/%d\n",
 67                     __func__, front_len, max_data_items, pool->name,
 68                     pool->front_len, pool->max_data_items);
 69                 WARN_ON_ONCE(1);
 70 
 71                 /* try to alloc a fresh message */
 72                 return ceph_msg_new2(pool->type, front_len, max_data_items,
 73                                      GFP_NOFS, false);
 74         }
 75 
 76         msg = mempool_alloc(pool->pool, GFP_NOFS);
 77         dout("msgpool_get %s %p\n", pool->name, msg);
 78         return msg;
 79 }
 80 
 81 void ceph_msgpool_put(struct ceph_msgpool *pool, struct ceph_msg *msg)
 82 {
 83         dout("msgpool_put %s %p\n", pool->name, msg);
 84 
 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);
 88 
 89         msg->data_length = 0;
 90         msg->num_data_items = 0;
 91 
 92         kref_init(&msg->kref);  /* retake single ref */
 93         mempool_free(msg, pool->pool);
 94 }
 95 

~ [ 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