summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--xlators/protocol/client/src/client-handshake.c8
1 files changed, 5 insertions, 3 deletions
diff --git a/xlators/protocol/client/src/client-handshake.c b/xlators/protocol/client/src/client-handshake.c
index 418307c41e0..1ba128b9496 100644
--- a/xlators/protocol/client/src/client-handshake.c
+++ b/xlators/protocol/client/src/client-handshake.c
@@ -459,6 +459,8 @@ client3_1_reopen_cbk (struct rpc_req *req, struct iovec *iov, int count,
}
pthread_mutex_unlock (&conf->lock);
+ ret = 0;
+
attempt_lock_recovery = _gf_false; /* temporarily */
if (attempt_lock_recovery) {
@@ -471,11 +473,10 @@ client3_1_reopen_cbk (struct rpc_req *req, struct iovec *iov, int count,
"need to attempt lock recovery on %"PRIu64
" open fds", fd_count);
}
+ } else {
+ fd_count = decrement_reopen_fd_count (frame->this, conf);
}
-
out:
- if (!attempt_lock_recovery)
- fd_count = decrement_reopen_fd_count (frame->this, conf);
if (fdctx)
client_fdctx_destroy (frame->this, fdctx);
@@ -558,6 +559,7 @@ client3_1_reopendir_cbk (struct rpc_req *req, struct iovec *iov, int count,
}
pthread_mutex_unlock (&conf->lock);
+ decrement_reopen_fd_count (frame->this, conf);
ret = 0;
out: