line |
true |
false |
branch |
188
|
0 |
0 |
if (requests > first_page) |
206
|
0 |
0 |
while (count--) |
227
|
0 |
0 |
while (linuxaio_iocbpmax--) |
236
|
0 |
0 |
array_needsize (ANIOCBP, linuxaio_iocbps, linuxaio_iocbpmax, fd + 1, linuxaio_array_needsize_iocbp); |
240
|
0 |
0 |
if (ecb_expect_false (iocb->io.aio_reqprio < 0)) |
248
|
0 |
0 |
else if (ecb_expect_false (iocb->io.aio_buf)) |
255
|
0 |
0 |
if (ecb_expect_false (evsys_io_cancel (linuxaio_ctx, &iocb->io, (struct io_event *)0) == 0)) |
258
|
0 |
0 |
if (ecb_expect_true (errno == EINPROGRESS)) |
262
|
0 |
0 |
if (errno != EINTR) |
274
|
0 |
0 |
| (nev & EV_WRITE ? POLLOUT : 0); |
276
|
0 |
0 |
if (nev) |
283
|
0 |
0 |
array_needsize (struct iocb *, linuxaio_submits, linuxaio_submitmax, linuxaio_submitcnt, array_needsize_noinit); |
306
|
0 |
0 |
while (nr) |
315
|
0 |
0 |
if (ecb_expect_true (gen == (uint32_t)anfds [fd].egen)) |
321
|
0 |
0 |
(res & (POLLOUT | POLLERR | POLLHUP) ? EV_WRITE : 0) |
348
|
0 |
0 |
if (head == tail) |
352
|
0 |
0 |
if (ecb_expect_true (tail > head)) /* normal case around */ |
374
|
0 |
0 |
&& ring->incompat_features == EV_AIO_RING_INCOMPAT_FEATURES |
375
|
0 |
0 |
&& ring->header_length == sizeof (struct aio_ring); /* TODO: or use it to find io_event[0]? */ |
|
0 |
0 |
&& ring->header_length == sizeof (struct aio_ring); /* TODO: or use it to find io_event[0]? */ |
388
|
0 |
0 |
if (ecb_expect_true (ringbuf_valid)) |
391
|
0 |
0 |
if (linuxaio_get_events_from_ring (EV_A)) |
395
|
0 |
0 |
if (!timeout) |
409
|
0 |
0 |
EV_RELEASE_CB; |
414
|
0 |
0 |
EV_ACQUIRE_CB; |
416
|
0 |
0 |
if (res < 0) |
417
|
0 |
0 |
if (errno == EINTR) |
421
|
0 |
0 |
else if (res) |
426
|
0 |
0 |
if (ecb_expect_true (ringbuf_valid)) |
434
|
0 |
0 |
else if (res < want) |
463
|
0 |
0 |
for (submitted = 0; submitted < linuxaio_submitcnt; ) |
467
|
0 |
0 |
if (ecb_expect_false (res < 0)) |
468
|
0 |
0 |
if (errno == EINVAL) |
483
|
0 |
0 |
else if (errno == EAGAIN) |
499
|
0 |
0 |
for (fd = 0; fd < linuxaio_iocbpmax; ++fd) |
500
|
0 |
0 |
if (linuxaio_iocbps [fd]->io.aio_buf) |
505
|
0 |
0 |
if (linuxaio_io_setup (EV_A) < 0) |
525
|
0 |
0 |
else if (errno == EBADF) |
532
|
0 |
0 |
else if (errno == EINTR) /* not seen in reality, not documented */ |
557
|
0 |
0 |
if (ev_linux_version () < 0x041300) |
560
|
0 |
0 |
if (!epoll_init (EV_A_ 0)) |
565
|
0 |
0 |
if (linuxaio_io_setup (EV_A) < 0) |
608
|
0 |
0 |
while (linuxaio_io_setup (EV_A) < 0) |