Branch Coverage

ring.h
Criterion Covered Total %
branch 82 176 46.5


line true false branch
91 13 0 if (__atomic_compare_exchange_n(&hdr->head, &pos, pos + 1,
99 0 13 if (cp < sz) memset(ring_slot(h, pos) + cp, 0, sz - cp);
104 1 12 if (cnt > hdr->capacity)
109 0 13 if (__atomic_load_n(&hdr->waiters, __ATOMIC_RELAXED) > 0)
123 0 17 if (head == 0) return 0;
125 1 16 if (n >= avail) return 0;
134 1 4 if (seq >= head) return 0; /* not yet written */
135 2 2 uint64_t oldest = (head > h->hdr->capacity) ? head - h->hdr->capacity : 0;
136 1 3 if (seq < oldest) return 0; /* already overwritten */
162 0 2 if (dl->tv_nsec >= 1000000000L) { dl->tv_sec++; dl->tv_nsec -= 1000000000L; }
170 2 1 if (rem->tv_nsec < 0) { rem->tv_sec--; rem->tv_nsec += 1000000000L; }
175 0 2 if (__atomic_load_n(&h->hdr->count, __ATOMIC_ACQUIRE) != expected_count) return 1;
176 0 2 if (timeout == 0) return 0;
180 2 0 if (has_dl) ring_make_deadline(timeout, &dl);
185 2 0 if (cur == expected_count) {
187 2 0 if (has_dl) {
188 0 2 if (!ring_remaining(&dl, &rem)) {
198 1 1 if (__atomic_load_n(&h->hdr->count, __ATOMIC_ACQUIRE) != expected_count) return 1;
199 1 0 if (has_dl && !ring_remaining(&dl, &rem)) return 0;
1 0 if (has_dl && !ring_remaining(&dl, &rem)) return 0;
227 0 8 if (!h) { munmap(base, ms); return NULL; }
232 3 5 h->path = path ? strdup(path) : NULL;
241 6 0 if (errbuf) errbuf[0] = '\0';
242 0 6 if (capacity == 0) { RING_ERR("capacity must be > 0"); return NULL; }
0 0 if (capacity == 0) { RING_ERR("capacity must be > 0"); return NULL; }
243 0 6 if (elem_size == 0) { RING_ERR("elem_size must be > 0"); return NULL; }
0 0 if (elem_size == 0) { RING_ERR("elem_size must be > 0"); return NULL; }
244 0 6 if (capacity > (UINT64_MAX - sizeof(RingHeader)) / elem_size) {
245 0 0 RING_ERR("capacity * elem_size overflow"); return NULL;
254 3 3 if (anonymous) {
257 0 3 if (base == MAP_FAILED) { RING_ERR("mmap: %s", strerror(errno)); return NULL; }
0 0 if (base == MAP_FAILED) { RING_ERR("mmap: %s", strerror(errno)); return NULL; }
260 0 3 if (fd < 0) { RING_ERR("open: %s", strerror(errno)); return NULL; }
0 0 if (fd < 0) { RING_ERR("open: %s", strerror(errno)); return NULL; }
261 0 3 if (flock(fd, LOCK_EX) < 0) { RING_ERR("flock: %s", strerror(errno)); close(fd); return NULL; }
0 0 if (flock(fd, LOCK_EX) < 0) { RING_ERR("flock: %s", strerror(errno)); close(fd); return NULL; }
263 0 3 if (fstat(fd, &st) < 0) { RING_ERR("fstat: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL; }
0 0 if (fstat(fd, &st) < 0) { RING_ERR("fstat: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL; }
265 2 1 if (is_new && ftruncate(fd, (off_t)total) < 0) {
0 2 if (is_new && ftruncate(fd, (off_t)total) < 0) {
266 0 0 RING_ERR("ftruncate: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL;
268 1 2 map_size = is_new ? (size_t)total : (size_t)st.st_size;
270 0 3 if (base == MAP_FAILED) { RING_ERR("mmap: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL; }
0 0 if (base == MAP_FAILED) { RING_ERR("mmap: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL; }
271 1 2 if (!is_new) {
273 1 0 if (hdr->magic != RING_MAGIC || hdr->version != RING_VERSION ||
1 0 if (hdr->magic != RING_MAGIC || hdr->version != RING_VERSION ||
274 1 0 hdr->variant_id != variant_id ||
275 0 1 hdr->total_size != (uint64_t)st.st_size) {
276 0 0 RING_ERR("invalid ring file"); munmap(base, map_size); flock(fd, LOCK_UN); close(fd); return NULL;
283 2 3 if (fd >= 0) { flock(fd, LOCK_UN); close(fd); }
290 1 0 if (errbuf) errbuf[0] = '\0';
291 0 1 if (capacity == 0) { RING_ERR("capacity must be > 0"); return NULL; }
0 0 if (capacity == 0) { RING_ERR("capacity must be > 0"); return NULL; }
292 0 1 if (elem_size == 0) { RING_ERR("elem_size must be > 0"); return NULL; }
0 0 if (elem_size == 0) { RING_ERR("elem_size must be > 0"); return NULL; }
293 0 1 if (capacity > (UINT64_MAX - sizeof(RingHeader)) / elem_size) {
294 0 0 RING_ERR("capacity * elem_size overflow"); return NULL;
297 1 0 int fd = memfd_create(name ? name : "ring", MFD_CLOEXEC);
298 0 1 if (fd < 0) { RING_ERR("memfd_create: %s", strerror(errno)); return NULL; }
0 0 if (fd < 0) { RING_ERR("memfd_create: %s", strerror(errno)); return NULL; }
299 0 1 if (ftruncate(fd, (off_t)total) < 0) { RING_ERR("ftruncate: %s", strerror(errno)); close(fd); return NULL; }
0 0 if (ftruncate(fd, (off_t)total) < 0) { RING_ERR("ftruncate: %s", strerror(errno)); close(fd); return NULL; }
301 0 1 if (base == MAP_FAILED) { RING_ERR("mmap: %s", strerror(errno)); close(fd); return NULL; }
0 0 if (base == MAP_FAILED) { RING_ERR("mmap: %s", strerror(errno)); close(fd); return NULL; }
307 1 0 if (errbuf) errbuf[0] = '\0';
309 0 1 if (fstat(fd, &st) < 0) { RING_ERR("fstat: %s", strerror(errno)); return NULL; }
0 0 if (fstat(fd, &st) < 0) { RING_ERR("fstat: %s", strerror(errno)); return NULL; }
310 0 1 if ((uint64_t)st.st_size < sizeof(RingHeader)) { RING_ERR("too small"); return NULL; }
0 0 if ((uint64_t)st.st_size < sizeof(RingHeader)) { RING_ERR("too small"); return NULL; }
313 0 1 if (base == MAP_FAILED) { RING_ERR("mmap: %s", strerror(errno)); return NULL; }
0 0 if (base == MAP_FAILED) { RING_ERR("mmap: %s", strerror(errno)); return NULL; }
315 1 0 if (hdr->magic != RING_MAGIC || hdr->version != RING_VERSION ||
1 0 if (hdr->magic != RING_MAGIC || hdr->version != RING_VERSION ||
316 1 0 hdr->variant_id != variant_id ||
317 0 1 hdr->total_size != (uint64_t)st.st_size) {
318 0 0 RING_ERR("invalid ring"); munmap(base, ms); return NULL;
321 0 1 if (myfd < 0) { RING_ERR("fcntl: %s", strerror(errno)); munmap(base, ms); return NULL; }
0 0 if (myfd < 0) { RING_ERR("fcntl: %s", strerror(errno)); munmap(base, ms); return NULL; }
326 0 8 if (!h) return;
327 1 7 if (h->notify_fd >= 0) close(h->notify_fd);
328 2 6 if (h->backing_fd >= 0) close(h->backing_fd);
329 8 0 if (h->hdr) munmap(h->hdr, h->mmap_size);
340 0 1 if (h->notify_fd >= 0) close(h->notify_fd);
342 0 1 if (efd < 0) return -1;
346 0 1 if (h->notify_fd < 0) return 0;
350 0 1 if (h->notify_fd < 0) return -1;
352 0 1 if (read(h->notify_fd, &v, sizeof(v)) != sizeof(v)) return -1;