use actual number of received messages github#68

lukepalmer · Nov 9, 2019 · 24d0177 · 24d0177
1 parent 35b3902
commit 24d0177
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/samplers/statsd.c b/src/samplers/statsd.c
@@ -51,9 +51,9 @@ static void statsd_run_recvmmsg(struct brubeck_statsd *statsd, int sock)
 		}
 
 		/* store stats */
-		brubeck_atomic_add(&statsd->sampler.inflow, SIM_PACKETS);
+		brubeck_atomic_add(&statsd->sampler.inflow, res);
 
-		for (i = 0; i < SIM_PACKETS; ++i) {
+		for (i = 0; i < res; ++i) {
 			char *buf = msgs[i].msg_hdr.msg_iov->iov_base;
 			char *end = buf + msgs[i].msg_len;
 			brubeck_statsd_packet_parse(server, buf, end);