dialogus/statistics.c at main · OpenResearchInstitute/dialogus · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
#include <pthread.h>
#include <stdbool.h>
#include <stdint.h>
#include <stdio.h>
#include <unistd.h>

#include "debug_printf.h"
#include "frame_header.h"
#include "receiver.h"
#include "statistics.h"
#include "timestamp.h"

// OVP Statistics
uint64_t ovp_frames_received = 0;
uint64_t ovp_frames_processed = 0;
uint64_t ovp_frame_errors = 0;
uint64_t ovp_sessions_started = 0;
uint64_t ovp_sessions_ended = 0;
uint64_t ovp_dummy_frames_sent = 0;
uint64_t ovp_untimely_frames = 0;
extern volatile int ovp_transmission_active;
extern bool hang_timer_active;
extern int dummy_frames_sent;
extern int hang_timer_frames;

// OVP periodic reporting thread mechanisms
static pthread_t ovp_reporter_thread;
extern bool stop;
extern pthread_mutex_t timeline_lock;

void print_ovp_statistics(void) {
	printf("\n======= OVP TX Statistics =======\n");
	printf("UDP Frames received:      %llu\n", (unsigned long long)ovp_frames_received);
	printf("UDP Frames processed:     %llu\n", (unsigned long long)ovp_frames_processed);
	printf("UDP Frame errors:         %llu\n", (unsigned long long)ovp_frame_errors);
	printf("Untimely frames:          %llu\n", (unsigned long long)ovp_untimely_frames);
	printf("Total Dummy frames sent:  %llu\n", (unsigned long long)ovp_dummy_frames_sent);
	printf("Tx Sessions started:      %llu\n", (unsigned long long)ovp_sessions_started);
	printf("Tx Sessions ended:        %llu\n", (unsigned long long)ovp_sessions_ended);
	printf("Active Tx session:        %s\n", ovp_transmission_active ? "YES" : "NO");
	if (ovp_transmission_active) {
		printf("Active station ID:       %s\n", active_station_id_ascii);
	}
	printf("Hang timer active:        %s\n", hang_timer_active ? "YES" : "NO");
	if (hang_timer_active) {
		printf("Dummy frames sent:         %d of %d (for %s)\n",
				dummy_frames_sent, hang_timer_frames, active_station_id_ascii);
	}
	printf("\n======= OVP RX Statistics =======\n");
	printf("Total Frames Received:    %llu\n", (unsigned long long)ovp_refill_count);
	printf("Wrong Length Frames:      %llu\n", (unsigned long long)ovp_refill_error_count);
	printf("Forwarded Frames:         %llu\n", (unsigned long long)ovp_forwarded_count);
	printf("=================================\n\n");
}

// OVP Periodic Statistics Reporter thread
// Wakes up at intervals of about 10 seconds and print a report.
void* ovp_periodic_statistics_reporter_thread(__attribute__((unused)) void *arg) {
	while (!stop) {
		debug_printf(LEVEL_INFO, DEBUG_MUTEX, "MUTEX timeline_lock: locking in statistics\n");
		pthread_mutex_lock(&timeline_lock);
		debug_printf(LEVEL_INFO, DEBUG_MUTEX, "MUTEX timeline_lock: acquired in statistics\n");
		print_ovp_statistics();
		debug_printf(LEVEL_INFO, DEBUG_MUTEX, "MUTEX RELEASE in statistics\n");
		pthread_mutex_unlock(&timeline_lock);
		debug_printf(LEVEL_INFO, DEBUG_MUTEX, "MUTEX RELEASED in statistics\n");
		// don't sleep all at once; makes exiting the program too slow.
		for (int i=0; i < 100; i++) {
			usleep(100e3);	// 100 iterations of 100ms = 10 seconds
			if (stop) {
				break;
			}
		}
	}
	debug_printf(LEVEL_BORING, DEBUG_THREADS, "Periodic reporter thread exiting\n");
	return NULL;
}

int start_periodic_statistics_reporter(void) {
	if (pthread_create(&ovp_reporter_thread, NULL, ovp_periodic_statistics_reporter_thread, NULL) != 0) {
		debug_printf(LEVEL_URGENT, DEBUG_THREADS, "Failed to create periodic statistics reporter thread");
		return -1;
	}

	debug_printf(LEVEL_BORING, DEBUG_THREADS, "Reporter started successfully\n");
	return 0;
}

void stop_periodic_statistics_reporter(void) {
	if (ovp_reporter_thread) {
		pthread_cancel(ovp_reporter_thread);
	}

	debug_printf(LEVEL_BORING, DEBUG_THREADS, "Reporter stopped\n");
}