summaryrefslogtreecommitdiffstats
path: root/fs/btrfs/locking.c
diff options
context:
space:
mode:
authorDavid Sterba <dsterba@suse.com>2018-08-24 08:56:28 -0400
committerDavid Sterba <dsterba@suse.com>2019-04-29 13:02:20 -0400
commit843ccf9f46baff289946e897b11fd813de62d06f (patch)
tree6cd5a503bd2492124fe8fe4a463f5953d658df47 /fs/btrfs/locking.c
parente4e9fd0f326212ee3971418334c255a26c8a2735 (diff)
btrfs: use assertion helpers for spinning writers
Use the helpers where open coded. On non-debug builds, the warnings will not trigger and extent_buffer::spining_writers become unused and can be moved to the appropriate section, saving a few bytes. Reviewed-by: Nikolay Borisov <nborisov@suse.com> Reviewed-by: Johannes Thumshirn <jthumshirn@suse.de> Signed-off-by: David Sterba <dsterba@suse.com>
Diffstat (limited to 'fs/btrfs/locking.c')
-rw-r--r--fs/btrfs/locking.c16
1 files changed, 6 insertions, 10 deletions
diff --git a/fs/btrfs/locking.c b/fs/btrfs/locking.c
index 13ef1decdea6..a5a3c5118f61 100644
--- a/fs/btrfs/locking.c
+++ b/fs/btrfs/locking.c
@@ -64,8 +64,7 @@ void btrfs_set_lock_blocking_write(struct extent_buffer *eb)
64 if (eb->lock_nested && current->pid == eb->lock_owner) 64 if (eb->lock_nested && current->pid == eb->lock_owner)
65 return; 65 return;
66 if (atomic_read(&eb->blocking_writers) == 0) { 66 if (atomic_read(&eb->blocking_writers) == 0) {
67 WARN_ON(atomic_read(&eb->spinning_writers) != 1); 67 btrfs_assert_spinning_writers_put(eb);
68 atomic_dec(&eb->spinning_writers);
69 btrfs_assert_tree_locked(eb); 68 btrfs_assert_tree_locked(eb);
70 atomic_inc(&eb->blocking_writers); 69 atomic_inc(&eb->blocking_writers);
71 write_unlock(&eb->lock); 70 write_unlock(&eb->lock);
@@ -101,8 +100,7 @@ void btrfs_clear_lock_blocking_write(struct extent_buffer *eb)
101 return; 100 return;
102 BUG_ON(atomic_read(&eb->blocking_writers) != 1); 101 BUG_ON(atomic_read(&eb->blocking_writers) != 1);
103 write_lock(&eb->lock); 102 write_lock(&eb->lock);
104 WARN_ON(atomic_read(&eb->spinning_writers)); 103 btrfs_assert_spinning_writers_get(eb);
105 atomic_inc(&eb->spinning_writers);
106 /* atomic_dec_and_test implies a barrier */ 104 /* atomic_dec_and_test implies a barrier */
107 if (atomic_dec_and_test(&eb->blocking_writers)) 105 if (atomic_dec_and_test(&eb->blocking_writers))
108 cond_wake_up_nomb(&eb->write_lock_wq); 106 cond_wake_up_nomb(&eb->write_lock_wq);
@@ -200,7 +198,7 @@ int btrfs_try_tree_write_lock(struct extent_buffer *eb)
200 return 0; 198 return 0;
201 } 199 }
202 atomic_inc(&eb->write_locks); 200 atomic_inc(&eb->write_locks);
203 atomic_inc(&eb->spinning_writers); 201 btrfs_assert_spinning_writers_get(eb);
204 eb->lock_owner = current->pid; 202 eb->lock_owner = current->pid;
205 return 1; 203 return 1;
206} 204}
@@ -266,8 +264,7 @@ again:
266 write_unlock(&eb->lock); 264 write_unlock(&eb->lock);
267 goto again; 265 goto again;
268 } 266 }
269 WARN_ON(atomic_read(&eb->spinning_writers)); 267 btrfs_assert_spinning_writers_get(eb);
270 atomic_inc(&eb->spinning_writers);
271 atomic_inc(&eb->write_locks); 268 atomic_inc(&eb->write_locks);
272 eb->lock_owner = current->pid; 269 eb->lock_owner = current->pid;
273} 270}
@@ -286,14 +283,13 @@ void btrfs_tree_unlock(struct extent_buffer *eb)
286 atomic_dec(&eb->write_locks); 283 atomic_dec(&eb->write_locks);
287 284
288 if (blockers) { 285 if (blockers) {
289 WARN_ON(atomic_read(&eb->spinning_writers)); 286 btrfs_assert_no_spinning_writers(eb);
290 atomic_dec(&eb->blocking_writers); 287 atomic_dec(&eb->blocking_writers);
291 /* Use the lighter barrier after atomic */ 288 /* Use the lighter barrier after atomic */
292 smp_mb__after_atomic(); 289 smp_mb__after_atomic();
293 cond_wake_up_nomb(&eb->write_lock_wq); 290 cond_wake_up_nomb(&eb->write_lock_wq);
294 } else { 291 } else {
295 WARN_ON(atomic_read(&eb->spinning_writers) != 1); 292 btrfs_assert_spinning_writers_put(eb);
296 atomic_dec(&eb->spinning_writers);
297 write_unlock(&eb->lock); 293 write_unlock(&eb->lock);
298 } 294 }
299} 295}