Lines Matching defs:pend_tcp
428 reuse_tcp_insert(struct outside_network* outnet, struct pending_tcp* pend_tcp)
430 log_reuse_tcp(VERB_CLIENT, "reuse_tcp_insert", &pend_tcp->reuse);
431 if(pend_tcp->reuse.item_on_lru_list) {
432 if(!pend_tcp->reuse.node.key)
436 pend_tcp->reuse.node.key = &pend_tcp->reuse;
437 pend_tcp->reuse.pending = pend_tcp;
438 if(!rbtree_insert(&outnet->tcp_reuse, &pend_tcp->reuse.node)) {
441 pend_tcp->reuse.node.key = NULL;
445 pend_tcp->reuse.lru_prev = NULL;
447 pend_tcp->reuse.lru_next = outnet->tcp_reuse_first;
448 outnet->tcp_reuse_first->lru_prev = &pend_tcp->reuse;
450 pend_tcp->reuse.lru_next = NULL;
451 outnet->tcp_reuse_last = &pend_tcp->reuse;
453 outnet->tcp_reuse_first = &pend_tcp->reuse;
454 pend_tcp->reuse.item_on_lru_list = 1;
980 reuse_tcp_setup_timeout(struct pending_tcp* pend_tcp)
982 log_reuse_tcp(VERB_CLIENT, "reuse_tcp_setup_timeout", &pend_tcp->reuse);
983 comm_point_start_listening(pend_tcp->c, -1, REUSE_TIMEOUT);
988 reuse_tcp_setup_read_and_timeout(struct pending_tcp* pend_tcp)
990 log_reuse_tcp(VERB_CLIENT, "reuse_tcp_setup_readtimeout", &pend_tcp->reuse);
991 sldns_buffer_clear(pend_tcp->c->buffer);
992 pend_tcp->c->tcp_is_reading = 1;
993 pend_tcp->c->tcp_byte_count = 0;
994 comm_point_stop_listening(pend_tcp->c);
995 comm_point_start_listening(pend_tcp->c, -1, REUSE_TIMEOUT);
2359 struct pending_tcp* pend_tcp = (struct pending_tcp*)w->next_waiting;
2368 if(pend_tcp->c->fd == -1) {
2373 if(pend_tcp->reuse.node.key) {
2382 if(pend_tcp->c->fd != -1 && sq->outnet->tcp_reuse.count <
2386 if(!reuse_tcp_insert(sq->outnet, pend_tcp)) {
2389 reuse_tcp_setup_timeout(pend_tcp);