From 32f5bc795046fad2fc5dcdafafcf1e8c3df7d7a3 Mon Sep 17 00:00:00 2001 From: Raghavendra G Date: Thu, 8 Feb 2018 13:44:38 +0530 Subject: 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 --- xlators/cluster/dht/src/dht-lock.h | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) (limited to 'xlators/cluster/dht/src/dht-lock.h') 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, -- cgit