Commit db02754c authored by Sunil Mushran's avatar Sunil Mushran Committed by Joel Becker
Browse files

ocfs2/cluster: Show o2net timing statistics 



Adds debugfs dentry o2net/stats to show the o2net timing statistics.

Signed-off-by: default avatarSunil Mushran <sunil.mushran@oracle.com>
Signed-off-by: default avatarJoel Becker <joel.becker@oracle.com>
parent e453039f

fs/ocfs2/cluster/netdebug.c

+157 −54
Original line number Diff line number Diff line
@@ -46,10 +46,15 @@ 
#define O2NET_DEBUG_DIR		"o2net"

#define SC_DEBUG_NAME		"sock_containers"

#define NST_DEBUG_NAME		"send_tracking"

#define STATS_DEBUG_NAME	"stats"



#define SHOW_SOCK_CONTAINERS	0

#define SHOW_SOCK_STATS		1



static struct dentry *o2net_dentry;

static struct dentry *sc_dentry;

static struct dentry *nst_dentry;

static struct dentry *stats_dentry;



static DEFINE_SPINLOCK(o2net_debug_lock);
@@ -232,6 +237,11 @@ void o2net_debug_del_sc(struct o2net_sock_container *sc) 
	spin_unlock(&o2net_debug_lock);

}



struct o2net_sock_debug {

	int dbg_ctxt;

	struct o2net_sock_container *dbg_sock;

};



static struct o2net_sock_container

			*next_sc(struct o2net_sock_container *sc_start)

