From ee0795e32d7b069c925906d4b04c6c045d0f189d Mon Sep 17 00:00:00 2001

From: menakamohan <menaka.m@outlook.com>

Date: Tue, 31 Jan 2017 17:14:30 +0530

Subject: [PATCH 428/473] Added the missing FOPs in the io-stats xlator

Backport of : https://review.gluster.org/16490

The following FOPs are not implemented in the io-stats xlator.

1)fentrylk

2)compound

3)seek

4)lease

5)getactivelk

6)setactivelk

Added the missing FOPs to the io-stats xlator

Change-Id: Ifd8051eb12d81e56342257878e4444379c86cf08

BUG: 1449684

Signed-off-by: Ravishankar N <ravishankar@redhat.com>

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

Reviewed-by: Poornima Gurusiddaiah <pgurusid@redhat.com>

Reviewed-by: Shyam Ranganathan <srangana@redhat.com>

Reviewed-by: Atin Mukherjee <amukherj@redhat.com>

---

 xlators/debug/io-stats/src/io-stats.c | 168 ++++++++++++++++++++++++++++++++++

 1 file changed, 168 insertions(+)

diff --git a/xlators/debug/io-stats/src/io-stats.c b/xlators/debug/io-stats/src/io-stats.c

index 23cab8b..46e1272 100644

--- a/xlators/debug/io-stats/src/io-stats.c

+++ b/xlators/debug/io-stats/src/io-stats.c

@@ -2500,6 +2500,76 @@ io_stats_entrylk_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

         return 0;

 }

+int

+io_stats_fentrylk_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

+                        int32_t op_ret, int32_t op_errno, dict_t *xdata)

+{

+        UPDATE_PROFILE_STATS (frame, FENTRYLK);

+        STACK_UNWIND_STRICT (fentrylk, frame, op_ret, op_errno, xdata);

+        return 0;

+}

+

+int

+io_stats_rchecksum_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

+                       int32_t op_ret, int32_t op_errno, uint32_t weak_checksum,

+                       uint8_t *strong_checksum, dict_t *xdata)

+{

+        UPDATE_PROFILE_STATS (frame, RCHECKSUM);

+        STACK_UNWIND_STRICT (rchecksum, frame, op_ret, op_errno, weak_checksum,

+                            strong_checksum, xdata);

+        return 0;

+}

+

+int

+io_stats_seek_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

+                   int32_t op_ret, int32_t op_errno, off_t offset,

+                   dict_t *xdata)

+{

+        UPDATE_PROFILE_STATS (frame, SEEK);

+        STACK_UNWIND_STRICT (seek, frame, op_ret, op_errno, offset, xdata);

+        return 0;

+}

+

+int

+io_stats_lease_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

+                   int32_t op_ret, int32_t op_errno,

+                   struct gf_lease *lease, dict_t *xdata)

+{

+        UPDATE_PROFILE_STATS (frame, LEASE);

+        STACK_UNWIND_STRICT (lease, frame, op_ret, op_errno, lease, xdata);

+        return 0;

+}

+

+int

+io_stats_getactivelk_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

+                          int32_t op_ret, int32_t op_errno,

+                          lock_migration_info_t *locklist,

+                          dict_t *xdata)

+{

+        UPDATE_PROFILE_STATS (frame, GETACTIVELK);

+        STACK_UNWIND_STRICT (getactivelk, frame, op_ret, op_errno,

+                             locklist, xdata);

+        return 0;

+}

+

+int

+io_stats_setactivelk_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

+                          int32_t op_ret, int32_t op_errno, dict_t *xdata)

+{

+        UPDATE_PROFILE_STATS (frame, SETACTIVELK);

+        STACK_UNWIND_STRICT (setactivelk, frame, op_ret, op_errno, xdata);

+        return 0;

+}

+

+int

+io_stats_compound_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

+                     int32_t op_ret, int32_t op_errno, void *data,

+                     dict_t *xdata)

