server_internal.h

Go to the documentation of this file.

 
#ifndef CSILK_SERVER_INTERNAL_H
#define CSILK_SERVER_INTERNAL_H
 
#include <openssl/ssl.h>
#include <stdatomic.h>
#include <uv.h>
#include <llhttp.h>
#include <nghttp2/nghttp2.h>
 
#include "csilk/csilk.h"
#include "context_internal.h"
 
#define CSILK_DEFAULT_IDLE_TIMEOUT 5000
#define CSILK_DEFAULT_MAX_BODY_SIZE (1024UL * 1024UL)
#define CSILK_DEFAULT_MAX_HEADER_SIZE (64UL * 1024UL)
#define CSILK_DEFAULT_LISTEN_BACKLOG 128
#define CSILK_DEFAULT_ARENA_SIZE 4096
 
typedef struct csilk_hook_node_s {
    void* handler;
    struct csilk_hook_node_s* next;
} csilk_hook_node_t;
 
typedef enum { CSILK_PROTO_UNKNOWN, CSILK_PROTO_HTTP1, CSILK_PROTO_HTTP2 } csilk_protocol_t;
 
typedef struct csilk_client_s csilk_client_t;
 
struct csilk_server_s {
    uv_loop_t* loop;         
    csilk_router_t* router;      
    uv_tcp_t server_handle;      
    uv_signal_t sig_handle;      
    uv_async_t async_handle;     
    llhttp_settings_t settings;  
    csilk_server_config_t config;    
    csilk_handler_t middlewares[32]; 
    int middleware_count;        
    int max_connections;         
    atomic_int active_connections;   
    /* close tracking for async shutdown — see csilk_server_free */
    uv_thread_t* worker_tids;       
    int worker_count;           
    uv_async_t* worker_stop_async;      
    int worker_stop_count;          
    csilk_handler_t not_found_handler;  
    char* spa_doc_root;         
    csilk_storage_driver_t* storage_driver; 
    csilk_crypto_driver_t* crypto_driver;   
    csilk_cipher_driver_t* cipher_driver;   
    SSL_CTX* ssl_ctx;           
    csilk_mq_t* mq;             
    csilk_hook_node_t* hooks[CSILK_HOOK_COUNT]; 
    csilk_client_t* active_clients;         
    uv_mutex_t clients_mutex;           
    csilk_client_t* client_pool[32];        
    int client_pool_count;              
    uv_mutex_t pool_mutex;              
};
 
struct csilk_client_s {
    uv_tcp_t handle;      
    uv_timer_t timer;     
    uv_timer_t read_timer;    
    uv_timer_t write_timer;   
    uv_timer_t request_timer; 
    int close_pending;    
    csilk_protocol_t protocol;   
    nghttp2_session* h2_session; 
    csilk_ctx_t* h2_streams;     
    llhttp_t parser; 
    csilk_server_t* server; 
    csilk_ctx_t ctx;    
    size_t total_header_size;     
    size_t header_count;          
    size_t current_url_capacity;  
    size_t header_field_capacity; 
    size_t header_value_capacity; 
    char* current_url;        
    char* current_header_field;   
    char* current_header_value;   
    SSL* ssl;             
    BIO* read_bio;            
    BIO* write_bio;           
    struct csilk_client_s* next;  
    struct csilk_client_s* prev;  
};
 
void csilk_client_write(csilk_client_t* client, const uint8_t* data, size_t length);
 
#endif /* CSILK_SERVER_INTERNAL_H */