diff options
author | Stanislav Kinsbursky <skinsbursky@parallels.com> | 2011-12-26 07:43:49 -0500 |
---|---|---|
committer | Trond Myklebust <Trond.Myklebust@netapp.com> | 2012-01-31 18:20:25 -0500 |
commit | d706ed1f50d3f7fae61a177183562179abe8e4bb (patch) | |
tree | 8f66aaf4276a616ac6006c3fb96b13d6b543143d /fs/nfs/blocklayout | |
parent | d0fe13ba9178d3bb78bbd8577bdedc00f76b7a66 (diff) |
SUNPRC: cleanup RPC PipeFS pipes upcall interface
RPC pipe upcall doesn't requires only private pipe data. Thus RPC inode
references in this code can be removed.
Signed-off-by: Stanislav Kinsbursky <skinsbursky@parallels.com>
Signed-off-by: Trond Myklebust <Trond.Myklebust@netapp.com>
Diffstat (limited to 'fs/nfs/blocklayout')
-rw-r--r-- | fs/nfs/blocklayout/blocklayoutdev.c | 2 | ||||
-rw-r--r-- | fs/nfs/blocklayout/blocklayoutdm.c | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/fs/nfs/blocklayout/blocklayoutdev.c b/fs/nfs/blocklayout/blocklayoutdev.c index d08ba9107fde..81019190e46d 100644 --- a/fs/nfs/blocklayout/blocklayoutdev.c +++ b/fs/nfs/blocklayout/blocklayoutdev.c | |||
@@ -146,7 +146,7 @@ nfs4_blk_decode_device(struct nfs_server *server, | |||
146 | 146 | ||
147 | dprintk("%s CALLING USERSPACE DAEMON\n", __func__); | 147 | dprintk("%s CALLING USERSPACE DAEMON\n", __func__); |
148 | add_wait_queue(&bl_wq, &wq); | 148 | add_wait_queue(&bl_wq, &wq); |
149 | rc = rpc_queue_upcall(bl_device_pipe->d_inode, &msg); | 149 | rc = rpc_queue_upcall(RPC_I(bl_device_pipe->d_inode)->pipe, &msg); |
150 | if (rc < 0) { | 150 | if (rc < 0) { |
151 | remove_wait_queue(&bl_wq, &wq); | 151 | remove_wait_queue(&bl_wq, &wq); |
152 | rv = ERR_PTR(rc); | 152 | rv = ERR_PTR(rc); |
diff --git a/fs/nfs/blocklayout/blocklayoutdm.c b/fs/nfs/blocklayout/blocklayoutdm.c index d055c7558073..3c38244a8724 100644 --- a/fs/nfs/blocklayout/blocklayoutdm.c +++ b/fs/nfs/blocklayout/blocklayoutdm.c | |||
@@ -66,7 +66,7 @@ static void dev_remove(dev_t dev) | |||
66 | msg.len = sizeof(bl_msg) + bl_msg.totallen; | 66 | msg.len = sizeof(bl_msg) + bl_msg.totallen; |
67 | 67 | ||
68 | add_wait_queue(&bl_wq, &wq); | 68 | add_wait_queue(&bl_wq, &wq); |
69 | if (rpc_queue_upcall(bl_device_pipe->d_inode, &msg) < 0) { | 69 | if (rpc_queue_upcall(RPC_I(bl_device_pipe->d_inode)->pipe, &msg) < 0) { |
70 | remove_wait_queue(&bl_wq, &wq); | 70 | remove_wait_queue(&bl_wq, &wq); |
71 | goto out; | 71 | goto out; |
72 | } | 72 | } |