diff options
Diffstat (limited to 'xlators/mgmt/glusterd/src/glusterd-statedump.c')
| -rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-statedump.c | 243 |
1 files changed, 243 insertions, 0 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-statedump.c b/xlators/mgmt/glusterd/src/glusterd-statedump.c new file mode 100644 index 00000000000..225d10cc546 --- /dev/null +++ b/xlators/mgmt/glusterd/src/glusterd-statedump.c @@ -0,0 +1,243 @@ +/* + Copyright (c) 2014 Red Hat, Inc. <http://www.redhat.com> + This file is part of GlusterFS. + + This file is licensed to you under your choice of the GNU Lesser + General Public License, version 3 or any later version (LGPLv3 or + later), or the GNU General Public License, version 2 (GPLv2), in all + cases as published by the Free Software Foundation. +*/ + +#include <glusterfs/statedump.h> +#include "glusterd.h" +#include "glusterd-shd-svc.h" +#include "glusterd-quotad-svc.h" +#include "glusterd-locks.h" +#include "glusterd-messages.h" + +static void +glusterd_dump_peer(glusterd_peerinfo_t *peerinfo, char *input_key, int index, + gf_boolean_t xpeers) +{ + char subkey[GF_DUMP_MAX_BUF_LEN + 11] = ""; + char key[GF_DUMP_MAX_BUF_LEN] = ""; + + strncpy(key, input_key, sizeof(key) - 1); + + snprintf(subkey, sizeof(subkey), "%s%d", key, index); + + gf_proc_dump_build_key(key, subkey, "uuid"); + gf_proc_dump_write(key, "%s", uuid_utoa(peerinfo->uuid)); + + gf_proc_dump_build_key(key, subkey, "hostname"); + gf_proc_dump_write(key, "%s", peerinfo->hostname); + + gf_proc_dump_build_key(key, subkey, "port"); + gf_proc_dump_write(key, "%d", peerinfo->port); + + gf_proc_dump_build_key(key, subkey, "state"); + gf_proc_dump_write(key, "%d", peerinfo->state.state); + + gf_proc_dump_build_key(key, subkey, "quorum-action"); + gf_proc_dump_write(key, "%d", peerinfo->quorum_action); + + gf_proc_dump_build_key(key, subkey, "quorum-contrib"); + gf_proc_dump_write(key, "%d", peerinfo->quorum_contrib); + + gf_proc_dump_build_key(key, subkey, "detaching"); + gf_proc_dump_write(key, "%d", peerinfo->detaching); + + gf_proc_dump_build_key(key, subkey, "locked"); + gf_proc_dump_write(key, "%d", peerinfo->locked); +} + +static void +glusterd_dump_peer_rpcstat(glusterd_peerinfo_t *peerinfo, char *input_key, + int index) +{ + rpc_clnt_connection_t *conn = NULL; + int ret = -1; + rpc_clnt_t *rpc = NULL; + char rpcsvc_peername[RPCSVC_PEER_STRLEN] = ""; + char subkey[GF_DUMP_MAX_BUF_LEN + 11] = ""; + char key[GF_DUMP_MAX_BUF_LEN] = ""; + + strncpy(key, input_key, sizeof(key) - 1); + + /* Dump the rpc connection statistics */ + rpc = peerinfo->rpc; + if (rpc) { + conn = &rpc->conn; + snprintf(subkey, sizeof(subkey), "%s%d", key, index); + ret = rpcsvc_transport_peername(conn->trans, (char *)&rpcsvc_peername, + sizeof(rpcsvc_peername)); + if (!ret) { + gf_proc_dump_build_key(key, subkey, "rpc.peername"); + gf_proc_dump_write(key, "%s", rpcsvc_peername); + } + gf_proc_dump_build_key(key, subkey, "rpc.connected"); + gf_proc_dump_write(key, "%d", conn->connected); + + gf_proc_dump_build_key(key, subkey, "rpc.total-bytes-read"); + gf_proc_dump_write(key, "%" PRIu64, conn->trans->total_bytes_read); + + gf_proc_dump_build_key(key, subkey, "rpc.total-bytes-written"); + gf_proc_dump_write(key, "%" PRIu64, conn->trans->total_bytes_write); + + gf_proc_dump_build_key(key, subkey, "rpc.ping_msgs_sent"); + gf_proc_dump_write(key, "%" PRIu64, conn->pingcnt); + + gf_proc_dump_build_key(key, subkey, "rpc.msgs_sent"); + gf_proc_dump_write(key, "%" PRIu64, conn->msgcnt); + } +} + +static void +glusterd_dump_client_details(glusterd_conf_t *conf) +{ + rpc_transport_t *xprt = NULL; + char key[GF_DUMP_MAX_BUF_LEN] = ""; + char subkey[50] = ""; + int index = 1; + + pthread_mutex_lock(&conf->xprt_lock); + { + list_for_each_entry(xprt, &conf->xprt_list, list) + { + snprintf(subkey, sizeof(subkey), "glusterd.client%d", index); + + gf_proc_dump_build_key(key, subkey, "identifier"); + gf_proc_dump_write(key, "%s", xprt->peerinfo.identifier); + + gf_proc_dump_build_key(key, subkey, "volname"); + gf_proc_dump_write(key, "%s", xprt->peerinfo.volname); + + gf_proc_dump_build_key(key, subkey, "max-op-version"); + gf_proc_dump_write(key, "%u", xprt->peerinfo.max_op_version); + + gf_proc_dump_build_key(key, subkey, "min-op-version"); + gf_proc_dump_write(key, "%u", xprt->peerinfo.min_op_version); + index++; + } + } + pthread_mutex_unlock(&conf->xprt_lock); +} + +/* The following function is just for dumping mgmt_v3_lock dictionary, any other + * dict passed to this API will not work */ + +static void +glusterd_dict_mgmt_v3_lock_statedump(dict_t *dict) +{ + int ret = 0; + int dumplen = 0; + data_pair_t *trav = NULL; + char key[GF_DUMP_MAX_BUF_LEN] = ""; + char dump[64 * 1024] = ""; + + if (!dict) { + gf_msg_callingfn("glusterd", GF_LOG_WARNING, EINVAL, GD_MSG_DICT_EMPTY, + "dict NULL"); + goto out; + } + for (trav = dict->members_list; trav; trav = trav->next) { + if (strstr(trav->key, "debug.last-success-bt") != NULL) { + ret = snprintf(&dump[dumplen], sizeof(dump) - dumplen, "\n\t%s:%s", + trav->key, trav->value->data); + } else { + ret = snprintf( + &dump[dumplen], sizeof(dump) - dumplen, "\n\t%s:%s", trav->key, + uuid_utoa(((glusterd_mgmt_v3_lock_obj *)(trav->value->data)) + ->lock_owner)); + } + if ((ret == -1) || !ret) + return; + dumplen += ret; + } + + if (dumplen) { + gf_proc_dump_build_key(key, "glusterd", "mgmt_v3_lock"); + gf_proc_dump_write(key, "%s", dump); + } + +out: + return; +} + +int +glusterd_dump_priv(xlator_t *this) +{ + glusterd_conf_t *priv = NULL; + char key[GF_DUMP_MAX_BUF_LEN] = ""; + int port = 0; + struct pmap_registry *pmap = NULL; + + GF_VALIDATE_OR_GOTO("glusterd", this, out); + + priv = this->private; + if (!priv) + return 0; + + gf_proc_dump_build_key(key, "xlator.glusterd", "priv"); + gf_proc_dump_add_section("%s", key); + + pthread_mutex_lock(&priv->mutex); + { + gf_proc_dump_build_key(key, "glusterd", "my-uuid"); + gf_proc_dump_write(key, "%s", uuid_utoa(priv->uuid)); + + gf_proc_dump_build_key(key, "glusterd", "working-directory"); + gf_proc_dump_write(key, "%s", priv->workdir); + + gf_proc_dump_build_key(key, "glusterd", "max-op-version"); + gf_proc_dump_write(key, "%d", GD_OP_VERSION_MAX); + + gf_proc_dump_build_key(key, "glusterd", "min-op-version"); + gf_proc_dump_write(key, "%d", GD_OP_VERSION_MIN); + + gf_proc_dump_build_key(key, "glusterd", "current-op-version"); + gf_proc_dump_write(key, "%d", priv->op_version); + + gf_proc_dump_build_key(key, "glusterd", "ping-timeout"); + gf_proc_dump_write(key, "%d", priv->ping_timeout); +#ifdef BUILD_GNFS + gf_proc_dump_build_key(key, "glusterd", "nfs.online"); + gf_proc_dump_write(key, "%d", priv->nfs_svc.online); +#endif + gf_proc_dump_build_key(key, "glusterd", "quotad.online"); + gf_proc_dump_write(key, "%d", priv->quotad_svc.online); + + gf_proc_dump_build_key(key, "glusterd", "bitd.online"); + gf_proc_dump_write(key, "%d", priv->bitd_svc.online); + + gf_proc_dump_build_key(key, "glusterd", "scrub.online"); + gf_proc_dump_write(key, "%d", priv->scrub_svc.online); + + /* Dump peer details */ + GLUSTERD_DUMP_PEERS(&priv->peers, uuid_list, _gf_false); + + /* Dump pmap data structure from base port to last alloc */ + pmap = priv->pmap; + if (pmap) { + for (port = pmap->base_port; port <= pmap->last_alloc; port++) { + gf_proc_dump_build_key(key, "glusterd", "pmap_port"); + gf_proc_dump_write(key, "%d", port); + gf_proc_dump_build_key(key, "glusterd", "pmap[%d].type", port); + gf_proc_dump_write(key, "%d", pmap->ports[port].type); + gf_proc_dump_build_key(key, "glusterd", "pmap[%d].brickname", + port); + gf_proc_dump_write(key, "%s", pmap->ports[port].brickname); + } + } + /* Dump client details */ + glusterd_dump_client_details(priv); + + /* Dump mgmt_v3_lock from the dictionary if any */ + glusterd_dict_mgmt_v3_lock_statedump(priv->mgmt_v3_lock); + dict_dump_to_statedump(priv->opts, "options", "glusterd"); + } + pthread_mutex_unlock(&priv->mutex); + +out: + return 0; +} |