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

ocfs2/cluster: Track process message timing stats for each socket 



Tracks total time taken to process messages received on a socket.

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

fs/ocfs2/cluster/tcp.c

+15 −0
Original line number Diff line number Diff line
@@ -209,6 +209,11 @@ static inline void o2net_set_func_stop_time(struct o2net_sock_container *sc) 
{

	sc->sc_tv_func_stop = ktime_get();

}



static ktime_t o2net_get_func_run_time(struct o2net_sock_container *sc)

{

	return ktime_sub(sc->sc_tv_func_stop, sc->sc_tv_func_start);

}

#else  /* CONFIG_DEBUG_FS */

# define o2net_init_nst(a, b, c, d, e)

# define o2net_set_nst_sock_time(a)
@@ -222,6 +227,7 @@ static inline void o2net_set_func_stop_time(struct o2net_sock_container *sc) 
# define o2net_set_advance_stop_time(a)

# define o2net_set_func_start_time(a)

# define o2net_set_func_stop_time(a)

# define o2net_get_func_run_time(a)		(ktime_t)0

#endif /* CONFIG_DEBUG_FS */



#ifdef CONFIG_OCFS2_FS_STATS
@@ -240,6 +246,13 @@ static void o2net_update_send_stats(struct o2net_send_tracking *nst, 
	sc->sc_send_count++;

}



static void o2net_update_recv_stats(struct o2net_sock_container *sc)

{

	sc->sc_tv_process_total = ktime_add(sc->sc_tv_process_total,

					    o2net_get_func_run_time(sc));

	sc->sc_recv_count++;

}



#else



# define o2net_update_send_stats(a, b)
@@ -1238,6 +1251,8 @@ static int o2net_process_message(struct o2net_sock_container *sc, 
					nmh->nh_func_data, &ret_data);

	o2net_set_func_stop_time(sc);



	o2net_update_recv_stats(sc);



out_respond:

	/* this destroys the hdr, so don't use it after this */

	mutex_lock(&sc->sc_send_lock);

fs/ocfs2/cluster/tcp_internal.h

+2 −0
Original line number Diff line number Diff line
@@ -184,6 +184,8 @@ struct o2net_sock_container { 
	ktime_t			sc_tv_send_total;

	ktime_t			sc_tv_status_total;

	u32			sc_send_count;

	u32			sc_recv_count;

	ktime_t			sc_tv_process_total;

#endif

	struct mutex		sc_send_lock;

};