about summary refs log tree commit diff
diff options
context:
space:
mode:
authorJune McEnroe <june@causal.agency>2019-10-30 17:14:51 -0400
committerJune McEnroe <june@causal.agency>2019-10-30 17:15:44 -0400
commitd052c88217354523063c2c4212aa56601ada5751 (patch)
tree215543f00f92812ff7da13fc98567ef1fa01f618
parentAllocate ring buffer at runtime (diff)
downloadpounce-d052c88217354523063c2c4212aa56601ada5751.tar.gz
pounce-d052c88217354523063c2c4212aa56601ada5751.zip
Warn when consumers drop messages
-rw-r--r--ring.c4
1 files changed, 4 insertions, 0 deletions
diff --git a/ring.c b/ring.c
index 0fec6d0..f99d9d4 100644
--- a/ring.c
+++ b/ring.c
@@ -87,6 +87,10 @@ size_t ringDiff(size_t consumer) {
 const char *ringPeek(time_t *time, size_t consumer) {
 	if (!ringDiff(consumer)) return NULL;
 	if (ringDiff(consumer) > ring.len) {
+		warnx(
+			"consumer %s dropped %zu messages",
+			consumers.ptr[consumer].name, ringDiff(consumer) - ring.len
+		);
 		consumers.ptr[consumer].pos = producer - ring.len;
 	}
 	size_t i = consumers.ptr[consumer].pos & (ring.len - 1);