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 * 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 * 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 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 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 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 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 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 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