From a33f967c77ccf580db42a9f02708fa39f5d7f310 Mon Sep 17 00:00:00 2001

From: Pranith Kumar K <pkarampu@redhat.com>

Date: Fri, 2 Mar 2018 12:37:42 +0530

Subject: [PATCH 193/201] cluster/afr: Remove unused code paths

Removed

1) afr-v1 self-heal locks related code which is not used anymore

2) transaction has some data types that are not needed, so removed them

3) Never used lock tracing available in afr as gluster's network tracing does

the job. So removed that as well.

4) Changelog is always enabled and afr is always used with locks, so

__changelog_enabled, afr_lock_server_count etc functions can be deleted.

5) transaction.fop/done/resume always call the same functions, so no need

to have these variables.

 > BUG: 1549606

Upstream-patch: https://review.gluster.org/19661

BUG: 1491785

Change-Id: I370c146fec2892d40e674d232a5d7256e003c7f1

Signed-off-by: Pranith Kumar K <pkarampu@redhat.com>

Reviewed-on: https://code.engineering.redhat.com/gerrit/131944

Tested-by: RHGS Build Bot <nigelb@redhat.com>

---

 xlators/cluster/afr/src/afr-common.c      |  10 +-

 xlators/cluster/afr/src/afr-dir-write.c   |  18 +-

 xlators/cluster/afr/src/afr-inode-write.c |  39 +--

 xlators/cluster/afr/src/afr-lk-common.c   | 508 +-----------------------------

 xlators/cluster/afr/src/afr-transaction.c | 137 +-------

 xlators/cluster/afr/src/afr-transaction.h |   2 -

 xlators/cluster/afr/src/afr.c             |  35 +-

 xlators/cluster/afr/src/afr.h             |  52 +--

 8 files changed, 41 insertions(+), 760 deletions(-)

diff --git a/xlators/cluster/afr/src/afr-common.c b/xlators/cluster/afr/src/afr-common.c

index 04c8613..06863b6 100644

--- a/xlators/cluster/afr/src/afr-common.c

+++ b/xlators/cluster/afr/src/afr-common.c

@@ -4526,9 +4526,6 @@ afr_priv_dump (xlator_t *this)

         gf_proc_dump_write("data_self_heal", "%s", priv->data_self_heal);

         gf_proc_dump_write("metadata_self_heal", "%d", priv->metadata_self_heal);

         gf_proc_dump_write("entry_self_heal", "%d", priv->entry_self_heal);

-        gf_proc_dump_write("data_change_log", "%d", priv->data_change_log);

-        gf_proc_dump_write("metadata_change_log", "%d", priv->metadata_change_log);

-        gf_proc_dump_write("entry-change_log", "%d", priv->entry_change_log);

         gf_proc_dump_write("read_child", "%d", priv->read_child);

         gf_proc_dump_write("favorite_child", "%d", priv->favorite_child);

         gf_proc_dump_write("wait_count", "%u", priv->wait_count);

@@ -5252,8 +5249,7 @@ out:

 }

 int

-afr_internal_lock_init (afr_internal_lock_t *lk, size_t child_count,

-                        transaction_lk_type_t lk_type)

