/curl/lib/ |
H A D | select.c | 74 if(!timeout_ms) in Curl_wait_ms() 76 if(timeout_ms < 0) { in Curl_wait_ms() 81 delay(timeout_ms); in Curl_wait_ms() 85 if(timeout_ms >= ULONG_MAX) in Curl_wait_ms() 86 timeout_ms = ULONG_MAX-1; in Curl_wait_ms() 89 Sleep((ULONG)timeout_ms); in Curl_wait_ms() 304 if(timeout_ms > INT_MAX) in Curl_poll() 305 timeout_ms = INT_MAX; in Curl_poll() 307 if(timeout_ms > 0) in Curl_poll() 308 pending_ms = (int)timeout_ms; in Curl_poll() [all …]
|
H A D | gopher.c | 143 timediff_t timeout_ms; in gopher_do() local 204 timeout_ms = Curl_timeleft(data, NULL, FALSE); in gopher_do() 205 if(timeout_ms < 0) { in gopher_do() 209 if(!timeout_ms) in gopher_do() 210 timeout_ms = TIMEDIFF_T_MAX; in gopher_do() 218 what = SOCKET_WRITABLE(sockfd, timeout_ms); in gopher_do()
|
H A D | pingpong.c | 54 timediff_t timeout_ms; /* in milliseconds */ in Curl_pp_state_timeout() local 65 timeout_ms = response_time - in Curl_pp_state_timeout() 74 timeout_ms = CURLMIN(timeout_ms, timeout2_ms); in Curl_pp_state_timeout() 77 return timeout_ms; in Curl_pp_state_timeout() 91 timediff_t timeout_ms = Curl_pp_state_timeout(data, pp, disconnecting); in Curl_pp_statemach() local 94 if(timeout_ms <= 0) { in Curl_pp_statemach() 101 if(timeout_ms < interval_ms) in Curl_pp_statemach() 102 interval_ms = timeout_ms; in Curl_pp_statemach()
|
H A D | select.h | 78 timediff_t timeout_ms); 84 int Curl_poll(struct pollfd ufds[], unsigned int nfds, timediff_t timeout_ms); 85 int Curl_wait_ms(timediff_t timeout_ms);
|
H A D | tftp.c | 207 timediff_t timeout_ms; in tftp_set_timeouts() local 211 timeout_ms = Curl_timeleft(state->data, NULL, start); in tftp_set_timeouts() 213 if(timeout_ms < 0) { in tftp_set_timeouts() 219 if(timeout_ms > 0) in tftp_set_timeouts() 220 maxtime = (time_t)(timeout_ms + 500) / 1000; in tftp_set_timeouts() 1188 timediff_t timeout_ms; in tftp_state_timeout() local 1193 timeout_ms = Curl_timeleft(state->data, NULL, in tftp_state_timeout() 1195 if(timeout_ms < 0) { in tftp_state_timeout() 1207 return timeout_ms; in tftp_state_timeout() 1223 timediff_t timeout_ms = tftp_state_timeout(data, &event); in tftp_multi_statemach() local [all …]
|
H A D | asyn-ares.c | 314 static int waitperform(struct Curl_easy *data, timediff_t timeout_ms) in waitperform() argument 344 nfds = Curl_poll(pfd, (unsigned int)num, timeout_ms); in waitperform() 463 timediff_t timeout_ms; in Curl_resolver_wait_resolv() local 480 timeout_ms = (timediff_t)(tvp->tv_usec/1000); in Curl_resolver_wait_resolv() 482 timeout_ms = 1000; in Curl_resolver_wait_resolv() 484 if(waitperform(data, timeout_ms) < 0) in Curl_resolver_wait_resolv()
|
H A D | multi.c | 1277 if(timeout_ms < 0) 1478 if(sleep_ms > timeout_ms) 1479 sleep_ms = timeout_ms; 1483 sleep_ms = timeout_ms; 1680 if(timeout_ms < 0) { 3737 *timeout_ms = 0; 3759 *timeout_ms = (long)diff; 3763 *timeout_ms = 0; 3768 *timeout_ms = -1; 3799 long timeout_ms; local [all …]
|
/curl/docs/examples/ |
H A D | multi-event.c | 151 static int start_timeout(CURLM *multi, long timeout_ms, void *userp) in start_timeout() argument 153 if(timeout_ms < 0) { in start_timeout() 157 if(timeout_ms == 0) in start_timeout() 158 timeout_ms = 1; /* 0 means call socket_action asap */ in start_timeout() 160 tv.tv_sec = timeout_ms / 1000; in start_timeout() 161 tv.tv_usec = (timeout_ms % 1000) * 1000; in start_timeout()
|
H A D | multi-uv.c | 170 static int cb_timeout(CURLM *multi, long timeout_ms, in cb_timeout() argument 174 if(timeout_ms < 0) in cb_timeout() 177 if(timeout_ms == 0) in cb_timeout() 178 timeout_ms = 1; /* 0 means call curl_multi_socket_action asap but NOT in cb_timeout() 180 uv_timer_start(&uv->timeout, on_uv_timeout, timeout_ms, in cb_timeout()
|
H A D | sendrecv.c | 34 static int wait_on_socket(curl_socket_t sockfd, int for_recv, long timeout_ms) in wait_on_socket() argument 40 tv.tv_sec = timeout_ms / 1000; in wait_on_socket() 41 tv.tv_usec = (int)(timeout_ms % 1000) * 1000; in wait_on_socket()
|
H A D | ghiper.c | 158 static int update_timeout_cb(CURLM *multi, long timeout_ms, void *userp) in update_timeout_cb() argument 162 timeout.tv_sec = timeout_ms/1000; in update_timeout_cb() 163 timeout.tv_usec = (timeout_ms%1000)*1000; in update_timeout_cb() 166 timeout_ms, timeout.tv_sec, timeout.tv_usec); in update_timeout_cb() 174 if(timeout_ms >= 0) in update_timeout_cb() 175 g->timer_event = g_timeout_add(timeout_ms, timer_cb, g); in update_timeout_cb()
|
H A D | hiperfifo.c | 142 static int multi_timer_cb(CURLM *multi, long timeout_ms, GlobalInfo *g) in multi_timer_cb() argument 147 timeout.tv_sec = timeout_ms/1000; in multi_timer_cb() 148 timeout.tv_usec = (timeout_ms%1000)*1000; in multi_timer_cb() 149 fprintf(MSG_OUT, "multi_timer_cb: Setting timeout to %ld ms\n", timeout_ms); in multi_timer_cb() 157 if(timeout_ms == -1) in multi_timer_cb()
|
H A D | ephiperfifo.c | 144 static int multi_timer_cb(CURLM *multi, long timeout_ms, GlobalInfo *g) in multi_timer_cb() argument 148 fprintf(MSG_OUT, "multi_timer_cb: Setting timeout to %ld ms\n", timeout_ms); in multi_timer_cb() 150 if(timeout_ms > 0) { in multi_timer_cb() 153 its.it_value.tv_sec = timeout_ms / 1000; in multi_timer_cb() 154 its.it_value.tv_nsec = (timeout_ms % 1000) * 1000 * 1000; in multi_timer_cb() 156 else if(timeout_ms == 0) { in multi_timer_cb()
|
H A D | evhiperfifo.c | 120 static int multi_timer_cb(CURLM *multi, long timeout_ms, GlobalInfo *g) in multi_timer_cb() argument 122 DPRINT("%s %li\n", __PRETTY_FUNCTION__, timeout_ms); in multi_timer_cb() 124 if(timeout_ms >= 0) { in multi_timer_cb() 126 double t = timeout_ms / 1000; in multi_timer_cb()
|
/curl/docs/libcurl/opts/ |
H A D | CURLMOPT_TIMERFUNCTION.md | 25 long timeout_ms, /* timeout in number of ms */ 40 non-repeating timer with an expire time of **timeout_ms** milliseconds. When 48 A **timeout_ms** value of -1 passed to this callback means you should delete 63 the **timeout_ms** value is zero, since it risks triggering an unpleasant 80 static int timerfunc(CURLM *multi, long timeout_ms, void *clientp) 85 if(timeout_ms) {
|
H A D | CURLMOPT_TIMERDATA.md | 48 static int timerfunc(CURLM *multi, long timeout_ms, void *clientp) 53 if(timeout_ms) {
|
/curl/src/ |
H A D | tool_cb_rea.c | 57 if(config->timeout_ms) { in tool_read_cb() 61 if(msdelta > config->timeout_ms) in tool_read_cb() 70 long wait = config->timeout_ms - msdelta; in tool_read_cb()
|
/curl/include/curl/ |
H A D | multi.h | 175 int timeout_ms, 189 int timeout_ms, 313 long timeout_ms, /* see above */
|
/curl/tests/unit/ |
H A D | unit1303.c | 73 unsigned int timeout_ms; member 148 TIMEOUTS(run[i].timeout_ms, run[i].connecttimeout_ms);
|
/curl/docs/libcurl/ |
H A D | curl_multi_poll.md | 29 int timeout_ms, 37 detected on at least one of the handles or *timeout_ms* has passed. 39 shorter expiry time than *timeout_ms*, that shorter time is used instead 57 to offer to wait for, this function instead waits during *timeout_ms*
|
H A D | curl_multi_wait.md | 28 int timeout_ms, 36 detected on at least one of the handles or *timeout_ms* has passed. 38 shorter expiry time than *timeout_ms*, that shorter time is being used
|
/curl/tests/server/ |
H A D | util.c | 229 int wait_ms(int timeout_ms) in wait_ms() argument 240 if(!timeout_ms) in wait_ms() 242 if(timeout_ms < 0) { in wait_ms() 247 delay(timeout_ms); in wait_ms() 249 Sleep((DWORD)timeout_ms); in wait_ms() 251 pending_ms = timeout_ms; in wait_ms() 267 pending_ms = timeout_ms - (int)timediff(tvnow(), initial_tv); in wait_ms()
|
H A D | util.h | 65 int wait_ms(int timeout_ms);
|
/curl/tests/libtest/ |
H A D | lib582.c | 124 static int curlTimerCallback(CURLM *multi, long timeout_ms, void *userp) in curlTimerCallback() argument 129 if(timeout_ms != -1) { in curlTimerCallback() 131 timeout->tv_usec += (int)timeout_ms * 1000; in curlTimerCallback()
|
H A D | lib530.c | 151 static int curlTimerCallback(CURLM *multi, long timeout_ms, void *userp) in curlTimerCallback() argument 161 if(timeout_ms != -1) { in curlTimerCallback() 163 timeout->tv_usec += (int)timeout_ms * 1000; in curlTimerCallback()
|