delegation.c 21.4 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4 5 6 7 8 9
/*
 * linux/fs/nfs/delegation.c
 *
 * Copyright (C) 2004 Trond Myklebust
 *
 * NFS file delegation management
 *
 */
#include <linux/completion.h>
10
#include <linux/kthread.h>
L
Linus Torvalds 已提交
11 12
#include <linux/module.h>
#include <linux/sched.h>
13
#include <linux/slab.h>
L
Linus Torvalds 已提交
14 15 16 17 18 19
#include <linux/spinlock.h>

#include <linux/nfs4.h>
#include <linux/nfs_fs.h>
#include <linux/nfs_xdr.h>

20
#include "nfs4_fs.h"
L
Linus Torvalds 已提交
21
#include "delegation.h"
22
#include "internal.h"
L
Linus Torvalds 已提交
23

24 25
static void nfs_free_delegation(struct nfs_delegation *delegation)
{
26 27 28 29
	if (delegation->cred) {
		put_rpccred(delegation->cred);
		delegation->cred = NULL;
	}
30
	kfree_rcu(delegation, rcu);
31 32
}

33 34 35 36 37
/**
 * nfs_mark_delegation_referenced - set delegation's REFERENCED flag
 * @delegation: delegation to process
 *
 */
38 39 40 41 42
void nfs_mark_delegation_referenced(struct nfs_delegation *delegation)
{
	set_bit(NFS_DELEGATION_REFERENCED, &delegation->flags);
}

43 44 45 46 47 48 49
/**
 * nfs_have_delegation - check if inode has a delegation
 * @inode: inode to check
 * @flags: delegation types to check for
 *
 * Returns one if inode has the indicated delegation, otherwise zero.
 */
50
int nfs4_have_delegation(struct inode *inode, fmode_t flags)
51 52 53 54 55 56 57
{
	struct nfs_delegation *delegation;
	int ret = 0;

	flags &= FMODE_READ|FMODE_WRITE;
	rcu_read_lock();
	delegation = rcu_dereference(NFS_I(inode)->delegation);
58 59
	if (delegation != NULL && (delegation->type & flags) == flags &&
	    !test_bit(NFS_DELEGATION_RETURNING, &delegation->flags)) {
60 61 62 63 64 65 66
		nfs_mark_delegation_referenced(delegation);
		ret = 1;
	}
	rcu_read_unlock();
	return ret;
}

67
static int nfs_delegation_claim_locks(struct nfs_open_context *ctx, struct nfs4_state *state, const nfs4_stateid *stateid)
68 69 70
{
	struct inode *inode = state->inode;
	struct file_lock *fl;
71
	int status = 0;
72

73 74
	if (inode->i_flock == NULL)
		goto out;
75

76 77
	/* Protect inode->i_flock using the i_lock */
	spin_lock(&inode->i_lock);
H
Harvey Harrison 已提交
78
	for (fl = inode->i_flock; fl != NULL; fl = fl->fl_next) {
79 80
		if (!(fl->fl_flags & (FL_POSIX|FL_FLOCK)))
			continue;
81
		if (nfs_file_open_context(fl->fl_file) != ctx)
82
			continue;
83
		spin_unlock(&inode->i_lock);
84
		status = nfs4_lock_delegation_recall(fl, state, stateid);
85
		if (status < 0)
86
			goto out;
87
		spin_lock(&inode->i_lock);
88
	}
89
	spin_unlock(&inode->i_lock);
90
out:
91 92 93
	return status;
}

