1
2
3
4
5
6
7
8
9#include <linux/completion.h>
10#include <linux/ip.h>
11#include <linux/module.h>
12#include <linux/sunrpc/svc.h>
13#include <linux/sunrpc/svcsock.h>
14#include <linux/nfs_fs.h>
15#include <linux/errno.h>
16#include <linux/mutex.h>
17#include <linux/freezer.h>
18#include <linux/kthread.h>
19#include <linux/sunrpc/svcauth_gss.h>
20#include <linux/sunrpc/bc_xprt.h>
21
22#include <net/inet_sock.h>
23
24#include "nfs4_fs.h"
25#include "callback.h"
26#include "internal.h"
27#include "netns.h"
28
29#define NFSDBG_FACILITY NFSDBG_CALLBACK
30
31struct nfs_callback_data {
32 unsigned int users;
33 struct svc_serv *serv;
34 struct svc_rqst *rqst;
35 struct task_struct *task;
36};
37
38static struct nfs_callback_data nfs_callback_info[NFS4_MAX_MINOR_VERSION + 1];
39static DEFINE_MUTEX(nfs_callback_mutex);
40static struct svc_program nfs4_callback_program;
41
42static int nfs4_callback_up_net(struct svc_serv *serv, struct net *net)
43{
44 int ret;
45 struct nfs_net *nn = net_generic(net, nfs_net_id);
46
47 ret = svc_create_xprt(serv, "tcp", net, PF_INET,
48 nfs_callback_set_tcpport, SVC_SOCK_ANONYMOUS);
49 if (ret <= 0)
50 goto out_err;
51 nn->nfs_callback_tcpport = ret;
52 dprintk("NFS: Callback listener port = %u (af %u, net %p)\n",
53 nn->nfs_callback_tcpport, PF_INET, net);
54
55 ret = svc_create_xprt(serv, "tcp", net, PF_INET6,
56 nfs_callback_set_tcpport, SVC_SOCK_ANONYMOUS);
57 if (ret > 0) {
58 nn->nfs_callback_tcpport6 = ret;
59 dprintk("NFS: Callback listener port = %u (af %u, net %p)\n",
60 nn->nfs_callback_tcpport6, PF_INET6, net);
61 } else if (ret != -EAFNOSUPPORT)
62 goto out_err;
63 return 0;
64
65out_err:
66 return (ret) ? ret : -ENOMEM;
67}
68
69
70
71
72static int
73nfs4_callback_svc(void *vrqstp)
74{
75 int err;
76 struct svc_rqst *rqstp = vrqstp;
77
78 set_freezable();
79
80 while (!kthread_should_stop()) {
81
82
83
84 err = svc_recv(rqstp, MAX_SCHEDULE_TIMEOUT);
85 if (err == -EAGAIN || err == -EINTR)
86 continue;
87 svc_process(rqstp);
88 }
89 return 0;
90}
91
92
93
94
95static struct svc_rqst *
96nfs4_callback_up(struct svc_serv *serv)
97{
98 return svc_prepare_thread(serv, &serv->sv_pools[0], NUMA_NO_NODE);
99}
100
101#if defined(CONFIG_NFS_V4_1)
102static int nfs41_callback_up_net(struct svc_serv *serv, struct net *net)
103{
104
105
106
107
108
109 return svc_create_xprt(serv, "tcp-bc", net, PF_INET, 0,
110 SVC_SOCK_ANONYMOUS);
111}
112
113
114
115
116static int
117nfs41_callback_svc(void *vrqstp)
118{
119 struct svc_rqst *rqstp = vrqstp;
120 struct svc_serv *serv = rqstp->rq_server;
121 struct rpc_rqst *req;
122 int error;
123 DEFINE_WAIT(wq);
124
125 set_freezable();
126
127 while (!kthread_should_stop()) {
128 if (try_to_freeze())
129 continue;
130
131 prepare_to_wait(&serv->sv_cb_waitq, &wq, TASK_INTERRUPTIBLE);
132 spin_lock_bh(&serv->sv_cb_lock);
133 if (!list_empty(&serv->sv_cb_list)) {
134 req = list_first_entry(&serv->sv_cb_list,
135 struct rpc_rqst, rq_bc_list);
136 list_del(&req->rq_bc_list);
137 spin_unlock_bh(&serv->sv_cb_lock);
138 dprintk("Invoking bc_svc_process()\n");
139 error = bc_svc_process(serv, req, rqstp);
140 dprintk("bc_svc_process() returned w/ error code= %d\n",
141 error);
142 } else {
143 spin_unlock_bh(&serv->sv_cb_lock);
144 schedule();
145 }
146 finish_wait(&serv->sv_cb_waitq, &wq);
147 }
148 return 0;
149}
150
151
152
153
154static struct svc_rqst *
155nfs41_callback_up(struct svc_serv *serv)
156{
157 struct svc_rqst *rqstp;
158
159 INIT_LIST_HEAD(&serv->sv_cb_list);
160 spin_lock_init(&serv->sv_cb_lock);
161 init_waitqueue_head(&serv->sv_cb_waitq);
162 rqstp = svc_prepare_thread(serv, &serv->sv_pools[0], NUMA_NO_NODE);
163 if (IS_ERR(rqstp)) {
164 svc_xprt_put(serv->sv_bc_xprt);
165 serv->sv_bc_xprt = NULL;
166 }
167 dprintk("--> %s return %ld\n", __func__,
168 IS_ERR(rqstp) ? PTR_ERR(rqstp) : 0);
169 return rqstp;
170}
171
172static void nfs_minorversion_callback_svc_setup(struct svc_serv *serv,
173 struct svc_rqst **rqstpp, int (**callback_svc)(void *vrqstp))
174{
175 *rqstpp = nfs41_callback_up(serv);
176 *callback_svc = nfs41_callback_svc;
177}
178
179static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt,
180 struct svc_serv *serv)
181{
182 if (minorversion)
183
184
185
186
187 xprt->bc_serv = serv;
188}
189#else
190static int nfs41_callback_up_net(struct svc_serv *serv, struct net *net)
191{
192 return 0;
193}
194
195static void nfs_minorversion_callback_svc_setup(struct svc_serv *serv,
196 struct svc_rqst **rqstpp, int (**callback_svc)(void *vrqstp))
197{
198 *rqstpp = ERR_PTR(-ENOTSUPP);
199 *callback_svc = ERR_PTR(-ENOTSUPP);
200}
201
202static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt,
203 struct svc_serv *serv)
204{
205}
206#endif
207
208static int nfs_callback_start_svc(int minorversion, struct rpc_xprt *xprt,
209 struct svc_serv *serv)
210{
211 struct svc_rqst *rqstp;
212 int (*callback_svc)(void *vrqstp);
213 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
214 char svc_name[12];
215 int ret;
216
217 nfs_callback_bc_serv(minorversion, xprt, serv);
218
219 if (cb_info->task)
220 return 0;
221
222 switch (minorversion) {
223 case 0:
224
225 rqstp = nfs4_callback_up(serv);
226 callback_svc = nfs4_callback_svc;
227 break;
228 default:
229 nfs_minorversion_callback_svc_setup(serv,
230 &rqstp, &callback_svc);
231 }
232
233 if (IS_ERR(rqstp))
234 return PTR_ERR(rqstp);
235
236 svc_sock_update_bufs(serv);
237
238 sprintf(svc_name, "nfsv4.%u-svc", minorversion);
239 cb_info->serv = serv;
240 cb_info->rqst = rqstp;
241 cb_info->task = kthread_run(callback_svc, cb_info->rqst, svc_name);
242 if (IS_ERR(cb_info->task)) {
243 ret = PTR_ERR(cb_info->task);
244 svc_exit_thread(cb_info->rqst);
245 cb_info->rqst = NULL;
246 cb_info->task = NULL;
247 return ret;
248 }
249 dprintk("nfs_callback_up: service started\n");
250 return 0;
251}
252
253static void nfs_callback_down_net(u32 minorversion, struct svc_serv *serv, struct net *net)
254{
255 struct nfs_net *nn = net_generic(net, nfs_net_id);
256
257 if (--nn->cb_users[minorversion])
258 return;
259
260 dprintk("NFS: destroy per-net callback data; net=%p\n", net);
261 svc_shutdown_net(serv, net);
262}
263
264static int nfs_callback_up_net(int minorversion, struct svc_serv *serv, struct net *net)
265{
266 struct nfs_net *nn = net_generic(net, nfs_net_id);
267 int ret;
268
269 if (nn->cb_users[minorversion]++)
270 return 0;
271
272 dprintk("NFS: create per-net callback data; net=%p\n", net);
273
274 ret = svc_bind(serv, net);
275 if (ret < 0) {
276 printk(KERN_WARNING "NFS: bind callback service failed\n");
277 goto err_bind;
278 }
279
280 switch (minorversion) {
281 case 0:
282 ret = nfs4_callback_up_net(serv, net);
283 break;
284 case 1:
285 ret = nfs41_callback_up_net(serv, net);
286 break;
287 default:
288 printk(KERN_ERR "NFS: unknown callback version: %d\n",
289 minorversion);
290 ret = -EINVAL;
291 break;
292 }
293
294 if (ret < 0) {
295 printk(KERN_ERR "NFS: callback service start failed\n");
296 goto err_socks;
297 }
298 return 0;
299
300err_socks:
301 svc_rpcb_cleanup(serv, net);
302err_bind:
303 dprintk("NFS: Couldn't create callback socket: err = %d; "
304 "net = %p\n", ret, net);
305 return ret;
306}
307
308static struct svc_serv *nfs_callback_create_svc(int minorversion)
309{
310 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
311 struct svc_serv *serv;
312
313
314
315
316 if (cb_info->task) {
317
318
319
320
321 svc_get(cb_info->serv);
322 return cb_info->serv;
323 }
324
325
326
327
328
329 if (cb_info->users)
330 printk(KERN_WARNING "nfs_callback_create_svc: no kthread, %d users??\n",
331 cb_info->users);
332
333 serv = svc_create(&nfs4_callback_program, NFS4_CALLBACK_BUFSIZE, NULL);
334 if (!serv) {
335 printk(KERN_ERR "nfs_callback_create_svc: create service failed\n");
336 return ERR_PTR(-ENOMEM);
337 }
338
339
340
341 serv->sv_maxconn = 1024;
342 dprintk("nfs_callback_create_svc: service created\n");
343 return serv;
344}
345
346
347
348
349int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt)
350{
351 struct svc_serv *serv;
352 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
353 int ret;
354 struct net *net = xprt->xprt_net;
355
356 mutex_lock(&nfs_callback_mutex);
357
358 serv = nfs_callback_create_svc(minorversion);
359 if (IS_ERR(serv)) {
360 ret = PTR_ERR(serv);
361 goto err_create;
362 }
363
364 ret = nfs_callback_up_net(minorversion, serv, net);
365 if (ret < 0)
366 goto err_net;
367
368 ret = nfs_callback_start_svc(minorversion, xprt, serv);
369 if (ret < 0)
370 goto err_start;
371
372 cb_info->users++;
373
374
375
376
377
378
379err_net:
380 svc_destroy(serv);
381err_create:
382 mutex_unlock(&nfs_callback_mutex);
383 return ret;
384
385err_start:
386 nfs_callback_down_net(minorversion, serv, net);
387 dprintk("NFS: Couldn't create server thread; err = %d\n", ret);
388 goto err_net;
389}
390
391
392
393
394void nfs_callback_down(int minorversion, struct net *net)
395{
396 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
397
398 mutex_lock(&nfs_callback_mutex);
399 nfs_callback_down_net(minorversion, cb_info->serv, net);
400 cb_info->users--;
401 if (cb_info->users == 0 && cb_info->task != NULL) {
402 kthread_stop(cb_info->task);
403 dprintk("nfs_callback_down: service stopped\n");
404 svc_exit_thread(cb_info->rqst);
405 dprintk("nfs_callback_down: service destroyed\n");
406 cb_info->serv = NULL;
407 cb_info->rqst = NULL;
408 cb_info->task = NULL;
409 }
410 mutex_unlock(&nfs_callback_mutex);
411}
412
413
414int
415check_gss_callback_principal(struct nfs_client *clp, struct svc_rqst *rqstp)
416{
417 char *p = rqstp->rq_cred.cr_principal;
418
419 if (rqstp->rq_authop->flavour != RPC_AUTH_GSS)
420 return 1;
421
422
423 if (clp->cl_minorversion != 0)
424 return 0;
425
426
427
428
429 if (p == NULL)
430 return 0;
431
432
433
434 if (memcmp(p, "nfs@", 4) != 0)
435 return 0;
436 p += 4;
437 if (strcmp(p, clp->cl_hostname) != 0)
438 return 0;
439 return 1;
440}
441
442
443
444
445
446
447
448
449
450
451static int nfs_callback_authenticate(struct svc_rqst *rqstp)
452{
453 switch (rqstp->rq_authop->flavour) {
454 case RPC_AUTH_NULL:
455 if (rqstp->rq_proc != CB_NULL)
456 return SVC_DROP;
457 break;
458 case RPC_AUTH_GSS:
459
460 if (svc_is_backchannel(rqstp))
461 return SVC_DROP;
462 }
463 return SVC_OK;
464}
465
466
467
468
469static struct svc_version *nfs4_callback_version[] = {
470 [1] = &nfs4_callback_version1,
471 [4] = &nfs4_callback_version4,
472};
473
474static struct svc_stat nfs4_callback_stats;
475
476static struct svc_program nfs4_callback_program = {
477 .pg_prog = NFS4_CALLBACK,
478 .pg_nvers = ARRAY_SIZE(nfs4_callback_version),
479 .pg_vers = nfs4_callback_version,
480 .pg_name = "NFSv4 callback",
481 .pg_class = "nfs",
482 .pg_stats = &nfs4_callback_stats,
483 .pg_authenticate = nfs_callback_authenticate,
484};
485