diff options
| author | Raghavendra G <rgowdapp@redhat.com> | 2018-02-08 13:44:38 +0530 |
|---|---|---|
| committer | Raghavendra G <rgowdapp@redhat.com> | 2018-02-23 03:19:58 +0000 |
| commit | 32f5bc795046fad2fc5dcdafafcf1e8c3df7d7a3 (patch) | |
| tree | 85284f2ef9e4917890ff84fe2bd35ba84c5ec025 /xlators/cluster/dht/src/dht-lock.h | |
| parent | cfbc524239b1d3bc417849e68379c81e83fd56d9 (diff) | |
cluster/dht: store the 'reaction' on failures per lock
Currently its passed in dht_blocking_inode(entry)lk, which would be a
global value for all the locks passed in the argument. This would
be a limitation for cases where we want to ignore failures on only few
locks and fail for others.
Change-Id: I02cfbcaafb593ad8140c0e5af725c866b630fb6b
BUG: 1543279
Signed-off-by: Raghavendra G <rgowdapp@redhat.com>
Diffstat (limited to 'xlators/cluster/dht/src/dht-lock.h')
| -rw-r--r-- | xlators/cluster/dht/src/dht-lock.h | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/xlators/cluster/dht/src/dht-lock.h b/xlators/cluster/dht/src/dht-lock.h index 0557858041e..f36bf3fd685 100644 --- a/xlators/cluster/dht/src/dht-lock.h +++ b/xlators/cluster/dht/src/dht-lock.h @@ -22,7 +22,8 @@ dht_lock_count (dht_lock_t **lk_array, int lk_count); dht_lock_t * dht_lock_new (xlator_t *this, xlator_t *xl, loc_t *loc, short type, - const char *domain, const char *basename); + const char *domain, const char *basename, + dht_reaction_type_t do_on_failure); int32_t dht_unlock_entrylk_wrapper (call_frame_t *, dht_elock_wrap_t *); @@ -32,8 +33,7 @@ dht_blocking_entrylk_rec (call_frame_t *frame, int i); int dht_blocking_entrylk (call_frame_t *frame, dht_lock_t **lk_array, - int lk_count, dht_reaction_type_t reaction, - fop_inodelk_cbk_t entrylk_cbk); + int lk_count, fop_inodelk_cbk_t entrylk_cbk); int32_t dht_unlock_inodelk (call_frame_t *frame, dht_lock_t **lk_array, int lk_count, @@ -70,8 +70,7 @@ dht_blocking_inodelk_rec (call_frame_t *frame, int i); int dht_blocking_inodelk (call_frame_t *frame, dht_lock_t **lk_array, - int lk_count, dht_reaction_type_t reaction, - fop_inodelk_cbk_t inodelk_cbk); + int lk_count, fop_inodelk_cbk_t inodelk_cbk); int32_t dht_blocking_entrylk_after_inodelk (call_frame_t *frame, void *cookie, |