osmocom
/
libosmocore
mirror of https://gerrit.osmocom.org/libosmocore
11
0
Fork 0
Code Issues Releases Wiki Activity

io_uring: check all operations in osmo_iofd_uring_init() 

check all operations in osmo_iofd_uring_init() and panic if any of them
fails.

Change-Id: I03752c0114cc6fad0c31fff6fff43072f36a50a7
This commit is contained in:
Harald Welte 2024-03-14 08:21:42 +01:00
parent 5fcfbe0c69
commit 9c604f4738
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/core/osmo_io_uring.c
View File

@ -88,7 +88,8 @@ static int iofd_uring_poll_cb(struct osmo_fd *ofd, unsigned int what)
/*! initialize the uring and tie it into our event loop */
void osmo_iofd_uring_init(void)
{
int rc;
int rc, evfd;
rc = io_uring_queue_init(IOFD_URING_ENTRIES, &g_ring.ring, 0);
if (rc < 0)
osmo_panic("failure during io_uring_queue_init(): %s\n", strerror(-rc));
@ -98,10 +99,22 @@ void osmo_iofd_uring_init(void)
io_uring_queue_exit(&g_ring.ring);
osmo_panic("failure creating eventfd(0, 0) for io_uring: %s\n", strerror(-rc));
}
evfd = rc;
osmo_fd_setup(&g_ring.event_ofd, rc, OSMO_FD_READ, iofd_uring_poll_cb, &g_ring.ring, 0);
osmo_fd_register(&g_ring.event_ofd);
io_uring_register_eventfd(&g_ring.ring, rc);
osmo_fd_setup(&g_ring.event_ofd, evfd, OSMO_FD_READ, iofd_uring_poll_cb, &g_ring.ring, 0);
rc = osmo_fd_register(&g_ring.event_ofd);
if (rc < 0) {
close(evfd);
io_uring_queue_exit(&g_ring.ring);
osmo_panic("failure registering io_uring-eventfd as osmo_fd: %d\n", rc);
}
rc = io_uring_register_eventfd(&g_ring.ring, rc);
if (rc < 0) {
osmo_fd_unregister(&g_ring.event_ofd);
close(evfd);
io_uring_queue_exit(&g_ring.ring);
osmo_panic("failure registering eventfd with io_uring: %s\n", strerror(-rc));
}
}