blob: 900a2e38e11bc9e7ac82f386ce678bdad0756c65 [file] [log] [blame]
Mike Marshall274dcf52015-07-17 10:38:13 -04001/*
2 * (C) 2001 Clemson University and The University of Chicago
3 *
4 * See COPYING in top-level directory.
5 */
6
7#include "protocol.h"
Mike Marshall575e9462015-12-04 12:56:14 -05008#include "orangefs-kernel.h"
Mike Marshall274dcf52015-07-17 10:38:13 -04009
10/* tags assigned to kernel upcall operations */
11static __u64 next_tag_value;
12static DEFINE_SPINLOCK(next_tag_value_lock);
13
Yi Liu8bb8aef2015-11-24 15:12:14 -050014/* the orangefs memory caches */
Mike Marshall274dcf52015-07-17 10:38:13 -040015
Yi Liu8bb8aef2015-11-24 15:12:14 -050016/* a cache for orangefs upcall/downcall operations */
Mike Marshall274dcf52015-07-17 10:38:13 -040017static struct kmem_cache *op_cache;
18
Mike Marshall274dcf52015-07-17 10:38:13 -040019int op_cache_initialize(void)
20{
Yi Liu8bb8aef2015-11-24 15:12:14 -050021 op_cache = kmem_cache_create("orangefs_op_cache",
22 sizeof(struct orangefs_kernel_op_s),
Mike Marshall274dcf52015-07-17 10:38:13 -040023 0,
Yi Liu8bb8aef2015-11-24 15:12:14 -050024 ORANGEFS_CACHE_CREATE_FLAGS,
Mike Marshall274dcf52015-07-17 10:38:13 -040025 NULL);
26
27 if (!op_cache) {
Yi Liu8bb8aef2015-11-24 15:12:14 -050028 gossip_err("Cannot create orangefs_op_cache\n");
Mike Marshall274dcf52015-07-17 10:38:13 -040029 return -ENOMEM;
30 }
31
32 /* initialize our atomic tag counter */
33 spin_lock(&next_tag_value_lock);
34 next_tag_value = 100;
35 spin_unlock(&next_tag_value_lock);
36 return 0;
37}
38
39int op_cache_finalize(void)
40{
41 kmem_cache_destroy(op_cache);
42 return 0;
43}
44
Yi Liu8bb8aef2015-11-24 15:12:14 -050045char *get_opname_string(struct orangefs_kernel_op_s *new_op)
Mike Marshall274dcf52015-07-17 10:38:13 -040046{
47 if (new_op) {
48 __s32 type = new_op->upcall.type;
49
Yi Liu8bb8aef2015-11-24 15:12:14 -050050 if (type == ORANGEFS_VFS_OP_FILE_IO)
Mike Marshall274dcf52015-07-17 10:38:13 -040051 return "OP_FILE_IO";
Yi Liu8bb8aef2015-11-24 15:12:14 -050052 else if (type == ORANGEFS_VFS_OP_LOOKUP)
Mike Marshall274dcf52015-07-17 10:38:13 -040053 return "OP_LOOKUP";
Yi Liu8bb8aef2015-11-24 15:12:14 -050054 else if (type == ORANGEFS_VFS_OP_CREATE)
Mike Marshall274dcf52015-07-17 10:38:13 -040055 return "OP_CREATE";
Yi Liu8bb8aef2015-11-24 15:12:14 -050056 else if (type == ORANGEFS_VFS_OP_GETATTR)
Mike Marshall274dcf52015-07-17 10:38:13 -040057 return "OP_GETATTR";
Yi Liu8bb8aef2015-11-24 15:12:14 -050058 else if (type == ORANGEFS_VFS_OP_REMOVE)
Mike Marshall274dcf52015-07-17 10:38:13 -040059 return "OP_REMOVE";
Yi Liu8bb8aef2015-11-24 15:12:14 -050060 else if (type == ORANGEFS_VFS_OP_MKDIR)
Mike Marshall274dcf52015-07-17 10:38:13 -040061 return "OP_MKDIR";
Yi Liu8bb8aef2015-11-24 15:12:14 -050062 else if (type == ORANGEFS_VFS_OP_READDIR)
Mike Marshall274dcf52015-07-17 10:38:13 -040063 return "OP_READDIR";
Yi Liu8bb8aef2015-11-24 15:12:14 -050064 else if (type == ORANGEFS_VFS_OP_READDIRPLUS)
Mike Marshall274dcf52015-07-17 10:38:13 -040065 return "OP_READDIRPLUS";
Yi Liu8bb8aef2015-11-24 15:12:14 -050066 else if (type == ORANGEFS_VFS_OP_SETATTR)
Mike Marshall274dcf52015-07-17 10:38:13 -040067 return "OP_SETATTR";
Yi Liu8bb8aef2015-11-24 15:12:14 -050068 else if (type == ORANGEFS_VFS_OP_SYMLINK)
Mike Marshall274dcf52015-07-17 10:38:13 -040069 return "OP_SYMLINK";
Yi Liu8bb8aef2015-11-24 15:12:14 -050070 else if (type == ORANGEFS_VFS_OP_RENAME)
Mike Marshall274dcf52015-07-17 10:38:13 -040071 return "OP_RENAME";
Yi Liu8bb8aef2015-11-24 15:12:14 -050072 else if (type == ORANGEFS_VFS_OP_STATFS)
Mike Marshall274dcf52015-07-17 10:38:13 -040073 return "OP_STATFS";
Yi Liu8bb8aef2015-11-24 15:12:14 -050074 else if (type == ORANGEFS_VFS_OP_TRUNCATE)
Mike Marshall274dcf52015-07-17 10:38:13 -040075 return "OP_TRUNCATE";
Yi Liu8bb8aef2015-11-24 15:12:14 -050076 else if (type == ORANGEFS_VFS_OP_MMAP_RA_FLUSH)
Mike Marshall274dcf52015-07-17 10:38:13 -040077 return "OP_MMAP_RA_FLUSH";
Yi Liu8bb8aef2015-11-24 15:12:14 -050078 else if (type == ORANGEFS_VFS_OP_FS_MOUNT)
Mike Marshall274dcf52015-07-17 10:38:13 -040079 return "OP_FS_MOUNT";
Yi Liu8bb8aef2015-11-24 15:12:14 -050080 else if (type == ORANGEFS_VFS_OP_FS_UMOUNT)
Mike Marshall274dcf52015-07-17 10:38:13 -040081 return "OP_FS_UMOUNT";
Yi Liu8bb8aef2015-11-24 15:12:14 -050082 else if (type == ORANGEFS_VFS_OP_GETXATTR)
Mike Marshall274dcf52015-07-17 10:38:13 -040083 return "OP_GETXATTR";
Yi Liu8bb8aef2015-11-24 15:12:14 -050084 else if (type == ORANGEFS_VFS_OP_SETXATTR)
Mike Marshall274dcf52015-07-17 10:38:13 -040085 return "OP_SETXATTR";
Yi Liu8bb8aef2015-11-24 15:12:14 -050086 else if (type == ORANGEFS_VFS_OP_LISTXATTR)
Mike Marshall274dcf52015-07-17 10:38:13 -040087 return "OP_LISTXATTR";
Yi Liu8bb8aef2015-11-24 15:12:14 -050088 else if (type == ORANGEFS_VFS_OP_REMOVEXATTR)
Mike Marshall274dcf52015-07-17 10:38:13 -040089 return "OP_REMOVEXATTR";
Yi Liu8bb8aef2015-11-24 15:12:14 -050090 else if (type == ORANGEFS_VFS_OP_PARAM)
Mike Marshall274dcf52015-07-17 10:38:13 -040091 return "OP_PARAM";
Yi Liu8bb8aef2015-11-24 15:12:14 -050092 else if (type == ORANGEFS_VFS_OP_PERF_COUNT)
Mike Marshall274dcf52015-07-17 10:38:13 -040093 return "OP_PERF_COUNT";
Yi Liu8bb8aef2015-11-24 15:12:14 -050094 else if (type == ORANGEFS_VFS_OP_CANCEL)
Mike Marshall274dcf52015-07-17 10:38:13 -040095 return "OP_CANCEL";
Yi Liu8bb8aef2015-11-24 15:12:14 -050096 else if (type == ORANGEFS_VFS_OP_FSYNC)
Mike Marshall274dcf52015-07-17 10:38:13 -040097 return "OP_FSYNC";
Yi Liu8bb8aef2015-11-24 15:12:14 -050098 else if (type == ORANGEFS_VFS_OP_FSKEY)
Mike Marshall274dcf52015-07-17 10:38:13 -040099 return "OP_FSKEY";
Mike Marshall274dcf52015-07-17 10:38:13 -0400100 }
101 return "OP_UNKNOWN?";
102}
103
Al Viro78699e22016-02-11 23:07:19 -0500104void orangefs_new_tag(struct orangefs_kernel_op_s *op)
105{
106 spin_lock(&next_tag_value_lock);
107 op->tag = next_tag_value++;
108 if (next_tag_value == 0)
109 next_tag_value = 100;
110 spin_unlock(&next_tag_value_lock);
111}
112
Yi Liu8bb8aef2015-11-24 15:12:14 -0500113struct orangefs_kernel_op_s *op_alloc(__s32 type)
Mike Marshall274dcf52015-07-17 10:38:13 -0400114{
Yi Liu8bb8aef2015-11-24 15:12:14 -0500115 struct orangefs_kernel_op_s *new_op = NULL;
Mike Marshall274dcf52015-07-17 10:38:13 -0400116
Mike Marshall2d4cae02016-02-04 13:48:16 -0500117 new_op = kmem_cache_zalloc(op_cache, GFP_KERNEL);
Mike Marshall274dcf52015-07-17 10:38:13 -0400118 if (new_op) {
Mike Marshall274dcf52015-07-17 10:38:13 -0400119 INIT_LIST_HEAD(&new_op->list);
120 spin_lock_init(&new_op->lock);
Al Virod2d87a32016-02-13 10:15:22 -0500121 init_completion(&new_op->waitq);
Mike Marshall274dcf52015-07-17 10:38:13 -0400122
Al Viro115b93a2016-01-23 14:04:31 -0500123 new_op->upcall.type = ORANGEFS_VFS_OP_INVALID;
124 new_op->downcall.type = ORANGEFS_VFS_OP_INVALID;
125 new_op->downcall.status = -1;
126
127 new_op->op_state = OP_VFS_STATE_UNKNOWN;
Mike Marshall274dcf52015-07-17 10:38:13 -0400128
129 /* initialize the op specific tag and upcall credentials */
Al Viro78699e22016-02-11 23:07:19 -0500130 orangefs_new_tag(new_op);
Mike Marshall274dcf52015-07-17 10:38:13 -0400131 new_op->upcall.type = type;
132 new_op->attempts = 0;
133 gossip_debug(GOSSIP_CACHE_DEBUG,
134 "Alloced OP (%p: %llu %s)\n",
135 new_op,
136 llu(new_op->tag),
137 get_opname_string(new_op));
138
139 new_op->upcall.uid = from_kuid(current_user_ns(),
140 current_fsuid());
141
142 new_op->upcall.gid = from_kgid(current_user_ns(),
143 current_fsgid());
Mike Marshall274dcf52015-07-17 10:38:13 -0400144 } else {
Mike Marshall2d4cae02016-02-04 13:48:16 -0500145 gossip_err("op_alloc: kmem_cache_zalloc failed!\n");
Mike Marshall274dcf52015-07-17 10:38:13 -0400146 }
147 return new_op;
148}
149
Al Viroc1223ca2016-02-18 19:17:51 -0500150void op_release(struct orangefs_kernel_op_s *orangefs_op)
Mike Marshall274dcf52015-07-17 10:38:13 -0400151{
Yi Liu8bb8aef2015-11-24 15:12:14 -0500152 if (orangefs_op) {
Mike Marshall274dcf52015-07-17 10:38:13 -0400153 gossip_debug(GOSSIP_CACHE_DEBUG,
154 "Releasing OP (%p: %llu)\n",
Yi Liu8bb8aef2015-11-24 15:12:14 -0500155 orangefs_op,
156 llu(orangefs_op->tag));
Yi Liu8bb8aef2015-11-24 15:12:14 -0500157 kmem_cache_free(op_cache, orangefs_op);
Mike Marshall274dcf52015-07-17 10:38:13 -0400158 } else {
159 gossip_err("NULL pointer in op_release\n");
160 }
161}