[core] server_run_con_queue()
func to run queued (connection *) jobspersonal/stbuehler/tests-path
parent
a3001b968f
commit
52d9b0da88
16
src/server.c
16
src/server.c
|
@ -1798,6 +1798,16 @@ static void server_handle_sigchld (server * const srv) {
|
|||
} while (pid > 0 || (-1 == pid && errno == EINTR));
|
||||
}
|
||||
|
||||
__attribute_hot__
|
||||
static void server_run_con_queue (connections * const restrict joblist) {
|
||||
connection * const * const restrict conlist = joblist->ptr;
|
||||
const uint32_t used = joblist->used;
|
||||
joblist->used = 0;
|
||||
for (uint32_t i = 0; i < used; ++i) {
|
||||
connection_state_machine(conlist[i]);
|
||||
}
|
||||
}
|
||||
|
||||
__attribute_hot__
|
||||
__attribute_noinline__
|
||||
static void server_main_loop (server * const srv) {
|
||||
|
@ -1856,11 +1866,7 @@ static void server_main_loop (server * const srv) {
|
|||
? &srv->joblist_B
|
||||
: &srv->joblist_A;
|
||||
|
||||
for (uint32_t ndx = 0, used = joblist->used; ndx < used; ++ndx) {
|
||||
connection *con = joblist->ptr[ndx];
|
||||
connection_state_machine(con);
|
||||
}
|
||||
joblist->used = 0;
|
||||
server_run_con_queue(joblist);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue