Return-Path: Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1755908AbZCIWrX (ORCPT ); Mon, 9 Mar 2009 18:47:23 -0400 Received: (majordomo@vger.kernel.org) by vger.kernel.org id S1754810AbZCIWlx (ORCPT ); Mon, 9 Mar 2009 18:41:53 -0400 Received: from cobra.newdream.net ([66.33.216.30]:50073 "EHLO cobra.newdream.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1754158AbZCIWk3 (ORCPT ); Mon, 9 Mar 2009 18:40:29 -0400 From: Sage Weil To: linux-kernel@vger.kernel.org, linux-fsdevel@vger.kernel.org Cc: Sage Weil Subject: [PATCH 19/20] ceph: sysfs Date: Mon, 9 Mar 2009 15:40:38 -0700 Message-Id: <1236638439-6753-20-git-send-email-sage@newdream.net> X-Mailer: git-send-email 1.5.6.5 In-Reply-To: <1236638439-6753-19-git-send-email-sage@newdream.net> References: <1236638439-6753-1-git-send-email-sage@newdream.net> <1236638439-6753-2-git-send-email-sage@newdream.net> <1236638439-6753-3-git-send-email-sage@newdream.net> <1236638439-6753-4-git-send-email-sage@newdream.net> <1236638439-6753-5-git-send-email-sage@newdream.net> <1236638439-6753-6-git-send-email-sage@newdream.net> <1236638439-6753-7-git-send-email-sage@newdream.net> <1236638439-6753-8-git-send-email-sage@newdream.net> <1236638439-6753-9-git-send-email-sage@newdream.net> <1236638439-6753-10-git-send-email-sage@newdream.net> <1236638439-6753-11-git-send-email-sage@newdream.net> <1236638439-6753-12-git-send-email-sage@newdream.net> <1236638439-6753-13-git-send-email-sage@newdream.net> <1236638439-6753-14-git-send-email-sage@newdream.net> <1236638439-6753-15-git-send-email-sage@newdream.net> <1236638439-6753-16-git-send-email-sage@newdream.net> <1236638439-6753-17-git-send-email-sage@newdream.net> <1236638439-6753-18-git-send-email-sage@newdream.net> <1236638439-6753-19-git-send-email-sage@newdream.net> Sender: linux-kernel-owner@vger.kernel.org List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Length: 12597 Lines: 489 Basic state information is available via /sys/fs/ceph, including instances of the client, fsids, current monitor, mds and osd maps, and hooks to adjust debug levels. Signed-off-by: Sage Weil --- fs/ceph/sysfs.c | 465 +++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 465 insertions(+), 0 deletions(-) create mode 100644 fs/ceph/sysfs.c diff --git a/fs/ceph/sysfs.c b/fs/ceph/sysfs.c new file mode 100644 index 0000000..fc107fd --- /dev/null +++ b/fs/ceph/sysfs.c @@ -0,0 +1,465 @@ +#include +#include + +#include "super.h" + +static struct kobject ceph_kobj; + +/* + * default kobject attribute operations. duplicated here from + * kobject.c + */ + +#define DEF_ATTR_OP(name) \ +static ssize_t name##_attr_show(struct kobject *kobj, struct attribute *attr,\ + char *buf) \ +{ \ + struct name##_attr *a = \ + container_of(attr, struct name##_attr, attr); \ + struct name *c = container_of(kobj, struct name, kobj); \ + ssize_t ret = -EIO; \ + \ + if (a->show) \ + ret = a->show(c, a, buf); \ + return ret; \ +} \ + \ +static ssize_t name##_attr_store(struct kobject *kobj, struct attribute *attr, \ + const char *buf, size_t count) \ +{ \ + struct name##_attr *a = container_of(attr, struct name##_attr, attr); \ + struct name *c = container_of(kobj, struct name, kobj); \ + ssize_t ret = -EIO; \ + \ + if (a->store) \ + ret = a->store(c, a, buf, count); \ + return ret; \ +} \ + \ +static struct sysfs_ops name##_sysfs_ops = { \ + .show = name##_attr_show, \ + .store = name##_attr_store, \ +}; \ + \ +static struct kobj_type name##_ops = { \ + .sysfs_ops = &name##_sysfs_ops, \ +}; + +#define ADD_ENTITY_ATTR(ent, a, n, m, sh, st) \ + ent->a.attr.name = n; \ + ent->a.attr.mode = m; \ + ent->a.show = sh; \ + ent->a.store = st; \ + ret = sysfs_create_file(&ent->kobj, &ent->a.attr); + + + +DEF_ATTR_OP(ceph_client) + + +/* + * per-client attributes + */ +#define to_client(c) container_of(c, struct ceph_client, kobj) + +static ssize_t fsid_show(struct ceph_client *client, + struct ceph_client_attr *attr, char *buf) +{ + return sprintf(buf, "%llx.%llx\n", + le64_to_cpu(__ceph_fsid_major(&client->monc.monmap->fsid)), + le64_to_cpu(__ceph_fsid_minor(&client->monc.monmap->fsid))); +} + +static ssize_t monmap_show(struct ceph_client *client, + struct ceph_client_attr *attr, char *buf) +{ + int i, pos; + + if (client->monc.monmap == NULL) + return 0; + + pos = sprintf(buf, "epoch %d\n", client->monc.monmap->epoch); + for (i = 0; i < client->monc.monmap->num_mon; i++) { + struct ceph_entity_inst *inst = + &client->monc.monmap->mon_inst[i]; + + if (pos > PAGE_SIZE - 128) + break; /* be conservative */ + pos += sprintf(buf + pos, "\t%s%d\t%u.%u.%u.%u:%u\n", + ENTITY_NAME(inst->name), + IPQUADPORT(inst->addr.ipaddr)); + } + return pos; +} + +static ssize_t mdsmap_show(struct ceph_client *client, + struct ceph_client_attr *attr, char *buf) +{ + int i, pos; + + if (client->mdsc.mdsmap == NULL) + return 0; + pos = sprintf(buf, "epoch %d\n", client->mdsc.mdsmap->m_epoch); + pos += sprintf(buf + pos, "root %d\n", client->mdsc.mdsmap->m_root); + pos += sprintf(buf + pos, "session_timeout %d\n", + client->mdsc.mdsmap->m_session_timeout); + pos += sprintf(buf + pos, "session_autoclose %d\n", + client->mdsc.mdsmap->m_session_autoclose); + for (i = 0; i < client->mdsc.mdsmap->m_max_mds; i++) { + struct ceph_entity_addr *addr = &client->mdsc.mdsmap->m_addr[i]; + int state = client->mdsc.mdsmap->m_state[i]; + + if (pos > PAGE_SIZE - 128) + break; /* be conservative */ + pos += sprintf(buf+pos, "\tmds%d\t%u.%u.%u.%u:%u\t(%s)\n", + i, + IPQUADPORT(addr->ipaddr), + ceph_mdsmap_state_str(state)); + } + return pos; +} + +static ssize_t osdmap_show(struct ceph_client *client, + struct ceph_client_attr *attr, char *buf) +{ + int i, pos; + + if (client->osdc.osdmap == NULL) + return 0; + pos = sprintf(buf, "epoch %d\n", client->osdc.osdmap->epoch); + pos += sprintf(buf + pos, "pg_num %d / %d\n", + client->osdc.osdmap->pg_num, + client->osdc.osdmap->pg_num_mask); + pos += sprintf(buf + pos, "lpg_num %d / %d\n", + client->osdc.osdmap->lpg_num, + client->osdc.osdmap->lpg_num_mask); + pos += sprintf(buf + pos, "flags%s%s\n", + (client->osdc.osdmap->flags & CEPH_OSDMAP_NEARFULL) ? + " NEARFULL":"", + (client->osdc.osdmap->flags & CEPH_OSDMAP_FULL) ? + " FULL":""); + for (i = 0; i < client->osdc.osdmap->max_osd; i++) { + struct ceph_entity_addr *addr = + &client->osdc.osdmap->osd_addr[i]; + int state = client->osdc.osdmap->osd_state[i]; + char sb[64]; + + if (pos > PAGE_SIZE - 128) + break; /* be conservative */ + pos += sprintf(buf + pos, + "\tosd%d\t%u.%u.%u.%u:%u\t%3d%%\t(%s)\n", + i, IPQUADPORT(addr->ipaddr), + ((client->osdc.osdmap->osd_weight[i]*100) >> 16), + ceph_osdmap_state_str(sb, sizeof(sb), state)); + } + return pos; +} + +static struct kobj_type entity_ops = { + .sysfs_ops = &ceph_client_sysfs_ops, +}; + + +int ceph_sysfs_client_init(struct ceph_client *client) +{ + int ret = 0; + +#if LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 25) + ret = kobject_init_and_add(&client->kobj, &ceph_client_ops, + &ceph_kobj, "client%d", client->whoami); + if (ret) + goto out; + + ret = kobject_init_and_add(&client->mdsc.kobj, &entity_ops, + &client->kobj, "mdsc"); + if (ret) + goto out; + + ADD_ENTITY_ATTR(client, k_fsid, "fsid", 0400, fsid_show, NULL); + ADD_ENTITY_ATTR(client, k_monmap, "monmap", 0400, monmap_show, NULL); + ADD_ENTITY_ATTR(client, k_mdsmap, "mdsmap", 0400, mdsmap_show, NULL); + ADD_ENTITY_ATTR(client, k_osdmap, "osdmap", 0400, osdmap_show, NULL); + return 0; + +out: +#endif + return ret; +} + +void ceph_sysfs_client_cleanup(struct ceph_client *client) +{ +#if LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 25) + kobject_del(&client->mdsc.kobj); + kobject_del(&client->kobj); +#endif +} + +DEF_ATTR_OP(ceph_mds_request) + +static ssize_t req_mds_show(struct ceph_mds_request *req, + struct ceph_mds_request_attr *attr, char *buf) +{ + return sprintf(buf, "%u.%u.%u.%u:%u (%s%d)\n", + IPQUADPORT(req->r_request->hdr.dst.addr.ipaddr), + ENTITY_NAME(req->r_request->hdr.dst.name)); +} + +static ssize_t req_op_show(struct ceph_mds_request *req, + struct ceph_mds_request_attr *attr, char *buf) +{ + int pos = 0, pathlen; + u64 pathbase; + + char *path; + + pos += sprintf(buf, "%s", ceph_mds_op_name(req->r_op)); + + if (req->r_dentry) { + path = ceph_mdsc_build_path(req->r_dentry, &pathlen, &pathbase, -1); + if (path) { + pos += sprintf(buf+pos, " %s", path); + kfree(path); + } + } else if (req->r_path1) { + pos += sprintf(buf+pos, " %s", req->r_path1); + } + + if (req->r_old_dentry) { + path = ceph_mdsc_build_path(req->r_old_dentry, &pathlen, &pathbase, -1); + if (path) { + pos += sprintf(buf+pos, " %s", path); + kfree(path); + } + } else if (req->r_path2 && + req->r_op != CEPH_MDS_OP_FINDINODE) { + pos += sprintf(buf+pos, " %s", req->r_path2); + } + + pos += sprintf(buf+pos, "\n"); + + return pos; +} + +int ceph_sysfs_mds_req_init(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) +{ + int ret = 0; + +#if LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 25) + ret = kobject_init_and_add(&req->kobj, &ceph_mds_request_ops, + &mdsc->kobj, "%d", req->r_tid); + if (ret) + goto out; + + ADD_ENTITY_ATTR(req, k_mds, "mds", 0400, req_mds_show, NULL); + ADD_ENTITY_ATTR(req, k_op, "op", 0400, req_op_show, NULL); + + return 0; + +out: +#endif + return ret; +} + +void ceph_sysfs_mds_req_cleanup(struct ceph_mds_request *req) +{ +#if LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 25) + kobject_del(&req->kobj); +#endif +} + +/* + * ceph attrs + */ +struct ceph_attr { + struct attribute attr; + ssize_t (*show)(struct ceph_attr *, char *); + ssize_t (*store)(struct ceph_attr *, const char *, size_t); + int *val; +}; + +static ssize_t ceph_attr_show(struct kobject *ko, struct attribute *a, + char *buf) +{ + struct ceph_attr *ca = container_of(a, struct ceph_attr, attr); + return ca->show(ca, buf); +} + +static ssize_t ceph_attr_store(struct kobject *ko, struct attribute *a, + const char *buf, size_t len) +{ + struct ceph_attr *ca = container_of(a, struct ceph_attr, attr); + return ca->store(ca, buf, len); +} + +static struct sysfs_ops ceph_sysfs_ops = { + .show = ceph_attr_show, + .store = ceph_attr_store, +}; + +static struct kobj_type ceph_type = { + .sysfs_ops = &ceph_sysfs_ops, +}; + +/* + * simple int attrs (debug levels) + */ +static ssize_t int_attr_show(struct ceph_attr *a, char *buf) +{ + return sprintf(buf, "%d\n", *a->val); +} + +static ssize_t int_attr_store(struct ceph_attr *a, const char *buf, size_t len) +{ + if (sscanf(buf, "%d", a->val) < 1) + return 0; + return len; +} + +#define DECLARE_DEBUG_ATTR(_name) \ + static struct ceph_attr ceph_attr_##_name = { \ + .attr = { .name = __stringify(_name), .mode = 0600 }, \ + .show = int_attr_show, \ + .store = int_attr_store, \ + .val = &ceph_##_name, \ + }; + +DECLARE_DEBUG_ATTR(debug); +DECLARE_DEBUG_ATTR(debug_msgr); +DECLARE_DEBUG_ATTR(debug_console); + +/* + * ceph_debug_mask + */ +struct _debug_mask_name { + int mask; + char *name; +}; + +static struct _debug_mask_name _debug_mask_names[] = { + {DOUT_MASK_ADDR, "addr"}, + {DOUT_MASK_CAPS, "caps"}, + {DOUT_MASK_DIR, "dir"}, + {DOUT_MASK_EXPORT, "export"}, + {DOUT_MASK_FILE, "file"}, + {DOUT_MASK_INODE, "inode"}, + {DOUT_MASK_IOCTL, "ioctl"}, + {DOUT_MASK_MDSC, "mdsc"}, + {DOUT_MASK_MDSMAP, "mdsmap"}, + {DOUT_MASK_MSGR, "msgr"}, + {DOUT_MASK_MON, "mon"}, + {DOUT_MASK_OSDC, "osdc"}, + {DOUT_MASK_OSDMAP, "osdmap"}, + {DOUT_MASK_SNAP, "snap"}, + {DOUT_MASK_SUPER, "super"}, + {DOUT_MASK_PROTOCOL, "protocol"}, + {DOUT_MASK_PROC, "proc"}, + {DOUT_MASK_TOOLS, "tools"}, + {0, NULL} +}; + +static ssize_t debug_mask_show(struct ceph_attr *a, char *buf) +{ + int i = 0, pos; + + pos = sprintf(buf, "0x%x", ceph_debug_mask); + + while (_debug_mask_names[i].mask) { + if (ceph_debug_mask & _debug_mask_names[i].mask) + pos += sprintf(buf+pos, " %s", + _debug_mask_names[i].name); + i++; + } + pos += sprintf(buf+pos, "\n"); + return pos; +} + +static int get_debug_mask(const char *name, int len) +{ + int i = 0; + + while (_debug_mask_names[i].name) { + if (strncmp(_debug_mask_names[i].name, name, len) == 0) + return _debug_mask_names[i].mask; + i++; + } + return 0; +} + +static ssize_t debug_mask_store(struct ceph_attr *a, const char *buf, + size_t len) +{ + const char *next = buf, *tok; + + while (1) { + tok = next; + next = strpbrk(tok, " \t\r\n"); + if (!next) + break; + if (isdigit(*tok)) { + ceph_debug_mask = simple_strtol(tok, NULL, 0); + } else { + int remove = 0; + int mask; + + if (*tok == '-') { + remove = 1; + tok++; + } else if (*tok == '+') + tok++; + mask = get_debug_mask(tok, next-tok); + if (mask) { + if (remove) + ceph_debug_mask &= ~mask; + else + ceph_debug_mask |= mask; + } + } + next++; + } + + return len; +} + +static struct ceph_attr ceph_attr_debug_mask = { + .attr = { .name = "debug_mask", .mode = 0600 }, + .show = debug_mask_show, + .store = debug_mask_store, +}; + +int ceph_sysfs_init(void) +{ +#if LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 25) + int ret; + + ret = kobject_init_and_add(&ceph_kobj, &ceph_type, fs_kobj, "ceph"); + if (ret) + goto out; + ret = sysfs_create_file(&ceph_kobj, &ceph_attr_debug.attr); + if (ret) + goto out_del; + ret = sysfs_create_file(&ceph_kobj, &ceph_attr_debug_msgr.attr); + if (ret) + goto out_del; + ret = sysfs_create_file(&ceph_kobj, &ceph_attr_debug_console.attr); + if (ret) + goto out_del; + ret = sysfs_create_file(&ceph_kobj, &ceph_attr_debug_mask.attr); + if (ret) + goto out_del; + return 0; + +out_del: + kobject_del(&ceph_kobj); +out: + return ret; +#else + return 0; +#endif +} + +void ceph_sysfs_cleanup(void) +{ +#if LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 25) + kobject_del(&ceph_kobj); +#endif +} -- 1.5.6.5 -- To unsubscribe from this list: send the line "unsubscribe linux-kernel" in the body of a message to majordomo@vger.kernel.org More majordomo info at http://vger.kernel.org/majordomo-info.html Please read the FAQ at http://www.tux.org/lkml/