You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2014/04/11 23:04:14 UTC
svn commit: r1586774 - in /qpid/dispatch/trunk: src/router_agent.c
tools/qdstat.in
Author: tross
Date: Fri Apr 11 21:04:14 2014
New Revision: 1586774
URL: http://svn.apache.org/r1586774
Log:
NO-JIRA - Added fifo-depths to the link display in qdstat
Modified:
qpid/dispatch/trunk/src/router_agent.c
qpid/dispatch/trunk/tools/qdstat.in
Modified: qpid/dispatch/trunk/src/router_agent.c
URL: http://svn.apache.org/viewvc/qpid/dispatch/trunk/src/router_agent.c?rev=1586774&r1=1586773&r2=1586774&view=diff
==============================================================================
--- qpid/dispatch/trunk/src/router_agent.c (original)
+++ qpid/dispatch/trunk/src/router_agent.c Fri Apr 11 21:04:14 2014
@@ -56,6 +56,8 @@ static void qd_router_schema_handler(voi
qd_agent_value_string(cor, 0, "link-type");
qd_agent_value_string(cor, 0, "link-dir");
qd_agent_value_string(cor, 0, "owning-addr");
+ qd_agent_value_string(cor, 0, "event-fifo-depth");
+ qd_agent_value_string(cor, 0, "msg-fifo-depth");
break;
case QD_ROUTER_CLASS_NODE:
@@ -145,6 +147,9 @@ static void qd_router_query_link(qd_rout
else
qd_agent_value_null(cor, "owning-addr");
+ qd_agent_value_uint(cor, "event-fifo-depth", DEQ_SIZE(link->event_fifo));
+ qd_agent_value_uint(cor, "msg-fifo-depth", DEQ_SIZE(link->msg_fifo));
+
link = DEQ_NEXT(link);
qd_agent_value_complete(cor, link != 0);
}
Modified: qpid/dispatch/trunk/tools/qdstat.in
URL: http://svn.apache.org/viewvc/qpid/dispatch/trunk/tools/qdstat.in?rev=1586774&r1=1586773&r2=1586774&view=diff
==============================================================================
--- qpid/dispatch/trunk/tools/qdstat.in (original)
+++ qpid/dispatch/trunk/tools/qdstat.in Fri Apr 11 21:04:14 2014
@@ -212,6 +212,8 @@ class BusManager:
heads.append(Header("class"))
heads.append(Header("addr"))
heads.append(Header("phase"))
+ heads.append(Header("event-fifo"))
+ heads.append(Header("msg-fifo"))
rows = []
objects = self._get_object('org.apache.qpid.dispatch.router.link')
@@ -227,6 +229,11 @@ class BusManager:
row.append(self._addr_class(link['owning-addr']))
row.append(self._addr_text(link['owning-addr']))
row.append(self._addr_phase(link['owning-addr']))
+ row.append(link['event-fifo-depth'])
+ if link['link-dir'] == 'out':
+ row.append(link['msg-fifo-depth'])
+ else:
+ row.append('-')
rows.append(row)
title = "Router Links"
dispRows = rows
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org