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 2016/03/19 00:06:31 UTC
[13/50] [abbrv] qpid-dispatch git commit: DISPATCH-179 - Added
connectors and containers lists to the agent for "route".
DISPATCH-179 - Added connectors and containers lists to the agent for "route".
Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/f9708279
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/f9708279
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/f9708279
Branch: refs/heads/master
Commit: f970827921fd3a367d6358f3bb2d2387df0d08c1
Parents: 0d603e1
Author: Ted Ross <tr...@redhat.com>
Authored: Fri Mar 4 15:23:48 2016 -0500
Committer: Ted Ross <tr...@redhat.com>
Committed: Fri Mar 4 15:23:48 2016 -0500
----------------------------------------------------------------------
src/router_core/agent_route.c | 24 ++++++++++++++++++++++++
1 file changed, 24 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/f9708279/src/router_core/agent_route.c
----------------------------------------------------------------------
diff --git a/src/router_core/agent_route.c b/src/router_core/agent_route.c
index 97e70cf..2373624 100644
--- a/src/router_core/agent_route.c
+++ b/src/router_core/agent_route.c
@@ -47,6 +47,8 @@ const char *qdr_route_columns[] =
static void qdr_route_insert_column_CT(qdr_route_config_t *route, int col, qd_composed_field_t *body, bool as_map)
{
const char *text = 0;
+ qdr_route_active_t *active;
+ const char *key;
if (as_map)
qd_compose_insert_string(body, qdr_route_columns[col]);
@@ -99,7 +101,29 @@ static void qdr_route_insert_column_CT(qdr_route_config_t *route, int col, qd_co
break;
case QDR_ROUTE_CONNECTORS:
+ qd_compose_start_list(body);
+ active = DEQ_HEAD(route->active_list);
+ while(active) {
+ key = (const char*) qd_hash_key_by_handle(active->conn_id->hash_handle);
+ if (key && key[0] == 'L')
+ qd_compose_insert_string(body, &key[1]);
+ active = DEQ_NEXT(active);
+ }
+ qd_compose_end_list(body);
+ break;
+
case QDR_ROUTE_CONTAINERS:
+ qd_compose_start_list(body);
+ active = DEQ_HEAD(route->active_list);
+ while(active) {
+ key = (const char*) qd_hash_key_by_handle(active->conn_id->hash_handle);
+ if (key && key[0] == 'C')
+ qd_compose_insert_string(body, &key[1]);
+ active = DEQ_NEXT(active);
+ }
+ qd_compose_end_list(body);
+ break;
+
case QDR_ROUTE_ROUTE_ADDRESS:
qd_compose_insert_null(body);
break;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org