2 * (C) 2001 Clemson University and The University of Chicago
4 * See COPYING in top-level directory.
8 #include "pvfs2-kernel.h"
10 /* tags assigned to kernel upcall operations */
11 static __u64 next_tag_value;
12 static DEFINE_SPINLOCK(next_tag_value_lock);
14 /* the pvfs2 memory caches */
16 /* a cache for pvfs2 upcall/downcall operations */
17 static struct kmem_cache *op_cache;
19 /* a cache for device (/dev/pvfs2-req) communication */
20 static struct kmem_cache *dev_req_cache;
22 /* a cache for pvfs2_kiocb objects (i.e pvfs2 iocb structures ) */
23 static struct kmem_cache *pvfs2_kiocb_cache;
25 int op_cache_initialize(void)
27 op_cache = kmem_cache_create("pvfs2_op_cache",
28 sizeof(struct pvfs2_kernel_op_s),
30 PVFS2_CACHE_CREATE_FLAGS,
34 gossip_err("Cannot create pvfs2_op_cache\n");
38 /* initialize our atomic tag counter */
39 spin_lock(&next_tag_value_lock);
41 spin_unlock(&next_tag_value_lock);
45 int op_cache_finalize(void)
47 kmem_cache_destroy(op_cache);
51 char *get_opname_string(struct pvfs2_kernel_op_s *new_op)
54 __s32 type = new_op->upcall.type;
56 if (type == PVFS2_VFS_OP_FILE_IO)
58 else if (type == PVFS2_VFS_OP_LOOKUP)
60 else if (type == PVFS2_VFS_OP_CREATE)
62 else if (type == PVFS2_VFS_OP_GETATTR)
64 else if (type == PVFS2_VFS_OP_REMOVE)
66 else if (type == PVFS2_VFS_OP_MKDIR)
68 else if (type == PVFS2_VFS_OP_READDIR)
70 else if (type == PVFS2_VFS_OP_READDIRPLUS)
71 return "OP_READDIRPLUS";
72 else if (type == PVFS2_VFS_OP_SETATTR)
74 else if (type == PVFS2_VFS_OP_SYMLINK)
76 else if (type == PVFS2_VFS_OP_RENAME)
78 else if (type == PVFS2_VFS_OP_STATFS)
80 else if (type == PVFS2_VFS_OP_TRUNCATE)
82 else if (type == PVFS2_VFS_OP_MMAP_RA_FLUSH)
83 return "OP_MMAP_RA_FLUSH";
84 else if (type == PVFS2_VFS_OP_FS_MOUNT)
86 else if (type == PVFS2_VFS_OP_FS_UMOUNT)
87 return "OP_FS_UMOUNT";
88 else if (type == PVFS2_VFS_OP_GETXATTR)
90 else if (type == PVFS2_VFS_OP_SETXATTR)
92 else if (type == PVFS2_VFS_OP_LISTXATTR)
93 return "OP_LISTXATTR";
94 else if (type == PVFS2_VFS_OP_REMOVEXATTR)
95 return "OP_REMOVEXATTR";
96 else if (type == PVFS2_VFS_OP_PARAM)
98 else if (type == PVFS2_VFS_OP_PERF_COUNT)
99 return "OP_PERF_COUNT";
100 else if (type == PVFS2_VFS_OP_CANCEL)
102 else if (type == PVFS2_VFS_OP_FSYNC)
104 else if (type == PVFS2_VFS_OP_FSKEY)
106 else if (type == PVFS2_VFS_OP_FILE_IOX)
107 return "OP_FILE_IOX";
109 return "OP_UNKNOWN?";
112 static struct pvfs2_kernel_op_s *op_alloc_common(__s32 op_linger, __s32 type)
114 struct pvfs2_kernel_op_s *new_op = NULL;
116 new_op = kmem_cache_alloc(op_cache, PVFS2_CACHE_ALLOC_FLAGS);
118 memset(new_op, 0, sizeof(struct pvfs2_kernel_op_s));
120 INIT_LIST_HEAD(&new_op->list);
121 spin_lock_init(&new_op->lock);
122 init_waitqueue_head(&new_op->waitq);
124 init_waitqueue_head(&new_op->io_completion_waitq);
125 atomic_set(&new_op->aio_ref_count, 0);
127 pvfs2_op_initialize(new_op);
129 /* initialize the op specific tag and upcall credentials */
130 spin_lock(&next_tag_value_lock);
131 new_op->tag = next_tag_value++;
132 if (next_tag_value == 0)
133 next_tag_value = 100;
134 spin_unlock(&next_tag_value_lock);
135 new_op->upcall.type = type;
136 new_op->attempts = 0;
137 gossip_debug(GOSSIP_CACHE_DEBUG,
138 "Alloced OP (%p: %llu %s)\n",
141 get_opname_string(new_op));
143 new_op->upcall.uid = from_kuid(current_user_ns(),
146 new_op->upcall.gid = from_kgid(current_user_ns(),
149 new_op->op_linger = new_op->op_linger_tmp = op_linger;
151 gossip_err("op_alloc: kmem_cache_alloc failed!\n");
156 struct pvfs2_kernel_op_s *op_alloc(__s32 type)
158 return op_alloc_common(1, type);
161 struct pvfs2_kernel_op_s *op_alloc_trailer(__s32 type)
163 return op_alloc_common(2, type);
166 void op_release(struct pvfs2_kernel_op_s *pvfs2_op)
169 gossip_debug(GOSSIP_CACHE_DEBUG,
170 "Releasing OP (%p: %llu)\n",
173 pvfs2_op_initialize(pvfs2_op);
174 kmem_cache_free(op_cache, pvfs2_op);
176 gossip_err("NULL pointer in op_release\n");
180 int dev_req_cache_initialize(void)
182 dev_req_cache = kmem_cache_create("pvfs2_devreqcache",
183 MAX_ALIGNED_DEV_REQ_DOWNSIZE,
185 PVFS2_CACHE_CREATE_FLAGS,
188 if (!dev_req_cache) {
189 gossip_err("Cannot create pvfs2_dev_req_cache\n");
195 int dev_req_cache_finalize(void)
197 kmem_cache_destroy(dev_req_cache);
201 void *dev_req_alloc(void)
205 buffer = kmem_cache_alloc(dev_req_cache, PVFS2_CACHE_ALLOC_FLAGS);
207 gossip_err("Failed to allocate from dev_req_cache\n");
209 memset(buffer, 0, sizeof(MAX_ALIGNED_DEV_REQ_DOWNSIZE));
213 void dev_req_release(void *buffer)
216 kmem_cache_free(dev_req_cache, buffer);
218 gossip_err("NULL pointer passed to dev_req_release\n");
221 int kiocb_cache_initialize(void)
223 pvfs2_kiocb_cache = kmem_cache_create("pvfs2_kiocbcache",
224 sizeof(struct pvfs2_kiocb_s),
226 PVFS2_CACHE_CREATE_FLAGS,
229 if (!pvfs2_kiocb_cache) {
230 gossip_err("Cannot create pvfs2_kiocb_cache!\n");
236 int kiocb_cache_finalize(void)
238 kmem_cache_destroy(pvfs2_kiocb_cache);
242 struct pvfs2_kiocb_s *kiocb_alloc(void)
244 struct pvfs2_kiocb_s *x = NULL;
246 x = kmem_cache_alloc(pvfs2_kiocb_cache, PVFS2_CACHE_ALLOC_FLAGS);
248 gossip_err("kiocb_alloc: kmem_cache_alloc failed!\n");
250 memset(x, 0, sizeof(struct pvfs2_kiocb_s));
254 void kiocb_release(struct pvfs2_kiocb_s *x)
257 kmem_cache_free(pvfs2_kiocb_cache, x);
259 gossip_err("kiocb_release: kmem_cache_free NULL pointer!\n");