diff options
Diffstat (limited to 'xlators/features/locks/src/internal.c')
| -rw-r--r-- | xlators/features/locks/src/internal.c | 16 |
1 files changed, 14 insertions, 2 deletions
diff --git a/xlators/features/locks/src/internal.c b/xlators/features/locks/src/internal.c index 34087da6e4a..116902fa814 100644 --- a/xlators/features/locks/src/internal.c +++ b/xlators/features/locks/src/internal.c @@ -134,6 +134,8 @@ pl_inodelk (call_frame_t *frame, xlator_t *this, goto unwind; } + pl_trace_in (this, frame, NULL, loc, cmd, flock); + if (client_pid == 0) { /* special case: this means release all locks @@ -169,8 +171,11 @@ pl_inodelk (call_frame_t *frame, xlator_t *this, can_block, GF_LOCK_INTERNAL); if (ret == -1) { - if (can_block) + if (can_block) { + pl_trace_block (this, frame, NULL, loc, + cmd, flock); goto out; + } gf_log (this->name, GF_LOG_TRACE, "returning EAGAIN"); op_errno = EAGAIN; @@ -192,6 +197,7 @@ pl_inodelk (call_frame_t *frame, xlator_t *this, unwind: pl_update_refkeeper (this, loc->inode); + pl_trace_out (this, frame, NULL, loc, cmd, flock, op_ret, op_errno); STACK_UNWIND (frame, op_ret, op_errno); out: return 0; @@ -236,6 +242,8 @@ pl_finodelk (call_frame_t *frame, xlator_t *this, goto unwind; } + pl_trace_in (this, frame, fd, NULL, cmd, flock); + if (client_pid == 0) { /* special case: this means release all locks @@ -272,8 +280,11 @@ pl_finodelk (call_frame_t *frame, xlator_t *this, can_block, GF_LOCK_INTERNAL); if (ret == -1) { - if (can_block) + if (can_block) { + pl_trace_block (this, frame, fd, NULL, + cmd, flock); goto out; + } gf_log (this->name, GF_LOG_TRACE, "Returning EAGAIN"); op_errno = EAGAIN; @@ -295,6 +306,7 @@ pl_finodelk (call_frame_t *frame, xlator_t *this, unwind: pl_update_refkeeper (this, fd->inode); + pl_trace_out (this, frame, fd, NULL, cmd, flock, op_ret, op_errno); STACK_UNWIND (frame, op_ret, op_errno); out: return 0; |