blob: cff089a412c7f4bde3bd2f1d5138a4679535b772 [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 }
Andy Adamson01c9a0b2011-01-06 02:04:28 +0000167 dprintk("--> %s return %ld\n", __func__,
168 IS_ERR(rqstp) ? PTR_ERR(rqstp) : 0);
Benny Halevy8f975242009-04-01 09:23:11 -0400169 return rqstp;
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400170}
171
Trond Myklebust758201e2012-10-01 16:33:18 -0700172static void nfs_minorversion_callback_svc_setup(struct svc_serv *serv,
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400173 struct svc_rqst **rqstpp, int (**callback_svc)(void *vrqstp))
174{
Trond Myklebust758201e2012-10-01 16:33:18 -0700175 *rqstpp = nfs41_callback_up(serv);
176 *callback_svc = nfs41_callback_svc;
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400177}
178
179static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt,
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400180 struct svc_serv *serv)
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400181{
182 if (minorversion)
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400183 /*
184 * Save the svc_serv in the transport so that it can
185 * be referenced when the session backchannel is initialized
186 */
187 xprt->bc_serv = serv;
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400188}
189#else
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400190static int nfs41_callback_up_net(struct svc_serv *serv, struct net *net)
191{
192 return 0;
193}
194
Trond Myklebust758201e2012-10-01 16:33:18 -0700195static void nfs_minorversion_callback_svc_setup(struct svc_serv *serv,
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400196 struct svc_rqst **rqstpp, int (**callback_svc)(void *vrqstp))
197{
Trond Myklebust758201e2012-10-01 16:33:18 -0700198 *rqstpp = ERR_PTR(-ENOTSUPP);
199 *callback_svc = ERR_PTR(-ENOTSUPP);
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400200}
201
202static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt,
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400203 struct svc_serv *serv)
Ricardo Labiagaa43cde92009-04-01 09:23:08 -0400204{
205}
206#endif /* CONFIG_NFS_V4_1 */
207
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400208static 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;
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
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;
Trond Myklebuste9b7e912012-10-16 12:30:44 -0400247 return ret;
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400248 }
249 dprintk("nfs_callback_up: service started\n");
250 return 0;
251}
252
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400253static 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
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400264static int nfs_callback_up_net(int minorversion, struct svc_serv *serv, struct net *net)
265{
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400266 struct nfs_net *nn = net_generic(net, nfs_net_id);
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400267 int ret;
268
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400269 if (nn->cb_users[minorversion]++)
270 return 0;
271
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400272 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:
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400303 dprintk("NFS: Couldn't create callback socket: err = %d; "
304 "net = %p\n", ret, net);
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400305 return ret;
306}
307
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400308static 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 * Check whether we're already up and running.
315 */
316 if (cb_info->task) {
317 /*
318 * Note: increase service usage, because later in case of error
319 * svc_destroy() will be called.
320 */
321 svc_get(cb_info->serv);
322 return cb_info->serv;
323 }
324
325 /*
326 * Sanity check: if there's no task,
327 * we should be the first user ...
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 /* As there is only one thread we need to over-ride the
339 * default maximum of 80 connections
340 */
341 serv->sv_maxconn = 1024;
342 dprintk("nfs_callback_create_svc: service created\n");
343 return serv;
344}
345
Benny Halevy71468512009-04-01 09:22:56 -0400346/*
347 * Bring up the callback thread if it is not already up.
348 */
349int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt)
350{
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400351 struct svc_serv *serv;
Andy Adamsone82dc222009-04-01 09:23:14 -0400352 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400353 int ret;
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400354 struct net *net = xprt->xprt_net;
Benny Halevy71468512009-04-01 09:22:56 -0400355
356 mutex_lock(&nfs_callback_mutex);
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400357
358 serv = nfs_callback_create_svc(minorversion);
359 if (IS_ERR(serv)) {
360 ret = PTR_ERR(serv);
361 goto err_create;
362 }
363
Stanislav Kinsburskyc9465562012-08-20 18:00:16 +0400364 ret = nfs_callback_up_net(minorversion, serv, net);
365 if (ret < 0)
366 goto err_net;
Stanislav Kinsbursky9793f7c2012-05-02 16:08:38 +0400367
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400368 ret = nfs_callback_start_svc(minorversion, xprt, serv);
369 if (ret < 0)
370 goto err_start;
Stanislav Kinsbursky691c4572012-08-20 18:00:21 +0400371
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400372 cb_info->users++;
Jeff Layton8e600292008-02-11 10:00:20 -0500373 /*
374 * svc_create creates the svc_serv with sv_nrthreads == 1, and then
Jeff Laytona277e332008-02-20 08:55:30 -0500375 * svc_prepare_thread increments that. So we need to call svc_destroy
Jeff Layton8e600292008-02-11 10:00:20 -0500376 * on both success and failure so that the refcount is 1 when the
377 * thread exits.
378 */
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400379err_net:
Stanislav Kinsburskydd018422012-08-20 18:00:11 +0400380 svc_destroy(serv);
381err_create:
Ingo Molnar353ab6e2006-03-26 01:37:12 -0800382 mutex_unlock(&nfs_callback_mutex);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700383 return ret;
Stanislav Kinsbursky8e246142012-08-20 18:00:26 +0400384
385err_start:
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400386 nfs_callback_down_net(minorversion, serv, net);
Stanislav Kinsbursky23c20ec2012-08-20 18:00:31 +0400387 dprintk("NFS: Couldn't create server thread; err = %d\n", ret);
388 goto err_net;
Linus Torvalds1da177e2005-04-16 15:20:36 -0700389}
390
391/*
Jeff Layton5afc5972008-06-11 10:03:11 -0400392 * Kill the callback thread if it's no longer being used.
Linus Torvalds1da177e2005-04-16 15:20:36 -0700393 */
Stanislav Kinsburskyc8ceb412012-08-20 18:00:06 +0400394void nfs_callback_down(int minorversion, struct net *net)
Linus Torvalds1da177e2005-04-16 15:20:36 -0700395{
Andy Adamsone82dc222009-04-01 09:23:14 -0400396 struct nfs_callback_data *cb_info = &nfs_callback_info[minorversion];
397
Ingo Molnar353ab6e2006-03-26 01:37:12 -0800398 mutex_lock(&nfs_callback_mutex);
Stanislav Kinsburskyb3d19c52012-08-20 18:00:46 +0400399 nfs_callback_down_net(minorversion, cb_info->serv, net);
Andy Adamsone82dc222009-04-01 09:23:14 -0400400 cb_info->users--;
401 if (cb_info->users == 0 && cb_info->task != NULL) {
402 kthread_stop(cb_info->task);
Stanislav Kinsbursky1dc42e02012-08-20 18:00:51 +0400403 dprintk("nfs_callback_down: service stopped\n");
Andy Adamsone82dc222009-04-01 09:23:14 -0400404 svc_exit_thread(cb_info->rqst);
Stanislav Kinsbursky1dc42e02012-08-20 18:00:51 +0400405 dprintk("nfs_callback_down: service destroyed\n");
Andy Adamsone82dc222009-04-01 09:23:14 -0400406 cb_info->serv = NULL;
407 cb_info->rqst = NULL;
408 cb_info->task = NULL;
Jeff Layton5afc5972008-06-11 10:03:11 -0400409 }
Ingo Molnar353ab6e2006-03-26 01:37:12 -0800410 mutex_unlock(&nfs_callback_mutex);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700411}
412
Andy Adamson778be232011-01-25 15:38:01 +0000413/* Boolean check of RPC_AUTH_GSS principal */
414int
415check_gss_callback_principal(struct nfs_client *clp, struct svc_rqst *rqstp)
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500416{
J. Bruce Fields03a4e1f2012-05-14 19:55:22 -0400417 char *p = rqstp->rq_cred.cr_principal;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500418
Andy Adamson778be232011-01-25 15:38:01 +0000419 if (rqstp->rq_authop->flavour != RPC_AUTH_GSS)
420 return 1;
421
Andy Adamsonece0de62011-01-06 02:04:33 +0000422 /* No RPC_AUTH_GSS on NFSv4.1 back channel yet */
423 if (clp->cl_minorversion != 0)
Andy Adamson778be232011-01-25 15:38:01 +0000424 return 0;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500425 /*
426 * It might just be a normal user principal, in which case
427 * userspace won't bother to tell us the name at all.
428 */
429 if (p == NULL)
Andy Adamson778be232011-01-25 15:38:01 +0000430 return 0;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500431
432 /* Expect a GSS_C_NT_HOSTBASED_NAME like "nfs@serverhostname" */
433
434 if (memcmp(p, "nfs@", 4) != 0)
Andy Adamson778be232011-01-25 15:38:01 +0000435 return 0;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500436 p += 4;
Trond Myklebust4e0038b2012-03-01 17:01:05 -0500437 if (strcmp(p, clp->cl_hostname) != 0)
Andy Adamson778be232011-01-25 15:38:01 +0000438 return 0;
439 return 1;
Olga Kornievskaia945b34a2008-12-23 16:18:34 -0500440}
441
Andy Adamson778be232011-01-25 15:38:01 +0000442/*
443 * pg_authenticate method for nfsv4 callback threads.
444 *
445 * The authflavor has been negotiated, so an incorrect flavor is a server
446 * bug. Drop packets with incorrect authflavor.
447 *
448 * All other checking done after NFS decoding where the nfs_client can be
449 * found in nfs4_callback_compound
450 */
Linus Torvalds1da177e2005-04-16 15:20:36 -0700451static int nfs_callback_authenticate(struct svc_rqst *rqstp)
452{
Linus Torvalds1da177e2005-04-16 15:20:36 -0700453 switch (rqstp->rq_authop->flavour) {
Andy Adamson778be232011-01-25 15:38:01 +0000454 case RPC_AUTH_NULL:
455 if (rqstp->rq_proc != CB_NULL)
456 return SVC_DROP;
457 break;
458 case RPC_AUTH_GSS:
459 /* No RPC_AUTH_GSS support yet in NFSv4.1 */
460 if (svc_is_backchannel(rqstp))
461 return SVC_DROP;
Linus Torvalds1da177e2005-04-16 15:20:36 -0700462 }
Andy Adamson778be232011-01-25 15:38:01 +0000463 return SVC_OK;
Linus Torvalds1da177e2005-04-16 15:20:36 -0700464}
465
466/*
467 * Define NFS4 callback program
468 */
Linus Torvalds1da177e2005-04-16 15:20:36 -0700469static struct svc_version *nfs4_callback_version[] = {
470 [1] = &nfs4_callback_version1,
Alexandros Batsakis07bccc22009-12-05 13:19:01 -0500471 [4] = &nfs4_callback_version4,
Linus Torvalds1da177e2005-04-16 15:20:36 -0700472};
473
474static struct svc_stat nfs4_callback_stats;
475
476static struct svc_program nfs4_callback_program = {
477 .pg_prog = NFS4_CALLBACK, /* RPC service number */
478 .pg_nvers = ARRAY_SIZE(nfs4_callback_version), /* Number of entries */
479 .pg_vers = nfs4_callback_version, /* version table */
480 .pg_name = "NFSv4 callback", /* service name */
481 .pg_class = "nfs", /* authentication class */
482 .pg_stats = &nfs4_callback_stats,
483 .pg_authenticate = nfs_callback_authenticate,
484};