diff options
Diffstat (limited to 'fs/ceph/caps.c')
| -rw-r--r-- | fs/ceph/caps.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/fs/ceph/caps.c b/fs/ceph/caps.c index 6afc1affb50a..b81be9a56487 100644 --- a/fs/ceph/caps.c +++ b/fs/ceph/caps.c | |||
| @@ -627,7 +627,7 @@ retry: | |||
| 627 | if (fmode >= 0) | 627 | if (fmode >= 0) |
| 628 | __ceph_get_fmode(ci, fmode); | 628 | __ceph_get_fmode(ci, fmode); |
| 629 | spin_unlock(&inode->i_lock); | 629 | spin_unlock(&inode->i_lock); |
| 630 | wake_up(&ci->i_cap_wq); | 630 | wake_up_all(&ci->i_cap_wq); |
| 631 | return 0; | 631 | return 0; |
| 632 | } | 632 | } |
| 633 | 633 | ||
| @@ -1181,7 +1181,7 @@ static int __send_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap, | |||
| 1181 | } | 1181 | } |
| 1182 | 1182 | ||
| 1183 | if (wake) | 1183 | if (wake) |
| 1184 | wake_up(&ci->i_cap_wq); | 1184 | wake_up_all(&ci->i_cap_wq); |
| 1185 | 1185 | ||
| 1186 | return delayed; | 1186 | return delayed; |
| 1187 | } | 1187 | } |
| @@ -2153,7 +2153,7 @@ void ceph_put_cap_refs(struct ceph_inode_info *ci, int had) | |||
| 2153 | else if (flushsnaps) | 2153 | else if (flushsnaps) |
| 2154 | ceph_flush_snaps(ci); | 2154 | ceph_flush_snaps(ci); |
| 2155 | if (wake) | 2155 | if (wake) |
| 2156 | wake_up(&ci->i_cap_wq); | 2156 | wake_up_all(&ci->i_cap_wq); |
| 2157 | if (put) | 2157 | if (put) |
| 2158 | iput(inode); | 2158 | iput(inode); |
| 2159 | } | 2159 | } |
| @@ -2229,7 +2229,7 @@ void ceph_put_wrbuffer_cap_refs(struct ceph_inode_info *ci, int nr, | |||
| 2229 | iput(inode); | 2229 | iput(inode); |
| 2230 | } else if (complete_capsnap) { | 2230 | } else if (complete_capsnap) { |
| 2231 | ceph_flush_snaps(ci); | 2231 | ceph_flush_snaps(ci); |
| 2232 | wake_up(&ci->i_cap_wq); | 2232 | wake_up_all(&ci->i_cap_wq); |
| 2233 | } | 2233 | } |
| 2234 | if (drop_capsnap) | 2234 | if (drop_capsnap) |
| 2235 | iput(inode); | 2235 | iput(inode); |
| @@ -2405,7 +2405,7 @@ static void handle_cap_grant(struct inode *inode, struct ceph_mds_caps *grant, | |||
| 2405 | if (queue_invalidate) | 2405 | if (queue_invalidate) |
| 2406 | ceph_queue_invalidate(inode); | 2406 | ceph_queue_invalidate(inode); |
| 2407 | if (wake) | 2407 | if (wake) |
| 2408 | wake_up(&ci->i_cap_wq); | 2408 | wake_up_all(&ci->i_cap_wq); |
| 2409 | 2409 | ||
| 2410 | if (check_caps == 1) | 2410 | if (check_caps == 1) |
| 2411 | ceph_check_caps(ci, CHECK_CAPS_NODELAY|CHECK_CAPS_AUTHONLY, | 2411 | ceph_check_caps(ci, CHECK_CAPS_NODELAY|CHECK_CAPS_AUTHONLY, |
| @@ -2460,7 +2460,7 @@ static void handle_cap_flush_ack(struct inode *inode, u64 flush_tid, | |||
| 2460 | struct ceph_inode_info, | 2460 | struct ceph_inode_info, |
| 2461 | i_flushing_item)->vfs_inode); | 2461 | i_flushing_item)->vfs_inode); |
| 2462 | mdsc->num_cap_flushing--; | 2462 | mdsc->num_cap_flushing--; |
| 2463 | wake_up(&mdsc->cap_flushing_wq); | 2463 | wake_up_all(&mdsc->cap_flushing_wq); |
| 2464 | dout(" inode %p now !flushing\n", inode); | 2464 | dout(" inode %p now !flushing\n", inode); |
| 2465 | 2465 | ||
| 2466 | if (ci->i_dirty_caps == 0) { | 2466 | if (ci->i_dirty_caps == 0) { |
| @@ -2472,7 +2472,7 @@ static void handle_cap_flush_ack(struct inode *inode, u64 flush_tid, | |||
| 2472 | } | 2472 | } |
| 2473 | } | 2473 | } |
| 2474 | spin_unlock(&mdsc->cap_dirty_lock); | 2474 | spin_unlock(&mdsc->cap_dirty_lock); |
| 2475 | wake_up(&ci->i_cap_wq); | 2475 | wake_up_all(&ci->i_cap_wq); |
| 2476 | 2476 | ||
| 2477 | out: | 2477 | out: |
| 2478 | spin_unlock(&inode->i_lock); | 2478 | spin_unlock(&inode->i_lock); |
