| line |
true |
false |
branch |
|
112
|
0 |
2 |
if (dl->tv_nsec >= 1000000000L) { dl->tv_sec++; dl->tv_nsec -= 1000000000L; } |
|
120
|
2 |
1 |
if (rem->tv_nsec < 0) { rem->tv_sec--; rem->tv_nsec += 1000000000L; } |
|
131
|
0 |
113 |
if (len == 0) return -1; /* 0 is the uncommitted marker */ |
|
134
|
0 |
113 |
if (len > UINT32_MAX - LOG_ENTRY_HDR - 3U) return -1; |
|
141
|
4 |
109 |
if (t + entry_size > hdr->data_size) return -1; |
|
143
|
109 |
0 |
if (__atomic_compare_exchange_n(&hdr->tail, &t, t + entry_size, |
|
166
|
0 |
109 |
if (__atomic_load_n(&hdr->waiters, __ATOMIC_RELAXED) > 0) |
|
192
|
1 |
239 |
if (offset < trunc) return LOG_READ_EMPTY; /* truncated */ |
|
194
|
10 |
229 |
if (offset >= t) return LOG_READ_EMPTY; |
|
195
|
0 |
229 |
if (offset + LOG_ENTRY_HDR > h->hdr->data_size) return LOG_READ_EMPTY; |
|
212
|
229 |
0 |
if (reserve_size > 0) { |
|
215
|
229 |
0 |
if (len > 0) { |
|
216
|
0 |
229 |
if (offset + LOG_ENTRY_HDR + len > t) return LOG_READ_EMPTY; |
|
223
|
0 |
0 |
if (waited >= abandon_wait_us) break; |
|
236
|
0 |
0 |
if (reserve_size == 0) return LOG_READ_EMPTY; |
|
240
|
0 |
0 |
if (reserve_size <= LOG_ENTRY_HDR |
|
241
|
0 |
0 |
|| (reserve_size & 3U) != 0 |
|
242
|
0 |
0 |
|| offset + reserve_size > h->hdr->data_size |
|
243
|
0 |
0 |
|| offset + reserve_size > t) |
|
281
|
0 |
2 |
if (log_entry_count(h) != expected_count) return 1; |
|
282
|
0 |
2 |
if (timeout == 0) return 0; |
|
286
|
2 |
0 |
if (has_dl) log_make_deadline(timeout, &dl); |
|
293
|
2 |
0 |
if (cur == expected_count) { |
|
295
|
2 |
0 |
if (has_dl) { |
|
296
|
0 |
2 |
if (!log_remaining(&dl, &rem)) { |
|
306
|
1 |
1 |
if (log_entry_count(h) != expected_count) return 1; |
|
307
|
1 |
0 |
if (has_dl && !log_remaining(&dl, &rem)) { |
|
|
1 |
0 |
if (has_dl && !log_remaining(&dl, &rem)) { |
|
335
|
0 |
2 |
if (hdr->magic != LOG_MAGIC) { |
|
337
|
0 |
0 |
if (hdr->magic == 0x4C4F4731U) { |
|
338
|
0 |
0 |
LOG_ERR("v1 log file (LOG1) not compatible with v0.04+ (LOG2): recreate"); |
|
340
|
0 |
0 |
LOG_ERR("bad magic: 0x%08x (expected 0x%08x)", |
|
345
|
0 |
2 |
if (hdr->version != LOG_VERSION) { |
|
346
|
0 |
0 |
LOG_ERR("version mismatch: %u (expected %u)", |
|
350
|
0 |
2 |
if (hdr->data_size == 0) { LOG_ERR("data_size = 0"); return 0; } |
|
|
0 |
0 |
if (hdr->data_size == 0) { LOG_ERR("data_size = 0"); return 0; } |
|
351
|
0 |
2 |
if (hdr->data_size > UINT64_MAX - sizeof(LogHeader)) { |
|
352
|
0 |
0 |
LOG_ERR("data_size too large"); return 0; |
|
354
|
0 |
2 |
if (hdr->total_size != file_size) { |
|
355
|
0 |
0 |
LOG_ERR("total_size mismatch"); return 0; |
|
357
|
0 |
2 |
if (hdr->data_off != sizeof(LogHeader)) { |
|
358
|
0 |
0 |
LOG_ERR("data_off mismatch"); return 0; |
|
360
|
0 |
2 |
if (hdr->total_size != sizeof(LogHeader) + hdr->data_size) { |
|
361
|
0 |
0 |
LOG_ERR("size invariant broken"); return 0; |
|
364
|
0 |
2 |
if (hdr->tail > hdr->data_size) { LOG_ERR("tail > data_size"); return 0; } |
|
|
0 |
0 |
if (hdr->tail > hdr->data_size) { LOG_ERR("tail > data_size"); return 0; } |
|
365
|
0 |
2 |
if (hdr->truncation > hdr->data_size) { LOG_ERR("truncation > data_size"); return 0; } |
|
|
0 |
0 |
if (hdr->truncation > hdr->data_size) { LOG_ERR("truncation > data_size"); return 0; } |
|
372
|
0 |
14 |
if (!h) { munmap(base, ms); return NULL; } |
|
376
|
3 |
11 |
h->path = path ? strdup(path) : NULL; |
|
386
|
6 |
0 |
if (errbuf) errbuf[0] = '\0'; |
|
387
|
0 |
6 |
if (data_size == 0) { LOG_ERR("data_size must be > 0"); return NULL; } |
|
|
0 |
0 |
if (data_size == 0) { LOG_ERR("data_size must be > 0"); return NULL; } |
|
388
|
0 |
6 |
if (data_size > UINT64_MAX - sizeof(LogHeader)) { LOG_ERR("data_size too large"); return NULL; } |
|
|
0 |
0 |
if (data_size > UINT64_MAX - sizeof(LogHeader)) { LOG_ERR("data_size too large"); return NULL; } |
|
396
|
3 |
3 |
if (anonymous) { |
|
399
|
0 |
3 |
if (base == MAP_FAILED) { LOG_ERR("mmap: %s", strerror(errno)); return NULL; } |
|
|
0 |
0 |
if (base == MAP_FAILED) { LOG_ERR("mmap: %s", strerror(errno)); return NULL; } |
|
402
|
0 |
3 |
if (fd < 0) { LOG_ERR("open: %s", strerror(errno)); return NULL; } |
|
|
0 |
0 |
if (fd < 0) { LOG_ERR("open: %s", strerror(errno)); return NULL; } |
|
403
|
0 |
3 |
if (flock(fd, LOCK_EX) < 0) { LOG_ERR("flock: %s", strerror(errno)); close(fd); return NULL; } |
|
|
0 |
0 |
if (flock(fd, LOCK_EX) < 0) { LOG_ERR("flock: %s", strerror(errno)); close(fd); return NULL; } |
|
405
|
0 |
3 |
if (fstat(fd, &st) < 0) { |
|
406
|
0 |
0 |
LOG_ERR("fstat: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL; |
|
409
|
1 |
2 |
if (!is_new && (uint64_t)st.st_size < sizeof(LogHeader)) { |
|
|
0 |
1 |
if (!is_new && (uint64_t)st.st_size < sizeof(LogHeader)) { |
|
410
|
0 |
0 |
LOG_ERR("%s: file too small (%lld)", path, (long long)st.st_size); |
|
413
|
2 |
1 |
if (is_new && ftruncate(fd, (off_t)total) < 0) { |
|
|
0 |
2 |
if (is_new && ftruncate(fd, (off_t)total) < 0) { |
|
414
|
0 |
0 |
LOG_ERR("ftruncate: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL; |
|
416
|
1 |
2 |
map_size = is_new ? (size_t)total : (size_t)st.st_size; |
|
418
|
0 |
3 |
if (base == MAP_FAILED) { LOG_ERR("mmap: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL; } |
|
|
0 |
0 |
if (base == MAP_FAILED) { LOG_ERR("mmap: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL; } |
|
419
|
1 |
2 |
if (!is_new) { |
|
420
|
0 |
1 |
if (!log_validate_header((LogHeader *)base, (uint64_t)st.st_size, errbuf)) { |
|
428
|
2 |
3 |
if (fd >= 0) { flock(fd, LOCK_UN); close(fd); } |
|
433
|
7 |
0 |
if (errbuf) errbuf[0] = '\0'; |
|
434
|
0 |
7 |
if (data_size == 0) { LOG_ERR("data_size must be > 0"); return NULL; } |
|
|
0 |
0 |
if (data_size == 0) { LOG_ERR("data_size must be > 0"); return NULL; } |
|
435
|
0 |
7 |
if (data_size > UINT64_MAX - sizeof(LogHeader)) { LOG_ERR("data_size too large"); return NULL; } |
|
|
0 |
0 |
if (data_size > UINT64_MAX - sizeof(LogHeader)) { LOG_ERR("data_size too large"); return NULL; } |
|
437
|
7 |
0 |
int fd = memfd_create(name ? name : "log", MFD_CLOEXEC | MFD_ALLOW_SEALING); |
|
438
|
0 |
7 |
if (fd < 0) { LOG_ERR("memfd_create: %s", strerror(errno)); return NULL; } |
|
|
0 |
0 |
if (fd < 0) { LOG_ERR("memfd_create: %s", strerror(errno)); return NULL; } |
|
439
|
0 |
7 |
if (ftruncate(fd, (off_t)total) < 0) { LOG_ERR("ftruncate: %s", strerror(errno)); close(fd); return NULL; } |
|
|
0 |
0 |
if (ftruncate(fd, (off_t)total) < 0) { LOG_ERR("ftruncate: %s", strerror(errno)); close(fd); return NULL; } |
|
442
|
0 |
7 |
if (base == MAP_FAILED) { LOG_ERR("mmap: %s", strerror(errno)); close(fd); return NULL; } |
|
|
0 |
0 |
if (base == MAP_FAILED) { LOG_ERR("mmap: %s", strerror(errno)); close(fd); return NULL; } |
|
448
|
1 |
0 |
if (errbuf) errbuf[0] = '\0'; |
|
450
|
0 |
1 |
if (fstat(fd, &st) < 0) { LOG_ERR("fstat: %s", strerror(errno)); return NULL; } |
|
|
0 |
0 |
if (fstat(fd, &st) < 0) { LOG_ERR("fstat: %s", strerror(errno)); return NULL; } |
|
451
|
0 |
1 |
if ((uint64_t)st.st_size < sizeof(LogHeader)) { LOG_ERR("too small"); return NULL; } |
|
|
0 |
0 |
if ((uint64_t)st.st_size < sizeof(LogHeader)) { LOG_ERR("too small"); return NULL; } |
|
454
|
0 |
1 |
if (base == MAP_FAILED) { LOG_ERR("mmap: %s", strerror(errno)); return NULL; } |
|
|
0 |
0 |
if (base == MAP_FAILED) { LOG_ERR("mmap: %s", strerror(errno)); return NULL; } |
|
455
|
0 |
1 |
if (!log_validate_header((LogHeader *)base, (uint64_t)st.st_size, errbuf)) { |
|
459
|
0 |
1 |
if (myfd < 0) { LOG_ERR("fcntl: %s", strerror(errno)); munmap(base, ms); return NULL; } |
|
|
0 |
0 |
if (myfd < 0) { LOG_ERR("fcntl: %s", strerror(errno)); munmap(base, ms); return NULL; } |
|
464
|
0 |
14 |
if (!h) return; |
|
465
|
2 |
12 |
if (h->notify_fd >= 0) close(h->notify_fd); |
|
466
|
8 |
6 |
if (h->backing_fd >= 0) close(h->backing_fd); |
|
467
|
14 |
0 |
if (h->hdr) munmap(h->hdr, h->mmap_size); |
|
486
|
0 |
7 |
if (__atomic_load_n(&h->hdr->waiters, __ATOMIC_RELAXED) > 0) |
|
496
|
1 |
3 |
if (offset <= cur) return; /* can only advance, not retreat */ |
|
497
|
3 |
0 |
if (__atomic_compare_exchange_n(&h->hdr->truncation, &cur, offset, |
|
508
|
0 |
2 |
if (h->notify_fd >= 0) return h->notify_fd; |
|
510
|
0 |
2 |
if (efd < 0) return -1; |
|
514
|
0 |
2 |
if (h->notify_fd < 0) return 0; |
|
518
|
0 |
2 |
if (h->notify_fd < 0) return -1; |
|
520
|
0 |
2 |
if (read(h->notify_fd, &v, sizeof(v)) != sizeof(v)) return -1; |