94
static int nfs_delegation_claim_opens(struct inode *inode, const nfs4_stateid *stateid)
L
Linus Torvalds 已提交
95 96 97
{
	struct nfs_inode *nfsi = NFS_I(inode);
	struct nfs_open_context *ctx;
98
	struct nfs4_state_owner *sp;
L
Linus Torvalds 已提交
99
	struct nfs4_state *state;
100
	unsigned int seq;
101
	int err;
L
Linus Torvalds 已提交
102 103 104 105 106 107 108 109 110

again:
	spin_lock(&inode->i_lock);
	list_for_each_entry(ctx, &nfsi->open_files, list) {
		state = ctx->state;
		if (state == NULL)
			continue;
		if (!test_bit(NFS_DELEGATED_STATE, &state->flags))
			continue;
111
		if (!nfs4_stateid_match(&state->stateid, stateid))
112
			continue;
L
Linus Torvalds 已提交
113 114
		get_nfs_open_context(ctx);
		spin_unlock(&inode->i_lock);
115
		sp = state->owner;
116 117
		/* Block nfs4_proc_unlck */
		mutex_lock(&sp->so_delegreturn_mutex);
118
		seq = raw_seqcount_begin(&sp->so_reclaim_seqcount);
119
		err = nfs4_open_delegation_recall(ctx, state, stateid);
120
		if (!err)
121
			err = nfs_delegation_claim_locks(ctx, state, stateid);
122 123
		if (!err && read_seqcount_retry(&sp->so_reclaim_seqcount, seq))
			err = -EAGAIN;
124
		mutex_unlock(&sp->so_delegreturn_mutex);
L
Linus Torvalds 已提交
125
		put_nfs_open_context(ctx);
126
		if (err != 0)
127
			return err;
L
Linus Torvalds 已提交
128 129 130
		goto again;
	}
	spin_unlock(&inode->i_lock);
131
	return 0;
L
Linus Torvalds 已提交
132 133
}

134 135 136 137 138 139
/**
 * nfs_inode_reclaim_delegation - process a delegation reclaim request
 * @inode: inode to process
 * @cred: credential to use for request
 * @res: new delegation state from server
 *
L
Linus Torvalds 已提交
140
 */
141 142
void nfs_inode_reclaim_delegation(struct inode *inode, struct rpc_cred *cred,
				  struct nfs_openres *res)
L
Linus Torvalds 已提交
143
{
144 145
	struct nfs_delegation *delegation;
	struct rpc_cred *oldcred = NULL;
L
Linus Torvalds 已提交
146

147 148 149 150 151
	rcu_read_lock();
	delegation = rcu_dereference(NFS_I(inode)->delegation);
	if (delegation != NULL) {
		spin_lock(&delegation->lock);
		if (delegation->inode != NULL) {
152
			nfs4_stateid_copy(&delegation->stateid, &res->delegation);
153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171
			delegation->type = res->delegation_type;
			delegation->maxsize = res->maxsize;
			oldcred = delegation->cred;
			delegation->cred = get_rpccred(cred);
			clear_bit(NFS_DELEGATION_NEED_RECLAIM,
				  &delegation->flags);
			NFS_I(inode)->delegation_state = delegation->type;
			spin_unlock(&delegation->lock);
			put_rpccred(oldcred);
			rcu_read_unlock();
		} else {
			/* We appear to have raced with a delegation return. */
			spin_unlock(&delegation->lock);
			rcu_read_unlock();
			nfs_inode_set_delegation(inode, cred, res);
		}
	} else {
		rcu_read_unlock();
	}
L
Linus Torvalds 已提交
172 173
}

174 175 176 177 178 179 180 181 182
static int nfs_do_return_delegation(struct inode *inode, struct nfs_delegation *delegation, int issync)
{
	int res = 0;

	res = nfs4_proc_delegreturn(inode, delegation->cred, &delegation->stateid, issync);
	nfs_free_delegation(delegation);
	return res;
}

183 184 185 186 187 188 189 190 191 192 193
static struct inode *nfs_delegation_grab_inode(struct nfs_delegation *delegation)
{
	struct inode *inode = NULL;

	spin_lock(&delegation->lock);
	if (delegation->inode != NULL)
		inode = igrab(delegation->inode);
	spin_unlock(&delegation->lock);
	return inode;
}

