Lines Matching refs:uv
2559 struct datauv *uv; member
2564 static void check_multi_info(struct datauv *uv) in check_multi_info() argument
2568 result = check_finished(uv->s); in check_multi_info()
2569 if(result && !uv->s->result) in check_multi_info()
2570 uv->s->result = result; in check_multi_info()
2572 if(uv->s->more_transfers) { in check_multi_info()
2573 result = add_parallel_transfers(uv->s->global, uv->s->multi, in check_multi_info()
2574 uv->s->share, in check_multi_info()
2575 &uv->s->more_transfers, in check_multi_info()
2576 &uv->s->added_transfers); in check_multi_info()
2577 if(result && !uv->s->result) in check_multi_info()
2578 uv->s->result = result; in check_multi_info()
2580 uv_stop(uv->loop); in check_multi_info()
2595 curl_multi_socket_action(c->uv->s->multi, c->sockfd, flags, in on_uv_socket()
2596 &c->uv->s->still_running); in on_uv_socket()
2602 struct datauv *uv = (struct datauv *) req->data; in on_uv_timeout() local
2606 if(uv && uv->s) { in on_uv_timeout()
2607 curl_multi_socket_action(uv->s->multi, CURL_SOCKET_TIMEOUT, 0, in on_uv_timeout()
2608 &uv->s->still_running); in on_uv_timeout()
2609 check_multi_info(uv); in on_uv_timeout()
2615 struct datauv *uv) in cb_timeout() argument
2622 uv_timer_stop(&uv->timeout); in cb_timeout()
2627 uv_timer_start(&uv->timeout, on_uv_timeout, timeout_ms, in cb_timeout()
2634 struct datauv *uv) in create_context() argument
2641 c->uv = uv; in create_context()
2643 uv_poll_init_socket(uv->loop, &c->poll_handle, sockfd); in create_context()
2662 struct datauv *uv, in cb_socket() argument
2674 (struct contextuv *) socketp : create_context(s, uv); in cb_socket()
2676 curl_multi_assign(uv->s->multi, s, c); in cb_socket()
2690 curl_multi_assign(uv->s->multi, s, NULL); in cb_socket()
2692 check_multi_info(uv); in cb_socket()
2705 struct datauv uv = { 0 }; in parallel_event() local
2708 uv.s = s; in parallel_event()
2709 uv.loop = uv_default_loop(); in parallel_event()
2710 uv_timer_init(uv.loop, &uv.timeout); in parallel_event()
2711 uv.timeout.data = &uv; in parallel_event()
2715 curl_multi_setopt(s->multi, CURLMOPT_SOCKETDATA, &uv); in parallel_event()
2717 curl_multi_setopt(s->multi, CURLMOPT_TIMERDATA, &uv); in parallel_event()
2726 "%d more\n", s->mcode, uv.s->still_running, s->more_transfers); in parallel_event()
2728 uv_run(uv.loop, UV_RUN_DEFAULT); in parallel_event()
2761 s->result, s->mcode, uv.s->still_running, s->more_transfers); in parallel_event()
