tree-wide: don't ignore return code from sd_event_source_set_enabled()
CID#1465793 CID#1465794 CID#1465795
This commit is contained in:
committed by
Lennart Poettering
parent
fe0777fb94
commit
c3c50474d2
@@ -243,13 +243,13 @@ int journal_remote_add_source(RemoteServer *s, int fd, char* name, bool own_name
|
||||
r = sd_event_add_defer(s->events, &source->buffer_event,
|
||||
dispatch_raw_source_until_block, source);
|
||||
if (r == 0)
|
||||
sd_event_source_set_enabled(source->buffer_event, SD_EVENT_OFF);
|
||||
r = sd_event_source_set_enabled(source->buffer_event, SD_EVENT_OFF);
|
||||
} else if (r == -EPERM) {
|
||||
log_debug("Falling back to sd_event_add_defer for fd:%d (%s)", fd, name);
|
||||
r = sd_event_add_defer(s->events, &source->event,
|
||||
dispatch_blocking_source_event, source);
|
||||
if (r == 0)
|
||||
sd_event_source_set_enabled(source->event, SD_EVENT_ON);
|
||||
r = sd_event_source_set_enabled(source->event, SD_EVENT_ON);
|
||||
}
|
||||
if (r < 0) {
|
||||
log_error_errno(r, "Failed to register event source for fd:%d: %m",
|
||||
|
||||
@@ -3691,7 +3691,7 @@ static int source_dispatch(sd_event_source *s) {
|
||||
if (s->n_ref == 0)
|
||||
source_free(s);
|
||||
else if (r < 0)
|
||||
sd_event_source_set_enabled(s, SD_EVENT_OFF);
|
||||
assert_se(sd_event_source_set_enabled(s, SD_EVENT_OFF) >= 0);
|
||||
|
||||
return 1;
|
||||
}
|
||||
@@ -3732,7 +3732,7 @@ static int event_prepare(sd_event *e) {
|
||||
if (s->n_ref == 0)
|
||||
source_free(s);
|
||||
else if (r < 0)
|
||||
sd_event_source_set_enabled(s, SD_EVENT_OFF);
|
||||
assert_se(sd_event_source_set_enabled(s, SD_EVENT_OFF) >= 0);
|
||||
}
|
||||
|
||||
return 0;
|
||||
|
||||
Reference in New Issue
Block a user