summaryrefslogtreecommitdiffstats
path: root/xlators/mgmt/glusterd
diff options
context:
space:
mode:
Diffstat (limited to 'xlators/mgmt/glusterd')
-rw-r--r--xlators/mgmt/glusterd/src/glusterd-locks.c12
-rw-r--r--xlators/mgmt/glusterd/src/glusterd.c223
-rw-r--r--xlators/mgmt/glusterd/src/glusterd.h30
3 files changed, 261 insertions, 4 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-locks.c b/xlators/mgmt/glusterd/src/glusterd-locks.c
index b2629fd87b8..1f1de2ae4f0 100644
--- a/xlators/mgmt/glusterd/src/glusterd-locks.c
+++ b/xlators/mgmt/glusterd/src/glusterd-locks.c
@@ -661,6 +661,18 @@ glusterd_mgmt_v3_unlock (const char *name, uuid_t uuid, char *type)
/* Removing the mgmt_v3 lock from the global list */
dict_del (priv->mgmt_v3_lock, key);
+ /* Remove the backtrace key as well */
+ ret = snprintf (key, sizeof(key), "debug.last-success-bt-%s-%s", name,
+ type);
+ if (ret != strlen ("debug.last-success-bt-") + strlen (name) +
+ strlen (type) + 1) {
+ gf_log (this->name, GF_LOG_ERROR, "Unable to create backtrace "
+ "key");
+ ret = -1;
+ goto out;
+ }
+ dict_del (priv->mgmt_v3_lock, key);
+
gf_log (this->name, GF_LOG_DEBUG,
"Lock for %s %s successfully released",
type, name);
diff --git a/xlators/mgmt/glusterd/src/glusterd.c b/xlators/mgmt/glusterd/src/glusterd.c
index b9a43cd32ce..df1ff41f4ef 100644
--- a/xlators/mgmt/glusterd/src/glusterd.c
+++ b/xlators/mgmt/glusterd/src/glusterd.c
@@ -277,13 +277,227 @@ glusterd_fetchsnap_notify (xlator_t *this)
return ret;
}
-int
-glusterd_priv (xlator_t *this)
+void
+glusterd_dump_peer (glusterd_peerinfo_t *peerinfo, char *input_key, int index,
+ gf_boolean_t xpeers)
{
- return 0;
+ char subkey[50] = {0,};
+ char key[GF_DUMP_MAX_BUF_LEN] = {0,};
+
+ strcpy (key, input_key);
+
+ 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, "%d", 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);
+
+}
+
+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] = {0,};
+ char subkey[50] = {0,};
+ char key[GF_DUMP_MAX_BUF_LEN] = {0,};
+
+ strcpy (key, input_key);
+
+ /* 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] = {0,};
+ char subkey[50] = {0,};
+ 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] = {0,};
+ char dump[64*1024] = {0,};
+
+ if (!dict) {
+ gf_log_callingfn ("glusterd", GF_LOG_WARNING, "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)
+{
+ int index = 1;
+ glusterd_conf_t *priv = NULL;
+ char key[GF_DUMP_MAX_BUF_LEN] = {0,};
+ char subkey[50] = {0,};
+ glusterd_peerinfo_t *peerinfo = NULL;
+ glusterd_volinfo_t *volinfo = 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 (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);
+
+ gf_proc_dump_build_key (key, "glusterd", "shd.online");
+ gf_proc_dump_write (key, "%d", priv->shd->online);
+
+ gf_proc_dump_build_key (key, "glusterd", "nfs.online");
+ gf_proc_dump_write (key, "%d", priv->nfs->online);
+
+ gf_proc_dump_build_key (key, "glusterd", "quotad.online");
+ gf_proc_dump_write (key, "%d", priv->quotad->online);
+
+ GLUSTERD_DUMP_PEERS (&priv->peers, uuid_list, _gf_false);
+ GLUSTERD_DUMP_PEERS (&priv->xaction_peers, op_peers_list,
+ _gf_true);
+ glusterd_dump_client_details (priv);
+ 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;
+}
int32_t
mem_acct_init (xlator_t *this)
@@ -1446,6 +1660,7 @@ init (xlator_t *this)
GF_VALIDATE_OR_GOTO(this->name, conf->quotad, out);
INIT_LIST_HEAD (&conf->peers);
+ INIT_LIST_HEAD (&conf->xaction_peers);
INIT_LIST_HEAD (&conf->volumes);
INIT_LIST_HEAD (&conf->snapshots);
INIT_LIST_HEAD (&conf->missed_snaps_list);
@@ -1630,7 +1845,7 @@ struct xlator_fops fops;
struct xlator_cbks cbks;
struct xlator_dumpops dumpops = {
- .priv = glusterd_priv,
+ .priv = glusterd_dump_priv,
};
diff --git a/xlators/mgmt/glusterd/src/glusterd.h b/xlators/mgmt/glusterd/src/glusterd.h
index 846603585b1..64fe63933a5 100644
--- a/xlators/mgmt/glusterd/src/glusterd.h
+++ b/xlators/mgmt/glusterd/src/glusterd.h
@@ -624,6 +624,28 @@ typedef ssize_t (*gd_serialize_t) (struct iovec outmsg, void *args);
*snap_volname_ptr = '\0'; \
} while (0)
+#define GLUSTERD_DUMP_PEERS(head, member, xpeers) do { \
+ glusterd_peerinfo_t *_peerinfo = NULL; \
+ char subkey[50] = {0,}; \
+ int index = 1; \
+ char key[GF_DUMP_MAX_BUF_LEN] = {0,}; \
+ \
+ if (!xpeers) \
+ snprintf (key, sizeof (key), "glusterd.peer"); \
+ else \
+ snprintf (key, sizeof (key), \
+ "glusterd.xaction_peer"); \
+ \
+ list_for_each_entry (_peerinfo, head, member) { \
+ glusterd_dump_peer (_peerinfo, key, index, xpeers); \
+ if (!xpeers) \
+ glusterd_dump_peer_rpcstat (_peerinfo, key, \
+ index); \
+ index++; \
+ } \
+ \
+ } while (0)
+
int glusterd_uuid_init();
int glusterd_uuid_generate_save ();
@@ -1057,4 +1079,12 @@ glusterd_add_brick_status_to_dict (dict_t *dict, glusterd_volinfo_t *volinfo,
int32_t
glusterd_handle_snap_limit (dict_t *dict, dict_t *rsp_dict);
+void
+glusterd_dump_peer (glusterd_peerinfo_t *peerinfo, char *key, int index,
+ gf_boolean_t xpeers);
+
+void
+glusterd_dump_peer_rpcstat (glusterd_peerinfo_t *peerinfo, char *key,
+ int index);
+
#endif
generated by cgit (git 2.34.1) at 2024-11-16 14:21:46 +0000