vectorloop.h

Go to the documentation of this file.

 
#ifndef VECTORLOOP_H
#define VECTORLOOP_H
 
#include <stdint.h>
#include <sys/epoll.h>
#include <time.h>
 
// Debug
#include <stdio.h>
//EofDebug
 
 
#include "channel.h"
#include "constants.h"
#include "conn.h"
#include "metrics.h"
#include "query.h"
 
 
typedef struct vectorloop_s
{
    config_t *cfg;
 
    uint16_t id;
 
    channel_bss_t *resource_channel;
 
    channel_log_t *app_log_channel;
 
    channel_bss_t *query_log_channel;
 
    metrics_t *metrics;
 
    struct timespec loop_timestamp;
 
    int ep_fd_udp;
 
    int ep_fd_tcp;
 
    uint64_t conns_tcp_active;
 
    struct epoll_event *ep_events;
 
    conn_t *listener_udp_ipv4;
 
    conn_t *listener_udp_ipv6;
 
    conn_t *listener_tcp_ipv4;
 
    conn_t *listener_tcp_ipv6;
 
    conn_t *conn_tcp_lru_cache;
 
    uint64_t conn_tcp_id_base;
 
    conn_fifo_queue_t conn_udp_read_queue;
 
    conn_fifo_queue_t conn_udp_write_queue;
 
    conn_fifo_queue_t conn_tcp_accept_conns_queue;
 
    conn_fifo_queue_t conn_tcp_read_queue;
 
    conn_fifo_queue_t conn_tcp_write_queue;
 
    conn_fifo_queue_t conn_tcp_release_queue;
 
    conn_fifo_queue_t query_parse_queue;
 
    conn_fifo_queue_t query_resolve_queue;
 
    conn_fifo_queue_t query_response_pack_queue;
 
    conn_fifo_queue_t query_log_queue;
 
    query_log_t query_log;
 
    uint32_t idle_count;
} vectorloop_t;
 
vectorloop_t * vl_new(config_t *cfg, int id, channel_bss_t *res_ch,
                      channel_log_t *app_log_channel,
                      channel_bss_t *query_log_channel,
                      metrics_t *metrics);
void         * vl_run(void *arg);
 
#endif /* End of VECTORLOOP_H */