vitalif
/
vitastor
5
4
Fork 9
Code Issues 1 Pull Requests 2 Actions Releases 69 Wiki Activity

Reset eventfd on every ringloop::loop()

hotfix-1.0.0
Vitaliy Filippov 2023-07-20 23:27:34 +03:00
parent 0b2d12eef1
commit 1c316ef350
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/ringloop.cpp
View File

@ -66,6 +66,16 @@ void ring_loop_t::unregister_consumer(ring_consumer_t *consumer)
void ring_loop_t::loop() void ring_loop_t::loop()
{ {
if (ring_eventfd >= 0)
{
// Reset eventfd counter
uint64_t ctr = 0;
int r = read(ring_eventfd, &ctr, 8);
if (r < 0 && errno != EAGAIN && errno != EINTR)
{
fprintf(stderr, "Error resetting eventfd: %s\n", strerror(errno));
}
}
struct io_uring_cqe *cqe; struct io_uring_cqe *cqe;
while (!io_uring_peek_cqe(&ring, &cqe)) while (!io_uring_peek_cqe(&ring, &cqe))
{ {
@ -84,7 +94,7 @@ void ring_loop_t::loop()
} }
else else
{ {
printf("Warning: empty callback in SQE\n"); fprintf(stderr, "Warning: empty callback in SQE\n");
free_ring_data[free_ring_data_ptr++] = d - ring_datas; free_ring_data[free_ring_data_ptr++] = d - ring_datas;
} }
io_uring_cqe_seen(&ring, cqe); io_uring_cqe_seen(&ring, cqe);