97 lines
2.2 KiB
C
97 lines
2.2 KiB
C
/**
|
|
* sesimos - secure, simple, modern web server
|
|
* @brief Worker function header file
|
|
* @file src/worker/func.h
|
|
* @author Lorenz Stechauner
|
|
* @date 2022-12-29
|
|
*/
|
|
|
|
#ifndef SESIMOS_FUNC_H
|
|
#define SESIMOS_FUNC_H
|
|
|
|
#include "../defs.h"
|
|
#include "../lib/sock.h"
|
|
#include "../lib/http.h"
|
|
#include "../lib/uri.h"
|
|
#include "../lib/config.h"
|
|
#include "../lib/proxy.h"
|
|
#include "../lib/fastcgi.h"
|
|
|
|
typedef struct {
|
|
sock socket;
|
|
int req_num;
|
|
unsigned char s_keep_alive:1, c_keep_alive:1, use_fastcgi:4, use_proxy:2, ws_close:2, chunks_transferred:1;
|
|
char cc[3], host[256];
|
|
char req_host[256], err_msg[256];
|
|
char log_prefix[128];
|
|
char _c_addr[INET6_ADDRSTRLEN + 1], _s_addr[INET6_ADDRSTRLEN + 1];
|
|
long cnx_s, cnx_e, req_s, res_ts, req_e;
|
|
http_req req;
|
|
http_res res;
|
|
http_uri uri;
|
|
http_status_ctx status;
|
|
http_status custom_status;
|
|
host_config_t *conf;
|
|
FILE *file;
|
|
long content_length;
|
|
char *msg_buf, *msg_buf_ptr, msg_content[1024];
|
|
proxy_ctx_t *proxy;
|
|
void *fcgi_ctx;
|
|
} client_ctx_t;
|
|
|
|
typedef struct {
|
|
client_ctx_t *client;
|
|
sock *socket;
|
|
void *other;
|
|
} ws_ctx_t;
|
|
|
|
typedef struct {
|
|
int closed:2;
|
|
client_ctx_t *client;
|
|
fastcgi_cnx_t cnx;
|
|
} fastcgi_ctx_t;
|
|
|
|
typedef struct {
|
|
client_ctx_t *client;
|
|
sock *socket;
|
|
int flags;
|
|
void (*next_cb)(void *);
|
|
void (*err_cb)(void *);
|
|
} chunk_ctx_t;
|
|
|
|
void tcp_acceptor_func(client_ctx_t *ctx);
|
|
|
|
void request_handler_func(client_ctx_t *ctx);
|
|
|
|
void local_handler_func(client_ctx_t *ctx);
|
|
|
|
void fastcgi_handler_func(client_ctx_t *ctx);
|
|
|
|
void fastcgi_frame_handler_func(fastcgi_ctx_t *ctx);
|
|
|
|
void proxy_handler_func(client_ctx_t *ctx);
|
|
|
|
void ws_frame_handler_func(ws_ctx_t *ctx);
|
|
|
|
void chunk_handler_func(chunk_ctx_t *ctx);
|
|
|
|
int respond(client_ctx_t *ctx);
|
|
|
|
void request_complete(client_ctx_t *ctx);
|
|
|
|
void timeout_request(client_ctx_t *ctx);
|
|
|
|
void tcp_close(client_ctx_t *ctx);
|
|
|
|
int ws_handle_connection(client_ctx_t *ctx);
|
|
|
|
void ws_close(ws_ctx_t *ctx);
|
|
|
|
int handle_chunks(client_ctx_t *ctx, sock *socket, int flags, void (*next_cb)(chunk_ctx_t *), void (*err_cb)(chunk_ctx_t *));
|
|
|
|
int fastcgi_handle_connection(client_ctx_t *ctx, fastcgi_cnx_t **cnx);
|
|
|
|
void fastcgi_close(fastcgi_ctx_t *ctx);
|
|
|
|
#endif //SESIMOS_FUNC_H
|