Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit ade61088 authored by Linus Torvalds's avatar Linus Torvalds
Browse files

Merge branch 'bugfixes' of git://git.linux-nfs.org/projects/trondmy/nfs-2.6 

* 'bugfixes' of git://git.linux-nfs.org/projects/trondmy/nfs-2.6:
  NFS: Fix another nfs_wb_page() deadlock
  NFS: Ensure that we mark the inode as dirty if we exit early from commit
  NFS: Fix a lock imbalance typo in nfs_access_cache_shrinker
  sunrpc: fix leak on error on socket xprt setup
parents 7eb1053f 0522f6ad

fs/nfs/dir.c

+1 −0
Original line number Diff line number Diff line
@@ -1741,6 +1741,7 @@ int nfs_access_cache_shrinker(int nr_to_scan, gfp_t gfp_mask) 
			clear_bit(NFS_INO_ACL_LRU_SET, &nfsi->flags);

			smp_mb__after_clear_bit();

		}

		spin_unlock(&inode->i_lock);

	}

	spin_unlock(&nfs_access_lru_lock);

	nfs_access_free_list(&head);

fs/nfs/write.c

+16 −4
Original line number Diff line number Diff line
@@ -1386,7 +1386,7 @@ static int nfs_commit_inode(struct inode *inode, int how) 
	int res = 0;



	if (!nfs_commit_set_lock(NFS_I(inode), may_wait))

		goto out;

		goto out_mark_dirty;

	spin_lock(&inode->i_lock);

	res = nfs_scan_commit(inode, &head, 0, 0);

	spin_unlock(&inode->i_lock);
@@ -1398,9 +1398,18 @@ static int nfs_commit_inode(struct inode *inode, int how) 
			wait_on_bit(&NFS_I(inode)->flags, NFS_INO_COMMIT,

					nfs_wait_bit_killable,

					TASK_KILLABLE);

		else

			goto out_mark_dirty;

	} else

		nfs_commit_clear_lock(NFS_I(inode));

out:

	return res;

	/* Note: If we exit without ensuring that the commit is complete,

	 * we must mark the inode as dirty. Otherwise, future calls to

	 * sync_inode() with the WB_SYNC_ALL flag set will fail to ensure

	 * that the data is on the disk.

	 */

out_mark_dirty:

	__mark_inode_dirty(inode, I_DIRTY_DATASYNC);

	return res;

}
@@ -1509,14 +1518,17 @@ int nfs_wb_page(struct inode *inode, struct page *page) 
	};

	int ret;



	while(PagePrivate(page)) {

	for (;;) {

		wait_on_page_writeback(page);

		if (clear_page_dirty_for_io(page)) {

			ret = nfs_writepage_locked(page, &wbc);

			if (ret < 0)

				goto out_error;

			continue;

		}

		ret = sync_inode(inode, &wbc);

		if (!PagePrivate(page))

			break;

		ret = nfs_commit_inode(inode, FLUSH_SYNC);

		if (ret < 0)

			goto out_error;

	}

net/sunrpc/xprtsock.c

+18 −11
Original line number Diff line number Diff line
@@ -2293,6 +2293,7 @@ static struct rpc_xprt *xs_setup_udp(struct xprt_create *args) 
	struct sockaddr *addr = args->dstaddr;

	struct rpc_xprt *xprt;

	struct sock_xprt *transport;

	struct rpc_xprt *ret;



	xprt = xs_setup_xprt(args, xprt_udp_slot_table_entries);

	if (IS_ERR(xprt))
@@ -2330,8 +2331,8 @@ static struct rpc_xprt *xs_setup_udp(struct xprt_create *args) 
		xs_format_peer_addresses(xprt, "udp", RPCBIND_NETID_UDP6);

		break;

	default:

		kfree(xprt);

		return ERR_PTR(-EAFNOSUPPORT);

		ret = ERR_PTR(-EAFNOSUPPORT);

		goto out_err;

	}



	if (xprt_bound(xprt))
@@ -2346,10 +2347,11 @@ static struct rpc_xprt *xs_setup_udp(struct xprt_create *args) 


	if (try_module_get(THIS_MODULE))

		return xprt;



	ret = ERR_PTR(-EINVAL);

out_err:

	kfree(xprt->slot);

	kfree(xprt);

	return ERR_PTR(-EINVAL);

	return ret;

}



static const struct rpc_timeout xs_tcp_default_timeout = {
@@ -2368,6 +2370,7 @@ static struct rpc_xprt *xs_setup_tcp(struct xprt_create *args) 
	struct sockaddr *addr = args->dstaddr;

	struct rpc_xprt *xprt;

	struct sock_xprt *transport;

	struct rpc_xprt *ret;



	xprt = xs_setup_xprt(args, xprt_tcp_slot_table_entries);

	if (IS_ERR(xprt))
@@ -2403,8 +2406,8 @@ static struct rpc_xprt *xs_setup_tcp(struct xprt_create *args) 
		xs_format_peer_addresses(xprt, "tcp", RPCBIND_NETID_TCP6);

		break;

	default:

		kfree(xprt);

		return ERR_PTR(-EAFNOSUPPORT);

		ret = ERR_PTR(-EAFNOSUPPORT);

		goto out_err;

	}



	if (xprt_bound(xprt))
@@ -2420,10 +2423,11 @@ static struct rpc_xprt *xs_setup_tcp(struct xprt_create *args) 


	if (try_module_get(THIS_MODULE))

		return xprt;



	ret = ERR_PTR(-EINVAL);

out_err:

	kfree(xprt->slot);

	kfree(xprt);

	return ERR_PTR(-EINVAL);

	return ret;

}



/**
@@ -2437,6 +2441,7 @@ static struct rpc_xprt *xs_setup_bc_tcp(struct xprt_create *args) 
	struct rpc_xprt *xprt;

	struct sock_xprt *transport;

	struct svc_sock *bc_sock;

	struct rpc_xprt *ret;



	xprt = xs_setup_xprt(args, xprt_tcp_slot_table_entries);

	if (IS_ERR(xprt))
@@ -2476,8 +2481,8 @@ static struct rpc_xprt *xs_setup_bc_tcp(struct xprt_create *args) 
				   RPCBIND_NETID_TCP6);

		break;

	default:

		kfree(xprt);

		return ERR_PTR(-EAFNOSUPPORT);

		ret = ERR_PTR(-EAFNOSUPPORT);

		goto out_err;

	}



	if (xprt_bound(xprt))
@@ -2499,9 +2504,11 @@ static struct rpc_xprt *xs_setup_bc_tcp(struct xprt_create *args) 


	if (try_module_get(THIS_MODULE))

		return xprt;

	ret = ERR_PTR(-EINVAL);

out_err:

	kfree(xprt->slot);

	kfree(xprt);

	return ERR_PTR(-EINVAL);

	return ret;

}



static struct xprt_class	xs_udp_transport = {