[Ocfs2-commits] smushran commits r3097 - branches/ocfs2-1.2/fs/ocfs2/dlm
svn-commits at oss.oracle.com
svn-commits at oss.oracle.com
Tue May 6 13:43:50 PDT 2008
Author: smushran
Date: 2008-05-06 13:43:50 -0700 (Tue, 06 May 2008)
New Revision: 3097
Modified:
branches/ocfs2-1.2/fs/ocfs2/dlm/dlmdebug.c
Log:
ocfs2: add dlm_ctxt printing for dlm debugging
cat /proc/fs/ocfs2_dlm/<domain>/ctxt dumps values from dlm_ctxt
useful for debugging
Authored by: Wengang Wang <wen.gang.wang at oracle.com>
Signed-off-by: smushran
Signed-off-by: jlbec
Modified: branches/ocfs2-1.2/fs/ocfs2/dlm/dlmdebug.c
===================================================================
--- branches/ocfs2-1.2/fs/ocfs2/dlm/dlmdebug.c 2008-05-06 20:33:32 UTC (rev 3096)
+++ branches/ocfs2-1.2/fs/ocfs2/dlm/dlmdebug.c 2008-05-06 20:43:50 UTC (rev 3097)
@@ -61,6 +61,8 @@
static int dlm_proc_stats(char *page, char **start, off_t off,
int count, int *eof, void *data);
+static int dlm_proc_ctxts(char *page, char **start, off_t off,
+ int count, int *eof, void *data);
typedef int (dlm_debug_func_t)(const char __user *data, unsigned int len);
@@ -120,6 +122,7 @@
#define OCFS2_DLM_PROC_PATH "fs/ocfs2_dlm"
#define DLM_DEBUG_PROC_NAME "debug"
#define DLM_STAT_PROC_NAME "stat"
+#define DLM_CTXT_PROC_NAME "ctxt"
static struct proc_dir_entry *ocfs2_dlm_proc;
@@ -172,6 +175,164 @@
return len;
}
+static int stringify_nodemap(unsigned long *nodemap, int maxnodes,
+ char *buf, int len)
+{
+ int out = 0;
+ int i = -1;
+
+ while ((i = find_next_bit(nodemap, maxnodes, i + 1)) < maxnodes)
+ out += snprintf(buf + out, len - out, "%d ", i);
+
+ return out;
+}
+
+static int dlm_proc_ctxts(char *page, char **start, off_t off,
+ int count, int *eof, void *data)
+{
+ struct dlm_ctxt *dlm = data;
+ struct dlm_reco_node_data *node;
+ char *state;
+ int lres, rres, ures, tres;
+ int len = 0;
+
+ lres = atomic_read(&dlm->local_resources);
+ rres = atomic_read(&dlm->remote_resources);
+ ures = atomic_read(&dlm->unknown_resources);
+ tres = lres + rres + ures;
+
+ spin_lock(&dlm->spinlock);
+
+ switch (dlm->dlm_state) {
+ case DLM_CTXT_NEW:
+ state = "NEW"; break;
+ case DLM_CTXT_JOINED:
+ state = "JOINED"; break;
+ case DLM_CTXT_IN_SHUTDOWN:
+ state = "SHUTDOWN"; break;
+ case DLM_CTXT_LEAVING:
+ state = "LEAVING"; break;
+ default:
+ state = "UNKNOWN"; break;
+ }
+
+ /* Domain: xxxxxxxxxx Key: 0xdfbac769 */
+ len += snprintf(page + len, count - len,
+ "Domain: %s Key: 0x%08x\n", dlm->name, dlm->key);
+
+ /* Thread Pid: xxx Node: xxx State: xxxxx */
+ len += snprintf(page + len, count - len,
+ "Thread Pid: %d Node: %d State: %s\n",
+ dlm->dlm_thread_task->pid, dlm->node_num, state);
+
+ /* Number of Joins: xxx Joining Node: xxx */
+ len += snprintf(page + len, count - len,
+ "Number of Joins: %d Joining Node: %d\n",
+ dlm->num_joins, dlm->joining_node);
+
+ /* Domain Map: xx xx xx */
+ len += snprintf(page + len, count - len, "Domain Map: ");
+ len += stringify_nodemap(dlm->domain_map, O2NM_MAX_NODES,
+ page + len, count - len);
+ len += snprintf(page + len, count - len, "\n");
+
+ /* Live Map: xx xx xx */
+ len += snprintf(page + len, count - len, "Live Map: ");
+ len += stringify_nodemap(dlm->live_nodes_map, O2NM_MAX_NODES,
+ page + len, count - len);
+ len += snprintf(page + len, count - len, "\n");
+
+ /* Mastered Resources Total: xxx Locally: xxx Remotely: ... */
+ len += snprintf(page + len, count - len,
+ "Mastered Resources Total: %d Locally: %d "
+ "Remotely: %d Unknown: %d\n",
+ tres, lres, rres, ures);
+
+ /* Lists: Dirty=Empty Purge=InUse PendingASTs=Empty ... */
+ len += snprintf(page + len, count - len,
+ "Lists: Dirty=%s Purge=%s PendingASTs=%s "
+ "PendingBASTs=%s Master=%s\n",
+ (list_empty(&dlm->dirty_list) ? "Empty" : "InUse"),
+ (list_empty(&dlm->purge_list) ? "Empty" : "InUse"),
+ (list_empty(&dlm->pending_asts) ? "Empty" : "InUse"),
+ (list_empty(&dlm->pending_basts) ? "Empty" : "InUse"),
+ (list_empty(&dlm->master_list) ? "Empty" : "InUse"));
+
+ /* Purge Count: xxx Refs: xxx */
+ len += snprintf(page + len, count - len,
+ "Purge Count: %d Refs: %d\n", dlm->purge_count,
+ atomic_read(&dlm->dlm_refs.refcount));
+
+ /* Dead Node: xxx */
+ len += snprintf(page + len, count - len,
+ "Dead Node: %d\n", dlm->reco.dead_node);
+
+ /* What about DLM_RECO_STATE_FINALIZE? */
+ if (dlm->reco.state == DLM_RECO_STATE_ACTIVE)
+ state = "ACTIVE";
+ else
+ state = "INACTIVE";
+
+ /* Recovery Pid: xxxx Master: xxx State: xxxx */
+ len += snprintf(page + len, count - len,
+ "Recovery Pid: %d Master: %d State: %s\n",
+ dlm->dlm_reco_thread_task->pid,
+ dlm->reco.new_master, state);
+
+ /* Recovery Map: xx xx */
+ len += snprintf(page + len, count - len, "Recovery Map: ");
+ len += stringify_nodemap(dlm->recovery_map, O2NM_MAX_NODES,
+ page + len, count - len);
+ len += snprintf(page + len, count - len, "\n");
+
+ /* Recovery Node State: */
+ len += snprintf(page + len, count - len, "Recovery Node State:\n");
+ list_for_each_entry(node, &dlm->reco.node_data, list) {
+ switch (node->state) {
+ case DLM_RECO_NODE_DATA_INIT:
+ state = "INIT";
+ break;
+ case DLM_RECO_NODE_DATA_REQUESTING:
+ state = "REQUESTING";
+ break;
+ case DLM_RECO_NODE_DATA_DEAD:
+ state = "DEAD";
+ break;
+ case DLM_RECO_NODE_DATA_RECEIVING:
+ state = "RECEIVING";
+ break;
+ case DLM_RECO_NODE_DATA_REQUESTED:
+ state = "REQUESTED";
+ break;
+ case DLM_RECO_NODE_DATA_DONE:
+ state = "DONE";
+ break;
+ case DLM_RECO_NODE_DATA_FINALIZE_SENT:
+ state = "FINALIZE-SENT";
+ break;
+ default:
+ state = "BAD";
+ break;
+ }
+ len += snprintf(page + len, count - len, "\t%u - %s\n",
+ node->node_num, state);
+ }
+
+ spin_unlock(&dlm->spinlock);
+
+ if (len <= off + count)
+ *eof = 1;
+
+ *start = page + off;
+ len -= off;
+ if (len > count)
+ len = count;
+ if(len < 0)
+ len = 0;
+
+ return len;
+}
+
void dlm_proc_add_domain(struct dlm_ctxt *dlm)
{
struct proc_dir_entry *entry;
@@ -183,6 +344,11 @@
dlm_proc_stats, (char *)dlm);
if (entry)
entry->owner = THIS_MODULE;
+ entry = create_proc_read_entry(DLM_CTXT_PROC_NAME,
+ S_IFREG | S_IRUGO, dlm->dlm_proc,
+ dlm_proc_ctxts, (char *)dlm);
+ if (entry)
+ entry->owner = THIS_MODULE;
}
}
@@ -190,6 +356,7 @@
{
if (dlm->dlm_proc) {
remove_proc_entry(DLM_STAT_PROC_NAME, dlm->dlm_proc);
+ remove_proc_entry(DLM_CTXT_PROC_NAME, dlm->dlm_proc);
remove_proc_entry(dlm->name, ocfs2_dlm_proc);
}
}
More information about the Ocfs2-commits
mailing list