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

Fix typo in workers.c

Browse Source
This commit is contained in:
Lorenz Stechauner
2023-01-23 10:09:34 +01:00
parent 5b98fd0dab
commit d461ba6f29
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/workers.c
View File

@ -12,14 +12,14 @@
#include "worker/func.h" #include "worker/func.h"
#include "async.h" #include "async.h"
static mpmc_t tcp_acceptor_ctx, request_handler_ctx, local_handler_ctx, fastcgi_handler_cxt, proxy_handler_ctx, static mpmc_t tcp_acceptor_ctx, request_handler_ctx, local_handler_ctx, fastcgi_handler_ctx, proxy_handler_ctx,
ws_frame_handler_ctx; ws_frame_handler_ctx;
int workers_init(void) { int workers_init(void) {
mpmc_init(&tcp_acceptor_ctx, 8, 64, (void (*)(void *)) tcp_acceptor_func, "tcp"); mpmc_init(&tcp_acceptor_ctx, 8, 64, (void (*)(void *)) tcp_acceptor_func, "tcp");
mpmc_init(&request_handler_ctx, 16, 64, (void (*)(void *)) request_handler_func, "req"); mpmc_init(&request_handler_ctx, 16, 64, (void (*)(void *)) request_handler_func, "req");
mpmc_init(&local_handler_ctx, 16, 64, (void (*)(void *)) local_handler_func, "local"); mpmc_init(&local_handler_ctx, 16, 64, (void (*)(void *)) local_handler_func, "local");
mpmc_init(&fastcgi_handler_cxt, 16, 64, (void (*)(void *)) fastcgi_handler_func, "fcgi"); mpmc_init(&fastcgi_handler_ctx, 16, 64, (void (*)(void *)) fastcgi_handler_func, "fcgi");
mpmc_init(&proxy_handler_ctx, 16, 64, (void (*)(void *)) proxy_handler_func, "proxy"); mpmc_init(&proxy_handler_ctx, 16, 64, (void (*)(void *)) proxy_handler_func, "proxy");
mpmc_init(&ws_frame_handler_ctx, 16, 64, (void (*)(void *)) ws_frame_handler_func, "ws"); mpmc_init(&ws_frame_handler_ctx, 16, 64, (void (*)(void *)) ws_frame_handler_func, "ws");
return -1; return -1;
@ -28,7 +28,7 @@ int workers_init(void) {
void workers_stop(void) { void workers_stop(void) {
mpmc_stop(&tcp_acceptor_ctx); mpmc_stop(&tcp_acceptor_ctx);
mpmc_stop(&local_handler_ctx); mpmc_stop(&local_handler_ctx);
mpmc_stop(&fastcgi_handler_cxt); mpmc_stop(&fastcgi_handler_ctx);
mpmc_stop(&proxy_handler_ctx); mpmc_stop(&proxy_handler_ctx);
mpmc_stop(&request_handler_ctx); mpmc_stop(&request_handler_ctx);
mpmc_stop(&ws_frame_handler_ctx); mpmc_stop(&ws_frame_handler_ctx);
@ -37,7 +37,7 @@ void workers_stop(void) {
void workers_destroy(void) { void workers_destroy(void) {
mpmc_destroy(&tcp_acceptor_ctx); mpmc_destroy(&tcp_acceptor_ctx);
mpmc_destroy(&local_handler_ctx); mpmc_destroy(&local_handler_ctx);
mpmc_destroy(&fastcgi_handler_cxt); mpmc_destroy(&fastcgi_handler_ctx);
mpmc_destroy(&proxy_handler_ctx); mpmc_destroy(&proxy_handler_ctx);
mpmc_destroy(&request_handler_ctx); mpmc_destroy(&request_handler_ctx);
mpmc_destroy(&ws_frame_handler_ctx); mpmc_destroy(&ws_frame_handler_ctx);
@ -68,7 +68,7 @@ int local_handle(client_ctx_t *ctx) {
} }
int fastcgi_handle(client_ctx_t *ctx) { int fastcgi_handle(client_ctx_t *ctx) {
return mpmc_queue(&fastcgi_handler_cxt, ctx); return mpmc_queue(&fastcgi_handler_ctx, ctx);
} }
int proxy_handle(client_ctx_t *ctx) { int proxy_handle(client_ctx_t *ctx) {