| line |
true |
false |
branch |
|
78
|
0 |
2 |
if (dl->tv_nsec >= 1000000000L) { dl->tv_sec++; dl->tv_nsec -= 1000000000L; } |
|
86
|
2 |
1 |
if (rem->tv_nsec < 0) { rem->tv_sec--; rem->tv_nsec += 1000000000L; } |
|
95
|
0 |
50 |
if (len == 0) return -1; /* 0 is the uncommitted marker */ |
|
98
|
0 |
50 |
if (len > UINT32_MAX - LOG_ENTRY_HDR) return -1; |
|
103
|
2 |
48 |
if (t + entry_size > hdr->data_size) return -1; |
|
105
|
48 |
0 |
if (__atomic_compare_exchange_n(&hdr->tail, &t, t + entry_size, |
|
118
|
0 |
48 |
if (__atomic_load_n(&hdr->waiters, __ATOMIC_RELAXED) > 0) |
|
134
|
4 |
211 |
if (offset >= t) return 0; |
|
135
|
0 |
211 |
if (offset + LOG_ENTRY_HDR > h->hdr->data_size) return 0; |
|
141
|
0 |
211 |
if (len == 0) return 0; /* uncommitted */ |
|
143
|
0 |
211 |
if (offset + LOG_ENTRY_HDR + len > t) return 0; |
|
172
|
0 |
2 |
if (log_entry_count(h) != expected_count) return 1; |
|
173
|
0 |
2 |
if (timeout == 0) return 0; |
|
177
|
2 |
0 |
if (has_dl) log_make_deadline(timeout, &dl); |
|
183
|
2 |
0 |
if (cur == expected_count) { |
|
185
|
2 |
0 |
if (has_dl) { |
|
186
|
0 |
2 |
if (!log_remaining(&dl, &rem)) { |
|
197
|
1 |
1 |
if (log_entry_count(h) != expected_count) return 1; |
|
198
|
1 |
0 |
if (has_dl && !log_remaining(&dl, &rem)) { |
|
|
1 |
0 |
if (has_dl && !log_remaining(&dl, &rem)) { |
|
225
|
0 |
7 |
if (!h) { munmap(base, ms); return NULL; } |
|
229
|
3 |
4 |
h->path = path ? strdup(path) : NULL; |
|
236
|
5 |
0 |
if (errbuf) errbuf[0] = '\0'; |
|
237
|
0 |
5 |
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; } |
|
238
|
0 |
5 |
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; } |
|
246
|
2 |
3 |
if (anonymous) { |
|
249
|
0 |
2 |
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; } |
|
252
|
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; } |
|
253
|
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; } |
|
255
|
0 |
3 |
if (fstat(fd, &st) < 0) { |
|
256
|
0 |
0 |
LOG_ERR("fstat: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL; |
|
259
|
2 |
1 |
if (is_new && ftruncate(fd, (off_t)total) < 0) { |
|
|
0 |
2 |
if (is_new && ftruncate(fd, (off_t)total) < 0) { |
|
260
|
0 |
0 |
LOG_ERR("ftruncate: %s", strerror(errno)); flock(fd, LOCK_UN); close(fd); return NULL; |
|
262
|
1 |
2 |
map_size = is_new ? (size_t)total : (size_t)st.st_size; |
|
264
|
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; } |
|
265
|
1 |
2 |
if (!is_new) { |
|
267
|
1 |
0 |
if (hdr->magic != LOG_MAGIC || hdr->version != LOG_VERSION || |
|
|
1 |
0 |
if (hdr->magic != LOG_MAGIC || hdr->version != LOG_VERSION || |
|
268
|
0 |
1 |
hdr->total_size != (uint64_t)st.st_size) { |
|
269
|
0 |
0 |
LOG_ERR("invalid log file"); munmap(base, map_size); flock(fd, LOCK_UN); close(fd); return NULL; |
|
276
|
2 |
2 |
if (fd >= 0) { flock(fd, LOCK_UN); close(fd); } |
|
281
|
1 |
0 |
if (errbuf) errbuf[0] = '\0'; |
|
282
|
0 |
1 |
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; } |
|
283
|
0 |
1 |
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; } |
|
285
|
1 |
0 |
int fd = memfd_create(name ? name : "log", MFD_CLOEXEC); |
|
286
|
0 |
1 |
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; } |
|
287
|
0 |
1 |
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; } |
|
289
|
0 |
1 |
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; } |
|
295
|
1 |
0 |
if (errbuf) errbuf[0] = '\0'; |
|
297
|
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; } |
|
298
|
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; } |
|
301
|
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; } |
|
303
|
1 |
0 |
if (hdr->magic != LOG_MAGIC || hdr->version != LOG_VERSION || |
|
|
1 |
0 |
if (hdr->magic != LOG_MAGIC || hdr->version != LOG_VERSION || |
|
304
|
0 |
1 |
hdr->total_size != (uint64_t)st.st_size) { |
|
305
|
0 |
0 |
LOG_ERR("invalid log"); munmap(base, ms); return NULL; |
|
308
|
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; } |
|
313
|
0 |
7 |
if (!h) return; |
|
314
|
1 |
6 |
if (h->notify_fd >= 0) close(h->notify_fd); |
|
315
|
2 |
5 |
if (h->backing_fd >= 0) close(h->backing_fd); |
|
316
|
7 |
0 |
if (h->hdr) munmap(h->hdr, h->mmap_size); |
|
325
|
0 |
5 |
if (__atomic_load_n(&h->hdr->waiters, __ATOMIC_RELAXED) > 0) |
|
330
|
0 |
1 |
if (h->notify_fd >= 0) close(h->notify_fd); |
|
332
|
0 |
1 |
if (efd < 0) return -1; |
|
336
|
0 |
1 |
if (h->notify_fd < 0) return 0; |
|
340
|
0 |
1 |
if (h->notify_fd < 0) return -1; |
|
342
|
0 |
1 |
if (read(h->notify_fd, &v, sizeof(v)) != sizeof(v)) return -1; |