blob: 8d129bb7355afbb2ca7f1904ff0263f604e86dd6 [file] [log] [blame]
Linus Torvalds1da177e2005-04-16 15:20:36 -07001/*
2 * linux/fs/nfs/callback.c
3 *
4 * Copyright (C) 2004 Trond Myklebust
5 *
6 * NFSv4 callback handling
7 */
8
Linus Torvalds1da177e2005-04-16 15:20:36 -07009#include <linux/completion.h>
10#include <linux/ip.h>
11#include <linux/module.h>
Linus Torvalds1da177e2005-04-16 15:20:36 -070012#include <linux/sunrpc/svc.h>
13#include <linux/sunrpc/svcsock.h>
14#include <linux/nfs_fs.h>
Trond Myklebust758201e2012-10-01 16:33:18 -070015#include <linux/errno.h>
Ingo Molnar353ab6e2006-03-26 01:37:12 -080016#include <linux/mutex.h>
Rafael J. Wysocki83144182007-07-17 04:03:35 -070017#include <linux/freezer.h>
Jeff Laytona277e332008-02-20 08:55:30 -050018#include <linux/kthread.h>
Olga Kornievskaia945b34a2008-12-23 16:18:34 -050019#include <linux/sunrpc/svcauth_gss.h>
Ricardo Labiagaa43cde92009-04-01 09:23:08 -040020#include <linux/sunrpc/bc_xprt.h>
Arnaldo Carvalho de Melo14c85022005-12-27 02:43:12 -020021
22#include <net/inet_sock.h>
23
Trond Myklebust4ce79712005-06-22 17:16:21 +000024#include "nfs4_fs.h"
Linus Torvalds1da177e2005-04-16 15:20:36 -070025#include "callback.h"
David Howells24c8dbb2006-08-22 20:06:10 -040026#include "internal.h"
Stanislav Kinsburskybbe0a3a2012-08-20 18:00:36 +040027#include "netns.h"
Linus Torvalds1da177e2005-04-16 15:20:36 -070028
29#define NFSDBG_FACILITY NFSDBG_CALLBACK
30
31struct nfs_callback_data {
32 unsigned int users;
Ricardo Labiagaa43cde92009-04-01 09:23:08 -040033 struct svc_serv *serv;
Jeff Layton5afc5972008-06-11 10:03:11 -040034 struct svc_rqst *rqst;
Jeff Laytona277e332008-02-20 08:55:30 -050035 struct task_struct *task;
Linus Torvalds1da177e2005-04-16 15:20:36 -070036};
37
Andy Adamsone82dc222009-04-01 09:23:14 -040038static struct nfs_callback_data nfs_callback_info[NFS4_MAX_MINOR_VERSION + 1];
Ingo Molnar353ab6e2006-03-26 01:37:12 -080039static DEFINE_MUTEX(nfs_callback_mutex);
Linus Torvalds1da177e2005-04-16 15:20:36 -070040static struct svc_program nfs4_callback_program;
41
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +040042static int nfs4_callback_up_net(struct svc_serv *serv, struct net *net)
43{
44 int ret;
Stanislav Kinsburskybbe0a3a2012-08-20 18:00:36 +040045 struct nfs_net *nn = net_generic(net, nfs_net_id);
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +040046
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;
Stanislav Kinsburskybbe0a3a2012-08-20 18:00:36 +040051 nn->nfs_callback_tcpport = ret;
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +040052 dprintk("NFS: Callback listener port = %u (af %u, net %p)\n",
Stanislav Kinsburskybbe0a3a2012-08-20 18:00:36 +040053 nn->nfs_callback_tcpport, PF_INET, net);
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +040054
55 ret = svc_create_xprt(serv, "tcp", net, PF_INET6,
56 nfs_callback_set_tcpport, SVC_SOCK_ANONYMOUS);
57 if (ret > 0) {
Stanislav Kinsbursky29dcc162012-08-20 18:00:41 +040058 nn->nfs_callback_tcpport6 = ret;
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +040059 dprintk("NFS: Callback listener port = %u (af %u, net %p)\n",
Stanislav Kinsbursky29dcc162012-08-20 18:00:41 +040060 nn->nfs_callback_tcpport6, PF_INET6, net);
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +040061 } else if (ret != -EAFNOSUPPORT)
62 goto out_err;
63 return 0;
64
65out_err:
66 return (ret) ? ret : -ENOMEM;
67}
68
Linus Torvalds1da177e2005-04-16 15:20:36 -070069/*
Andy Adamsone82dc222009-04-01 09:23:14 -040070 * This is the NFSv4 callback kernel thread.
Linus Torvalds1da177e2005-04-16 15:20:36 -070071 */
Jeff Laytona277e332008-02-20 08:55:30 -050072static int
Benny Halevy71468512009-04-01 09:22:56 -040073nfs4_callback_svc(void *vrqstp)
Linus Torvalds1da177e2005-04-16 15:20:36 -070074{
J. Bruce Fields5b444cc2012-08-17 21:47:53 -040075 int err;
Jeff Laytona277e332008-02-20 08:55:30 -050076 struct svc_rqst *rqstp = vrqstp;
Linus Torvalds1da177e2005-04-16 15:20:36 -070077
Rafael J. Wysocki83144182007-07-17 04:03:35 -070078 set_freezable();
Linus Torvalds1da177e2005-04-16 15:20:36 -070079
Jeff Laytona277e332008-02-20 08:55:30 -050080 while (!kthread_should_stop()) {
Linus Torvalds1da177e2005-04-16 15:20:36 -070081 /*
82 * Listen for a request on the socket
83 */
NeilBrown6fb2b472006-10-02 02:17:50 -070084 err = svc_recv(rqstp, MAX_SCHEDULE_TIMEOUT);
J. Bruce Fields5b444cc2012-08-17 21:47:53 -040085 if (err == -EAGAIN || err == -EINTR)
Linus Torvalds1da177e2005-04-16 15:20:36 -070086 continue;
NeilBrown6fb2b472006-10-02 02:17:50 -070087 svc_process(rqstp);
Linus Torvalds1da177e2005-04-16 15:20:36 -070088 }
Jeff Laytona277e332008-02-20 08:55:30 -050089 return 0;
Linus Torvalds1da177e2005-04-16 15:20:36 -070090}
91
92/*
Benny Halevy71468512009-04-01 09:22:56 -040093 * Prepare to bring up the NFSv4 callback service
Linus Torvalds1da177e2005-04-16 15:20:36 -070094 */
Trond Myklebust17280172012-03-11 13:11:00 -040095static struct svc_rqst *
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +040096nfs4_callback_up(struct svc_serv *serv)
Linus Torvalds1da177e2005-04-16 15:20:36 -070097{
Eric Dumazet11fd1652011-07-28 20:04:09 +020098 return svc_prepare_thread(serv, &serv->sv_pools[0], NUMA_NO_NODE);
Benny Halevy71468512009-04-01 09:22:56 -040099}
100
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400101#if defined(CONFIG_NFS_V4_1)
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400102static int nfs41_callback_up_net(struct svc_serv *serv, struct net *net)
103{
104 /*
105 * Create an svc_sock for the back channel service that shares the
106 * fore channel connection.
107 * Returns the input port (0) and sets the svc_serv bc_xprt on success
108 */
109 return svc_create_xprt(serv, "tcp-bc", net, PF_INET, 0,
110 SVC_SOCK_ANONYMOUS);
111}
112
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400113/*
114 * The callback service for NFSv4.1 callbacks
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
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400127 while (!kthread_should_stop()) {
Jeff Layton25d280a2013-03-25 07:59:57 -0400128 if (try_to_freeze())
129 continue;
130
Jeff Layton5d05e542015-03-20 15:15:14 -0400131 prepare_to_wait(&serv->sv_cb_waitq, &wq, TASK_INTERRUPTIBLE);
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400132 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);
Jeff Layton6ffa30d2015-01-14 13:08:57 -0500138 finish_wait(&serv->sv_cb_waitq, &wq);
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400139 dprintk("Invoking bc_svc_process()\n");
140 error = bc_svc_process(serv, req, rqstp);
141 dprintk("bc_svc_process() returned w/ error code= %d\n",
142 error);
143 } else {
144 spin_unlock_bh(&serv->sv_cb_lock);
Jeff Layton5d05e542015-03-20 15:15:14 -0400145 schedule();
Jeff Layton6ffa30d2015-01-14 13:08:57 -0500146 finish_wait(&serv->sv_cb_waitq, &wq);
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400147 }
Jeff Layton5d05e542015-03-20 15:15:14 -0400148 flush_signals(current);
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400149 }
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400150 return 0;
151}
152
153/*
154 * Bring up the NFSv4.1 callback service
155 */
Trond Myklebust17280172012-03-11 13:11:00 -0400156static struct svc_rqst *
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400157nfs41_callback_up(struct svc_serv *serv)
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400158{
Andy Adamson01c9a0b2011-01-06 02:04:28 +0000159 struct svc_rqst *rqstp;
Benny Halevy8f975242009-04-01 09:23:11 -0400160
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400161 INIT_LIST_HEAD(&serv->sv_cb_list);
162 spin_lock_init(&serv->sv_cb_lock);
163 init_waitqueue_head(&serv->sv_cb_waitq);
Eric Dumazet11fd1652011-07-28 20:04:09 +0200164 rqstp = svc_prepare_thread(serv, &serv->sv_pools[0], NUMA_NO_NODE);
Andy Adamson01c9a0b2011-01-06 02:04:28 +0000165 if (IS_ERR(rqstp)) {
Andy Adamson4a19de02011-01-06 02:04:35 +0000166 svc_xprt_put(serv->sv_bc_xprt);
167 serv->sv_bc_xprt = NULL;
Andy Adamson01c9a0b2011-01-06 02:04:28 +0000168 }
Geyslan G. Bem54bcfa62013-10-14 17:24:15 -0300169 dprintk("--> %s return %d\n", __func__, PTR_ERR_OR_ZERO(rqstp));
Benny Halevy8f975242009-04-01 09:23:11 -0400170 return rqstp;
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400171}
172
Trond Myklebust758201e2012-10-01 16:33:18 -0700173static void nfs_minorversion_callback_svc_setup(struct svc_serv *serv,
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400174 struct svc_rqst **rqstpp, int (**callback_svc)(void *vrqstp))
175{
Trond Myklebust758201e2012-10-01 16:33:18 -0700176 *rqstpp = nfs41_callback_up(serv);
177 *callback_svc = nfs41_callback_svc;
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400178}
179
180static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt,
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400181 struct svc_serv *serv)
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400182{
183 if (minorversion)
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400184 /*
185 * Save the svc_serv in the transport so that it can
186 * be referenced when the session backchannel is initialized
187 */
188 xprt->bc_serv = serv;
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400189}
190#else
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400191static int nfs41_callback_up_net(struct svc_serv *serv, struct net *net)
192{
193 return 0;
194}
195
Trond Myklebust758201e2012-10-01 16:33:18 -0700196static void nfs_minorversion_callback_svc_setup(struct svc_serv *serv,
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400197 struct svc_rqst **rqstpp, int (**callback_svc)(void *vrqstp))
198{
Trond Myklebust758201e2012-10-01 16:33:18 -0700199 *rqstpp = ERR_PTR(-ENOTSUPP);
200 *callback_svc = ERR_PTR(-ENOTSUPP);
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400201}
202
203static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt,
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400204 struct svc_serv *serv)
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400205{
206}
207#endif /* CONFIG_NFS_V4_1 */
208
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400209static int nfs_callback_start_svc(int minorversion, struct rpc_xprt *xprt,
210 struct svc_serv *serv)
211{
212 struct svc_rqst *rqstp;
213 int (*callback_svc)(void *vrqstp);
214 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400215 int ret;
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400216
217 nfs_callback_bc_serv(minorversion, xprt, serv);
218
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400219 if (cb_info->task)
220 return 0;
221
Trond Myklebust758201e2012-10-01 16:33:18 -0700222 switch (minorversion) {
223 case 0:
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400224 /* v4.0 callback setup */
225 rqstp = nfs4_callback_up(serv);
226 callback_svc = nfs4_callback_svc;
Trond Myklebust758201e2012-10-01 16:33:18 -0700227 break;
228 default:
229 nfs_minorversion_callback_svc_setup(serv,
230 &rqstp, &callback_svc);
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400231 }
232
233 if (IS_ERR(rqstp))
234 return PTR_ERR(rqstp);
235
236 svc_sock_update_bufs(serv);
237
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400238 cb_info->serv = serv;
239 cb_info->rqst = rqstp;
Trond Myklebust66f09ca2014-09-02 13:58:58 -0400240 cb_info->task = kthread_create(callback_svc, cb_info->rqst,
Kees Cookf1701682013-07-03 15:04:58 -0700241 "nfsv4.%u-svc", minorversion);
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400242 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;
Trond Myklebuste9b7e912012-10-16 12:30:44 -0400247 return ret;
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400248 }
Trond Myklebust88799972014-08-03 13:03:08 -0400249 rqstp->rq_task = cb_info->task;
Trond Myklebust66f09ca2014-09-02 13:58:58 -0400250 wake_up_process(cb_info->task);
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400251 dprintk("nfs_callback_up: service started\n");
252 return 0;
253}
254
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400255static void nfs_callback_down_net(u32 minorversion, struct svc_serv *serv, struct net *net)
256{
257 struct nfs_net *nn = net_generic(net, nfs_net_id);
258
259 if (--nn->cb_users[minorversion])
260 return;
261
262 dprintk("NFS: destroy per-net callback data; net=%p\n", net);
263 svc_shutdown_net(serv, net);
264}
265
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400266static int nfs_callback_up_net(int minorversion, struct svc_serv *serv, struct net *net)
267{
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400268 struct nfs_net *nn = net_generic(net, nfs_net_id);
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400269 int ret;
270
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400271 if (nn->cb_users[minorversion]++)
272 return 0;
273
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400274 dprintk("NFS: create per-net callback data; net=%p\n", net);
275
276 ret = svc_bind(serv, net);
277 if (ret < 0) {
278 printk(KERN_WARNING "NFS: bind callback service failed\n");
279 goto err_bind;
280 }
281
282 switch (minorversion) {
283 case 0:
284 ret = nfs4_callback_up_net(serv, net);
285 break;
286 case 1:
Steve Dickson42c2c422013-05-22 12:50:38 -0400287 case 2:
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400288 ret = nfs41_callback_up_net(serv, net);
289 break;
290 default:
291 printk(KERN_ERR "NFS: unknown callback version: %d\n",
292 minorversion);
293 ret = -EINVAL;
294 break;
295 }
296
297 if (ret < 0) {
298 printk(KERN_ERR "NFS: callback service start failed\n");
299 goto err_socks;
300 }
301 return 0;
302
303err_socks:
304 svc_rpcb_cleanup(serv, net);
305err_bind:
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400306 dprintk("NFS: Couldn't create callback socket: err = %d; "
307 "net = %p\n", ret, net);
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400308 return ret;
309}
310
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400311static struct svc_serv *nfs_callback_create_svc(int minorversion)
312{
313 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
314 struct svc_serv *serv;
315
316 /*
317 * Check whether we're already up and running.
318 */
319 if (cb_info->task) {
320 /*
321 * Note: increase service usage, because later in case of error
322 * svc_destroy() will be called.
323 */
324 svc_get(cb_info->serv);
325 return cb_info->serv;
326 }
327
328 /*
329 * Sanity check: if there's no task,
330 * we should be the first user ...
331 */
332 if (cb_info->users)
333 printk(KERN_WARNING "nfs_callback_create_svc: no kthread, %d users??\n",
334 cb_info->users);
335
336 serv = svc_create(&nfs4_callback_program, NFS4_CALLBACK_BUFSIZE, NULL);
337 if (!serv) {
338 printk(KERN_ERR "nfs_callback_create_svc: create service failed\n");
339 return ERR_PTR(-ENOMEM);
340 }
341 /* As there is only one thread we need to over-ride the
342 * default maximum of 80 connections
343 */
344 serv->sv_maxconn = 1024;
345 dprintk("nfs_callback_create_svc: service created\n");
346 return serv;
347}
348
Benny Halevy71468512009-04-01 09:22:56 -0400349/*
350 * Bring up the callback thread if it is not already up.
351 */
352int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt)
353{
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400354 struct svc_serv *serv;
Andy Adamsone82dc222009-04-01 09:23:14 -0400355 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400356 int ret;
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400357 struct net *net = xprt->xprt_net;
Benny Halevy71468512009-04-01 09:22:56 -0400358
359 mutex_lock(&nfs_callback_mutex);
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400360
361 serv = nfs_callback_create_svc(minorversion);
362 if (IS_ERR(serv)) {
363 ret = PTR_ERR(serv);
364 goto err_create;
365 }
366
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400367 ret = nfs_callback_up_net(minorversion, serv, net);
368 if (ret < 0)
369 goto err_net;
Stanislav Kinsbursky9793f7c2012-05-02 16:08:38 +0400370
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400371 ret = nfs_callback_start_svc(minorversion, xprt, serv);
372 if (ret < 0)
373 goto err_start;
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400374
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400375 cb_info->users++;
Jeff Layton8e600292008-02-11 10:00:20 -0500376 /*
377 * svc_create creates the svc_serv with sv_nrthreads == 1, and then
Jeff Laytona277e332008-02-20 08:55:30 -0500378 * svc_prepare_thread increments that. So we need to call svc_destroy
Jeff Layton8e600292008-02-11 10:00:20 -0500379 * on both success and failure so that the refcount is 1 when the
380 * thread exits.
381 */
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400382err_net:
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400383 svc_destroy(serv);
384err_create:
Ingo Molnar353ab6e2006-03-26 01:37:12 -0800385 mutex_unlock(&nfs_callback_mutex);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700386 return ret;
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400387
388err_start:
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400389 nfs_callback_down_net(minorversion, serv, net);
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400390 dprintk("NFS: Couldn't create server thread; err = %d\n", ret);
391 goto err_net;
Linus Torvalds1da177e2005-04-16 15:20:36 -0700392}
393
394/*
Jeff Layton5afc5972008-06-11 10:03:11 -0400395 * Kill the callback thread if it's no longer being used.
Linus Torvalds1da177e2005-04-16 15:20:36 -0700396 */
Stanislav Kinsburskyc8ceb412012-08-20 18:00:06 +0400397void nfs_callback_down(int minorversion, struct net *net)
Linus Torvalds1da177e2005-04-16 15:20:36 -0700398{
Andy Adamsone82dc222009-04-01 09:23:14 -0400399 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
400
Ingo Molnar353ab6e2006-03-26 01:37:12 -0800401 mutex_lock(&nfs_callback_mutex);
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400402 nfs_callback_down_net(minorversion, cb_info->serv, net);
Andy Adamsone82dc222009-04-01 09:23:14 -0400403 cb_info->users--;
404 if (cb_info->users == 0 && cb_info->task != NULL) {
405 kthread_stop(cb_info->task);
Stanislav Kinsbursky1dc42e02012-08-20 18:00:51 +0400406 dprintk("nfs_callback_down: service stopped\n");
Andy Adamsone82dc222009-04-01 09:23:14 -0400407 svc_exit_thread(cb_info->rqst);
Stanislav Kinsbursky1dc42e02012-08-20 18:00:51 +0400408 dprintk("nfs_callback_down: service destroyed\n");
Andy Adamsone82dc222009-04-01 09:23:14 -0400409 cb_info->serv = NULL;
410 cb_info->rqst = NULL;
411 cb_info->task = NULL;
Jeff Layton5afc5972008-06-11 10:03:11 -0400412 }
Ingo Molnar353ab6e2006-03-26 01:37:12 -0800413 mutex_unlock(&nfs_callback_mutex);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700414}
415
Andy Adamson778be232011-01-25 15:38:01 +0000416/* Boolean check of RPC_AUTH_GSS principal */
417int
418check_gss_callback_principal(struct nfs_client *clp, struct svc_rqst *rqstp)
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500419{
J. Bruce Fields03a4e1f2012-05-14 19:55:22 -0400420 char *p = rqstp->rq_cred.cr_principal;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500421
Andy Adamson778be232011-01-25 15:38:01 +0000422 if (rqstp->rq_authop->flavour != RPC_AUTH_GSS)
423 return 1;
424
Andy Adamsonece0de62011-01-06 02:04:33 +0000425 /* No RPC_AUTH_GSS on NFSv4.1 back channel yet */
426 if (clp->cl_minorversion != 0)
Andy Adamson778be232011-01-25 15:38:01 +0000427 return 0;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500428 /*
429 * It might just be a normal user principal, in which case
430 * userspace won't bother to tell us the name at all.
431 */
432 if (p == NULL)
Andy Adamson778be232011-01-25 15:38:01 +0000433 return 0;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500434
Jeff Laytonf11b2a12014-06-21 20:52:17 -0400435 /*
436 * Did we get the acceptor from userland during the SETCLIENID
437 * negotiation?
438 */
439 if (clp->cl_acceptor)
440 return !strcmp(p, clp->cl_acceptor);
441
442 /*
443 * Otherwise try to verify it using the cl_hostname. Note that this
444 * doesn't work if a non-canonical hostname was used in the devname.
445 */
446
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500447 /* Expect a GSS_C_NT_HOSTBASED_NAME like "nfs@serverhostname" */
448
449 if (memcmp(p, "nfs@", 4) != 0)
Andy Adamson778be232011-01-25 15:38:01 +0000450 return 0;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500451 p += 4;
Trond Myklebust4e0038b2012-03-01 17:01:05 -0500452 if (strcmp(p, clp->cl_hostname) != 0)
Andy Adamson778be232011-01-25 15:38:01 +0000453 return 0;
454 return 1;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500455}
456
Andy Adamson778be232011-01-25 15:38:01 +0000457/*
458 * pg_authenticate method for nfsv4 callback threads.
459 *
460 * The authflavor has been negotiated, so an incorrect flavor is a server
461 * bug. Drop packets with incorrect authflavor.
462 *
463 * All other checking done after NFS decoding where the nfs_client can be
464 * found in nfs4_callback_compound
465 */
Linus Torvalds1da177e2005-04-16 15:20:36 -0700466static int nfs_callback_authenticate(struct svc_rqst *rqstp)
467{
Linus Torvalds1da177e2005-04-16 15:20:36 -0700468 switch (rqstp->rq_authop->flavour) {
Andy Adamson778be232011-01-25 15:38:01 +0000469 case RPC_AUTH_NULL:
470 if (rqstp->rq_proc != CB_NULL)
471 return SVC_DROP;
472 break;
473 case RPC_AUTH_GSS:
474 /* No RPC_AUTH_GSS support yet in NFSv4.1 */
475 if (svc_is_backchannel(rqstp))
476 return SVC_DROP;
Linus Torvalds1da177e2005-04-16 15:20:36 -0700477 }
Andy Adamson778be232011-01-25 15:38:01 +0000478 return SVC_OK;
Linus Torvalds1da177e2005-04-16 15:20:36 -0700479}
480
481/*
482 * Define NFS4 callback program
483 */
Linus Torvalds1da177e2005-04-16 15:20:36 -0700484static struct svc_version *nfs4_callback_version[] = {
485 [1] = &nfs4_callback_version1,
Alexandros Batsakis07bccc22009-12-05 13:19:01 -0500486 [4] = &nfs4_callback_version4,
Linus Torvalds1da177e2005-04-16 15:20:36 -0700487};
488
489static struct svc_stat nfs4_callback_stats;
490
491static struct svc_program nfs4_callback_program = {
492 .pg_prog = NFS4_CALLBACK, /* RPC service number */
493 .pg_nvers = ARRAY_SIZE(nfs4_callback_version), /* Number of entries */
494 .pg_vers = nfs4_callback_version, /* version table */
495 .pg_name = "NFSv4 callback", /* service name */
496 .pg_class = "nfs", /* authentication class */
497 .pg_stats = &nfs4_callback_stats,
498 .pg_authenticate = nfs_callback_authenticate,
499};