monkee.ch/snac2
1
0
Fork 0
mirror of https://codeberg.org/grunfink/snac2.git synced 2024-11-14 17:45:04 +00:00
Code Issues Projects Releases Packages Wiki Activity

Connections are now attended by threads.

Browse source
This commit is contained in:
default 2022-10-10 19:50:37 +02:00
parent 95d0ce8382
commit 1e9d21147b
1 changed files with 22 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
httpd.c
View file

@ -197,10 +197,10 @@ void term_handler(int s)
}
static void *helper_thread(void *arg)
/* helper thread (queue management) */
static void *queue_thread(void *arg)
/* queue thread (queue management) */
{
srv_log(xs_fmt("subthread start"));
srv_log(xs_fmt("queue thread start"));
while (srv_running) {
xs *list = user_list();
@ -219,12 +219,22 @@ static void *helper_thread(void *arg)
sleep(3);
}
srv_log(xs_fmt("subthread stop"));
srv_log(xs_fmt("queue thread stop"));
return NULL;
}
static void *connection_thread(void *arg)
/* connection thread */
{
httpd_connection((FILE *)arg);
return NULL;
}
int threaded_connections = 1;
void httpd(void)
/* starts the server */
{
@ -249,13 +259,19 @@ void httpd(void)
srv_log(xs_fmt("httpd start %s:%d", address, port));
pthread_create(&htid, NULL, helper_thread, NULL);
pthread_create(&htid, NULL, queue_thread, NULL);
if (setjmp(on_break) == 0) {
for (;;) {
FILE *f = xs_socket_accept(rs);
httpd_connection(f);
if (threaded_connections) {
pthread_t cth;
pthread_create(&cth, NULL, connection_thread, f);
}
else
httpd_connection(f);
}
}