common/include/tfe_packet_io.h


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
102
103
104
105
106
107
108
109
110
111
112

#ifndef _TFE_PACKET_IO_H
#define _TFE_PACKET_IO_H

#ifdef __cpluscplus
extern "C"
{
#endif

#include "tfe_addr_tuple4.h"

struct tap_ctx
{
    int tap_s;
    int tap_c;
    int tap_fd;

    int eventfd;
    int eventfd_c;
    int eventfd_s;

    struct io_uring_instance *io_uring_fd;
    struct io_uring_instance *io_uring_c;
    struct io_uring_instance *io_uring_s;

    int buff_size;
    char *buff;
};

struct packet_io_thread_ctx
{
    pthread_t tid;
    int thread_index;
    
    struct tap_ctx *tap_ctx;
    struct session_table *session_table;
    struct sf_metrics *sf_metrics;

    struct packet_io *ref_io;
    struct packet_io_fs *ret_fs_state;
    struct policy_enforcer *ref_enforcer;
    struct tfe_proxy *ref_proxy;
    struct acceptor_kni_v4 *ref_acceptor_ctx;

    int session_table_need_reset;
};

struct packet_info
{
    int is_e2i_dir;
    struct addr_tuple4 tuple4;

    char *header_data;
    int header_len;
};

struct session_ctx
{
    int policy_ids;
    uint64_t session_id;
    char *session_addr;

    char client_mac[6];
    char server_mac[6];

    struct packet_info c2s_info;
    struct packet_info s2c_info;

    struct metadata *raw_meta_i2e;
    struct metadata *raw_meta_e2i;
    struct metadata *ctrl_meta;

    struct tfe_cmsg *cmsg;

    struct packet_io_thread_ctx *ref_thread_ctx;
};

struct acceptor_kni_v4
{
    int firewall_sids;
    int proxy_sids;
    int sce_sids;
    int nr_worker_threads;
    
    int cpu_affinity_mask[TFE_THREAD_MAX];

    cpu_set_t coremask;
    struct packet_io *io;
    struct packet_io_fs *packet_io_fs;
    struct packet_io_thread_ctx work_threads[TFE_THREAD_MAX];

    struct tfe_proxy *ref_proxy;
};

int is_enable_iouring(struct packet_io *handle);

void tfe_tap_ctx_destory(struct tap_ctx *handler);
struct tap_ctx *tfe_tap_ctx_create(void *ctx);

int packet_io_thread_init(struct packet_io *handle, struct packet_io_thread_ctx *thread_ctx);
void packet_io_thread_wait(struct packet_io *handle, struct packet_io_thread_ctx *thread_ctx, int timeout_ms);
void packet_io_destory(struct packet_io *handle);
struct packet_io *packet_io_create(const char *profile, int thread_num, cpu_set_t *coremask);

int packet_io_polling_nf_interface(struct packet_io *handle, int thread_seq, void *ctx);
void handle_decryption_packet_from_tap(const char *data, int len, void *args);
void handle_raw_packet_from_tap(const char *data, int len, void *args);

#ifdef __cpluscplus
}
#endif

#endif