+{

+        UPDATE_PROFILE_STATS (frame, COMPOUND);

+        STACK_UNWIND_STRICT (compound, frame, op_ret, op_errno, data, xdata);

+        return 0;

+}

 int

 io_stats_xattrop_cbk (call_frame_t *frame, void *cookie, xlator_t *this,

@@ -2544,6 +2614,20 @@ io_stats_entrylk (call_frame_t *frame, xlator_t *this,

         return 0;

 }

+int

+io_stats_fentrylk (call_frame_t *frame, xlator_t *this,

+		    const char *volume, fd_t *fd, const char *basename,

+		    entrylk_cmd cmd, entrylk_type type, dict_t *xdata)

+{

+       START_FOP_LATENCY (frame);

+

+       STACK_WIND (frame, io_stats_fentrylk_cbk,

+		    FIRST_CHILD(this),

+		    FIRST_CHILD(this)->fops->fentrylk,

+		    volume, fd, basename, cmd, type, xdata);

+        return 0;

+}

+

 int

 io_stats_inodelk (call_frame_t *frame, xlator_t *this,

@@ -3368,6 +3452,83 @@ io_stats_lk (call_frame_t *frame, xlator_t *this,

         return 0;

 }

+int

+io_stats_rchecksum (call_frame_t *frame, xlator_t *this,

+                    fd_t *fd, off_t offset, int32_t len, dict_t *xdata)

+{

+        START_FOP_LATENCY (frame);

+

+        STACK_WIND (frame, io_stats_rchecksum_cbk,

+                    FIRST_CHILD(this),

+                    FIRST_CHILD(this)->fops->rchecksum,

+                    fd, offset, len, xdata);

+        return 0;

+}

+

+int

+io_stats_seek (call_frame_t *frame, xlator_t *this, fd_t *fd,

+                off_t offset, gf_seek_what_t what, dict_t *xdata)

+{

+        START_FOP_LATENCY (frame);

+

+        STACK_WIND (frame, io_stats_seek_cbk,

+                    FIRST_CHILD(this),

+                    FIRST_CHILD(this)->fops->seek,

+                    fd, offset, what, xdata);

+        return 0;

+}

+

+int

+io_stats_lease (call_frame_t *frame, xlator_t *this, loc_t *loc,

+                struct gf_lease *lease, dict_t *xdata)

+{

+        START_FOP_LATENCY (frame);

+

+        STACK_WIND (frame, io_stats_lease_cbk,

+                    FIRST_CHILD(this),

+                    FIRST_CHILD(this)->fops->lease,

+                    loc, lease, xdata);

+        return 0;

+}

+

+int

+io_stats_getactivelk (call_frame_t *frame, xlator_t *this, loc_t *loc,

+                      dict_t *xdata)

+{

+        START_FOP_LATENCY (frame);

+

+        STACK_WIND (frame, io_stats_getactivelk_cbk,

+                    FIRST_CHILD(this),

+                    FIRST_CHILD(this)->fops->getactivelk,

+                    loc, xdata);

+        return 0;

+}

+

+int

+io_stats_setactivelk (call_frame_t *frame, xlator_t *this, loc_t *loc,

+                      lock_migration_info_t *locklist, dict_t *xdata)

+{

+        START_FOP_LATENCY (frame);

+

+        STACK_WIND (frame, io_stats_setactivelk_cbk,

+                    FIRST_CHILD(this),

+                    FIRST_CHILD(this)->fops->setactivelk,

+                    loc, locklist, xdata);

+        return 0;

+}

+

+int

+io_stats_compound (call_frame_t *frame, xlator_t *this,

+                   void *args, dict_t *xdata)

+{

+        START_FOP_LATENCY (frame);

+

+        STACK_WIND (frame, io_stats_compound_cbk,

+                    FIRST_CHILD(this),

+                    FIRST_CHILD(this)->fops->compound,

+                    args, xdata);

+        return 0;

+}

 int

 io_stats_release (xlator_t *this, fd_t *fd)

@@ -4033,6 +4194,7 @@ struct xlator_fops fops = {

         .inodelk     = io_stats_inodelk,

         .finodelk    = io_stats_finodelk,

         .entrylk     = io_stats_entrylk,

+        .fentrylk    = io_stats_fentrylk,

         .lookup      = io_stats_lookup,

         .xattrop     = io_stats_xattrop,

         .fxattrop    = io_stats_fxattrop,

@@ -4042,6 +4204,12 @@ struct xlator_fops fops = {

 	.discard     = io_stats_discard,

         .zerofill    = io_stats_zerofill,

         .ipc         = io_stats_ipc,

+        .rchecksum   = io_stats_rchecksum,

+        .seek        = io_stats_seek,

+        .lease       = io_stats_lease,

+        .getactivelk = io_stats_getactivelk,

+        .setactivelk = io_stats_setactivelk,

+        .compound    = io_stats_compound,

 };

 struct xlator_cbks cbks = {

-- 

1.8.3.1