1*4882a593Smuzhiyun // SPDX-License-Identifier: GPL-2.0
2*4882a593Smuzhiyun /*
3*4882a593Smuzhiyun * (C) 2001 Clemson University and The University of Chicago
4*4882a593Smuzhiyun *
5*4882a593Smuzhiyun * See COPYING in top-level directory.
6*4882a593Smuzhiyun */
7*4882a593Smuzhiyun
8*4882a593Smuzhiyun #include "protocol.h"
9*4882a593Smuzhiyun #include "orangefs-kernel.h"
10*4882a593Smuzhiyun
11*4882a593Smuzhiyun /* tags assigned to kernel upcall operations */
12*4882a593Smuzhiyun static __u64 next_tag_value;
13*4882a593Smuzhiyun static DEFINE_SPINLOCK(next_tag_value_lock);
14*4882a593Smuzhiyun
15*4882a593Smuzhiyun /* the orangefs memory caches */
16*4882a593Smuzhiyun
17*4882a593Smuzhiyun /* a cache for orangefs upcall/downcall operations */
18*4882a593Smuzhiyun static struct kmem_cache *op_cache;
19*4882a593Smuzhiyun
op_cache_initialize(void)20*4882a593Smuzhiyun int op_cache_initialize(void)
21*4882a593Smuzhiyun {
22*4882a593Smuzhiyun op_cache = kmem_cache_create("orangefs_op_cache",
23*4882a593Smuzhiyun sizeof(struct orangefs_kernel_op_s),
24*4882a593Smuzhiyun 0,
25*4882a593Smuzhiyun ORANGEFS_CACHE_CREATE_FLAGS,
26*4882a593Smuzhiyun NULL);
27*4882a593Smuzhiyun
28*4882a593Smuzhiyun if (!op_cache) {
29*4882a593Smuzhiyun gossip_err("Cannot create orangefs_op_cache\n");
30*4882a593Smuzhiyun return -ENOMEM;
31*4882a593Smuzhiyun }
32*4882a593Smuzhiyun
33*4882a593Smuzhiyun /* initialize our atomic tag counter */
34*4882a593Smuzhiyun spin_lock(&next_tag_value_lock);
35*4882a593Smuzhiyun next_tag_value = 100;
36*4882a593Smuzhiyun spin_unlock(&next_tag_value_lock);
37*4882a593Smuzhiyun return 0;
38*4882a593Smuzhiyun }
39*4882a593Smuzhiyun
op_cache_finalize(void)40*4882a593Smuzhiyun int op_cache_finalize(void)
41*4882a593Smuzhiyun {
42*4882a593Smuzhiyun kmem_cache_destroy(op_cache);
43*4882a593Smuzhiyun return 0;
44*4882a593Smuzhiyun }
45*4882a593Smuzhiyun
get_opname_string(struct orangefs_kernel_op_s * new_op)46*4882a593Smuzhiyun char *get_opname_string(struct orangefs_kernel_op_s *new_op)
47*4882a593Smuzhiyun {
48*4882a593Smuzhiyun if (new_op) {
49*4882a593Smuzhiyun __s32 type = new_op->upcall.type;
50*4882a593Smuzhiyun
51*4882a593Smuzhiyun if (type == ORANGEFS_VFS_OP_FILE_IO)
52*4882a593Smuzhiyun return "OP_FILE_IO";
53*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_LOOKUP)
54*4882a593Smuzhiyun return "OP_LOOKUP";
55*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_CREATE)
56*4882a593Smuzhiyun return "OP_CREATE";
57*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_GETATTR)
58*4882a593Smuzhiyun return "OP_GETATTR";
59*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_REMOVE)
60*4882a593Smuzhiyun return "OP_REMOVE";
61*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_MKDIR)
62*4882a593Smuzhiyun return "OP_MKDIR";
63*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_READDIR)
64*4882a593Smuzhiyun return "OP_READDIR";
65*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_READDIRPLUS)
66*4882a593Smuzhiyun return "OP_READDIRPLUS";
67*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_SETATTR)
68*4882a593Smuzhiyun return "OP_SETATTR";
69*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_SYMLINK)
70*4882a593Smuzhiyun return "OP_SYMLINK";
71*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_RENAME)
72*4882a593Smuzhiyun return "OP_RENAME";
73*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_STATFS)
74*4882a593Smuzhiyun return "OP_STATFS";
75*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_TRUNCATE)
76*4882a593Smuzhiyun return "OP_TRUNCATE";
77*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_RA_FLUSH)
78*4882a593Smuzhiyun return "OP_RA_FLUSH";
79*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_FS_MOUNT)
80*4882a593Smuzhiyun return "OP_FS_MOUNT";
81*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_FS_UMOUNT)
82*4882a593Smuzhiyun return "OP_FS_UMOUNT";
83*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_GETXATTR)
84*4882a593Smuzhiyun return "OP_GETXATTR";
85*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_SETXATTR)
86*4882a593Smuzhiyun return "OP_SETXATTR";
87*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_LISTXATTR)
88*4882a593Smuzhiyun return "OP_LISTXATTR";
89*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_REMOVEXATTR)
90*4882a593Smuzhiyun return "OP_REMOVEXATTR";
91*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_PARAM)
92*4882a593Smuzhiyun return "OP_PARAM";
93*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_PERF_COUNT)
94*4882a593Smuzhiyun return "OP_PERF_COUNT";
95*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_CANCEL)
96*4882a593Smuzhiyun return "OP_CANCEL";
97*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_FSYNC)
98*4882a593Smuzhiyun return "OP_FSYNC";
99*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_FSKEY)
100*4882a593Smuzhiyun return "OP_FSKEY";
101*4882a593Smuzhiyun else if (type == ORANGEFS_VFS_OP_FEATURES)
102*4882a593Smuzhiyun return "OP_FEATURES";
103*4882a593Smuzhiyun }
104*4882a593Smuzhiyun return "OP_UNKNOWN?";
105*4882a593Smuzhiyun }
106*4882a593Smuzhiyun
orangefs_new_tag(struct orangefs_kernel_op_s * op)107*4882a593Smuzhiyun void orangefs_new_tag(struct orangefs_kernel_op_s *op)
108*4882a593Smuzhiyun {
109*4882a593Smuzhiyun spin_lock(&next_tag_value_lock);
110*4882a593Smuzhiyun op->tag = next_tag_value++;
111*4882a593Smuzhiyun if (next_tag_value == 0)
112*4882a593Smuzhiyun next_tag_value = 100;
113*4882a593Smuzhiyun spin_unlock(&next_tag_value_lock);
114*4882a593Smuzhiyun }
115*4882a593Smuzhiyun
op_alloc(__s32 type)116*4882a593Smuzhiyun struct orangefs_kernel_op_s *op_alloc(__s32 type)
117*4882a593Smuzhiyun {
118*4882a593Smuzhiyun struct orangefs_kernel_op_s *new_op = NULL;
119*4882a593Smuzhiyun
120*4882a593Smuzhiyun new_op = kmem_cache_zalloc(op_cache, GFP_KERNEL);
121*4882a593Smuzhiyun if (new_op) {
122*4882a593Smuzhiyun INIT_LIST_HEAD(&new_op->list);
123*4882a593Smuzhiyun spin_lock_init(&new_op->lock);
124*4882a593Smuzhiyun init_completion(&new_op->waitq);
125*4882a593Smuzhiyun
126*4882a593Smuzhiyun new_op->upcall.type = ORANGEFS_VFS_OP_INVALID;
127*4882a593Smuzhiyun new_op->downcall.type = ORANGEFS_VFS_OP_INVALID;
128*4882a593Smuzhiyun new_op->downcall.status = -1;
129*4882a593Smuzhiyun
130*4882a593Smuzhiyun new_op->op_state = OP_VFS_STATE_UNKNOWN;
131*4882a593Smuzhiyun
132*4882a593Smuzhiyun /* initialize the op specific tag and upcall credentials */
133*4882a593Smuzhiyun orangefs_new_tag(new_op);
134*4882a593Smuzhiyun new_op->upcall.type = type;
135*4882a593Smuzhiyun new_op->attempts = 0;
136*4882a593Smuzhiyun gossip_debug(GOSSIP_CACHE_DEBUG,
137*4882a593Smuzhiyun "Alloced OP (%p: %llu %s)\n",
138*4882a593Smuzhiyun new_op,
139*4882a593Smuzhiyun llu(new_op->tag),
140*4882a593Smuzhiyun get_opname_string(new_op));
141*4882a593Smuzhiyun
142*4882a593Smuzhiyun new_op->upcall.uid = from_kuid(&init_user_ns,
143*4882a593Smuzhiyun current_fsuid());
144*4882a593Smuzhiyun
145*4882a593Smuzhiyun new_op->upcall.gid = from_kgid(&init_user_ns,
146*4882a593Smuzhiyun current_fsgid());
147*4882a593Smuzhiyun } else {
148*4882a593Smuzhiyun gossip_err("op_alloc: kmem_cache_zalloc failed!\n");
149*4882a593Smuzhiyun }
150*4882a593Smuzhiyun return new_op;
151*4882a593Smuzhiyun }
152*4882a593Smuzhiyun
op_release(struct orangefs_kernel_op_s * orangefs_op)153*4882a593Smuzhiyun void op_release(struct orangefs_kernel_op_s *orangefs_op)
154*4882a593Smuzhiyun {
155*4882a593Smuzhiyun if (orangefs_op) {
156*4882a593Smuzhiyun gossip_debug(GOSSIP_CACHE_DEBUG,
157*4882a593Smuzhiyun "Releasing OP (%p: %llu)\n",
158*4882a593Smuzhiyun orangefs_op,
159*4882a593Smuzhiyun llu(orangefs_op->tag));
160*4882a593Smuzhiyun kmem_cache_free(op_cache, orangefs_op);
161*4882a593Smuzhiyun } else {
162*4882a593Smuzhiyun gossip_err("NULL pointer in op_release\n");
163*4882a593Smuzhiyun }
164*4882a593Smuzhiyun }
165