[sr-dev] git:tmp/k3.0_sr_backports: kex: support to update core stats via core events

[Andrei Pelinescu-Onciul]

Module: sip-router
Branch: tmp/k3.0_sr_backports
Commit: 492346e52903c48050a2ffadf2071cbca7e3bf34
URL:    http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=492346e52903c48050a2ffadf2071cbca7e3bf34

Author: Daniel-Constantin Mierla <miconda at gmail.com>
Committer: Andrei Pelinescu-Onciul <andrei at iptel.org>
Date:   Tue Oct 13 21:28:42 2009 +0200

kex: support to update core stats via core events
(cherry picked from commit ea5ee19268c6a7e6f69df674b16fb19d2a2d6409)

---

 modules_k/kex/core_stats.c |   45 ++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 45 insertions(+), 0 deletions(-)

diff --git a/modules_k/kex/core_stats.c b/modules_k/kex/core_stats.c
index 121bb15..466dd11 100644
--- a/modules_k/kex/core_stats.c
+++ b/modules_k/kex/core_stats.c
@@ -36,6 +36,7 @@
 
 #include "../../lib/kcore/statistics.h"
 #include "../../lib/kmi/mi.h"
+#include "../../events.h"
 #include "../../dprint.h"
 #include "../../timer.h"
 #include "../../parser/msg_parser.h"
@@ -127,6 +128,49 @@ static int km_cb_rpl_stats(struct sip_msg *msg,
 	return 1;
 }
 
+
+static int sts_update_core_stats(void *data)
+{
+	int type;
+
+	type = (int)data;
+	switch(type) {
+		case 1:
+			/* fwd_requests */
+			update_stat(fwd_reqs, 1);
+		break;
+		case 2:
+			/* fwd_replies */
+			update_stat(fwd_rpls, 1);
+		break;
+		case 3:
+			/* drop_requests */
+			update_stat(drp_reqs, 1);
+		break;
+		case 4:
+			/* drop_replies */
+			update_stat(drp_rpls, 1);
+		break;
+		case 5:
+			/* err_requests */
+			update_stat(err_reqs, 1);
+		break;
+		case 6:
+			/* err_replies */
+			update_stat(err_rpls, 1);
+		break;
+		case 7:
+			/* bad_URIs_rcvd */
+			update_stat(bad_URIs, 1);
+		break;
+		case 8:
+			/* bad_msg_hdr */
+			update_stat(bad_msg_hdr, 1);
+		break;
+	}
+	return 0;
+}
+
 int register_core_stats(void)
 {
 	/* register core statistics */
@@ -147,6 +191,7 @@ int register_core_stats(void)
 		LM_ERR("failed to register PRE request callback\n");
 		return -1;
 	}
+	sr_event_register_cb(SREV_CORE_STATS, sts_update_core_stats);
 
 	return 0;
 }