diff options
| -rw-r--r-- | xlators/protocol/client/src/client-handshake.c | 8 |
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: |