Lines Matching defs:pend_tcp

476 reuse_tcp_insert(struct outside_network* outnet, struct pending_tcp* pend_tcp)
478 	log_reuse_tcp(VERB_CLIENT, "reuse_tcp_insert", &pend_tcp->reuse);
479 	if(pend_tcp->reuse.item_on_lru_list) {
480 		if(!pend_tcp->reuse.node.key)
485 	pend_tcp->reuse.node.key = &pend_tcp->reuse;
486 	pend_tcp->reuse.pending = pend_tcp;
487 	if(!rbtree_insert(&outnet->tcp_reuse, &pend_tcp->reuse.node)) {
495 	pend_tcp->reuse.lru_prev = NULL;
497 		pend_tcp->reuse.lru_next = outnet->tcp_reuse_first;
498 		log_assert(pend_tcp->reuse.lru_next != &pend_tcp->reuse);
499 		outnet->tcp_reuse_first->lru_prev = &pend_tcp->reuse;
503 		pend_tcp->reuse.lru_next = NULL;
504 		outnet->tcp_reuse_last = &pend_tcp->reuse;
506 	outnet->tcp_reuse_first = &pend_tcp->reuse;
507 	pend_tcp->reuse.item_on_lru_list = 1;
949 		struct pending_tcp* pend_tcp = NULL;
965 			pend_tcp = reuse->pending;
998 			pend_tcp = pend;
1006 		if(outnet->dtenv && pend_tcp && w && w->sq &&
1012 				&pend_tcp->pi->addr, comm_tcp, NULL, w->sq->zone,
1261 reuse_tcp_setup_timeout(struct pending_tcp* pend_tcp, int tcp_reuse_timeout)
1263 	log_reuse_tcp(VERB_CLIENT, "reuse_tcp_setup_timeout", &pend_tcp->reuse);
1264 	comm_point_start_listening(pend_tcp->c, -1, tcp_reuse_timeout);
1269 reuse_tcp_setup_read_and_timeout(struct pending_tcp* pend_tcp, int tcp_reuse_timeout)
1271 	log_reuse_tcp(VERB_CLIENT, "reuse_tcp_setup_readtimeout", &pend_tcp->reuse);
1272 	sldns_buffer_clear(pend_tcp->c->buffer);
1273 	pend_tcp->c->tcp_is_reading = 1;
1274 	pend_tcp->c->tcp_byte_count = 0;
1275 	comm_point_stop_listening(pend_tcp->c);
1276 	comm_point_start_listening(pend_tcp->c, -1, tcp_reuse_timeout);
2697 	struct pending_tcp* pend_tcp = (struct pending_tcp*)w->next_waiting;
2706 	if(pend_tcp->c->fd == -1) {
2711 	if(pend_tcp->reuse.node.key) {
2720 	if(pend_tcp->c->fd != -1 && sq->outnet->tcp_reuse.count <
2724 		if(!reuse_tcp_insert(sq->outnet, pend_tcp)) {
2727 		reuse_tcp_setup_timeout(pend_tcp, sq->outnet->tcp_reuse_timeout);
3080 	struct pending_tcp* pend_tcp = NULL;
3083 		pend_tcp = (struct pending_tcp*)w->next_waiting;
3084 		pi = pend_tcp->pi;