aboutsummaryrefslogtreecommitdiffstats
path: root/net/sunrpc/rpc_pipe.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/sunrpc/rpc_pipe.c')
-rw-r--r--net/sunrpc/rpc_pipe.c58
1 files changed, 29 insertions, 29 deletions
diff --git a/net/sunrpc/rpc_pipe.c b/net/sunrpc/rpc_pipe.c
index e14c1cae7460..9764c80ab0b2 100644
--- a/net/sunrpc/rpc_pipe.c
+++ b/net/sunrpc/rpc_pipe.c
@@ -69,13 +69,13 @@ rpc_timeout_upcall_queue(void *data)
69 struct rpc_inode *rpci = (struct rpc_inode *)data; 69 struct rpc_inode *rpci = (struct rpc_inode *)data;
70 struct inode *inode = &rpci->vfs_inode; 70 struct inode *inode = &rpci->vfs_inode;
71 71
72 down(&inode->i_sem); 72 mutex_lock(&inode->i_mutex);
73 if (rpci->ops == NULL) 73 if (rpci->ops == NULL)
74 goto out; 74 goto out;
75 if (rpci->nreaders == 0 && !list_empty(&rpci->pipe)) 75 if (rpci->nreaders == 0 && !list_empty(&rpci->pipe))
76 __rpc_purge_upcall(inode, -ETIMEDOUT); 76 __rpc_purge_upcall(inode, -ETIMEDOUT);
77out: 77out:
78 up(&inode->i_sem); 78 mutex_unlock(&inode->i_mutex);
79} 79}
80 80
81int 81int
@@ -84,7 +84,7 @@ rpc_queue_upcall(struct inode *inode, struct rpc_pipe_msg *msg)
84 struct rpc_inode *rpci = RPC_I(inode); 84 struct rpc_inode *rpci = RPC_I(inode);
85 int res = -EPIPE; 85 int res = -EPIPE;
86 86
87 down(&inode->i_sem); 87 mutex_lock(&inode->i_mutex);
88 if (rpci->ops == NULL) 88 if (rpci->ops == NULL)
89 goto out; 89 goto out;
90 if (rpci->nreaders) { 90 if (rpci->nreaders) {
@@ -100,7 +100,7 @@ rpc_queue_upcall(struct inode *inode, struct rpc_pipe_msg *msg)
100 res = 0; 100 res = 0;
101 } 101 }
102out: 102out:
103 up(&inode->i_sem); 103 mutex_unlock(&inode->i_mutex);
104 wake_up(&rpci->waitq); 104 wake_up(&rpci->waitq);
105 return res; 105 return res;
106} 106}
@@ -116,7 +116,7 @@ rpc_close_pipes(struct inode *inode)
116{ 116{
117 struct rpc_inode *rpci = RPC_I(inode); 117 struct rpc_inode *rpci = RPC_I(inode);
118 118
119 down(&inode->i_sem); 119 mutex_lock(&inode->i_mutex);
120 if (rpci->ops != NULL) { 120 if (rpci->ops != NULL) {
121 rpci->nreaders = 0; 121 rpci->nreaders = 0;
122 __rpc_purge_list(rpci, &rpci->in_upcall, -EPIPE); 122 __rpc_purge_list(rpci, &rpci->in_upcall, -EPIPE);
@@ -127,7 +127,7 @@ rpc_close_pipes(struct inode *inode)
127 rpci->ops = NULL; 127 rpci->ops = NULL;
128 } 128 }
129 rpc_inode_setowner(inode, NULL); 129 rpc_inode_setowner(inode, NULL);
130 up(&inode->i_sem); 130 mutex_unlock(&inode->i_mutex);
131 cancel_delayed_work(&rpci->queue_timeout); 131 cancel_delayed_work(&rpci->queue_timeout);
132 flush_scheduled_work(); 132 flush_scheduled_work();
133} 133}
@@ -154,7 +154,7 @@ rpc_pipe_open(struct inode *inode, struct file *filp)
154 struct rpc_inode *rpci = RPC_I(inode); 154 struct rpc_inode *rpci = RPC_I(inode);
155 int res = -ENXIO; 155 int res = -ENXIO;
156 156
157 down(&inode->i_sem); 157 mutex_lock(&inode->i_mutex);
158 if (rpci->ops != NULL) { 158 if (rpci->ops != NULL) {
159 if (filp->f_mode & FMODE_READ) 159 if (filp->f_mode & FMODE_READ)
160 rpci->nreaders ++; 160 rpci->nreaders ++;
@@ -162,7 +162,7 @@ rpc_pipe_open(struct inode *inode, struct file *filp)
162 rpci->nwriters ++; 162 rpci->nwriters ++;
163 res = 0; 163 res = 0;
164 } 164 }
165 up(&inode->i_sem); 165 mutex_unlock(&inode->i_mutex);
166 return res; 166 return res;
167} 167}
168 168
@@ -172,7 +172,7 @@ rpc_pipe_release(struct inode *inode, struct file *filp)
172 struct rpc_inode *rpci = RPC_I(inode); 172 struct rpc_inode *rpci = RPC_I(inode);
173 struct rpc_pipe_msg *msg; 173 struct rpc_pipe_msg *msg;
174 174
175 down(&inode->i_sem); 175 mutex_lock(&inode->i_mutex);
176 if (rpci->ops == NULL) 176 if (rpci->ops == NULL)
177 goto out; 177 goto out;
178 msg = (struct rpc_pipe_msg *)filp->private_data; 178 msg = (struct rpc_pipe_msg *)filp->private_data;
@@ -190,7 +190,7 @@ rpc_pipe_release(struct inode *inode, struct file *filp)
190 if (rpci->ops->release_pipe) 190 if (rpci->ops->release_pipe)
191 rpci->ops->release_pipe(inode); 191 rpci->ops->release_pipe(inode);
192out: 192out:
193 up(&inode->i_sem); 193 mutex_unlock(&inode->i_mutex);
194 return 0; 194 return 0;
195} 195}
196 196
@@ -202,7 +202,7 @@ rpc_pipe_read(struct file *filp, char __user *buf, size_t len, loff_t *offset)
202 struct rpc_pipe_msg *msg; 202 struct rpc_pipe_msg *msg;
203 int res = 0; 203 int res = 0;
204 204
205 down(&inode->i_sem); 205 mutex_lock(&inode->i_mutex);
206 if (rpci->ops == NULL) { 206 if (rpci->ops == NULL) {
207 res = -EPIPE; 207 res = -EPIPE;
208 goto out_unlock; 208 goto out_unlock;
@@ -229,7 +229,7 @@ rpc_pipe_read(struct file *filp, char __user *buf, size_t len, loff_t *offset)
229 rpci->ops->destroy_msg(msg); 229 rpci->ops->destroy_msg(msg);
230 } 230 }
231out_unlock: 231out_unlock:
232 up(&inode->i_sem); 232 mutex_unlock(&inode->i_mutex);
233 return res; 233 return res;
234} 234}
235 235
@@ -240,11 +240,11 @@ rpc_pipe_write(struct file *filp, const char __user *buf, size_t len, loff_t *of
240 struct rpc_inode *rpci = RPC_I(inode); 240 struct rpc_inode *rpci = RPC_I(inode);
241 int res; 241 int res;
242 242
243 down(&inode->i_sem); 243 mutex_lock(&inode->i_mutex);
244 res = -EPIPE; 244 res = -EPIPE;
245 if (rpci->ops != NULL) 245 if (rpci->ops != NULL)
246 res = rpci->ops->downcall(filp, buf, len); 246 res = rpci->ops->downcall(filp, buf, len);
247 up(&inode->i_sem); 247 mutex_unlock(&inode->i_mutex);
248 return res; 248 return res;
249} 249}
250 250
@@ -322,7 +322,7 @@ rpc_info_open(struct inode *inode, struct file *file)
322 322
323 if (!ret) { 323 if (!ret) {
324 struct seq_file *m = file->private_data; 324 struct seq_file *m = file->private_data;
325 down(&inode->i_sem); 325 mutex_lock(&inode->i_mutex);
326 clnt = RPC_I(inode)->private; 326 clnt = RPC_I(inode)->private;
327 if (clnt) { 327 if (clnt) {
328 atomic_inc(&clnt->cl_users); 328 atomic_inc(&clnt->cl_users);
@@ -331,7 +331,7 @@ rpc_info_open(struct inode *inode, struct file *file)
331 single_release(inode, file); 331 single_release(inode, file);
332 ret = -EINVAL; 332 ret = -EINVAL;
333 } 333 }
334 up(&inode->i_sem); 334 mutex_unlock(&inode->i_mutex);
335 } 335 }
336 return ret; 336 return ret;
337} 337}
@@ -491,7 +491,7 @@ rpc_depopulate(struct dentry *parent)
491 struct dentry *dentry, *dvec[10]; 491 struct dentry *dentry, *dvec[10];
492 int n = 0; 492 int n = 0;
493 493
494 down(&dir->i_sem); 494 mutex_lock(&dir->i_mutex);
495repeat: 495repeat:
496 spin_lock(&dcache_lock); 496 spin_lock(&dcache_lock);
497 list_for_each_safe(pos, next, &parent->d_subdirs) { 497 list_for_each_safe(pos, next, &parent->d_subdirs) {
@@ -519,7 +519,7 @@ repeat:
519 } while (n); 519 } while (n);
520 goto repeat; 520 goto repeat;
521 } 521 }
522 up(&dir->i_sem); 522 mutex_unlock(&dir->i_mutex);
523} 523}
524 524
525static int 525static int
@@ -532,7 +532,7 @@ rpc_populate(struct dentry *parent,
532 struct dentry *dentry; 532 struct dentry *dentry;
533 int mode, i; 533 int mode, i;
534 534
535 down(&dir->i_sem); 535 mutex_lock(&dir->i_mutex);
536 for (i = start; i < eof; i++) { 536 for (i = start; i < eof; i++) {
537 dentry = d_alloc_name(parent, files[i].name); 537 dentry = d_alloc_name(parent, files[i].name);
538 if (!dentry) 538 if (!dentry)
@@ -552,10 +552,10 @@ rpc_populate(struct dentry *parent,
552 dir->i_nlink++; 552 dir->i_nlink++;
553 d_add(dentry, inode); 553 d_add(dentry, inode);
554 } 554 }
555 up(&dir->i_sem); 555 mutex_unlock(&dir->i_mutex);
556 return 0; 556 return 0;
557out_bad: 557out_bad:
558 up(&dir->i_sem); 558 mutex_unlock(&dir->i_mutex);
559 printk(KERN_WARNING "%s: %s failed to populate directory %s\n", 559 printk(KERN_WARNING "%s: %s failed to populate directory %s\n",
560 __FILE__, __FUNCTION__, parent->d_name.name); 560 __FILE__, __FUNCTION__, parent->d_name.name);
561 return -ENOMEM; 561 return -ENOMEM;
@@ -609,7 +609,7 @@ rpc_lookup_negative(char *path, struct nameidata *nd)
609 if ((error = rpc_lookup_parent(path, nd)) != 0) 609 if ((error = rpc_lookup_parent(path, nd)) != 0)
610 return ERR_PTR(error); 610 return ERR_PTR(error);
611 dir = nd->dentry->d_inode; 611 dir = nd->dentry->d_inode;
612 down(&dir->i_sem); 612 mutex_lock(&dir->i_mutex);
613 dentry = lookup_hash(nd); 613 dentry = lookup_hash(nd);
614 if (IS_ERR(dentry)) 614 if (IS_ERR(dentry))
615 goto out_err; 615 goto out_err;
@@ -620,7 +620,7 @@ rpc_lookup_negative(char *path, struct nameidata *nd)
620 } 620 }
621 return dentry; 621 return dentry;
622out_err: 622out_err:
623 up(&dir->i_sem); 623 mutex_unlock(&dir->i_mutex);
624 rpc_release_path(nd); 624 rpc_release_path(nd);
625 return dentry; 625 return dentry;
626} 626}
@@ -646,7 +646,7 @@ rpc_mkdir(char *path, struct rpc_clnt *rpc_client)
646 if (error) 646 if (error)
647 goto err_depopulate; 647 goto err_depopulate;
648out: 648out:
649 up(&dir->i_sem); 649 mutex_unlock(&dir->i_mutex);
650 rpc_release_path(&nd); 650 rpc_release_path(&nd);
651 return dentry; 651 return dentry;
652err_depopulate: 652err_depopulate:
@@ -671,7 +671,7 @@ rpc_rmdir(char *path)
671 if ((error = rpc_lookup_parent(path, &nd)) != 0) 671 if ((error = rpc_lookup_parent(path, &nd)) != 0)
672 return error; 672 return error;
673 dir = nd.dentry->d_inode; 673 dir = nd.dentry->d_inode;
674 down(&dir->i_sem); 674 mutex_lock(&dir->i_mutex);
675 dentry = lookup_hash(&nd); 675 dentry = lookup_hash(&nd);
676 if (IS_ERR(dentry)) { 676 if (IS_ERR(dentry)) {
677 error = PTR_ERR(dentry); 677 error = PTR_ERR(dentry);
@@ -681,7 +681,7 @@ rpc_rmdir(char *path)
681 error = __rpc_rmdir(dir, dentry); 681 error = __rpc_rmdir(dir, dentry);
682 dput(dentry); 682 dput(dentry);
683out_release: 683out_release:
684 up(&dir->i_sem); 684 mutex_unlock(&dir->i_mutex);
685 rpc_release_path(&nd); 685 rpc_release_path(&nd);
686 return error; 686 return error;
687} 687}
@@ -710,7 +710,7 @@ rpc_mkpipe(char *path, void *private, struct rpc_pipe_ops *ops, int flags)
710 rpci->ops = ops; 710 rpci->ops = ops;
711 inode_dir_notify(dir, DN_CREATE); 711 inode_dir_notify(dir, DN_CREATE);
712out: 712out:
713 up(&dir->i_sem); 713 mutex_unlock(&dir->i_mutex);
714 rpc_release_path(&nd); 714 rpc_release_path(&nd);
715 return dentry; 715 return dentry;
716err_dput: 716err_dput:
@@ -732,7 +732,7 @@ rpc_unlink(char *path)
732 if ((error = rpc_lookup_parent(path, &nd)) != 0) 732 if ((error = rpc_lookup_parent(path, &nd)) != 0)
733 return error; 733 return error;
734 dir = nd.dentry->d_inode; 734 dir = nd.dentry->d_inode;
735 down(&dir->i_sem); 735 mutex_lock(&dir->i_mutex);
736 dentry = lookup_hash(&nd); 736 dentry = lookup_hash(&nd);
737 if (IS_ERR(dentry)) { 737 if (IS_ERR(dentry)) {
738 error = PTR_ERR(dentry); 738 error = PTR_ERR(dentry);
@@ -746,7 +746,7 @@ rpc_unlink(char *path)
746 dput(dentry); 746 dput(dentry);
747 inode_dir_notify(dir, DN_DELETE); 747 inode_dir_notify(dir, DN_DELETE);
748out_release: 748out_release:
749 up(&dir->i_sem); 749 mutex_unlock(&dir->i_mutex);
750 rpc_release_path(&nd); 750 rpc_release_path(&nd);
751 return error; 751 return error;
752} 752}