xfrd_tcp_pipeline
{ cfg_parser->opt->xfrd_tcp_pipeline = (int)$2; }
SERV_GET_INT(xfrd_tcp_pipeline, o);
printf("\txfrd-tcp-pipeline: %d\n", opt->xfrd_tcp_pipeline);
opt->xfrd_tcp_pipeline = 128;
int xfrd_tcp_pipeline;
xfrd_tcp_setup_write_packet(struct xfrd_tcp_pipeline* tp, xfrd_zone_type* zone)
xfrd_tcp_write(struct xfrd_tcp_pipeline* tp, xfrd_zone_type* zone)
xfrd_tcp_read(struct xfrd_tcp_pipeline* tp)
struct xfrd_tcp_pipeline* tp = set->tcp_state[conn];
setup_ssl(struct xfrd_tcp_pipeline* tp, struct xfrd_tcp_set* tcp_set,
xfrd_tcp_pipe_release(struct xfrd_tcp_set* set, struct xfrd_tcp_pipeline* tp,
ssl_handshake(struct xfrd_tcp_pipeline* tp)
const struct xfrd_tcp_pipeline* x = (struct xfrd_tcp_pipeline*)a;
const struct xfrd_tcp_pipeline* y = (struct xfrd_tcp_pipeline*)b;
clear_pipeline_entry(struct xfrd_tcp_pipeline* tp, rbnode_type* node)
xfrd_tcp_pipeline_cleanup(struct xfrd_tcp_pipeline* tp)
xfrd_tcp_pipeline_init(struct xfrd_tcp_pipeline* tp)
struct xfrd_tcp_pipeline*
struct xfrd_tcp_pipeline* tp = (struct xfrd_tcp_pipeline*)
xfrd_tcp_pipeline_lookup_id(struct xfrd_tcp_pipeline* tp, uint16_t id)
xfrd_tcp_pipeline_insert_id(struct xfrd_tcp_pipeline* tp, uint16_t id,
xfrd_tcp_pipeline_remove_id(struct xfrd_tcp_pipeline* tp, uint16_t id)
xfrd_tcp_pipeline_skip_id(struct xfrd_tcp_pipeline* tp, uint16_t id)
static struct xfrd_tcp_pipeline*
struct xfrd_tcp_pipeline* r;
r = (struct xfrd_tcp_pipeline*)sme->key;
tcp_pipe_sendlist_remove(struct xfrd_tcp_pipeline* tp, xfrd_zone_type* zone)
tcp_pipe_sendlist_popfirst(struct xfrd_tcp_pipeline* tp, xfrd_zone_type* zone)
tcp_pipe_id_remove(struct xfrd_tcp_pipeline* tp, xfrd_zone_type* zone,
xfrd_tcp_pipe_stop(struct xfrd_tcp_pipeline* tp)
tcp_pipe_reset_timeout(struct xfrd_tcp_pipeline* tp)
struct xfrd_tcp_pipeline* tp = (struct xfrd_tcp_pipeline*)arg;
pipeline_setup_new_zone(struct xfrd_tcp_set* set, struct xfrd_tcp_pipeline* tp,
struct xfrd_tcp_pipeline* tp;
xfrd_tcp_open(struct xfrd_tcp_set* set, struct xfrd_tcp_pipeline* tp,
struct xfrd_tcp_pipeline* tp, int conn);
void xfrd_tcp_setup_write_packet(struct xfrd_tcp_pipeline* tp,
int xfrd_tcp_open(struct xfrd_tcp_set* set, struct xfrd_tcp_pipeline* tp,
void xfrd_tcp_read(struct xfrd_tcp_pipeline* tp);
void xfrd_tcp_write(struct xfrd_tcp_pipeline* tp, struct xfrd_zone* zone);
struct xfrd_tcp_pipeline* xfrd_tcp_pipeline_create(region_type* region,
struct xfrd_tcp_pipeline;
struct xfrd_tcp_pipeline **tcp_state;
xfrd->tcp_set = xfrd_tcp_set_create(xfrd->region, nsd->options->tls_cert_bundle, nsd->options->xfrd_tcp_max, nsd->options->xfrd_tcp_pipeline);
struct xfrd_tcp_pipeline* tp = NULL;
struct xfrd_tcp_pipeline* test_tp = xfrd->tcp_set->tcp_state[i];