From 07d47befe41ed54c0340e297e7f1ce9bf87bc3e6 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 671/675] 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

Change-Id: Ie33a3c8f9ddbe6741f0950d961af3d4daf497a8a

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

BUG: 1583733

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

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

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

Reviewed-by: Sunil Kumar Heggodu Gopala Acharya <sheggodu@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 +--

 xlators/cluster/afr/src/pump.c            |   3 -

 9 files changed, 41 insertions(+), 763 deletions(-)

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

index bffa71b..708182a 100644

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

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

@@ -4294,9 +4294,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);

@@ -4753,8 +4750,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;

@@ -4770,7 +4766,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:

@@ -4837,8 +4832,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 9099b8c..408c7de 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 c740599..e0f6541 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,14 +357,11 @@ 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;

         int ret = 0;

-        local = frame->local;

-

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

                               prebuf, postbuf, xdata);

@@ -375,7 +372,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

@@ -390,7 +387,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);

                 }

         }

@@ -463,8 +460,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;

@@ -650,8 +645,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);

@@ -774,8 +767,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;

@@ -882,8 +873,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);

@@ -987,8 +976,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);

@@ -1629,8 +1616,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);

@@ -1741,8 +1726,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);

@@ -1854,8 +1837,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);

@@ -1961,8 +1942,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);

@@ -2074,8 +2053,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;

@@ -2186,8 +2163,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;

@@ -2295,8 +2270,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;

@@ -2389,8 +2362,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);

@@ -2483,8 +2454,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);

@@ -2596,8 +2565,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 6019454..38cc87b 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,