194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232
static struct nfs_delegation *
nfs_start_delegation_return_locked(struct nfs_inode *nfsi)
{
	struct nfs_delegation *ret = NULL;
	struct nfs_delegation *delegation = rcu_dereference(nfsi->delegation);

	if (delegation == NULL)
		goto out;
	spin_lock(&delegation->lock);
	if (!test_and_set_bit(NFS_DELEGATION_RETURNING, &delegation->flags))
		ret = delegation;
	spin_unlock(&delegation->lock);
out:
	return ret;
}

static struct nfs_delegation *
nfs_start_delegation_return(struct nfs_inode *nfsi)
{
	struct nfs_delegation *delegation;

	rcu_read_lock();
	delegation = nfs_start_delegation_return_locked(nfsi);
	rcu_read_unlock();
	return delegation;
}

static void
nfs_abort_delegation_return(struct nfs_delegation *delegation,
		struct nfs_client *clp)
{

	spin_lock(&delegation->lock);
	clear_bit(NFS_DELEGATION_RETURNING, &delegation->flags);
	set_bit(NFS_DELEGATION_RETURN, &delegation->flags);
	spin_unlock(&delegation->lock);
	set_bit(NFS4CLNT_DELEGRETURN, &clp->cl_state);
}

233 234
static struct nfs_delegation *
nfs_detach_delegation_locked(struct nfs_inode *nfsi,
235 236
		struct nfs_delegation *delegation,
		struct nfs_client *clp)
237
{
238
	struct nfs_delegation *deleg_cur =
239
		rcu_dereference_protected(nfsi->delegation,
240
				lockdep_is_held(&clp->cl_lock));
241

242 243
	if (deleg_cur == NULL || delegation != deleg_cur)
		return NULL;
244

245
	spin_lock(&delegation->lock);
246
	set_bit(NFS_DELEGATION_RETURNING, &delegation->flags);
247
	list_del_rcu(&delegation->super_list);
248
	delegation->inode = NULL;
249 250
	nfsi->delegation_state = 0;
	rcu_assign_pointer(nfsi->delegation, NULL);
251
	spin_unlock(&delegation->lock);
252 253 254
	return delegation;
}

255
static struct nfs_delegation *nfs_detach_delegation(struct nfs_inode *nfsi,
256 257
		struct nfs_delegation *delegation,
		struct nfs_server *server)
258
{
259
	struct nfs_client *clp = server->nfs_client;
260 261

	spin_lock(&clp->cl_lock);
262
	delegation = nfs_detach_delegation_locked(nfsi, delegation, clp);
263 264 265 266
	spin_unlock(&clp->cl_lock);
	return delegation;
}

267 268 269 270 271 272 273 274 275 276 277 278 279
static struct nfs_delegation *
nfs_inode_detach_delegation(struct inode *inode)
{
	struct nfs_inode *nfsi = NFS_I(inode);
	struct nfs_server *server = NFS_SERVER(inode);
	struct nfs_delegation *delegation;

	delegation = nfs_start_delegation_return(nfsi);
	if (delegation == NULL)
		return NULL;
	return nfs_detach_delegation(nfsi, delegation, server);
}

280 281 282 283 284 285 286
/**
 * nfs_inode_set_delegation - set up a delegation on an inode
 * @inode: inode to which delegation applies
 * @cred: cred to use for subsequent delegation processing
 * @res: new delegation state from server
 *
 * Returns zero on success, or a negative errno value.
L
Linus Torvalds 已提交
287 288 289
 */
