oysteikt/mpd
oysteikt/mpd
0
0
Fork 0
Code Issues Pull Requests Releases Activity

io/uring/Ring: ignore EINTR

Browse Source
This commit is contained in:
Max Kellermann 2025-02-04 10:50:18 +01:00 committed by Max Kellermann
parent 45644759fe
commit c8e88408b2
1 changed files with 3 additions and 3 deletions

6
src/io/uring/Ring.cxx

@ -51,7 +51,7 @@ Ring::WaitCompletion()
struct io_uring_cqe *cqe; struct io_uring_cqe *cqe;
if (int error = io_uring_wait_cqe(&ring, &cqe); if (int error = io_uring_wait_cqe(&ring, &cqe);
error < 0) { error < 0) {
if (error == -EAGAIN) if (error == -EAGAIN || error == -EINTR)
return nullptr; return nullptr;
throw MakeErrno(-error, "io_uring_wait_cqe() failed"); throw MakeErrno(-error, "io_uring_wait_cqe() failed");
@ -66,7 +66,7 @@ Ring::SubmitAndWaitCompletion(struct __kernel_timespec &timeout)
struct io_uring_cqe *cqe; struct io_uring_cqe *cqe;
if (int error = io_uring_submit_and_wait_timeout(&ring, &cqe, 1, &timeout, nullptr); if (int error = io_uring_submit_and_wait_timeout(&ring, &cqe, 1, &timeout, nullptr);
error < 0) { error < 0) {
if (error == -ETIME || error == -EAGAIN) if (error == -ETIME || error == -EAGAIN || error == -EINTR)
return nullptr; return nullptr;
throw MakeErrno(-error, "io_uring_submit_and_wait_timeout() failed"); throw MakeErrno(-error, "io_uring_submit_and_wait_timeout() failed");
@ -80,7 +80,7 @@ Ring::PeekCompletion()
{ {
struct io_uring_cqe *cqe; struct io_uring_cqe *cqe;
if (int error = io_uring_peek_cqe(&ring, &cqe); error < 0) { if (int error = io_uring_peek_cqe(&ring, &cqe); error < 0) {
if (error == -EAGAIN) if (error == -EAGAIN || error == -EINTR)
return nullptr; return nullptr;
throw MakeErrno(-error, "io_uring_peek_cqe() failed"); throw MakeErrno(-error, "io_uring_peek_cqe() failed");