Lines Matching refs:td
330 struct thread_data *td = (struct thread_data*) async->os_specific;
332 if(td->dummy_sock != CURL_SOCKET_BAD)
333 sclose(td->dummy_sock);
335 if(td->thread_hnd != curl_thread_t_null)
336 Curl_thread_join(&td->thread_hnd);
338 destroy_thread_sync_data(&td->tsd);
356 struct thread_data *td = calloc(1, sizeof(struct thread_data));
359 conn->async.os_specific = (void*) td;
360 if(!td)
367 td->dummy_sock = CURL_SOCKET_BAD;
368 td->thread_hnd = curl_thread_t_null;
370 if(!init_thread_sync_data(&td->tsd, hostname, port, hints))
383 td->dummy_sock = socket(AF_INET, SOCK_DGRAM, 0);
384 if(td->dummy_sock == CURL_SOCKET_BAD)
389 td->thread_hnd = Curl_thread_create(getaddrinfo_thread, &td->tsd);
391 td->thread_hnd = Curl_thread_create(gethostbyname_thread, &td->tsd);
394 if(!td->thread_hnd) {
481 struct thread_data *td = (struct thread_data*) conn->async.os_specific;
484 DEBUGASSERT(conn && td);
487 if(Curl_thread_join(&td->thread_hnd))
526 struct thread_data *td = (struct thread_data*) conn->async.os_specific;
531 if(!td) {
532 DEBUGASSERT(td);
536 Curl_mutex_acquire(td->tsd.mtx);
537 done = td->tsd.done;
538 Curl_mutex_release(td->tsd.mtx);
556 if(td->poll_interval == 0)
558 td->poll_interval = 1;
559 else if(elapsed >= td->interval_end)
561 td->poll_interval *= 2;
563 if(td->poll_interval > 250)
564 td->poll_interval = 250;
566 td->interval_end = elapsed + td->poll_interval;
567 Curl_expire(conn->data, td->poll_interval);
577 const struct thread_data *td =
580 if(td && td->dummy_sock != CURL_SOCKET_BAD) {
584 socks[0] = td->dummy_sock;