Lines Matching refs:tcp_data
5190 struct tcp_handler_data *tcp_data; in handle_tcp_accept() local
5263 tcp_data = (struct tcp_handler_data *) region_alloc( in handle_tcp_accept()
5265 tcp_data->region = tcp_region; in handle_tcp_accept()
5266 tcp_data->query = query_create(tcp_region, compressed_dname_offsets, in handle_tcp_accept()
5268 tcp_data->nsd = data->nsd; in handle_tcp_accept()
5269 tcp_data->query_count = 0; in handle_tcp_accept()
5271 tcp_data->shake_state = tls_hs_none; in handle_tcp_accept()
5272 tcp_data->tls = NULL; in handle_tcp_accept()
5274 tcp_data->query_needs_reset = 1; in handle_tcp_accept()
5275 tcp_data->pp2_enabled = data->pp2_enabled; in handle_tcp_accept()
5276 tcp_data->pp2_header_state = pp2_header_none; in handle_tcp_accept()
5277 tcp_data->prev = NULL; in handle_tcp_accept()
5278 tcp_data->next = NULL; in handle_tcp_accept()
5280 tcp_data->query_state = QUERY_PROCESSED; in handle_tcp_accept()
5281 tcp_data->bytes_transmitted = 0; in handle_tcp_accept()
5282 memcpy(&tcp_data->query->remote_addr, &addr, addrlen); in handle_tcp_accept()
5283 tcp_data->query->remote_addrlen = addrlen; in handle_tcp_accept()
5286 memcpy(&tcp_data->query->client_addr, &addr, addrlen); in handle_tcp_accept()
5287 tcp_data->query->client_addrlen = addrlen; in handle_tcp_accept()
5288 tcp_data->query->is_proxied = 0; in handle_tcp_accept()
5290 tcp_data->tcp_no_more_queries = 0; in handle_tcp_accept()
5291 tcp_data->tcp_timeout = data->nsd->tcp_timeout * 1000; in handle_tcp_accept()
5294 tcp_data->tcp_timeout = 200; in handle_tcp_accept()
5296 memset(&tcp_data->event, 0, sizeof(tcp_data->event)); in handle_tcp_accept()
5297 timeout.tv_sec = tcp_data->tcp_timeout / 1000; in handle_tcp_accept()
5298 timeout.tv_usec = (tcp_data->tcp_timeout % 1000)*1000; in handle_tcp_accept()
5302 tcp_data->socket = data->socket; in handle_tcp_accept()
5307 tcp_data->tls = incoming_ssl_fd(tcp_data->nsd->tls_ctx, s); in handle_tcp_accept()
5308 if(!tcp_data->tls) { in handle_tcp_accept()
5312 tcp_data->shake_state = tls_hs_read; in handle_tcp_accept()
5313 memset(&tcp_data->event, 0, sizeof(tcp_data->event)); in handle_tcp_accept()
5314 event_set(&tcp_data->event, s, EV_PERSIST | EV_READ | EV_TIMEOUT, in handle_tcp_accept()
5315 handle_tls_reading, tcp_data); in handle_tcp_accept()
5318 memset(&tcp_data->event, 0, sizeof(tcp_data->event)); in handle_tcp_accept()
5319 event_set(&tcp_data->event, s, EV_PERSIST | EV_READ | EV_TIMEOUT, in handle_tcp_accept()
5320 handle_tcp_reading, tcp_data); in handle_tcp_accept()
5324 if(event_base_set(data->event.ev_base, &tcp_data->event) != 0) { in handle_tcp_accept()
5330 if(event_add(&tcp_data->event, &timeout) != 0) { in handle_tcp_accept()
5337 tcp_active_list->prev = tcp_data; in handle_tcp_accept()
5338 tcp_data->next = tcp_active_list; in handle_tcp_accept()
5340 tcp_active_list = tcp_data; in handle_tcp_accept()