fs/nfs/nfs4state.c

146  * nfs40_discover_server_trunking - Detect server IP address trunking (mv0)
208 nfs4_get_renew_cred_server_locked(struct nfs_server *server)
214 	for (pos = rb_first(&server->state_owners);
236 	struct nfs_server *server;
245 	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
246 		cred = nfs4_get_renew_cred_server_locked(server);
344  * nfs41_discover_server_trunking - Detect server IP address trunking (mv1)
375 	 * server via Transparent State Migration.
407 nfs4_find_state_owner_locked(struct nfs_server *server, const struct cred *cred)
409 	struct rb_node **p = &server->state_owners.rb_node,
436 	struct nfs_server *server = new->so_server;
437 	struct rb_node **p = &server->state_owners.rb_node,
459 	rb_insert_color(&new->so_server_node, &server->state_owners);
466 	struct nfs_server *server = sp->so_server;
469 		rb_erase(&sp->so_server_node, &server->state_owners);
495 nfs4_alloc_state_owner(struct nfs_server *server,
504 	sp->so_seqid.owner_id = ida_alloc(&server->openowner_id, gfp_flags);
509 	sp->so_server = server;
527 	 * return a delegation to the server.
529 	 * a new state_owner.  This will cause the server to
543 static void nfs4_gc_state_owners(struct nfs_server *server)
545 	struct nfs_client *clp = server->nfs_client;
553 	list_for_each_entry_safe(sp, tmp, &server->state_owners_lru, so_lru) {
570  * @server: nfs_server to search
576 struct nfs4_state_owner *nfs4_get_state_owner(struct nfs_server *server,
580 	struct nfs_client *clp = server->nfs_client;
584 	sp = nfs4_find_state_owner_locked(server, cred);
588 	new = nfs4_alloc_state_owner(server, cred, gfp_flags);
597 	nfs4_gc_state_owners(server);
615 	struct nfs_server *server = sp->so_server;
616 	struct nfs_client *clp = server->nfs_client;
622 	list_add_tail(&sp->so_lru, &server->state_owners_lru);
628  * @server: nfs_server with cached state owners to release
637 void nfs4_purge_state_owners(struct nfs_server *server, struct list_head *head)
639 	struct nfs_client *clp = server->nfs_client;
643 	list_for_each_entry_safe(sp, tmp, &server->state_owners_lru, so_lru) {
873 	struct nfs_server *server = state->owner->so_server;
882 	lsp->ls_seqid.owner_id = ida_alloc(&server->lockowner_id, GFP_KERNEL_ACCOUNT);
892 void nfs4_free_lock_state(struct nfs_server *server, struct nfs4_lock_state *lsp)
894 	ida_free(&server->lockowner_id, lsp->ls_seqid.owner_id);
937 	struct nfs_server *server;
949 	server = state->owner->so_server;
951 		struct nfs_client *clp = server->nfs_client;
953 		clp->cl_mvops->free_lock_state(server, lsp);
955 		nfs4_free_lock_state(server, lsp);
1127 			pr_warn_ratelimited("NFS: v4 server returned a bad"
1264 	dprintk("%s: scheduling lease recovery for server %s\n", __func__,
1273  * @server: FSID that is migrating
1278 int nfs4_schedule_migration_recovery(const struct nfs_server *server)
1280 	struct nfs_client *clp = server->nfs_client;
1282 	if (server->fh_expire_type != NFS4_FH_PERSISTENT) {
1283 		pr_err("NFS: volatile file handles not supported (server %s)\n",
1288 	if (test_bit(NFS_MIG_FAILED, &server->mig_status))
1293 			(unsigned long long)server->fsid.major,
1294 			(unsigned long long)server->fsid.minor,
1298 			&((struct nfs_server *)server)->mig_status);
1309  * @clp: server to check for moved leases
1371 	dprintk("%s: handling CB_PATHDOWN recovery for server %s\n", __func__,
1408 int nfs4_schedule_stateid_recovery(const struct nfs_server *server, struct nfs4_state *state)
1410 	struct nfs_client *clp = server->nfs_client;
1416 	dprintk("%s: scheduling stateid recovery for server %s\n", __func__,
1663 	 * This is needed to ensure that the server won't give us any
1666 	 * server that doesn't support a grace period.
1765 static void nfs4_reset_seqids(struct nfs_server *server,
1768 	struct nfs_client *clp = server->nfs_client;
1774 	for (pos = rb_first(&server->state_owners);
1792 	struct nfs_server *server;
1795 	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
1796 		nfs4_reset_seqids(server, mark_reclaim);
1812 	/* Notify the server we're done reclaiming our state */
1818 static void nfs4_clear_reclaim_server(struct nfs_server *server)
1820 	struct nfs_client *clp = server->nfs_client;
1826 	for (pos = rb_first(&server->state_owners);
1844 	struct nfs_server *server;
1850 	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
1851 		nfs4_clear_reclaim_server(server);
1912 		dprintk("%s: failed to handle error %d for server %s\n",
1916 	dprintk("%s: handled error %d for server %s\n", __func__, error,
1924 	struct nfs_server *server;
1935 	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
1936 		nfs4_purge_state_owners(server, &freeme);
1938 		for (pos = rb_first(&server->state_owners);
2034 		dprintk("%s: exit with error %d for server %s\n",
2044 		dprintk("%s: exit with error %d for server %s\n", __func__,
2049 	dprintk("%s: handled error %d for server %s\n", __func__, status,
2109  * Try remote migration of one FSID from a source server to a
2110  * destination server.  The source server provides a list of
2115 static int nfs4_try_migration(struct nfs_server *server, const struct cred *cred)
2117 	struct nfs_client *clp = server->nfs_client;
2124 			(unsigned long long)server->fsid.major,
2125 			(unsigned long long)server->fsid.minor,
2141 	inode = d_inode(server->super->s_root);
2142 	result = nfs4_proc_get_locations(server, NFS_FH(inode), locations,
2166 	status = nfs4_replace_transport(server, locations);
2183 		pr_err("NFS: migration recovery failed (server %s)\n",
2185 		set_bit(NFS_MIG_FAILED, &server->mig_status);
2197 	struct nfs_server *server;
2210 	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
2213 		if (server->mig_gen == clp->cl_mig_gen)
2215 		server->mig_gen = clp->cl_mig_gen;
2218 						&server->mig_status))
2222 		status = nfs4_try_migration(server, cred);
2236  * if it's moved to another server.  Stop when the server no longer
2243 	struct nfs_server *server;
2256 	list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
2260 		if (server->mig_gen == clp->cl_mig_gen)
2262 		server->mig_gen = clp->cl_mig_gen;
2266 		inode = d_inode(server->super->s_root);
2270 		if (nfs4_try_migration(server, cred) == -NFS4ERR_LEASE_MOVED)
2282  * nfs4_discover_server_trunking - Detect server IP address trunking
2402 	/* Use CHECK_LEASE to ping the server with a SEQUENCE */
2413 		dprintk("%s: scheduling reset of all state for server %s!\n",
2423 		dprintk("%s: server %s rebooted!\n", __func__,
2432 	dprintk("%s: state revoked on server %s\n", __func__, clp->cl_hostname);
2440 	dprintk("%s: state revoked on server %s\n", __func__, clp->cl_hostname);
2448 	dprintk("%s: Recallable state revoked on server %s!\n", __func__,
2457 	dprintk("%s: server %s declared a backchannel fault\n", __func__,
2535 		dprintk("%s: session reset failed with status %d for server %s!\n",
2541 	dprintk("%s: session reset was successful for server %s!\n",
2564 		dprintk("%s: bind_conn_to_session was successful for server %s!\n",
2744 	pr_warn_ratelimited("NFS: state manager%s%s failed on NFSv4 server %s"