{
@@ -257,7 +267,8 @@ static struct o2net_sock_container 


static void *sc_seq_start(struct seq_file *seq, loff_t *pos)

{

	struct o2net_sock_container *sc, *dummy_sc = seq->private;

	struct o2net_sock_debug *sd = seq->private;

	struct o2net_sock_container *sc, *dummy_sc = sd->dbg_sock;



	spin_lock(&o2net_debug_lock);

	sc = next_sc(dummy_sc);
@@ -268,7 +279,8 @@ static void *sc_seq_start(struct seq_file *seq, loff_t *pos) 


static void *sc_seq_next(struct seq_file *seq, void *v, loff_t *pos)

{

	struct o2net_sock_container *sc, *dummy_sc = seq->private;

	struct o2net_sock_debug *sd = seq->private;

	struct o2net_sock_container *sc, *dummy_sc = sd->dbg_sock;



	spin_lock(&o2net_debug_lock);

	sc = next_sc(dummy_sc);
@@ -280,19 +292,49 @@ static void *sc_seq_next(struct seq_file *seq, void *v, loff_t *pos) 
	return sc; /* unused, just needs to be null when done */

}



static int sc_seq_show(struct seq_file *seq, void *v)

#ifdef CONFIG_OCFS2_FS_STATS

# define sc_send_count(_s)		((_s)->sc_send_count)

# define sc_recv_count(_s)		((_s)->sc_recv_count)

# define sc_tv_acquiry_total_ns(_s)	(ktime_to_ns((_s)->sc_tv_acquiry_total))

# define sc_tv_send_total_ns(_s)	(ktime_to_ns((_s)->sc_tv_send_total))

# define sc_tv_status_total_ns(_s)	(ktime_to_ns((_s)->sc_tv_status_total))

# define sc_tv_process_total_ns(_s)	(ktime_to_ns((_s)->sc_tv_process_total))

#else

# define sc_send_count(_s)		(0U)

# define sc_recv_count(_s)		(0U)

# define sc_tv_acquiry_total_ns(_s)	(0LL)

# define sc_tv_send_total_ns(_s)	(0LL)

# define sc_tv_status_total_ns(_s)	(0LL)

# define sc_tv_process_total_ns(_s)	(0LL)

#endif



/* So that debugfs.ocfs2 can determine which format is being used */

#define O2NET_STATS_STR_VERSION		1

static void sc_show_sock_stats(struct seq_file *seq,

			       struct o2net_sock_container *sc)

{

	struct o2net_sock_container *sc, *dummy_sc = seq->private;

	if (!sc)

		return;



	spin_lock(&o2net_debug_lock);

	sc = next_sc(dummy_sc);

	seq_printf(seq, "%d,%u,%lu,%lld,%lld,%lld,%lu,%lld\n", O2NET_STATS_STR_VERSION,

		   sc->sc_node->nd_num, (unsigned long)sc_send_count(sc),

		   (long long)sc_tv_acquiry_total_ns(sc),

		   (long long)sc_tv_send_total_ns(sc),

		   (long long)sc_tv_status_total_ns(sc),

		   (unsigned long)sc_recv_count(sc),

		   (long long)sc_tv_process_total_ns(sc));

}



	if (sc != NULL) {

static void sc_show_sock_container(struct seq_file *seq,

				   struct o2net_sock_container *sc)

{

	struct inet_sock *inet = NULL;



	__be32 saddr = 0, daddr = 0;

	__be16 sport = 0, dport = 0;



	if (!sc)

		return;



	if (sc->sc_sock) {

		inet = inet_sk(sc->sc_sock->sk);

		/* the stack's structs aren't sparse endian clean */
@@ -336,6 +378,20 @@ static int sc_seq_show(struct seq_file *seq, void *v) 
		   sc->sc_msg_type);

}



static int sc_seq_show(struct seq_file *seq, void *v)

{

	struct o2net_sock_debug *sd = seq->private;

	struct o2net_sock_container *sc, *dummy_sc = sd->dbg_sock;



	spin_lock(&o2net_debug_lock);

	sc = next_sc(dummy_sc);



	if (sc) {

		if (sd->dbg_ctxt == SHOW_SOCK_CONTAINERS)

			sc_show_sock_container(seq, sc);

		else

			sc_show_sock_stats(seq, sc);

	}



	spin_unlock(&o2net_debug_lock);
@@ -353,7 +409,7 @@ static const struct seq_operations sc_seq_ops = { 
	.show = sc_seq_show,

};



static int sc_fop_open(struct inode *inode, struct file *file)

static int sc_common_open(struct file *file, struct o2net_sock_debug *sd)

{

	struct o2net_sock_container *dummy_sc;

	struct seq_file *seq;
@@ -371,7 +427,8 @@ static int sc_fop_open(struct inode *inode, struct file *file) 
		goto out;



	seq = file->private_data;

	seq->private = dummy_sc;

	seq->private = sd;

	sd->dbg_sock = dummy_sc;

	o2net_debug_add_sc(dummy_sc);



	dummy_sc = NULL;
@@ -384,12 +441,48 @@ static int sc_fop_open(struct inode *inode, struct file *file) 
static int sc_fop_release(struct inode *inode, struct file *file)

{

	struct seq_file *seq = file->private_data;

	struct o2net_sock_container *dummy_sc = seq->private;

	struct o2net_sock_debug *sd = seq->private;

	struct o2net_sock_container *dummy_sc = sd->dbg_sock;



	o2net_debug_del_sc(dummy_sc);

	return seq_release_private(inode, file);

}



static int stats_fop_open(struct inode *inode, struct file *file)

{

	struct o2net_sock_debug *sd;



	sd = kmalloc(sizeof(struct o2net_sock_debug), GFP_KERNEL);

	if (sd == NULL)

		return -ENOMEM;



	sd->dbg_ctxt = SHOW_SOCK_STATS;

	sd->dbg_sock = NULL;



	return sc_common_open(file, sd);

}



static const struct file_operations stats_seq_fops = {

	.open = stats_fop_open,

	.read = seq_read,

	.llseek = seq_lseek,

	.release = sc_fop_release,

};



static int sc_fop_open(struct inode *inode, struct file *file)

{

	struct o2net_sock_debug *sd;



	sd = kmalloc(sizeof(struct o2net_sock_debug), GFP_KERNEL);

	if (sd == NULL)

		return -ENOMEM;



	sd->dbg_ctxt = SHOW_SOCK_CONTAINERS;

	sd->dbg_sock = NULL;



	return sc_common_open(file, sd);

}



static const struct file_operations sc_seq_fops = {

	.open = sc_fop_open,

	.read = seq_read,
@@ -421,8 +514,17 @@ int o2net_debugfs_init(void) 
		goto bail;

	}



	stats_dentry = debugfs_create_file(STATS_DEBUG_NAME, S_IFREG|S_IRUSR,

					   o2net_dentry, NULL,

					   &stats_seq_fops);

	if (!stats_dentry) {

		mlog_errno(-ENOMEM);

		goto bail;

	}



	return 0;

bail:

	debugfs_remove(stats_dentry);

	debugfs_remove(sc_dentry);

	debugfs_remove(nst_dentry);

	debugfs_remove(o2net_dentry);
@@ -431,6 +533,7 @@ int o2net_debugfs_init(void) 


void o2net_debugfs_exit(void)

{

	debugfs_remove(stats_dentry);

	debugfs_remove(sc_dentry);

	debugfs_remove(nst_dentry);

	debugfs_remove(o2net_dentry);