int nfs_inode_set_delegation(struct inode *inode, struct rpc_cred *cred, struct nfs_openres *res)
{
290 291
	struct nfs_server *server = NFS_SERVER(inode);
	struct nfs_client *clp = server->nfs_client;
L
Linus Torvalds 已提交
292
	struct nfs_inode *nfsi = NFS_I(inode);
293
	struct nfs_delegation *delegation, *old_delegation;
294
	struct nfs_delegation *freeme = NULL;
L
Linus Torvalds 已提交
295 296
	int status = 0;

297
	delegation = kmalloc(sizeof(*delegation), GFP_NOFS);
L
Linus Torvalds 已提交
298 299
	if (delegation == NULL)
		return -ENOMEM;
300
	nfs4_stateid_copy(&delegation->stateid, &res->delegation);
L
Linus Torvalds 已提交
301 302
	delegation->type = res->delegation_type;
	delegation->maxsize = res->maxsize;
303
	delegation->change_attr = inode->i_version;
L
Linus Torvalds 已提交
304 305
	delegation->cred = get_rpccred(cred);
	delegation->inode = inode;
306
	delegation->flags = 1<<NFS_DELEGATION_REFERENCED;
307
	spin_lock_init(&delegation->lock);
L
Linus Torvalds 已提交
308 309

	spin_lock(&clp->cl_lock);
310
	old_delegation = rcu_dereference_protected(nfsi->delegation,
311
					lockdep_is_held(&clp->cl_lock));
312
	if (old_delegation != NULL) {
313 314
		if (nfs4_stateid_match(&delegation->stateid,
					&old_delegation->stateid) &&
315
				delegation->type == old_delegation->type) {
316
			goto out;
L
Linus Torvalds 已提交
317
		}
318 319 320
		/*
		 * Deal with broken servers that hand out two
		 * delegations for the same file.
321 322
		 * Allow for upgrades to a WRITE delegation, but
		 * nothing else.
323 324 325
		 */
		dfprintk(FILE, "%s: server %s handed out "
				"a duplicate delegation!\n",
326
				__func__, clp->cl_hostname);
327 328
		if (delegation->type == old_delegation->type ||
		    !(delegation->type & FMODE_WRITE)) {
329 330 331 332
			freeme = delegation;
			delegation = NULL;
			goto out;
		}
333 334 335 336
		freeme = nfs_detach_delegation_locked(nfsi, 
				old_delegation, clp);
		if (freeme == NULL)
			goto out;
L
Linus Torvalds 已提交
337
	}
338
	list_add_rcu(&delegation->super_list, &server->delegations);
339 340 341
	nfsi->delegation_state = delegation->type;
	rcu_assign_pointer(nfsi->delegation, delegation);
	delegation = NULL;
342 343 344 345 346 347

	/* Ensure we revalidate the attributes and page cache! */
	spin_lock(&inode->i_lock);
	nfsi->cache_validity |= NFS_INO_REVAL_FORCED;
	spin_unlock(&inode->i_lock);

348
out:
L
Linus Torvalds 已提交
349
	spin_unlock(&clp->cl_lock);
350 351
	if (delegation != NULL)
		nfs_free_delegation(delegation);
352 353
	if (freeme != NULL)
		nfs_do_return_delegation(inode, freeme, 0);
L
Linus Torvalds 已提交
354 355 356 357 358 359
	return status;
}

/*
 * Basic procedure for returning a delegation to the server
 */
360
static int nfs_end_delegation_return(struct inode *inode, struct nfs_delegation *delegation, int issync)
L
Linus Torvalds 已提交
361
{
362
	struct nfs_client *clp = NFS_SERVER(inode)->nfs_client;
L
Linus Torvalds 已提交
363
	struct nfs_inode *nfsi = NFS_I(inode);
364
	int err;
L
Linus Torvalds 已提交
365

366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382
	if (delegation == NULL)
		return 0;
	do {
		err = nfs_delegation_claim_opens(inode, &delegation->stateid);
		if (!issync || err != -EAGAIN)
			break;
		/*
		 * Guard against state recovery
		 */
		err = nfs4_wait_clnt_recover(clp);
	} while (err == 0);

	if (err) {
		nfs_abort_delegation_return(delegation, clp);
		goto out;
	}
	if (!nfs_detach_delegation(nfsi, delegation, NFS_SERVER(inode)))
383
		goto out;
L
Linus Torvalds 已提交
384

385 386 387
	err = nfs_do_return_delegation(inode, delegation, issync);
out:
	return err;
388 389
}

