1 #ifndef CTRS_H_
2 #define CTRS_H_
3
4 /* $FreeBSD$ */
5
6 #include <sys/time.h>
7
8 /* counters to accumulate statistics */
9 struct 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 */
20 static const char *
norm2(char * buf,double val,char * fmt,int normalize)21 norm2(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
34 static __inline const char *
norm(char * buf,double val,int normalize)35 norm(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
43 static __inline int
timespec_ge(const struct timespec * a,const struct timespec * b)44 timespec_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
56 static __inline struct timespec
timeval2spec(const struct timeval * a)57 timeval2spec(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
66 static __inline struct timeval
timespec2val(const struct timespec * a)67 timespec2val(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
77 static __inline struct timespec
timespec_add(struct timespec a,struct timespec b)78 timespec_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
88 static __inline struct timespec
timespec_sub(struct timespec a,struct timespec b)89 timespec_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
99 static __inline uint64_t
wait_for_next_report(struct timeval * prev,struct timeval * cur,int report_interval)100 wait_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