Lines Matching refs:uv
2493 struct datauv *uv; member
2498 static void check_multi_info(struct datauv *uv) in check_multi_info() argument
2502 result = check_finished(uv->s); in check_multi_info()
2503 if(result && !uv->s->result) in check_multi_info()
2504 uv->s->result = result; in check_multi_info()
2506 if(uv->s->more_transfers) { in check_multi_info()
2507 result = add_parallel_transfers(uv->s->global, uv->s->multi, in check_multi_info()
2508 uv->s->share, in check_multi_info()
2509 &uv->s->more_transfers, in check_multi_info()
2510 &uv->s->added_transfers); in check_multi_info()
2511 if(result && !uv->s->result) in check_multi_info()
2512 uv->s->result = result; in check_multi_info()
2514 uv_stop(uv->loop); in check_multi_info()
2529 curl_multi_socket_action(c->uv->s->multi, c->sockfd, flags, in on_uv_socket()
2530 &c->uv->s->still_running); in on_uv_socket()
2536 struct datauv *uv = (struct datauv *) req->data; in on_uv_timeout() local
2540 if(uv && uv->s) { in on_uv_timeout()
2541 curl_multi_socket_action(uv->s->multi, CURL_SOCKET_TIMEOUT, 0, in on_uv_timeout()
2542 &uv->s->still_running); in on_uv_timeout()
2543 check_multi_info(uv); in on_uv_timeout()
2549 struct datauv *uv) in cb_timeout() argument
2556 uv_timer_stop(&uv->timeout); in cb_timeout()
2561 uv_timer_start(&uv->timeout, on_uv_timeout, timeout_ms, in cb_timeout()
2568 struct datauv *uv) in create_context() argument
2575 c->uv = uv; in create_context()
2577 uv_poll_init_socket(uv->loop, &c->poll_handle, sockfd); in create_context()
2596 struct datauv *uv, in cb_socket() argument
2608 (struct contextuv *) socketp : create_context(s, uv); in cb_socket()
2610 curl_multi_assign(uv->s->multi, s, c); in cb_socket()
2624 curl_multi_assign(uv->s->multi, s, NULL); in cb_socket()
2626 check_multi_info(uv); in cb_socket()
2639 struct datauv uv = { 0 }; in parallel_event() local
2642 uv.s = s; in parallel_event()
2643 uv.loop = uv_default_loop(); in parallel_event()
2644 uv_timer_init(uv.loop, &uv.timeout); in parallel_event()
2645 uv.timeout.data = &uv; in parallel_event()
2649 curl_multi_setopt(s->multi, CURLMOPT_SOCKETDATA, &uv); in parallel_event()
2651 curl_multi_setopt(s->multi, CURLMOPT_TIMERDATA, &uv); in parallel_event()
2660 "%d more\n", s->mcode, uv.s->still_running, s->more_transfers); in parallel_event()
2662 uv_run(uv.loop, UV_RUN_DEFAULT); in parallel_event()
2695 s->result, s->mcode, uv.s->still_running, s->more_transfers); in parallel_event()
