performance/stat-prefetch: dump cache and list of ops waiting for lookup completion.

Signed-off-by: Raghavendra G <raghavendra@gluster.com>
Signed-off-by: Anand Avati <avati@gluster.com>

BUG: 1059 (enhancements for getting statistics from performance translators)
URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=1059

1 files changed, 178 insertions, 0 deletions

diff --git a/xlators/performance/stat-prefetch/src/stat-prefetch.c b/xlators/performance/stat-prefetch/src/stat-prefetch.c
index 43c5f5e72..346d03269 100644
--- a/xlators/performance/stat-prefetch/src/stat-prefetch.c
+++ b/xlators/performance/stat-prefetch/src/stat-prefetch.c
@@ -3988,6 +3988,182 @@ out:
 }
 
 
+struct sp_cache_dump {
+        int i;
+        char *key_prefix;
+};
+typedef struct sp_cache_dump sp_cache_dump_t;
+
+void
+sp_cache_traverse (void *data, void *mydata)
+{
+        gf_dirent_t     *dirent                   = NULL;
+        char             key[GF_DUMP_MAX_BUF_LEN] = {0, };
+        char             uuidbuf[256]             = {0, };
+        sp_cache_dump_t *dump                     = NULL;
+
+        if ((data == NULL) || (mydata == NULL)) {
+                goto out;
+        }
+
+        dirent = data;
+        dump = mydata;
+
+        gf_proc_dump_build_key (key, dump->key_prefix, "entry[%d].name",
+                                dump->i);
+        gf_proc_dump_write (key, "%s", dirent->d_name);
+
+        uuid_unparse (dirent->d_stat.ia_gfid, uuidbuf);
+        gf_proc_dump_build_key (key, dump->key_prefix, "entry[%d].inode.gfid",
+                                dump->i);
+        gf_proc_dump_write (key, "%s", uuidbuf);
+
+        gf_proc_dump_build_key(key, dump->key_prefix, "entry[%d].inode.ino",
+                               dump->i);
+        gf_proc_dump_write(key, "%ld", dirent->d_stat.ia_ino);
+        
+        dump->i++;
+out:
+        return;
+}
+
+
+int32_t
+sp_fdctx_dump (xlator_t *this, fd_t *fd)
+{
+        char            key[GF_DUMP_MAX_BUF_LEN]        = {0, };
+        char            key_prefix[GF_DUMP_MAX_BUF_LEN] = {0, };
+        char            uuidbuf[256]                    = {0, };
+        sp_cache_t     *cache                           = NULL;
+        int32_t         ret                             = -1;
+        sp_cache_dump_t *dump                           = NULL;
+        char            *parent                         = NULL;
+
+        cache = sp_get_cache_fd (this, fd);
+        if (cache == NULL) {
+                ret = 0;
+                goto out;
+        }
+
+        dump = GF_CALLOC(1, sizeof (*dump), gf_common_mt_char);
+        if (dump == NULL) {
+                goto out;
+        }
+
+        gf_proc_dump_build_key (key_prefix,
+                                "xlator.performance.stat-prefetch",
+                                "fdctx");
+        gf_proc_dump_add_section (key_prefix);
+        
+        gf_proc_dump_build_key (key, key_prefix, "fd");
+        gf_proc_dump_write (key, "%p", fd);
+
+        ret = __inode_path (fd->inode, NULL, &parent);
+        if (parent != NULL) {
+                gf_proc_dump_build_key (key, key_prefix, "name");
+                gf_proc_dump_write (key, "%s", parent);
+                GF_FREE (parent);
+        }
+
+        uuid_unparse (fd->inode->gfid, uuidbuf);
+        gf_proc_dump_build_key (key, key_prefix, "fd.inode.gfid");
+        gf_proc_dump_write (key, "%s", uuidbuf);
+
+        gf_proc_dump_build_key (key, key_prefix, "fd.inode.ino");
+        gf_proc_dump_write (key, "%ld", fd->inode->ino);
+
+        gf_proc_dump_build_key (key, key_prefix, "miss");
+        gf_proc_dump_write (key, "%lu", cache->miss);
+
+        gf_proc_dump_build_key (key, key_prefix, "hits");
+        gf_proc_dump_write (key, "%lu", cache->hits);
+
+        gf_proc_dump_build_key (key, key_prefix, "cache"); 
+        dump->key_prefix = key;
+        
+        rbthash_table_traverse (cache->table, sp_cache_traverse, dump);
+
+        GF_FREE (dump);
+        ret = 0;
+out:
+        return ret;
+}
+
+int32_t
+sp_inodectx_dump (xlator_t *this, inode_t *inode)
+{
+        char            key[GF_DUMP_MAX_BUF_LEN]        = {0, };
+        char            key_prefix[GF_DUMP_MAX_BUF_LEN] = {0, };
+        char            uuidbuf[256]                    = {0, };
+        sp_inode_ctx_t *inode_ctx                       = NULL;
+        call_stub_t    *stub                            = NULL;
+        uint64_t        value                           = 0;
+        int32_t         ret                             = -1, i = 0;
+
+        if ((this == NULL) || (inode == NULL)) {
+                goto out;
+        }
+
+        ret = inode_ctx_get (inode, this, &value);
+        if (ret == 0) {
+                inode_ctx = (sp_inode_ctx_t *)(long)value;
+        }
+
+        if (inode_ctx == NULL) {
+                goto out;
+        }
+
+        gf_proc_dump_build_key (key_prefix,
+                                "xlator.performance.stat-prefetch",
+                                "inodectx");
+        gf_proc_dump_add_section (key_prefix);
+        
+        uuid_unparse (inode->gfid, uuidbuf);
+        gf_proc_dump_build_key (key, key_prefix, "inode.gfid");
+        gf_proc_dump_write (key, "%s", uuidbuf);
+
+        gf_proc_dump_build_key (key, key_prefix, "inode.ino");
+        gf_proc_dump_write (key, "%ld", inode->ino);
+
+        LOCK (&inode_ctx->lock);
+        {
+                gf_proc_dump_build_key (key, key_prefix, "looked_up");
+                gf_proc_dump_write (key, "%s",
+                                    inode_ctx->looked_up ? "yes" : "no");
+
+                gf_proc_dump_build_key (key, key_prefix, "lookup_in_progress");
+                gf_proc_dump_write (key, "%s",
+                                    inode_ctx->lookup_in_progress ?
+                                    "yes" : "no");
+
+                gf_proc_dump_build_key (key, key_prefix, "need_unwind");
+                gf_proc_dump_write (key, "%s", inode_ctx->need_unwind ?
+                                    "yes" : "no");
+
+                gf_proc_dump_build_key (key, key_prefix, "op_ret");
+                gf_proc_dump_write (key, "%d", inode_ctx->op_ret);
+
+                gf_proc_dump_build_key (key, key_prefix, "op_errno");
+                gf_proc_dump_write (key, "%d", inode_ctx->op_errno);
+
+                list_for_each_entry (stub, &inode_ctx->waiting_ops, list) {
+                        gf_proc_dump_build_key (key, key_prefix,
+                                                "waiting-ops[%d].frame", i);
+                        gf_proc_dump_write (key, "%"PRId64,
+                                            stub->frame->root->unique);
+
+                        gf_proc_dump_build_key (key, key_prefix,
+                                                "waiting-ops[%d].fop", i);
+                        gf_proc_dump_write (key, "%s", gf_fop_list[stub->fop]);
+ 
+                        i++;
+                }
+        }
+        UNLOCK (&inode_ctx->lock);
+out:
+        return ret;
+}
+
 int
 sp_priv_dump (xlator_t *this)
 {
@@ -4127,4 +4303,6 @@ struct xlator_cbks cbks = {
 
 struct xlator_dumpops dumpops = {
         .priv = sp_priv_dump,
+        .inodectx = sp_inodectx_dump,
+        .fdctx = sp_fdctx_dump
 };