falcotcp 0.2.0

TCP server/client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

#ifndef NETWORKER_H
#define NETWORKER_H

#include <stddef.h>
#include <stdint.h>
#include <liburing.h>

// Aliases
typedef uint64_t u64;
typedef uint8_t u8;
typedef size_t usize;

// Client states
enum State {
    NonExistent = 0,
    Idle = 1,
    HeadersReaden = 2,
    Finished_H = 3,
    Reading = 4,
    Finished_R = 5,
    Available = 6,
    Processing = 7,
    Ready = 8,
    WrittingSock = 9,
    Kill = 10,
    Finished_WS = 11,
};

// Message headers
typedef struct {
    u64 size;
    u8 compr_alg;
} MessageHeaders;

// Client structure
typedef struct {
    int sock;
    unsigned char* request;
    unsigned char* response;
    MessageHeaders req_headers; 
    u64 response_size;
    usize recv_offset;
    usize writev_offset;
    u64 id; 
    int state;
    u64 activity;
    u64 capacity;
} Client;

// Compression algorithms
enum CompressionAlgorithm {
    None = 0,
    LZMA = 1,
    GZIP = 2,
    LZ4 = 3,
    ZSTD = 4,
};

// IO operations
enum Operation {
    OP_SocketAcc = 0,
    OP_Read = 1,
    OP_Write = 2,
    OP_Close = 3,
};

// Networker configuration
struct NetworkerSettings {
    char host[16];
    unsigned short port;
    unsigned short max_queue;
    unsigned short max_clients;
};

// Networker main structure
typedef struct {
    int initiated;
    int sock;
    u64 client_num;
    Client* clients;
    struct io_uring *ring;
    u64* author_log;
} Networker;

// Rust helper struct
typedef struct {
    Client* client;
    usize exists;
} SomeClient;

// Function declarations
int start(Networker* self, struct NetworkerSettings* s);
int proc(Networker* self);
int apply_client_response(Networker* self, u64 client_id, unsigned char* buffer, u64 buffer_size, int compression_algorithm);
SomeClient get_client(Networker* self);
int claim_client(Networker* self, u64 client_id);
int kill_client(Networker* self, u64 client_id);
int cycle(Networker* self);

#endif // NETWORKER_H