390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407
static bool nfs_delegation_need_return(struct nfs_delegation *delegation)
{
	bool ret = false;

	if (test_and_clear_bit(NFS_DELEGATION_RETURN, &delegation->flags))
		ret = true;
	if (test_and_clear_bit(NFS_DELEGATION_RETURN_IF_CLOSED, &delegation->flags) && !ret) {
		struct inode *inode;

		spin_lock(&delegation->lock);
		inode = delegation->inode;
		if (inode && list_empty(&NFS_I(inode)->open_files))
			ret = true;
		spin_unlock(&delegation->lock);
	}
	return ret;
}

408 409 410 411
/**
 * nfs_client_return_marked_delegations - return previously marked delegations
 * @clp: nfs_client to process
 *
412 413 414 415
 * Note that this function is designed to be called by the state
 * manager thread. For this reason, it cannot flush the dirty data,
 * since that could deadlock in case of a state recovery error.
 *
416
 * Returns zero on success, or a negative errno value.
417
 */
418
int nfs_client_return_marked_delegations(struct nfs_client *clp)
419 420
{
	struct nfs_delegation *delegation;
421
	struct nfs_server *server;
422
	struct inode *inode;
423
	int err = 0;
424 425 426

restart:
	rcu_read_lock();
427 428 429
	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
		list_for_each_entry_rcu(delegation, &server->delegations,
								super_list) {
430
			if (!nfs_delegation_need_return(delegation))
431 432 433 434
				continue;
			inode = nfs_delegation_grab_inode(delegation);
			if (inode == NULL)
				continue;
435
			delegation = nfs_start_delegation_return_locked(NFS_I(inode));
436 437
			rcu_read_unlock();

438
			err = nfs_end_delegation_return(inode, delegation, 0);
439 440 441 442 443
			iput(inode);
			if (!err)
				goto restart;
			set_bit(NFS4CLNT_DELEGRETURN, &clp->cl_state);
			return err;
444
		}
445 446
	}
	rcu_read_unlock();
447
	return 0;
448 449
}

450 451 452 453 454 455
/**
 * nfs_inode_return_delegation_noreclaim - return delegation, don't reclaim opens
 * @inode: inode to process
 *
 * Does not protect against delegation reclaims, therefore really only safe
 * to be called from nfs4_clear_inode().
456 457 458 459 460
 */
void nfs_inode_return_delegation_noreclaim(struct inode *inode)
{
	struct nfs_delegation *delegation;

461 462 463
	delegation = nfs_inode_detach_delegation(inode);
	if (delegation != NULL)
		nfs_do_return_delegation(inode, delegation, 0);
464 465
}

466 467 468 469
/**
 * nfs_inode_return_delegation - synchronously return a delegation
 * @inode: inode to process
 *
470 471 472 473
 * This routine will always flush any dirty data to disk on the
 * assumption that if we need to return the delegation, then
 * we should stop caching.
 *
474 475
 * Returns zero on success, or a negative errno value.
 */
476
int nfs4_inode_return_delegation(struct inode *inode)
477 478 479 480 481
{
	struct nfs_inode *nfsi = NFS_I(inode);
	struct nfs_delegation *delegation;
	int err = 0;

482
	nfs_wb_all(inode);
483 484 485
	delegation = nfs_start_delegation_return(nfsi);
	if (delegation != NULL)
		err = nfs_end_delegation_return(inode, delegation, 1);
486
	return err;
L
Linus Torvalds 已提交
487 488
}