+afr_internal_lock_init (afr_internal_lock_t *lk, size_t child_count)

 {

         int             ret = -ENOMEM;

@@ -5269,7 +5265,6 @@ afr_internal_lock_init (afr_internal_lock_t *lk, size_t child_count,

         lk->lock_op_ret   = -1;

         lk->lock_op_errno = EUCLEAN;

-        lk->transaction_lk_type = lk_type;

         ret = 0;

 out:

@@ -5336,8 +5331,7 @@ afr_transaction_local_init (afr_local_t *local, xlator_t *this)

         afr_private_t *priv = NULL;

         priv = this->private;

-        ret = afr_internal_lock_init (&local->internal_lock, priv->child_count,

-                                      AFR_TRANSACTION_LK);

+        ret = afr_internal_lock_init (&local->internal_lock, priv->child_count);

         if (ret < 0)

                 goto out;

diff --git a/xlators/cluster/afr/src/afr-dir-write.c b/xlators/cluster/afr/src/afr-dir-write.c

index e088ed6..75889de 100644

--- a/xlators/cluster/afr/src/afr-dir-write.c

+++ b/xlators/cluster/afr/src/afr-dir-write.c

@@ -267,7 +267,7 @@ __afr_dir_write_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

 		afr_mark_entry_pending_changelog (frame, this);

-                local->transaction.resume (frame, this);

+                afr_transaction_resume (frame, this);

         }

         return 0;

@@ -496,8 +496,6 @@ afr_create (call_frame_t *frame, xlator_t *this, loc_t *loc, int32_t flags,

 		goto out;

         local->transaction.wind   = afr_create_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_create_unwind;

         ret = afr_build_parent_loc (&local->transaction.parent_loc, loc,

@@ -626,8 +624,6 @@ afr_mknod (call_frame_t *frame, xlator_t *this, loc_t *loc, mode_t mode,

 		goto out;

         local->transaction.wind   = afr_mknod_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_mknod_unwind;

         ret = afr_build_parent_loc (&local->transaction.parent_loc, loc,

@@ -762,8 +758,6 @@ afr_mkdir (call_frame_t *frame, xlator_t *this, loc_t *loc, mode_t mode,

         local->op = GF_FOP_MKDIR;

         local->transaction.wind   = afr_mkdir_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_mkdir_unwind;

         ret = afr_build_parent_loc (&local->transaction.parent_loc, loc,

@@ -891,8 +885,6 @@ afr_link (call_frame_t *frame, xlator_t *this, loc_t *oldloc, loc_t *newloc,

         local->op = GF_FOP_LINK;

         local->transaction.wind   = afr_link_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_link_unwind;

         ret = afr_build_parent_loc (&local->transaction.parent_loc, newloc,

@@ -1021,8 +1013,6 @@ afr_symlink (call_frame_t *frame, xlator_t *this, const char *linkpath,

         local->op = GF_FOP_SYMLINK;

         local->transaction.wind   = afr_symlink_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_symlink_unwind;

         ret = afr_build_parent_loc (&local->transaction.parent_loc, loc,

@@ -1156,8 +1146,6 @@ afr_rename (call_frame_t *frame, xlator_t *this, loc_t *oldloc, loc_t *newloc,

         local->op = GF_FOP_RENAME;

         local->transaction.wind   = afr_rename_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_rename_unwind;

         ret = afr_build_parent_loc (&local->transaction.parent_loc, oldloc,

@@ -1308,8 +1296,6 @@ afr_unlink (call_frame_t *frame, xlator_t *this, loc_t *loc, int xflag,

         local->op = GF_FOP_UNLINK;

         local->transaction.wind   = afr_unlink_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_unlink_unwind;

         ret = afr_build_parent_loc (&local->transaction.parent_loc, loc,

@@ -1436,8 +1422,6 @@ afr_rmdir (call_frame_t *frame, xlator_t *this, loc_t *loc, int flags,

         local->op = GF_FOP_RMDIR;

         local->transaction.wind   = afr_rmdir_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_rmdir_unwind;

         ret = afr_build_parent_loc (&local->transaction.parent_loc, loc,

diff --git a/xlators/cluster/afr/src/afr-inode-write.c b/xlators/cluster/afr/src/afr-inode-write.c

index 0e50443..2402bb2 100644

--- a/xlators/cluster/afr/src/afr-inode-write.c

+++ b/xlators/cluster/afr/src/afr-inode-write.c

@@ -207,7 +207,7 @@ __afr_inode_write_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

                         local->transaction.unwind (frame, this);

                 }

-                local->transaction.resume (frame, this);

+                afr_transaction_resume (frame, this);

         }

         return 0;

@@ -357,13 +357,10 @@ afr_writev_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

                      int32_t op_ret, int32_t op_errno, struct iatt *prebuf,

                      struct iatt *postbuf, dict_t *xdata)

 {

-        afr_local_t     *local = NULL;

         call_frame_t    *fop_frame = NULL;

         int child_index = (long) cookie;

         int call_count  = -1;

-        local = frame->local;

-

         afr_inode_write_fill (frame, this, child_index, op_ret, op_errno,

                               prebuf, postbuf, xdata);

@@ -374,7 +371,7 @@ afr_writev_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

                 if (!afr_txn_nothing_failed (frame, this)) {

                         //Don't unwind until post-op is complete

-                        local->transaction.resume (frame, this);

+                        afr_transaction_resume (frame, this);

                 } else {

                 /*

                  * Generally inode-write fops do transaction.unwind then

@@ -389,7 +386,7 @@ afr_writev_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

                         fop_frame = afr_transaction_detach_fop_frame (frame);

                         afr_writev_copy_outvars (frame, fop_frame);

-                        local->transaction.resume (frame, this);

+                        afr_transaction_resume (frame, this);

                         afr_writev_unwind (fop_frame, this);

                 }

         }

@@ -462,8 +459,6 @@ afr_do_writev (call_frame_t *frame, xlator_t *this)

         local->op = GF_FOP_WRITE;

         local->transaction.wind   = afr_writev_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_transaction_writev_unwind;

         local->transaction.main_frame = frame;

@@ -652,8 +647,6 @@ afr_truncate (call_frame_t *frame, xlator_t *this,

 		goto out;

 	local->transaction.wind   = afr_truncate_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_truncate_unwind;

         loc_copy (&local->loc, loc);

@@ -780,8 +773,6 @@ afr_ftruncate (call_frame_t *frame, xlator_t *this, fd_t *fd, off_t offset,

         local->op = GF_FOP_FTRUNCATE;

 	local->transaction.wind   = afr_ftruncate_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_ftruncate_unwind;

         local->transaction.main_frame = frame;

@@ -888,8 +879,6 @@ afr_setattr (call_frame_t *frame, xlator_t *this, loc_t *loc, struct iatt *buf,

 		goto out;

         local->transaction.wind   = afr_setattr_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_setattr_unwind;

         loc_copy (&local->loc, loc);

@@ -995,8 +984,6 @@ afr_fsetattr (call_frame_t *frame, xlator_t *this,

 		goto out;

         local->transaction.wind   = afr_fsetattr_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_fsetattr_unwind;

         local->fd                 = fd_ref (fd);

@@ -1639,8 +1626,6 @@ afr_setxattr (call_frame_t *frame, xlator_t *this, loc_t *loc, dict_t *dict,

 		goto out;

         local->transaction.wind   = afr_setxattr_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_setxattr_unwind;

         loc_copy (&local->loc, loc);

@@ -1753,8 +1738,6 @@ afr_fsetxattr (call_frame_t *frame, xlator_t *this,

 		goto out;

         local->transaction.wind   = afr_fsetxattr_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_fsetxattr_unwind;

         local->fd                 = fd_ref (fd);

@@ -1868,8 +1851,6 @@ afr_removexattr (call_frame_t *frame, xlator_t *this,

 		goto out;

         local->transaction.wind   = afr_removexattr_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_removexattr_unwind;

         loc_copy (&local->loc, loc);

@@ -1977,8 +1958,6 @@ afr_fremovexattr (call_frame_t *frame, xlator_t *this, fd_t *fd,

 		goto out;

         local->transaction.wind   = afr_fremovexattr_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_fremovexattr_unwind;

         local->fd = fd_ref (fd);

@@ -2094,8 +2073,6 @@ afr_fallocate (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t mode,

         local->op = GF_FOP_FALLOCATE;

         local->transaction.wind   = afr_fallocate_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_fallocate_unwind;

         local->transaction.main_frame = frame;

@@ -2208,8 +2185,6 @@ afr_discard (call_frame_t *frame, xlator_t *this, fd_t *fd, off_t offset,

         local->op = GF_FOP_DISCARD;

         local->transaction.wind   = afr_discard_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_discard_unwind;

         local->transaction.main_frame = frame;

@@ -2319,8 +2294,6 @@ afr_zerofill (call_frame_t *frame, xlator_t *this, fd_t *fd, off_t offset,

         local->op = GF_FOP_ZEROFILL;

         local->transaction.wind   = afr_zerofill_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_zerofill_unwind;

         local->transaction.main_frame = frame;

@@ -2413,8 +2386,6 @@ afr_xattrop (call_frame_t *frame, xlator_t *this, loc_t *loc,

 		local->xdata_req = dict_ref (xdata);

         local->transaction.wind   = afr_xattrop_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_xattrop_unwind;

         loc_copy (&local->loc, loc);

@@ -2509,8 +2480,6 @@ afr_fxattrop (call_frame_t *frame, xlator_t *this, fd_t *fd,

 		local->xdata_req = dict_ref (xdata);

         local->transaction.wind   = afr_fxattrop_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_fxattrop_unwind;

 	local->fd = fd_ref (fd);

@@ -2626,8 +2595,6 @@ afr_fsync (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t datasync,

 	}

         local->transaction.wind   = afr_fsync_wind;

-        local->transaction.fop    = __afr_txn_write_fop;

-        local->transaction.done   = __afr_txn_write_done;

         local->transaction.unwind = afr_fsync_unwind;

         local->transaction.main_frame = frame;

diff --git a/xlators/cluster/afr/src/afr-lk-common.c b/xlators/cluster/afr/src/afr-lk-common.c

index f50c7b6..260815f 100644

--- a/xlators/cluster/afr/src/afr-lk-common.c

+++ b/xlators/cluster/afr/src/afr-lk-common.c

@@ -23,38 +23,6 @@

 #define LOCKED_YES      0x1        /* for DATA, METADATA, ENTRY and higher_path */

 #define LOCKED_LOWER    0x2        /* for lower path */

-#define AFR_TRACE_INODELK_IN(frame, this, params ...)           \

-        do {                                                    \

-                afr_private_t *_priv = this->private;           \

-                if (!_priv->inodelk_trace)                      \

-                        break;                                  \

-                afr_trace_inodelk_in (frame, this, params);     \

-        } while (0);

-

-#define AFR_TRACE_INODELK_OUT(frame, this, params ...)          \

-        do {                                                    \

-                afr_private_t *_priv = this->private;           \

-                if (!_priv->inodelk_trace)                      \

-                        break;                                  \

-                afr_trace_inodelk_out (frame, this, params);    \

-        } while (0);

-

-#define AFR_TRACE_ENTRYLK_IN(frame, this, params ...)           \

-        do {                                                    \

-                afr_private_t *_priv = this->private;           \

-                if (!_priv->entrylk_trace)                      \

-                        break;                                  \

-                afr_trace_entrylk_in (frame, this, params);     \

-        } while (0);

-

-#define AFR_TRACE_ENTRYLK_OUT(frame, this, params ...)          \

-        do {                                                    \

-                afr_private_t *_priv = this->private;           \

-                if (!_priv->entrylk_trace)                      \

-                        break;                                  \

-                afr_trace_entrylk_out (frame, this, params);    \

-        } while (0);

-

 int

 afr_entry_lockee_cmp (const void *l1, const void *l2)

 {

@@ -119,28 +87,6 @@ afr_set_lk_owner (call_frame_t *frame, xlator_t *this, void *lk_owner)

         set_lk_owner_from_ptr (&frame->root->lk_owner, lk_owner);

 }

-static int

-is_afr_lock_selfheal (afr_local_t *local)

-{

-        afr_internal_lock_t *int_lock = NULL;

-        int                  ret      = -1;

-

-        int_lock = &local->internal_lock;

-

-        switch (int_lock->selfheal_lk_type) {

-        case AFR_DATA_SELF_HEAL_LK:

-        case AFR_METADATA_SELF_HEAL_LK:

-                ret = 1;

-                break;

-        case AFR_ENTRY_SELF_HEAL_LK:

-                ret = 0;

-                break;

-        }

-

-        return ret;

-

-}

-

 int32_t

 internal_lock_count (call_frame_t *frame, xlator_t *this)

 {

@@ -160,315 +106,12 @@ internal_lock_count (call_frame_t *frame, xlator_t *this)

         return call_count;

 }

-static void

-afr_print_inodelk (char *str, int size, int cmd,

-                   struct gf_flock *flock, gf_lkowner_t *owner)

-{

-        char *cmd_str = NULL;

-        char *type_str = NULL;

-

-        switch (cmd) {

-#if F_GETLK != F_GETLK64

-        case F_GETLK64:

-#endif

-        case F_GETLK:

-                cmd_str = "GETLK";

-                break;

-

-#if F_SETLK != F_SETLK64

-        case F_SETLK64:

-#endif

-        case F_SETLK:

-                cmd_str = "SETLK";

-                break;

-

-#if F_SETLKW != F_SETLKW64

-        case F_SETLKW64:

-#endif

-        case F_SETLKW:

-                cmd_str = "SETLKW";

-                break;

-

-        default:

-                cmd_str = "<null>";

-                break;

-        }

-

-        switch (flock->l_type) {

-        case F_RDLCK:

-                type_str = "READ";

-                break;

-        case F_WRLCK:

-                type_str = "WRITE";

-                break;

-        case F_UNLCK:

-                type_str = "UNLOCK";

-                break;

-        default:

-                type_str = "UNKNOWN";

-                break;

-        }

-

-        snprintf (str, size, "lock=INODELK, cmd=%s, type=%s, "

-                  "start=%llu, len=%llu, pid=%llu, lk-owner=%s",

-                  cmd_str, type_str, (unsigned long long) flock->l_start,

-                  (unsigned long long) flock->l_len,

-                  (unsigned long long) flock->l_pid,

-                  lkowner_utoa (owner));

-

-}

-

-static void

-afr_print_lockee (char *str, int size, loc_t *loc, fd_t *fd,

-                  int child_index)

-{

-        snprintf (str, size, "path=%s, fd=%p, child=%d",

-                  loc->path ? loc->path : "<nul>",

-                  fd ? fd : NULL,

-                  child_index);

-}

-

-void

-afr_print_entrylk (char *str, int size, const char *basename,

-                   gf_lkowner_t *owner)

-{

-        snprintf (str, size, "Basename=%s, lk-owner=%s",

-                  basename ? basename : "<nul>",

-                  lkowner_utoa (owner));

-}

-

-static void

-afr_print_verdict (int op_ret, int op_errno, char *str)

-{

-        if (op_ret < 0) {

-                if (op_errno == EAGAIN)

-                        strcpy (str, "EAGAIN");

-                else

-                        strcpy (str, "FAILED");

-        }

-        else

-                strcpy (str, "GRANTED");

-}

-

-static void

-afr_set_lock_call_type (afr_lock_call_type_t lock_call_type,

-                        char *lock_call_type_str,

-                        afr_internal_lock_t *int_lock)

-{

-        switch (lock_call_type) {

-        case AFR_INODELK_TRANSACTION:

-                if (int_lock->transaction_lk_type == AFR_TRANSACTION_LK)

-                        strcpy (lock_call_type_str, "AFR_INODELK_TRANSACTION");

-                else

-                        strcpy (lock_call_type_str, "AFR_INODELK_SELFHEAL");

-                break;

-        case AFR_INODELK_NB_TRANSACTION:

-                if (int_lock->transaction_lk_type == AFR_TRANSACTION_LK)

-                        strcpy (lock_call_type_str, "AFR_INODELK_NB_TRANSACTION");

-                else

-                        strcpy (lock_call_type_str, "AFR_INODELK_NB_SELFHEAL");

-                break;

-        case AFR_ENTRYLK_TRANSACTION:

-                if (int_lock->transaction_lk_type == AFR_TRANSACTION_LK)

-                        strcpy (lock_call_type_str, "AFR_ENTRYLK_TRANSACTION");

-                else

-                        strcpy (lock_call_type_str, "AFR_ENTRYLK_SELFHEAL");

-                break;

-        case AFR_ENTRYLK_NB_TRANSACTION:

-                if (int_lock->transaction_lk_type == AFR_TRANSACTION_LK)

-                        strcpy (lock_call_type_str, "AFR_ENTRYLK_NB_TRANSACTION");

-                else

-                        strcpy (lock_call_type_str, "AFR_ENTRYLK_NB_SELFHEAL");

-                break;

-        default:

-                strcpy (lock_call_type_str, "UNKNOWN");

-                break;

-        }

-

-}

-

-static void

-afr_trace_inodelk_out (call_frame_t *frame, xlator_t *this,

-                       afr_lock_call_type_t lock_call_type,

-                       afr_lock_op_type_t lk_op_type, struct gf_flock *flock,

-                       int op_ret, int op_errno, int32_t child_index)

-{

-        afr_internal_lock_t *int_lock = NULL;

-        afr_local_t         *local    = NULL;

-

-        char lockee[256];

-        char lock_call_type_str[256];

-        char verdict[16];

-

-        local    = frame->local;

-        int_lock = &local->internal_lock;

-

-        afr_print_lockee (lockee, 256, &local->loc, local->fd, child_index);

-

-        afr_set_lock_call_type (lock_call_type, lock_call_type_str, int_lock);

-

-        afr_print_verdict (op_ret, op_errno, verdict);

-

-        gf_msg (this->name, GF_LOG_INFO, 0, AFR_MSG_LOCK_INFO,

-                "[%s %s] [%s] lk-owner=%s Lockee={%s} Number={%llu}",

-                lock_call_type_str,

-                lk_op_type == AFR_LOCK_OP ? "LOCK REPLY" : "UNLOCK REPLY",

-                verdict, lkowner_utoa (&frame->root->lk_owner), lockee,

-                (unsigned long long) int_lock->lock_number);

-

-}

-

-static void

-afr_trace_inodelk_in (call_frame_t *frame, xlator_t *this,

-                      afr_lock_call_type_t lock_call_type,

-                      afr_lock_op_type_t lk_op_type, struct gf_flock *flock,

-                      int32_t cmd, int32_t child_index)

-{

-        afr_local_t         *local    = NULL;

-        afr_internal_lock_t *int_lock = NULL;

-

-        char lock[256];

-        char lockee[256];

-        char lock_call_type_str[256];

-

-        local    = frame->local;

-        int_lock = &local->internal_lock;

-

-        afr_print_inodelk (lock, 256, cmd, flock, &frame->root->lk_owner);

-        afr_print_lockee (lockee, 256, &local->loc, local->fd, child_index);

-

-        afr_set_lock_call_type (lock_call_type, lock_call_type_str, int_lock);

-

-        gf_msg (this->name, GF_LOG_INFO, 0, AFR_MSG_LOCK_INFO,

-                "[%s %s] Lock={%s} Lockee={%s} Number={%llu}",

-                lock_call_type_str,

-                lk_op_type == AFR_LOCK_OP ? "LOCK REQUEST" : "UNLOCK REQUEST",

-                lock, lockee,

-                (unsigned long long) int_lock->lock_number);

-

-}

-

-static void

-afr_trace_entrylk_in (call_frame_t *frame, xlator_t *this,

-                      afr_lock_call_type_t lock_call_type,

-                      afr_lock_op_type_t lk_op_type, const char *basename,

-                      int32_t cookie)

-{

-        afr_local_t         *local    = NULL;

-        afr_internal_lock_t *int_lock = NULL;

-        afr_private_t       *priv     = NULL;

-        int                 child_index = 0;

-        int                 lockee_no = 0;

-

-        char lock[256];

-        char lockee[256];

-        char lock_call_type_str[256];

-

-        local    = frame->local;

-        int_lock = &local->internal_lock;

-        priv     = this->private;

-

-        if (!priv->entrylk_trace) {

-                return;

-        }

-        lockee_no = cookie / priv->child_count;

-        child_index = cookie % priv->child_count;

-

-        afr_print_entrylk (lock, 256, basename, &frame->root->lk_owner);

-        afr_print_lockee (lockee, 256, &int_lock->lockee[lockee_no].loc, local->fd,

-                          child_index);

-

-        afr_set_lock_call_type (lock_call_type, lock_call_type_str, int_lock);

-

-        gf_msg (this->name, GF_LOG_INFO, 0, AFR_MSG_LOCK_INFO,

-                "[%s %s] Lock={%s} Lockee={%s} Number={%llu}, Cookie={%d}",

-                lock_call_type_str,

-                lk_op_type == AFR_LOCK_OP ? "LOCK REQUEST" : "UNLOCK REQUEST",

-                lock, lockee,

-                (unsigned long long) int_lock->lock_number,

-                cookie);

-}

-

-static void

-afr_trace_entrylk_out (call_frame_t *frame, xlator_t *this,

-                       afr_lock_call_type_t lock_call_type,

-                       afr_lock_op_type_t lk_op_type, const char *basename,

-                       int op_ret, int op_errno, int32_t cookie)

-{

-        afr_internal_lock_t *int_lock = NULL;

-        afr_local_t         *local    = NULL;

-        afr_private_t       *priv     = NULL;

-        int                 lockee_no = 0;

-        int                 child_index = 0;

-

-        char lock[256];

-        char lockee[256];

-        char lock_call_type_str[256];

-        char verdict[16];

-

-        local    = frame->local;

-        int_lock = &local->internal_lock;

-        priv     = this->private;

-

-        if (!priv->entrylk_trace) {

-                return;

-        }

-        lockee_no = cookie / priv->child_count;

-        child_index = cookie % priv->child_count;

-

-        afr_print_entrylk (lock, 256, basename, &frame->root->lk_owner);

-        afr_print_lockee (lockee, 256, &int_lock->lockee[lockee_no].loc, local->fd,

-                          child_index);

-

-        afr_set_lock_call_type (lock_call_type, lock_call_type_str, int_lock);

-

-        afr_print_verdict (op_ret, op_errno, verdict);

-

-        gf_msg (this->name, GF_LOG_INFO, 0, AFR_MSG_LOCK_INFO,

-                "[%s %s] [%s] Lock={%s} Lockee={%s} Number={%llu} Cookie={%d}",

-                lock_call_type_str,

-                lk_op_type == AFR_LOCK_OP ? "LOCK REPLY" : "UNLOCK REPLY",

-                verdict,

-                lock, lockee,

-                (unsigned long long) int_lock->lock_number,

-                cookie);

-

-}

-

-static int

-transaction_lk_op (afr_local_t *local)

-{

-        afr_internal_lock_t *int_lock = NULL;

-        int ret = -1;

-

-        int_lock = &local->internal_lock;

-

-        if (int_lock->transaction_lk_type == AFR_TRANSACTION_LK) {

-                gf_msg_debug (THIS->name, 0,

-                              "lk op is for a transaction");

-                ret = 1;

-        }

-        else if (int_lock->transaction_lk_type == AFR_SELFHEAL_LK) {

-                gf_msg_debug (THIS->name, 0,

-                              "lk op is for a self heal");

-

-                ret = 0;

-        }

-

-        if (ret == -1)

-                gf_msg_debug (THIS->name, 0,

-                              "lk op is not set");

-

-        return ret;