lorenz.stechauner/sesimos
1
1
Fork 0
Code Issues Pull Requests Projects Releases Activity

Unset prefix at other position in async

Browse Source
This commit is contained in:
Lorenz Stechauner
2023-01-23 23:33:01 +01:00
parent 0394c3afb4
commit 1e0a7c95da
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/async.c
View File

@ -124,7 +124,6 @@ static int async_exec(evt_listen_t *evt, async_evt_t r_events) {
ret = -1; ret = -1;
} }
logger_set_prefix("");
errno = e; errno = e;
return ret; return ret;
} }
@ -254,7 +253,7 @@ void async_thread(void) {
// TODO timeout calculation = O(n) // TODO timeout calculation = O(n)
// calculate wait timeout // calculate wait timeout
min_ts = -1000, cur_ts = clock_micros();; min_ts = -1000, cur_ts = clock_micros();
for (int i = 0; i < list_size(local); i++) { for (int i = 0; i < list_size(local); i++) {
evt_listen_t *evt = local[i]; evt_listen_t *evt = local[i];
if (!evt->socket) continue; if (!evt->socket) continue;
@ -280,6 +279,7 @@ void async_thread(void) {
if (!list_contains(local, &evt)) continue; if (!list_contains(local, &evt)) continue;
if (async_exec(evt, async_e2a(events[i].events)) == 0) { if (async_exec(evt, async_e2a(events[i].events)) == 0) {
logger_set_prefix("");
if (epoll_ctl(epoll_fd, EPOLL_CTL_DEL, evt->fd, NULL) == -1) { if (epoll_ctl(epoll_fd, EPOLL_CTL_DEL, evt->fd, NULL) == -1) {
if (errno == EBADF) { if (errno == EBADF) {
// already closed fd, do not die // already closed fd, do not die
@ -298,6 +298,7 @@ void async_thread(void) {
free(evt); free(evt);
} }
logger_set_prefix("");
} }
// check, if some socket ran into a timeout // check, if some socket ran into a timeout