489 490 491 492 493 494 495
static void nfs_mark_return_if_closed_delegation(struct nfs_server *server,
		struct nfs_delegation *delegation)
{
	set_bit(NFS_DELEGATION_RETURN_IF_CLOSED, &delegation->flags);
	set_bit(NFS4CLNT_DELEGRETURN, &server->nfs_client->cl_state);
}

496 497
static void nfs_mark_return_delegation(struct nfs_server *server,
		struct nfs_delegation *delegation)
498 499
{
	set_bit(NFS_DELEGATION_RETURN, &delegation->flags);
500
	set_bit(NFS4CLNT_DELEGRETURN, &server->nfs_client->cl_state);
501 502
}

503 504 505 506 507 508 509 510 511 512 513 514
static bool nfs_server_mark_return_all_delegations(struct nfs_server *server)
{
	struct nfs_delegation *delegation;
	bool ret = false;

	list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
		nfs_mark_return_delegation(server, delegation);
		ret = true;
	}
	return ret;
}

515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541
static void nfs_client_mark_return_all_delegations(struct nfs_client *clp)
{
	struct nfs_server *server;

	rcu_read_lock();
	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
		nfs_server_mark_return_all_delegations(server);
	rcu_read_unlock();
}

static void nfs_delegation_run_state_manager(struct nfs_client *clp)
{
	if (test_bit(NFS4CLNT_DELEGRETURN, &clp->cl_state))
		nfs4_schedule_state_manager(clp);
}

/**
 * nfs_expire_all_delegations
 * @clp: client to process
 *
 */
void nfs_expire_all_delegations(struct nfs_client *clp)
{
	nfs_client_mark_return_all_delegations(clp);
	nfs_delegation_run_state_manager(clp);
}

542 543 544 545
/**
 * nfs_super_return_all_delegations - return delegations for one superblock
 * @sb: sb to process
 *
L
Linus Torvalds 已提交
546
 */
547
void nfs_server_return_all_delegations(struct nfs_server *server)
L
Linus Torvalds 已提交
548
{
549
	struct nfs_client *clp = server->nfs_client;
550
	bool need_wait;
L
Linus Torvalds 已提交
551 552 553

	if (clp == NULL)
		return;
554

555
	rcu_read_lock();
556
	need_wait = nfs_server_mark_return_all_delegations(server);
557
	rcu_read_unlock();
558

559
	if (need_wait) {
560
		nfs4_schedule_state_manager(clp);
561 562
		nfs4_wait_clnt_recover(clp);
	}
563 564
}

565
static void nfs_mark_return_unused_delegation_types(struct nfs_server *server,
566
						 fmode_t flags)
567 568 569
{
	struct nfs_delegation *delegation;

570
	list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
571 572 573
		if ((delegation->type == (FMODE_READ|FMODE_WRITE)) && !(flags & FMODE_WRITE))
			continue;
		if (delegation->type & flags)
574
			nfs_mark_return_if_closed_delegation(server, delegation);
575
	}
576 577
}

578
static void nfs_client_mark_return_unused_delegation_types(struct nfs_client *clp,
579 580 581 582 583 584
							fmode_t flags)
{
	struct nfs_server *server;

	rcu_read_lock();
	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
585
		nfs_mark_return_unused_delegation_types(server, flags);
586
	rcu_read_unlock();
L
Linus Torvalds 已提交
587 588
}

589 590 591 592
void nfs_remove_bad_delegation(struct inode *inode)
{
	struct nfs_delegation *delegation;

593
	delegation = nfs_inode_detach_delegation(inode);
594 595 596 597 598
	if (delegation) {
		nfs_inode_find_state_and_recover(inode, &delegation->stateid);
		nfs_free_delegation(delegation);
	}
}
A
Andy Adamson 已提交
599
EXPORT_SYMBOL_GPL(nfs_remove_bad_delegation);
600

