Lines Matching refs:tcp_data
5043 struct tcp_handler_data *tcp_data; in handle_tcp_accept() local
5116 tcp_data = (struct tcp_handler_data *) region_alloc( in handle_tcp_accept()
5118 tcp_data->region = tcp_region; in handle_tcp_accept()
5119 tcp_data->query = query_create(tcp_region, compressed_dname_offsets, in handle_tcp_accept()
5121 tcp_data->nsd = data->nsd; in handle_tcp_accept()
5122 tcp_data->query_count = 0; in handle_tcp_accept()
5124 tcp_data->shake_state = tls_hs_none; in handle_tcp_accept()
5125 tcp_data->tls = NULL; in handle_tcp_accept()
5127 tcp_data->query_needs_reset = 1; in handle_tcp_accept()
5128 tcp_data->pp2_enabled = data->pp2_enabled; in handle_tcp_accept()
5129 tcp_data->pp2_header_state = pp2_header_none; in handle_tcp_accept()
5130 tcp_data->prev = NULL; in handle_tcp_accept()
5131 tcp_data->next = NULL; in handle_tcp_accept()
5133 tcp_data->query_state = QUERY_PROCESSED; in handle_tcp_accept()
5134 tcp_data->bytes_transmitted = 0; in handle_tcp_accept()
5135 memcpy(&tcp_data->query->remote_addr, &addr, addrlen); in handle_tcp_accept()
5136 tcp_data->query->remote_addrlen = addrlen; in handle_tcp_accept()
5139 memcpy(&tcp_data->query->client_addr, &addr, addrlen); in handle_tcp_accept()
5140 tcp_data->query->client_addrlen = addrlen; in handle_tcp_accept()
5141 tcp_data->query->is_proxied = 0; in handle_tcp_accept()
5143 tcp_data->tcp_no_more_queries = 0; in handle_tcp_accept()
5144 tcp_data->tcp_timeout = data->nsd->tcp_timeout * 1000; in handle_tcp_accept()
5147 tcp_data->tcp_timeout = 200; in handle_tcp_accept()
5149 memset(&tcp_data->event, 0, sizeof(tcp_data->event)); in handle_tcp_accept()
5150 timeout.tv_sec = tcp_data->tcp_timeout / 1000; in handle_tcp_accept()
5151 timeout.tv_usec = (tcp_data->tcp_timeout % 1000)*1000; in handle_tcp_accept()
5155 tcp_data->socket = data->socket; in handle_tcp_accept()
5160 tcp_data->tls = incoming_ssl_fd(tcp_data->nsd->tls_ctx, s); in handle_tcp_accept()
5161 if(!tcp_data->tls) { in handle_tcp_accept()
5165 tcp_data->shake_state = tls_hs_read; in handle_tcp_accept()
5166 memset(&tcp_data->event, 0, sizeof(tcp_data->event)); in handle_tcp_accept()
5167 event_set(&tcp_data->event, s, EV_PERSIST | EV_READ | EV_TIMEOUT, in handle_tcp_accept()
5168 handle_tls_reading, tcp_data); in handle_tcp_accept()
5171 memset(&tcp_data->event, 0, sizeof(tcp_data->event)); in handle_tcp_accept()
5172 event_set(&tcp_data->event, s, EV_PERSIST | EV_READ | EV_TIMEOUT, in handle_tcp_accept()
5173 handle_tcp_reading, tcp_data); in handle_tcp_accept()
5177 if(event_base_set(data->event.ev_base, &tcp_data->event) != 0) { in handle_tcp_accept()
5183 if(event_add(&tcp_data->event, &timeout) != 0) { in handle_tcp_accept()
5190 tcp_active_list->prev = tcp_data; in handle_tcp_accept()
5191 tcp_data->next = tcp_active_list; in handle_tcp_accept()
5193 tcp_active_list = tcp_data; in handle_tcp_accept()