blob: 54de482143cc0708638e12bde9fbbfbd66d59224 [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
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400131 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 }
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400148 return 0;
149}
150
151/*
152 * Bring up the NFSv4.1 callback service
153 */
Trond Myklebust17280172012-03-11 13:11:00 -0400154static struct svc_rqst *
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400155nfs41_callback_up(struct svc_serv *serv)
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400156{
Andy Adamson01c9a0b2011-01-06 02:04:28 +0000157 struct svc_rqst *rqstp;
Benny Halevy8f975242009-04-01 09:23:11 -0400158
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400159 INIT_LIST_HEAD(&serv->sv_cb_list);
160 spin_lock_init(&serv->sv_cb_lock);
161 init_waitqueue_head(&serv->sv_cb_waitq);
Eric Dumazet11fd1652011-07-28 20:04:09 +0200162 rqstp = svc_prepare_thread(serv, &serv->sv_pools[0], NUMA_NO_NODE);
Andy Adamson01c9a0b2011-01-06 02:04:28 +0000163 if (IS_ERR(rqstp)) {
Andy Adamson4a19de02011-01-06 02:04:35 +0000164 svc_xprt_put(serv->sv_bc_xprt);
165 serv->sv_bc_xprt = NULL;
Andy Adamson01c9a0b2011-01-06 02:04:28 +0000166 }
Geyslan G. Bem54bcfa62013-10-14 17:24:15 -0300167 dprintk("--> %s return %d\n", __func__, PTR_ERR_OR_ZERO(rqstp));
Benny Halevy8f975242009-04-01 09:23:11 -0400168 return rqstp;
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400169}
170
Trond Myklebust758201e2012-10-01 16:33:18 -0700171static void nfs_minorversion_callback_svc_setup(struct svc_serv *serv,
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400172 struct svc_rqst **rqstpp, int (**callback_svc)(void *vrqstp))
173{
Trond Myklebust758201e2012-10-01 16:33:18 -0700174 *rqstpp = nfs41_callback_up(serv);
175 *callback_svc = nfs41_callback_svc;
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400176}
177
178static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt,
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400179 struct svc_serv *serv)
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400180{
181 if (minorversion)
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400182 /*
183 * Save the svc_serv in the transport so that it can
184 * be referenced when the session backchannel is initialized
185 */
186 xprt->bc_serv = serv;
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400187}
188#else
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400189static int nfs41_callback_up_net(struct svc_serv *serv, struct net *net)
190{
191 return 0;
192}
193
Trond Myklebust758201e2012-10-01 16:33:18 -0700194static void nfs_minorversion_callback_svc_setup(struct svc_serv *serv,
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400195 struct svc_rqst **rqstpp, int (**callback_svc)(void *vrqstp))
196{
Trond Myklebust758201e2012-10-01 16:33:18 -0700197 *rqstpp = ERR_PTR(-ENOTSUPP);
198 *callback_svc = ERR_PTR(-ENOTSUPP);
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400199}
200
201static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt,
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400202 struct svc_serv *serv)
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400203{
204}
205#endif /* CONFIG_NFS_V4_1 */
206
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400207static int nfs_callback_start_svc(int minorversion, struct rpc_xprt *xprt,
208 struct svc_serv *serv)
209{
210 struct svc_rqst *rqstp;
211 int (*callback_svc)(void *vrqstp);
212 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400213 int ret;
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400214
215 nfs_callback_bc_serv(minorversion, xprt, serv);
216
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400217 if (cb_info->task)
218 return 0;
219
Trond Myklebust758201e2012-10-01 16:33:18 -0700220 switch (minorversion) {
221 case 0:
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400222 /* v4.0 callback setup */
223 rqstp = nfs4_callback_up(serv);
224 callback_svc = nfs4_callback_svc;
Trond Myklebust758201e2012-10-01 16:33:18 -0700225 break;
226 default:
227 nfs_minorversion_callback_svc_setup(serv,
228 &rqstp, &callback_svc);
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400229 }
230
231 if (IS_ERR(rqstp))
232 return PTR_ERR(rqstp);
233
234 svc_sock_update_bufs(serv);
235
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400236 cb_info->serv = serv;
237 cb_info->rqst = rqstp;
Kees Cookf1701682013-07-03 15:04:58 -0700238 cb_info->task = kthread_run(callback_svc, cb_info->rqst,
239 "nfsv4.%u-svc", minorversion);
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400240 if (IS_ERR(cb_info->task)) {
241 ret = PTR_ERR(cb_info->task);
242 svc_exit_thread(cb_info->rqst);
243 cb_info->rqst = NULL;
244 cb_info->task = NULL;
Trond Myklebuste9b7e912012-10-16 12:30:44 -0400245 return ret;
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400246 }
247 dprintk("nfs_callback_up: service started\n");
248 return 0;
249}
250
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400251static void nfs_callback_down_net(u32 minorversion, struct svc_serv *serv, struct net *net)
252{
253 struct nfs_net *nn = net_generic(net, nfs_net_id);
254
255 if (--nn->cb_users[minorversion])
256 return;
257
258 dprintk("NFS: destroy per-net callback data; net=%p\n", net);
259 svc_shutdown_net(serv, net);
260}
261
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400262static int nfs_callback_up_net(int minorversion, struct svc_serv *serv, struct net *net)
263{
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400264 struct nfs_net *nn = net_generic(net, nfs_net_id);
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400265 int ret;
266
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400267 if (nn->cb_users[minorversion]++)
268 return 0;
269
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400270 dprintk("NFS: create per-net callback data; net=%p\n", net);
271
272 ret = svc_bind(serv, net);
273 if (ret < 0) {
274 printk(KERN_WARNING "NFS: bind callback service failed\n");
275 goto err_bind;
276 }
277
278 switch (minorversion) {
279 case 0:
280 ret = nfs4_callback_up_net(serv, net);
281 break;
282 case 1:
Steve Dickson42c2c422013-05-22 12:50:38 -0400283 case 2:
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400284 ret = nfs41_callback_up_net(serv, net);
285 break;
286 default:
287 printk(KERN_ERR "NFS: unknown callback version: %d\n",
288 minorversion);
289 ret = -EINVAL;
290 break;
291 }
292
293 if (ret < 0) {
294 printk(KERN_ERR "NFS: callback service start failed\n");
295 goto err_socks;
296 }
297 return 0;
298
299err_socks:
300 svc_rpcb_cleanup(serv, net);
301err_bind:
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400302 dprintk("NFS: Couldn't create callback socket: err = %d; "
303 "net = %p\n", ret, net);
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400304 return ret;
305}
306
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400307static struct svc_serv *nfs_callback_create_svc(int minorversion)
308{
309 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
310 struct svc_serv *serv;
311
312 /*
313 * Check whether we're already up and running.
314 */
315 if (cb_info->task) {
316 /*
317 * Note: increase service usage, because later in case of error
318 * svc_destroy() will be called.
319 */
320 svc_get(cb_info->serv);
321 return cb_info->serv;
322 }
323
324 /*
325 * Sanity check: if there's no task,
326 * we should be the first user ...
327 */
328 if (cb_info->users)
329 printk(KERN_WARNING "nfs_callback_create_svc: no kthread, %d users??\n",
330 cb_info->users);
331
332 serv = svc_create(&nfs4_callback_program, NFS4_CALLBACK_BUFSIZE, NULL);
333 if (!serv) {
334 printk(KERN_ERR "nfs_callback_create_svc: create service failed\n");
335 return ERR_PTR(-ENOMEM);
336 }
337 /* As there is only one thread we need to over-ride the
338 * default maximum of 80 connections
339 */
340 serv->sv_maxconn = 1024;
341 dprintk("nfs_callback_create_svc: service created\n");
342 return serv;
343}
344
Benny Halevy71468512009-04-01 09:22:56 -0400345/*
346 * Bring up the callback thread if it is not already up.
347 */
348int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt)
349{
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400350 struct svc_serv *serv;
Andy Adamsone82dc222009-04-01 09:23:14 -0400351 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400352 int ret;
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400353 struct net *net = xprt->xprt_net;
Benny Halevy71468512009-04-01 09:22:56 -0400354
355 mutex_lock(&nfs_callback_mutex);
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400356
357 serv = nfs_callback_create_svc(minorversion);
358 if (IS_ERR(serv)) {
359 ret = PTR_ERR(serv);
360 goto err_create;
361 }
362
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400363 ret = nfs_callback_up_net(minorversion, serv, net);
364 if (ret < 0)
365 goto err_net;
Stanislav Kinsbursky9793f7c2012-05-02 16:08:38 +0400366
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400367 ret = nfs_callback_start_svc(minorversion, xprt, serv);
368 if (ret < 0)
369 goto err_start;
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400370
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400371 cb_info->users++;
Jeff Layton8e600292008-02-11 10:00:20 -0500372 /*
373 * svc_create creates the svc_serv with sv_nrthreads == 1, and then
Jeff Laytona277e332008-02-20 08:55:30 -0500374 * svc_prepare_thread increments that. So we need to call svc_destroy
Jeff Layton8e600292008-02-11 10:00:20 -0500375 * on both success and failure so that the refcount is 1 when the
376 * thread exits.
377 */
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400378err_net:
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400379 svc_destroy(serv);
380err_create:
Ingo Molnar353ab6e2006-03-26 01:37:12 -0800381 mutex_unlock(&nfs_callback_mutex);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700382 return ret;
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400383
384err_start:
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400385 nfs_callback_down_net(minorversion, serv, net);
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400386 dprintk("NFS: Couldn't create server thread; err = %d\n", ret);
387 goto err_net;
Linus Torvalds1da177e2005-04-16 15:20:36 -0700388}
389
390/*
Jeff Layton5afc5972008-06-11 10:03:11 -0400391 * Kill the callback thread if it's no longer being used.
Linus Torvalds1da177e2005-04-16 15:20:36 -0700392 */
Stanislav Kinsburskyc8ceb412012-08-20 18:00:06 +0400393void nfs_callback_down(int minorversion, struct net *net)
Linus Torvalds1da177e2005-04-16 15:20:36 -0700394{
Andy Adamsone82dc222009-04-01 09:23:14 -0400395 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
396
Ingo Molnar353ab6e2006-03-26 01:37:12 -0800397 mutex_lock(&nfs_callback_mutex);
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400398 nfs_callback_down_net(minorversion, cb_info->serv, net);
Andy Adamsone82dc222009-04-01 09:23:14 -0400399 cb_info->users--;
400 if (cb_info->users == 0 && cb_info->task != NULL) {
401 kthread_stop(cb_info->task);
Stanislav Kinsbursky1dc42e02012-08-20 18:00:51 +0400402 dprintk("nfs_callback_down: service stopped\n");
Andy Adamsone82dc222009-04-01 09:23:14 -0400403 svc_exit_thread(cb_info->rqst);
Stanislav Kinsbursky1dc42e02012-08-20 18:00:51 +0400404 dprintk("nfs_callback_down: service destroyed\n");
Andy Adamsone82dc222009-04-01 09:23:14 -0400405 cb_info->serv = NULL;
406 cb_info->rqst = NULL;
407 cb_info->task = NULL;
Jeff Layton5afc5972008-06-11 10:03:11 -0400408 }
Ingo Molnar353ab6e2006-03-26 01:37:12 -0800409 mutex_unlock(&nfs_callback_mutex);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700410}
411
Andy Adamson778be232011-01-25 15:38:01 +0000412/* Boolean check of RPC_AUTH_GSS principal */
413int
414check_gss_callback_principal(struct nfs_client *clp, struct svc_rqst *rqstp)
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500415{
J. Bruce Fields03a4e1f2012-05-14 19:55:22 -0400416 char *p = rqstp->rq_cred.cr_principal;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500417
Andy Adamson778be232011-01-25 15:38:01 +0000418 if (rqstp->rq_authop->flavour != RPC_AUTH_GSS)
419 return 1;
420
Andy Adamsonece0de62011-01-06 02:04:33 +0000421 /* No RPC_AUTH_GSS on NFSv4.1 back channel yet */
422 if (clp->cl_minorversion != 0)
Andy Adamson778be232011-01-25 15:38:01 +0000423 return 0;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500424 /*
425 * It might just be a normal user principal, in which case
426 * userspace won't bother to tell us the name at all.
427 */
428 if (p == NULL)
Andy Adamson778be232011-01-25 15:38:01 +0000429 return 0;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500430
Jeff Laytonf11b2a12014-06-21 20:52:17 -0400431 /*
432 * Did we get the acceptor from userland during the SETCLIENID
433 * negotiation?
434 */
435 if (clp->cl_acceptor)
436 return !strcmp(p, clp->cl_acceptor);
437
438 /*
439 * Otherwise try to verify it using the cl_hostname. Note that this
440 * doesn't work if a non-canonical hostname was used in the devname.
441 */
442
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500443 /* Expect a GSS_C_NT_HOSTBASED_NAME like "nfs@serverhostname" */
444
445 if (memcmp(p, "nfs@", 4) != 0)
Andy Adamson778be232011-01-25 15:38:01 +0000446 return 0;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500447 p += 4;
Trond Myklebust4e0038b2012-03-01 17:01:05 -0500448 if (strcmp(p, clp->cl_hostname) != 0)
Andy Adamson778be232011-01-25 15:38:01 +0000449 return 0;
450 return 1;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500451}
452
Andy Adamson778be232011-01-25 15:38:01 +0000453/*
454 * pg_authenticate method for nfsv4 callback threads.
455 *
456 * The authflavor has been negotiated, so an incorrect flavor is a server
457 * bug. Drop packets with incorrect authflavor.
458 *
459 * All other checking done after NFS decoding where the nfs_client can be
460 * found in nfs4_callback_compound
461 */
Linus Torvalds1da177e2005-04-16 15:20:36 -0700462static int nfs_callback_authenticate(struct svc_rqst *rqstp)
463{
Linus Torvalds1da177e2005-04-16 15:20:36 -0700464 switch (rqstp->rq_authop->flavour) {
Andy Adamson778be232011-01-25 15:38:01 +0000465 case RPC_AUTH_NULL:
466 if (rqstp->rq_proc != CB_NULL)
467 return SVC_DROP;
468 break;
469 case RPC_AUTH_GSS:
470 /* No RPC_AUTH_GSS support yet in NFSv4.1 */
471 if (svc_is_backchannel(rqstp))
472 return SVC_DROP;
Linus Torvalds1da177e2005-04-16 15:20:36 -0700473 }
Andy Adamson778be232011-01-25 15:38:01 +0000474 return SVC_OK;
Linus Torvalds1da177e2005-04-16 15:20:36 -0700475}
476
477/*
478 * Define NFS4 callback program
479 */
Linus Torvalds1da177e2005-04-16 15:20:36 -0700480static struct svc_version *nfs4_callback_version[] = {
481 [1] = &nfs4_callback_version1,
Alexandros Batsakis07bccc22009-12-05 13:19:01 -0500482 [4] = &nfs4_callback_version4,
Linus Torvalds1da177e2005-04-16 15:20:36 -0700483};
484
485static struct svc_stat nfs4_callback_stats;
486
487static struct svc_program nfs4_callback_program = {
488 .pg_prog = NFS4_CALLBACK, /* RPC service number */
489 .pg_nvers = ARRAY_SIZE(nfs4_callback_version), /* Number of entries */
490 .pg_vers = nfs4_callback_version, /* version table */
491 .pg_name = "NFSv4 callback", /* service name */
492 .pg_class = "nfs", /* authentication class */
493 .pg_stats = &nfs4_callback_stats,
494 .pg_authenticate = nfs_callback_authenticate,
495};