601
/**
602
 * nfs_expire_unused_delegation_types
603 604 605 606
 * @clp: client to process
 * @flags: delegation types to expire
 *
 */
607
void nfs_expire_unused_delegation_types(struct nfs_client *clp, fmode_t flags)
608
{
609
	nfs_client_mark_return_unused_delegation_types(clp, flags);
610
	nfs_delegation_run_state_manager(clp);
611 612
}

613
static void nfs_mark_return_unreferenced_delegations(struct nfs_server *server)
614 615 616
{
	struct nfs_delegation *delegation;

617
	list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
618 619
		if (test_and_clear_bit(NFS_DELEGATION_REFERENCED, &delegation->flags))
			continue;
620
		nfs_mark_return_if_closed_delegation(server, delegation);
621 622 623
	}
}

624 625 626 627 628
/**
 * nfs_expire_unreferenced_delegations - Eliminate unused delegations
 * @clp: nfs_client to process
 *
 */
629 630
void nfs_expire_unreferenced_delegations(struct nfs_client *clp)
{
631 632 633 634 635 636 637
	struct nfs_server *server;

	rcu_read_lock();
	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
		nfs_mark_return_unreferenced_delegations(server);
	rcu_read_unlock();

638 639 640
	nfs_delegation_run_state_manager(clp);
}

641 642 643
/**
 * nfs_async_inode_return_delegation - asynchronously return a delegation
 * @inode: inode to process
644
 * @stateid: state ID information
645 646
 *
 * Returns zero on success, or a negative errno value.
L
Linus Torvalds 已提交
647
 */
648 649
int nfs_async_inode_return_delegation(struct inode *inode,
				      const nfs4_stateid *stateid)
L
Linus Torvalds 已提交
650
{
651 652
	struct nfs_server *server = NFS_SERVER(inode);
	struct nfs_client *clp = server->nfs_client;
653
	struct nfs_delegation *delegation;
L
Linus Torvalds 已提交
654

655 656
	filemap_flush(inode->i_mapping);

657 658
	rcu_read_lock();
	delegation = rcu_dereference(NFS_I(inode)->delegation);
A
Alexandros Batsakis 已提交
659

660
	if (!clp->cl_mvops->match_stateid(&delegation->stateid, stateid)) {
661 662 663
		rcu_read_unlock();
		return -ENOENT;
	}
664
	nfs_mark_return_delegation(server, delegation);
665
	rcu_read_unlock();
666

667 668
	nfs_delegation_run_state_manager(clp);
	return 0;
L
Linus Torvalds 已提交
669 670
}

671 672 673
static struct inode *
nfs_delegation_find_inode_server(struct nfs_server *server,
				 const struct nfs_fh *fhandle)
L
Linus Torvalds 已提交
674 675 676
{
	struct nfs_delegation *delegation;
	struct inode *res = NULL;
677 678

	list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
679 680 681
		spin_lock(&delegation->lock);
		if (delegation->inode != NULL &&
		    nfs_compare_fh(fhandle, &NFS_I(delegation->inode)->fh) == 0) {
L
Linus Torvalds 已提交
682 683
			res = igrab(delegation->inode);
		}
684 685 686
		spin_unlock(&delegation->lock);
		if (res != NULL)
			break;
L
Linus Torvalds 已提交
687
	}
688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710
	return res;
}

/**
 * nfs_delegation_find_inode - retrieve the inode associated with a delegation
 * @clp: client state handle
 * @fhandle: filehandle from a delegation recall
 *
 * Returns pointer to inode matching "fhandle," or NULL if a matching inode
 * cannot be found.
 */
struct inode *nfs_delegation_find_inode(struct nfs_client *clp,
					const struct nfs_fh *fhandle)
{
	struct nfs_server *server;
	struct inode *res = NULL;

	rcu_read_lock();
	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
		res = nfs_delegation_find_inode_server(server, fhandle);
		if (res != NULL)
			break;
	}
