diff options
| author | June McEnroe <june@causal.agency> | 2019-10-30 17:14:51 -0400 |
|---|---|---|
| committer | June McEnroe <june@causal.agency> | 2019-10-30 17:15:44 -0400 |
| commit | d052c88217354523063c2c4212aa56601ada5751 (patch) | |
| tree | 215543f00f92812ff7da13fc98567ef1fa01f618 | |
| parent | Allocate ring buffer at runtime (diff) | |
| download | pounce-d052c88217354523063c2c4212aa56601ada5751.tar.gz pounce-d052c88217354523063c2c4212aa56601ada5751.zip | |
Warn when consumers drop messages
| -rw-r--r-- | ring.c | 4 |
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); |