Home
last modified time | relevance | path

Searched refs:timeout_ms (Results 1 - 25 of 120) sorted by relevance

12345

/third_party/curl/lib/
H A Dselect.c67 int Curl_wait_ms(timediff_t timeout_ms) in Curl_wait_ms() argument
71 if(!timeout_ms) in Curl_wait_ms()
73 if(timeout_ms < 0) { in Curl_wait_ms()
78 delay(timeout_ms); in Curl_wait_ms()
80 /* prevent overflow, timeout_ms is typecast to ULONG/DWORD. */ in Curl_wait_ms()
82 if(timeout_ms >= ULONG_MAX) in Curl_wait_ms()
83 timeout_ms = ULONG_MAX-1; in Curl_wait_ms()
86 Sleep((ULONG)timeout_ms); in Curl_wait_ms()
89 /* prevent overflow, timeout_ms is typecast to int. */ in Curl_wait_ms()
91 if(timeout_ms > INT_MA in Curl_wait_ms()
124 our_select(curl_socket_t maxfd, fd_set *fds_read, fd_set *fds_write, fd_set *fds_err, timediff_t timeout_ms) our_select() argument
189 Curl_socket_check(curl_socket_t readfd0, curl_socket_t readfd1, curl_socket_t writefd, timediff_t timeout_ms) Curl_socket_check() argument
272 Curl_poll(struct pollfd ufds[], unsigned int nfds, timediff_t timeout_ms) Curl_poll() argument
[all...]
H A Dgopher.c141 timediff_t timeout_ms; in gopher_do() local
202 timeout_ms = Curl_timeleft(data, NULL, FALSE); in gopher_do()
203 if(timeout_ms < 0) { in gopher_do()
207 if(!timeout_ms) in gopher_do()
208 timeout_ms = TIMEDIFF_T_MAX; in gopher_do()
216 what = SOCKET_WRITABLE(sockfd, timeout_ms); in gopher_do()
H A Dpingpong.c54 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 Dselect.h78 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);
/third_party/lwip/test/sockets/
H A Dsockets_stresstest.c180 sockets_stresstest_wait_readable_select(int s, int timeout_ms) in sockets_stresstest_wait_readable_select() argument
195 tv.tv_sec = timeout_ms / 1000; in sockets_stresstest_wait_readable_select()
196 tv.tv_usec = (timeout_ms - (tv.tv_sec * 1000)) * 1000; in sockets_stresstest_wait_readable_select()
219 sockets_stresstest_wait_readable_poll(int s, int timeout_ms) in sockets_stresstest_wait_readable_poll() argument
228 ret = lwip_poll(&pfd, 1, timeout_ms); in sockets_stresstest_wait_readable_poll()
249 sockets_stresstest_wait_readable_recvtimeo(int s, int timeout_ms) in sockets_stresstest_wait_readable_recvtimeo() argument
254 int opt_on = timeout_ms; in sockets_stresstest_wait_readable_recvtimeo()
258 opt_on.tv_sec = timeout_ms / 1000; in sockets_stresstest_wait_readable_recvtimeo()
259 opt_on.tv_usec = (timeout_ms - (opt_on.tv_sec * 1000)) * 1000; in sockets_stresstest_wait_readable_recvtimeo()
290 sockets_stresstest_wait_readable_wait_peek(int s, int timeout_ms) in sockets_stresstest_wait_readable_wait_peek() argument
314 sockets_stresstest_wait_readable_nonblock(int s, int timeout_ms) sockets_stresstest_wait_readable_nonblock() argument
369 sockets_stresstest_wait_readable(int mode, int s, int timeout_ms) sockets_stresstest_wait_readable() argument
476 int timeout_ms = LWIP_RAND() % TEST_MAX_RXWAIT_MS; sockets_stresstest_conn_client() local
522 int timeout_ms = LWIP_RAND() % TEST_MAX_RXWAIT_MS; sockets_stresstest_conn_server() local
[all...]
/third_party/libwebsockets/lib/plat/windows/
H A Dwindows-service.c61 _lws_plat_service_tsi(struct lws_context *context, int timeout_ms, int tsi) in _lws_plat_service_tsi() argument
88 if (timeout_ms < 0) in _lws_plat_service_tsi()
89 timeout_ms = 0; in _lws_plat_service_tsi()
92 timeout_ms = 2000000000; in _lws_plat_service_tsi()
93 timeout_us = ((lws_usec_t)timeout_ms) * LWS_US_PER_MS; in _lws_plat_service_tsi()
184 lws_plat_service(struct lws_context *context, int timeout_ms) in lws_plat_service() argument
186 return _lws_plat_service_tsi(context, timeout_ms, 0); in lws_plat_service()
/third_party/libwebsockets/lib/plat/freertos/
H A Dfreertos-service.c28 lws_plat_service(struct lws_context *context, int timeout_ms) in lws_plat_service() argument
30 int n = _lws_plat_service_tsi(context, timeout_ms, 0); in lws_plat_service()
41 _lws_plat_service_tsi(struct lws_context *context, int timeout_ms, int tsi) in _lws_plat_service_tsi() argument
83 if (timeout_ms < 0) in _lws_plat_service_tsi()
84 timeout_ms = 0; in _lws_plat_service_tsi()
87 timeout_ms = 2000000000; in _lws_plat_service_tsi()
88 timeout_us = ((lws_usec_t)timeout_ms) * LWS_US_PER_MS; in _lws_plat_service_tsi()
128 // n = poll(pt->fds, pt->fds_count, timeout_ms); in _lws_plat_service_tsi()
/third_party/libwebsockets/lib/plat/optee/
H A Dnetwork.c90 _lws_plat_service_tsi(struct lws_context *context, int timeout_ms, int tsi) in _lws_plat_service_tsi() argument
92 lws_usec_t timeout_us = timeout_ms * LWS_US_PER_MS; in _lws_plat_service_tsi()
104 if (timeout_ms < 0) in _lws_plat_service_tsi()
105 timeout_ms = 0; in _lws_plat_service_tsi()
107 timeout_ms = 2000000000; in _lws_plat_service_tsi()
192 lws_plat_service(struct lws_context *context, int timeout_ms) in lws_plat_service() argument
194 return _lws_plat_service_tsi(context, timeout_ms, 0); in lws_plat_service()
/third_party/libwebsockets/lib/plat/unix/
H A Dunix-service.c72 _lws_plat_service_tsi(struct lws_context *context, int timeout_ms, int tsi) in _lws_plat_service_tsi() argument
99 if (timeout_ms < 0) in _lws_plat_service_tsi()
100 timeout_ms = 0; in _lws_plat_service_tsi()
103 timeout_ms = LWS_POLL_WAIT_LIMIT; in _lws_plat_service_tsi()
104 timeout_us = ((lws_usec_t)timeout_ms) * LWS_US_PER_MS; in _lws_plat_service_tsi()
233 lws_plat_service(struct lws_context *context, int timeout_ms) in lws_plat_service() argument
235 return _lws_plat_service_tsi(context, timeout_ms, 0); in lws_plat_service()
/third_party/curl/docs/examples/
H A Dmulti-event.c151 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 directly call socket_action, but we will do it in start_timeout()
161 tv.tv_sec = timeout_ms / 1000; in start_timeout()
162 tv.tv_usec = (timeout_ms % 1000) * 1000; in start_timeout()
H A Dmulti-uv.c161 static int start_timeout(CURLM *multi, long timeout_ms, void *userp) in start_timeout() argument
163 if(timeout_ms < 0) { in start_timeout()
167 if(timeout_ms == 0) in start_timeout()
168 timeout_ms = 1; /* 0 means directly call socket_action, but we will do it in start_timeout()
170 uv_timer_start(&timeout, on_timeout, timeout_ms, 0); in start_timeout()
H A Dsendrecv.c34 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()
/third_party/libuv/test/
H A Dtest-timer.c387 const uint64_t timeout_ms = 10; in TEST_IMPL() local
389 timer_early_check_expected_time = uv_now(uv_default_loop()) + timeout_ms; in TEST_IMPL()
394 timeout_ms, in TEST_IMPL()
411 const uint64_t timeout_ms = 10; in TEST_IMPL() local
416 timeout_ms, in TEST_IMPL()
417 timeout_ms)); in TEST_IMPL()
418 uv_sleep(timeout_ms * 2); in TEST_IMPL()
428 const uint64_t timeout_ms = 10; in TEST_IMPL() local
433 timeout_ms, in TEST_IMPL()
434 timeout_ms)); in TEST_IMPL()
[all...]
/third_party/node/deps/cares/src/lib/
H A Dares__threads.c124 unsigned long timeout_ms) in ares__thread_cond_timedwait()
130 if (!SleepConditionVariableCS(&cond->cond, &mut->mutex, timeout_ms)) { in ares__thread_cond_timedwait()
350 unsigned long timeout_ms) in ares__thread_cond_timedwait()
358 ares__timespec_timeout(&ts, timeout_ms); in ares__thread_cond_timedwait()
473 unsigned long timeout_ms) in ares__thread_cond_timedwait()
477 (void)timeout_ms; in ares__thread_cond_timedwait()
551 ares_status_t ares_queue_wait_empty(ares_channel_t *channel, int timeout_ms) in ares_queue_wait_empty() argument
564 if (timeout_ms >= 0) { in ares_queue_wait_empty()
566 tout.tv_sec += timeout_ms / 1000; in ares_queue_wait_empty()
567 tout.tv_usec += (timeout_ms in ares_queue_wait_empty()
122 ares__thread_cond_timedwait(ares__thread_cond_t *cond, ares__thread_mutex_t *mut, unsigned long timeout_ms) ares__thread_cond_timedwait() argument
348 ares__thread_cond_timedwait(ares__thread_cond_t *cond, ares__thread_mutex_t *mut, unsigned long timeout_ms) ares__thread_cond_timedwait() argument
471 ares__thread_cond_timedwait(ares__thread_cond_t *cond, ares__thread_mutex_t *mut, unsigned long timeout_ms) ares__thread_cond_timedwait() argument
[all...]
H A Dares_event_select.c71 unsigned long timeout_ms) in ares_evsys_select_wait()
101 if (timeout_ms) { in ares_evsys_select_wait()
102 tv.tv_sec = (int)(timeout_ms / 1000); in ares_evsys_select_wait()
103 tv.tv_usec = (int)((timeout_ms % 1000) * 1000); in ares_evsys_select_wait()
70 ares_evsys_select_wait(ares_event_thread_t *e, unsigned long timeout_ms) ares_evsys_select_wait() argument
/third_party/mesa3d/src/microsoft/vulkan/
H A Ddzn_sync.c180 DWORD timeout_ms; in dzn_sync_wait() local
183 int timeout_ms; in dzn_sync_wait() local
188 timeout_ms = timeout_infinite; in dzn_sync_wait()
194 timeout_ms = (rel_timeout_ns / 1000000) + (rel_timeout_ns % 1000000 ? 1 : 0); in dzn_sync_wait()
199 WaitForSingleObject(event, timeout_ms); in dzn_sync_wait()
208 VkResult ret = sync_wait(event_fd, timeout_ms) != 0 ? VK_TIMEOUT : VK_SUCCESS; in dzn_sync_wait()
/third_party/libwebsockets/include/libwebsockets/
H A Dlws-service.h37 * \param timeout_ms: Set to 0; ignored; for backward compatibility
52 lws_service(struct lws_context *context, int timeout_ms);
58 * \param timeout_ms: Set to 0; ignored; for backwards compatibility
65 lws_service_tsi(struct lws_context *context, int timeout_ms, int tsi);
138 * \param timeout_ms: The original poll timeout value. You can just set this
153 lws_service_adjust_timeout(struct lws_context *context, int timeout_ms, int tsi);
/third_party/vk-gl-cts/external/amber/src/src/vulkan/
H A Dcommand_buffer.cc76 Result CommandBuffer::SubmitAndReset(uint32_t timeout_ms) { in SubmitAndReset() argument
98 static_cast<uint64_t>(timeout_ms) * 1000ULL * 1000ULL /* nanosecond */); in SubmitAndReset()
144 Result CommandBufferGuard::Submit(uint32_t timeout_ms) { in Submit() argument
146 return buffer_->SubmitAndReset(timeout_ms); in Submit()
/third_party/libbpf/src/
H A Dringbuf.c304 int ring_buffer__poll(struct ring_buffer *rb, int timeout_ms) in ring_buffer__poll() argument
309 cnt = epoll_wait(rb->epoll_fd, rb->events, rb->ring_cnt, timeout_ms); in ring_buffer__poll()
592 void *user_ring_buffer__reserve_blocking(struct user_ring_buffer *rb, __u32 size, int timeout_ms) in user_ring_buffer__reserve_blocking() argument
595 int err, ms_remaining = timeout_ms; in user_ring_buffer__reserve_blocking()
598 if (timeout_ms < 0 && timeout_ms != -1) in user_ring_buffer__reserve_blocking()
601 if (timeout_ms != -1) { in user_ring_buffer__reserve_blocking()
633 if (timeout_ms == -1) in user_ring_buffer__reserve_blocking()
641 ms_remaining = timeout_ms - ms_elapsed; in user_ring_buffer__reserve_blocking()
/third_party/toybox/lib/
H A Dtty.c172 // Blocks for timeout_ms milliseconds, 0=return immediately, -1=wait forever.
176 int scan_key_getsize(char *scratch, int timeout_ms, unsigned *xx, unsigned *yy) in scan_key_getsize() argument
226 if (maybe || timeout_ms != -1) in scan_key_getsize()
227 if (!xpoll(&pfd, 1, maybe ? 30 : timeout_ms)) break; in scan_key_getsize()
246 int scan_key(char *scratch, int timeout_ms) in scan_key() argument
248 return scan_key_getsize(scratch, timeout_ms, NULL, NULL); in scan_key()
/third_party/curl/src/
H A Dtool_cb_rea.c58 if(config->timeout_ms) { in tool_read_cb()
62 if(msdelta > config->timeout_ms) in tool_read_cb()
71 long wait = config->timeout_ms - msdelta; in tool_read_cb()
/third_party/libuv/docs/code/uvwget/
H A Dmain.c103 void start_timeout(CURLM *multi, long timeout_ms, void *userp) { in start_timeout() argument
104 if (timeout_ms <= 0) in start_timeout()
105 timeout_ms = 1; /* 0 means directly call socket_action, but we'll do it in a bit */ in start_timeout()
106 uv_timer_start(&timeout, on_timeout, timeout_ms, 0); in start_timeout()
/third_party/mesa3d/src/gallium/drivers/d3d12/
H A Dd3d12_fence.cpp54 DWORD timeout_ms = (timeout_ns == PIPE_TIMEOUT_INFINITE || timeout_ns > MaxTimeoutInNs) ? INFINITE : timeout_ns / NsPerMs; in wait_event() local
55 return WaitForSingleObject(event, timeout_ms) == WAIT_OBJECT_0; in wait_event()
79 int timeout_ms = (timeout_ns == PIPE_TIMEOUT_INFINITE || timeout_ns > MaxTimeoutInNs) ? -1 : timeout_ns / NsPerMs; in wait_event() local
80 return sync_wait(event_fd, timeout_ms) == 0; in wait_event()
/third_party/libwebsockets/lib/core-net/
H A Dservice.c297 lws_service_adjust_timeout(struct lws_context *context, int timeout_ms, int tsi) in lws_service_adjust_timeout() argument
329 if (u && u < (lws_usec_t)timeout_ms * (lws_usec_t)1000) in lws_service_adjust_timeout()
330 timeout_ms = (int)(u / 1000); in lws_service_adjust_timeout()
375 return timeout_ms; in lws_service_adjust_timeout()
819 lws_service(struct lws_context *context, int timeout_ms) in lws_service() argument
838 n = lws_plat_service(context, timeout_ms); in lws_service()
847 lws_service_tsi(struct lws_context *context, int timeout_ms, int tsi) in lws_service_tsi() argument
870 n = _lws_plat_service_tsi(context, timeout_ms, tsi); in lws_service_tsi()
/third_party/ltp/testcases/kernel/syscalls/tkill/
H A Dtkill01.c39 int timeout_ms = 1000; in run() local
45 while (timeout_ms--) { in run()

Completed in 14 milliseconds

12345