711
	rcu_read_unlock();
L
Linus Torvalds 已提交
712 713 714
	return res;
}

715 716 717 718 719 720 721 722 723 724 725 726
static void nfs_delegation_mark_reclaim_server(struct nfs_server *server)
{
	struct nfs_delegation *delegation;

	list_for_each_entry_rcu(delegation, &server->delegations, super_list)
		set_bit(NFS_DELEGATION_NEED_RECLAIM, &delegation->flags);
}

/**
 * nfs_delegation_mark_reclaim - mark all delegations as needing to be reclaimed
 * @clp: nfs_client to process
 *
L
Linus Torvalds 已提交
727
 */
728
void nfs_delegation_mark_reclaim(struct nfs_client *clp)
L
Linus Torvalds 已提交
729
{
730 731
	struct nfs_server *server;

732
	rcu_read_lock();
733 734
	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
		nfs_delegation_mark_reclaim_server(server);
735
	rcu_read_unlock();
L
Linus Torvalds 已提交
736 737
}

738 739 740 741
/**
 * nfs_delegation_reap_unclaimed - reap unclaimed delegations after reboot recovery is done
 * @clp: nfs_client to process
 *
L
Linus Torvalds 已提交
742
 */
743
void nfs_delegation_reap_unclaimed(struct nfs_client *clp)
L
Linus Torvalds 已提交
744
{
745
	struct nfs_delegation *delegation;
746
	struct nfs_server *server;
747
	struct inode *inode;
748

749 750
restart:
	rcu_read_lock();
751 752 753 754 755 756 757 758 759 760
	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
		list_for_each_entry_rcu(delegation, &server->delegations,
								super_list) {
			if (test_bit(NFS_DELEGATION_NEED_RECLAIM,
						&delegation->flags) == 0)
				continue;
			inode = nfs_delegation_grab_inode(delegation);
			if (inode == NULL)
				continue;
			delegation = nfs_detach_delegation(NFS_I(inode),
761
					delegation, server);
762 763 764 765 766 767 768
			rcu_read_unlock();

			if (delegation != NULL)
				nfs_free_delegation(delegation);
			iput(inode);
			goto restart;
		}
L
Linus Torvalds 已提交
769
	}
770
	rcu_read_unlock();
L
Linus Torvalds 已提交
771
}
772

773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798
/**
 * nfs_delegations_present - check for existence of delegations
 * @clp: client state handle
 *
 * Returns one if there are any nfs_delegation structures attached
 * to this nfs_client.
 */
int nfs_delegations_present(struct nfs_client *clp)
{
	struct nfs_server *server;
	int ret = 0;

	rcu_read_lock();
	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
		if (!list_empty(&server->delegations)) {
			ret = 1;
			break;
		}
	rcu_read_unlock();
	return ret;
}

/**
 * nfs4_copy_delegation_stateid - Copy inode's state ID information
 * @dst: stateid data structure to fill in
 * @inode: inode to check
799
 * @flags: delegation type requirement
800
 *
801 802
 * Returns "true" and fills in "dst->data" * if inode had a delegation,
 * otherwise "false" is returned.
803
 */
804 805
bool nfs4_copy_delegation_stateid(nfs4_stateid *dst, struct inode *inode,
		fmode_t flags)
806 807 808
{
	struct nfs_inode *nfsi = NFS_I(inode);
	struct nfs_delegation *delegation;
809
	bool ret;
810

811
	flags &= FMODE_READ|FMODE_WRITE;
812 813
	rcu_read_lock();
	delegation = rcu_dereference(nfsi->delegation);
814 815
	ret = (delegation != NULL && (delegation->type & flags) == flags);
	if (ret) {
816
		nfs4_stateid_copy(dst, &delegation->stateid);
817
		nfs_mark_delegation_referenced(delegation);
818
	}
819 820
	rcu_read_unlock();
	return ret;
821
}