shaba/systemd-stable
1
1
Fork 0
mirror of https://github.com/systemd/systemd-stable.git synced 2024-12-23 17:34:00 +03:00
Code

varlink: refactor adding socket event source to the event loop

Browse Source
This commit is contained in:
Anita Zhang 2022-10-11 02:36:32 -07:00
parent c14e841f31
commit 536827e05a
1 changed files with 24 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/shared/varlink.c
View File

@ -2380,6 +2380,29 @@ int varlink_server_shutdown(VarlinkServer *s) {
return 0;
}
static int varlink_server_add_socket_event_source(VarlinkServer *s, VarlinkServerSocket *ss, int64_t priority) {
_cleanup_(sd_event_source_unrefp) sd_event_source *es = NULL;
int r;
assert(s);
assert(s->event);
assert(ss);
assert(ss->fd >= 0);
assert(!ss->event_source);
r = sd_event_add_io(s->event, &es, ss->fd, EPOLLIN, connect_callback, ss);
if (r < 0)
return r;
r = sd_event_source_set_priority(es, priority);
if (r < 0)
return r;
ss->event_source = TAKE_PTR(es);
return 0;
}
int varlink_server_attach_event(VarlinkServer *s, sd_event *e, int64_t priority) {
int r;
@ -2395,13 +2418,7 @@ int varlink_server_attach_event(VarlinkServer *s, sd_event *e, int64_t priority)
}
LIST_FOREACH(sockets, ss, s->sockets) {
assert(!ss->event_source);
r = sd_event_add_io(s->event, &ss->event_source, ss->fd, EPOLLIN, connect_callback, ss);
if (r < 0)
goto fail;
r = sd_event_source_set_priority(ss->event_source, priority);
r = varlink_server_add_socket_event_source(s, ss, priority);
if (r < 0)
goto fail;
}