summaryrefslogtreecommitdiffstats
path: root/xlators/performance/stat-prefetch
diff options
context:
space:
mode:
authorRaghavendra G <raghavendra@gluster.com>2011-06-14 01:41:36 +0000
committerAnand Avati <avati@gluster.com>2011-06-14 22:37:41 -0700
commitaae8ad0cf080ff3e4f704f3bcccef39a07cabb05 (patch)
tree858cde494f4072d865279a16b4b3cdd14f7c2b3e /xlators/performance/stat-prefetch
parente8f67179ca60eb81a4b1fa92e37bd0eb6213d659 (diff)
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
Diffstat (limited to 'xlators/performance/stat-prefetch')
-rw-r--r--xlators/performance/stat-prefetch/src/stat-prefetch.c178
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
};