1#ifndef CTRS_H_
2#define CTRS_H_
3
4/* $FreeBSD: stable/11/tools/tools/netmap/ctrs.h 341434 2018-12-03 17:51:22Z vmaffione $ */
5
6#include <sys/time.h>
7
8/* counters to accumulate statistics */
9struct my_ctrs {
10	uint64_t pkts, bytes, events;
11	uint64_t drop, drop_bytes;
12	uint64_t min_space;
13	struct timeval t;
14	uint32_t oq_n; /* number of elements in overflow queue (used in lb) */
15};
16
17/* very crude code to print a number in normalized form.
18 * Caller has to make sure that the buffer is large enough.
19 */
20static const char *
21norm2(char *buf, double val, char *fmt, int normalize)
22{
23	char *units[] = { "", "K", "M", "G", "T" };
24	u_int i;
25	if (normalize)
26		for (i = 0; val >=1000 && i < sizeof(units)/sizeof(char *) - 1; i++)
27			val /= 1000;
28	else
29		i=0;
30	sprintf(buf, fmt, val, units[i]);
31	return buf;
32}
33
34static __inline const char *
35norm(char *buf, double val, int normalize)
36{
37	if (normalize)
38		return norm2(buf, val, "%.3f %s", normalize);
39	else
40		return norm2(buf, val, "%.0f %s", normalize);
41}
42
43static __inline int
44timespec_ge(const struct timespec *a, const struct timespec *b)
45{
46
47	if (a->tv_sec > b->tv_sec)
48		return (1);
49	if (a->tv_sec < b->tv_sec)
50		return (0);
51	if (a->tv_nsec >= b->tv_nsec)
52		return (1);
53	return (0);
54}
55
56static __inline struct timespec
57timeval2spec(const struct timeval *a)
58{
59	struct timespec ts = {
60		.tv_sec = a->tv_sec,
61		.tv_nsec = a->tv_usec * 1000
62	};
63	return ts;
64}
65
66static __inline struct timeval
67timespec2val(const struct timespec *a)
68{
69	struct timeval tv = {
70		.tv_sec = a->tv_sec,
71		.tv_usec = a->tv_nsec / 1000
72	};
73	return tv;
74}
75
76
77static __inline struct timespec
78timespec_add(struct timespec a, struct timespec b)
79{
80	struct timespec ret = { a.tv_sec + b.tv_sec, a.tv_nsec + b.tv_nsec };
81	if (ret.tv_nsec >= 1000000000) {
82		ret.tv_sec++;
83		ret.tv_nsec -= 1000000000;
84	}
85	return ret;
86}
87
88static __inline struct timespec
89timespec_sub(struct timespec a, struct timespec b)
90{
91	struct timespec ret = { a.tv_sec - b.tv_sec, a.tv_nsec - b.tv_nsec };
92	if (ret.tv_nsec < 0) {
93		ret.tv_sec--;
94		ret.tv_nsec += 1000000000;
95	}
96	return ret;
97}
98
99static __inline uint64_t
100wait_for_next_report(struct timeval *prev, struct timeval *cur,
101		int report_interval)
102{
103	struct timeval delta;
104
105	delta.tv_sec = report_interval/1000;
106	delta.tv_usec = (report_interval%1000)*1000;
107	if (select(0, NULL, NULL, NULL, &delta) < 0 && errno != EINTR) {
108		perror("select");
109		abort();
110	}
111	gettimeofday(cur, NULL);
112	timersub(cur, prev, &delta);
113	return delta.tv_sec* 1000000 + delta.tv_usec;
114}
115#endif /* CTRS_H_ */
116
117