context_internal.h

Go to the documentation of this file.

 
#ifndef CSILK_CONTEXT_INTERNAL_H
#define CSILK_CONTEXT_INTERNAL_H
 
#include <setjmp.h>
#include <uv.h>
 
#include "csilk/csilk.h"
 
struct csilk_method_handler_s {
    char* method;                
    csilk_handler_t* handlers;       
    struct csilk_method_handler_s* next; 
    char* path;      
    const char* input_type;  
    const char* output_type; 
    const char* summary;     
    const char* description; 
    const char* perm_required; 
    const char* perm_resource; 
};
typedef struct csilk_method_handler_s csilk_method_handler_t;
 
typedef struct csilk_storage_item_s {
    char* key;             
    void* value;               
    struct csilk_storage_item_s* next; 
} csilk_storage_item_t;
 
struct csilk_ctx_s {
    /* === Handler Chain State === */
    int handler_index;     
    csilk_handler_t* handlers; 
    int aborted;           
    /* === Error Recovery (setjmp/longjmp) === */
    jmp_buf jump_buffer; 
    int has_jump_buffer; 
    /* === Memory Management === */
    csilk_arena_t* arena; 
    /* === Request Data === */
    csilk_request_t request; 
    /* === Response Data === */
    csilk_response_t response; 
    /* === URL Path Parameters === */
    csilk_param_t params[CSILK_MAX_PARAMS]; 
    int params_count; 
    /* === Protocol Mode Flags === */
    int is_websocket; 
    int is_sse;   
    void (*on_ws_message)(csilk_ctx_t* c, const uint8_t* payload, size_t len, int opcode);
 
    void (*on_ws_send)(csilk_ctx_t* c, const uint8_t* payload, size_t len, int opcode);
 
    /* === Pluggable Driver Pointers === */
    csilk_storage_driver_t* storage_driver; 
    csilk_crypto_driver_t* crypto_driver;   
    csilk_cipher_driver_t* cipher_driver;   
    /* === Simple Key-Value Storage (arena-backed linked list) === */
    csilk_storage_item_t* storage_head; 
    struct csilk_server_s* server; 
    /* === HTTP/2 Stream Support === */
    int32_t stream_id; 
    struct csilk_ctx_s*
        next_stream; 
    /* === Internal I/O State === */
    void* _internal_client; 
    uv_work_t work_req; 
    int is_async;       
    int response_started;   
    /* === Zero-Copy File Serving (sendfile) === */
    int file_fd;        
    size_t file_offset; 
    size_t file_size;   
    csilk_method_handler_t*
        current_handler; 
    char request_id[37];
};
 
void _csilk_ctx_init(csilk_ctx_t* c, struct csilk_server_s* s, void* client);
 
#endif /* CSILK_CONTEXT_INTERNAL_H */