From ee3d4fe7c54c082dc16f92283b91d69187bb809e Mon Sep 17 00:00:00 2001
From: miker <miker@9efc2488-bf62-4759-914b-345cdb29e865>
Date: Mon, 25 Jun 2007 20:48:18 +0000
Subject: [PATCH] adding yet more router commands to gather some stats about
 request counts

git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@976 9efc2488-bf62-4759-914b-345cdb29e865
---
 src/router/osrf_router.c | 55 ++++++++++++++++++++++++++++++++++++++++++++----
 1 file changed, 51 insertions(+), 4 deletions(-)

diff --git a/src/router/osrf_router.c b/src/router/osrf_router.c
index b7e7d60..4fdc053 100644
--- a/src/router/osrf_router.c
+++ b/src/router/osrf_router.c
@@ -6,8 +6,10 @@
 
 
 #define ROUTER_REQUEST_CLASS_LIST "opensrf.router.info.class.list"
-#define ROUTER_REQUEST_FULL_STATS "opensrf.router.info.stats.class.node.all"
-#define ROUTER_REQUEST_CLASS_STATS "opensrf.router.info.stats.class.all"
+#define ROUTER_REQUEST_STATS_NODE_FULL "opensrf.router.info.stats.class.node.all"
+#define ROUTER_REQUEST_STATS_CLASS_FULL "opensrf.router.info.stats.class.all"
+#define ROUTER_REQUEST_STATS_CLASS "opensrf.router.info.stats.class"
+#define ROUTER_REQUEST_STATS_CLASS_SUMMARY "opensrf.router.info.stats.class.summary"
 
 osrfRouter* osrfNewRouter( 
 		char* domain, char* name, 
@@ -557,7 +559,52 @@ int osrfRouterProcessAppRequest( osrfRouter* router, transport_message* msg, osr
 		osrfStringArrayFree(keys);
 
 
-	} else if(!strcmp( omsg->method_name, ROUTER_REQUEST_FULL_STATS )) {
+	} else if(!strcmp( omsg->method_name, ROUTER_REQUEST_STATS_CLASS_SUMMARY )) {
+
+		osrfRouterClass* class;
+		osrfRouterNode* node;
+		int count = 0;
+
+		char* classname = jsonObjectToSimpleString( jsonObjectGetIndex( omsg->_params, 0 ) );
+
+		if (!classname) {
+			free(classname);
+			return -1;
+		}
+
+		class = osrfHashGet(router->classes, classname);
+
+		osrfHashIterator* node_itr = osrfNewHashIterator(class->nodes);
+		while( (node = osrfHashIteratorNext(node_itr)) ) {
+			count += node->count;
+			//jsonObjectSetKey( class_res, node->remoteId, jsonNewNumberObject( (double) node->count ) );
+		}
+		osrfHashIteratorFree(node_itr);
+
+		jresponse = jsonNewNumberObject( (double) count );
+
+	} else if(!strcmp( omsg->method_name, ROUTER_REQUEST_STATS_CLASS )) {
+
+		osrfRouterClass* class;
+		osrfRouterNode* node;
+
+		char* classname = jsonObjectToSimpleString( jsonObjectGetIndex( omsg->_params, 0 ) );
+
+		if (!classname) {
+			free(classname);
+			return -1;
+		}
+
+		jresponse = jsonParseString("{}");
+		class = osrfHashGet(router->classes, classname);
+
+		osrfHashIterator* node_itr = osrfNewHashIterator(class->nodes);
+		while( (node = osrfHashIteratorNext(node_itr)) ) {
+			jsonObjectSetKey( jresponse, node->remoteId, jsonNewNumberObject( (double) node->count ) );
+		}
+		osrfHashIteratorFree(node_itr);
+
+	} else if(!strcmp( omsg->method_name, ROUTER_REQUEST_STATS_CLASS_FULL )) {
 
 		osrfRouterClass* class;
 		osrfRouterNode* node;
@@ -580,7 +627,7 @@ int osrfRouterProcessAppRequest( osrfRouter* router, transport_message* msg, osr
 
 		osrfHashIteratorFree(class_itr);
 
-	} else if(!strcmp( omsg->method_name, ROUTER_REQUEST_CLASS_STATS )) {
+	} else if(!strcmp( omsg->method_name, ROUTER_REQUEST_STATS_NODE_FULL )) {
 
 		osrfRouterClass* class;
 		osrfRouterNode* node;
-- 
2.11.0