Changeset 1372:6b1a2405cebb in freeDiameter for extensions/loadtest_cc/loadtest_cc.c

Timestamp:

Jun 12, 2019, 9:54:35 PM (5 years ago)

Author:

Thomas Klausner <tk@giga.or.at>

Branch:

default

Phase:

public

Message:

test_cc, loadtest_cc: write current statistics every second

File:

• extensions/loadtest_cc/loadtest_cc.c (modified) (5 diffs)

extensions/loadtest_cc/loadtest_cc.c

@@ -68 +68 @@
 } statistics;
 
+void print_statistics(void) {
+        uint64_t missing;
+
+        if (statistics.first == 0 || statistics.last == 0 || statistics.last == statistics.first) {
+                return;
+        }
+
+        missing = statistics.sent - statistics.error - statistics.success;
+
+        fd_log_error("%s: %lld CCR messages sent in %llds (%.2f messages/second), %lld success (%.2f%%), %lld errors (%.2f%%), %lld missing (%.2f%%)",
+                     fd_g_config->cnf_diamid,
+                     (long long)statistics.sent, (long long)(statistics.last-statistics.first), (float)statistics.sent / (statistics.last-statistics.first),
+                     (long long)statistics.success,
+                     100*(float)statistics.success/statistics.sent, (long long)statistics.error, 100*(float)statistics.error/statistics.sent,
+                     missing, 100*(float)missing/statistics.sent);
+}
+
 static int handle_message(struct msg **msg) {
         struct msg_hdr *hdr = NULL;
@@ -299 +316 @@
         do {
                 if (do_generate) {
+                        time_t now;
                         if (statistics.first == 0) {
                                 statistics.first = time(NULL);
@@ -305 +323 @@
                         fd_msg_send(&msg, NULL, NULL);
                         fd_log_debug("[%s] sent message", MODULE_NAME);
+                        now = time(NULL);
+                        if (statistics.last != now) {
+                                print_statistics();
+                        }
                         statistics.last = time(NULL);
                         statistics.sent++;
@@ -387 +409 @@
 void fd_ext_fini(void)
 {
-        uint64_t missing;
         /* stop sending */
         do_generate = 0;
@@ -400 +421 @@
         }
 
-        missing = statistics.sent - statistics.error - statistics.success;
-
-        fd_log_error("%lld messages sent in %llds (%.2f messages/second), %lld success (%.2f%%), %lld errors (%.2f%%), %lld missing (%.2f%%)",
-                     (long long)statistics.sent, (long long)(statistics.last-statistics.first), (float)statistics.sent / (statistics.last-statistics.first),
-                     (long long)statistics.success,
-                     100*(float)statistics.success/statistics.sent, (long long)statistics.error, 100*(float)statistics.error/statistics.sent,
-                     missing, 100*(float)missing/statistics.sent);
+        print_statistics();
 
         return;