diff options
Diffstat (limited to 'common/include/tfe_packet_io.h')
| -rw-r--r-- | common/include/tfe_packet_io.h | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/common/include/tfe_packet_io.h b/common/include/tfe_packet_io.h index eaf1d74..23c3bde 100644 --- a/common/include/tfe_packet_io.h +++ b/common/include/tfe_packet_io.h @@ -33,14 +33,13 @@ struct packet_io_thread_ctx 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 packet_io_fs *ret_fs_state; struct acceptor_kni_v4 *ref_acceptor_ctx; + void *logger; int session_table_need_reset; }; @@ -80,10 +79,9 @@ struct acceptor_kni_v4 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]; @@ -96,10 +94,10 @@ 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); +int packet_io_thread_init(struct packet_io *handle, struct packet_io_thread_ctx *thread_ctx, void *logger); 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); +struct packet_io *packet_io_create(const char *profile, int thread_num, cpu_set_t *coremask, void *logger); 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); |