/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | ForwardingBlockingQueue.java | 53 @Override public boolean offer(E e, long timeout, TimeUnit unit) argument 55 return delegate().offer(e, timeout, unit); 58 @Override public E poll(long timeout, TimeUnit unit) argument 60 return delegate().poll(timeout, unit);
|
H A D | AbstractExecutionThreadService.java | 203 @Override public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException { argument 204 delegate.awaitRunning(timeout, unit); 217 @Override public final void awaitTerminated(long timeout, TimeUnit unit) throws TimeoutException { argument 218 delegate.awaitTerminated(timeout, unit);
|
/external/guava/guava-bootstrap/src/java/util/concurrent/ |
H A D | ExecutorService.java | 25 boolean awaitTermination(long timeout, TimeUnit unit) argument 38 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 45 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 37 invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument 44 invokeAny( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument
|
/external/libdrm/freedreno/msm/ |
H A D | msm_pipe.c | 58 uint64_t timeout) 66 get_abs_timeout(&req.timeout, timeout); 57 msm_pipe_wait(struct fd_pipe *pipe, uint32_t timestamp, uint64_t timeout) argument
|
/external/libnfc-nci/src/nfc/nfc/ |
H A D | nfc_task.c | 53 ** NOTE: The timeout resolution is in SECONDS! (Even 59 void nfc_start_timer (TIMER_LIST_ENT *p_tle, UINT16 type, UINT32 timeout) argument 86 p_tle->ticks = timeout; /* Save the number of seconds for the timer */ 173 ** NOTE: The timeout resolution depends on including modules. 181 void nfc_start_quick_timer (TIMER_LIST_ENT *p_tle, UINT16 type, UINT32 timeout) argument 208 p_tle->ticks = timeout; /* Save the number of ticks for the timer */
|
/external/mesa3d/src/mesa/state_tracker/ |
H A D | st_cb_syncobj.c | 91 GLbitfield flags, GLuint64 timeout) 100 screen->fence_finish(screen, so->fence, timeout)) { 108 GLbitfield flags, GLuint64 timeout) 89 st_client_wait_sync(struct gl_context *ctx, struct gl_sync_object *obj, GLbitfield flags, GLuint64 timeout) argument 106 st_server_wait_sync(struct gl_context *ctx, struct gl_sync_object *obj, GLbitfield flags, GLuint64 timeout) argument
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
H A D | RetryableSink.java | 66 @Override public Timeout timeout() { method in class:RetryableSink
|
/external/okhttp/okio/okio/src/main/java/okio/ |
H A D | GzipSink.java | 77 @Override public Timeout timeout() { method in class:GzipSink 78 return sink.timeout();
|
/external/okhttp/okio/okio/src/test/java/okio/ |
H A D | MockSink.java | 61 @Override public Timeout timeout() { method in class:MockSink 62 log.add("timeout()");
|
/external/testng/src/main/java/org/testng/remote/adapter/ |
H A D | DefaultWorkerAdapter.java | 39 public XmlSuite getSuite(long timeout) throws InterruptedException, IOException
argument
|
/external/tlsdate/src/ |
H A D | routeup.c | 111 * was a timeout, and -1 if there was a read error. 114 routeup_once (struct routeup *rtc, unsigned int timeout) argument 118 struct timeval *rp = timeout ? &remaining : NULL; 120 remaining.tv_sec = timeout; 128 if (timeout && !remaining.tv_sec && !remaining.tv_usec)
|
/external/webrtc/webrtc/examples/peerconnection/server/ |
H A D | main.cc | 90 struct timeval timeout = { 10, 0 }; local 91 if (select(FD_SETSIZE, &socket_set, NULL, NULL, &timeout) == SOCKET_ERROR) {
|
/external/wpa_supplicant_8/wpa_supplicant/examples/p2p/ |
H A D | p2p_find.py | 3 # Will list all devices found/lost within a time frame (timeout) 17 print " %s -i <interface_name> [-t <timeout>] \ " \ 22 print " -t = timeout = 0s (infinite)" 43 global timeout 53 def __init__(self,interface_name,wpas_dbus_interface,timeout): 55 self.timeout = int(timeout) 111 {'Timeout':int(self.timeout)}) 117 # Required for timeout implementation 125 timeout variable [all...] |
H A D | p2p_stop_find.py | 42 global timeout 51 def __init__(self,interface_name,wpas_dbus_interface,timeout): 55 self.timeout = timeout 109 # Required for timeout implementation 118 timeout = 5 variable 157 wpas_dbus_interface,timeout) 168 time.sleep(int(p2p_stop_find_test.timeout))
|
/external/apache-http/src/org/apache/http/impl/ |
H A D | SocketHttpClientConnection.java | 159 public void setSocketTimeout(int timeout) { argument 163 this.socket.setSoTimeout(timeout);
|
H A D | SocketHttpServerConnection.java | 157 public void setSocketTimeout(int timeout) { argument 161 this.socket.setSoTimeout(timeout);
|
/external/autotest/client/cros/ |
H A D | mainloop.py | 44 logging.warning('ExceptionForwardingMainLoop: No timeout specified.') 45 logging.warning('(Specify timeout_s=0 explicitly for no timeout.)') 51 def timeout(self): member in class:ExceptionForwardingMainLoop 56 self.timeout() 125 def timeout(self): member in class:GenericTesterMainLoop 126 logging.error('Requirements unsatisfied upon timeout: %s' %
|
/external/avahi/avahi-common/ |
H A D | thread-watch.c | 48 static int poll_func(struct pollfd *ufds, unsigned int nfds, int timeout, void *userdata) { argument 56 r = poll(ufds, nfds, timeout);
|
/external/avahi/avahi-core/ |
H A D | conformance-test.c | 54 static void dump_timeout_callback(AvahiTimeout *timeout, AVAHI_GCC_UNUSED void* userdata) { argument 60 poll_api->timeout_update(timeout, &tv); 85 static void rename_timeout_callback(AvahiTimeout *timeout, AVAHI_GCC_UNUSED void *userdata) { argument 94 poll_api->timeout_update(timeout, &tv);
|
H A D | querier-test.c | 70 static void create_second_service_browser(AvahiTimeout *timeout, AVAHI_GCC_UNUSED void* userdata) { argument 75 poll_api->timeout_free(timeout); 78 static void quit(AVAHI_GCC_UNUSED AvahiTimeout *timeout, AVAHI_GCC_UNUSED void *userdata) { argument
|
/external/curl/docs/examples/ |
H A D | ftpuploadresume.c | 84 long timeout, long tries) 101 if (timeout) 102 curl_easy_setopt(curlhandle, CURLOPT_FTP_RESPONSE_TIMEOUT, timeout); 83 upload(CURL *curlhandle, const char * remotepath, const char * localpath, long timeout, long tries) argument
|
H A D | multi-debugcallback.c | 148 struct timeval timeout; local 163 /* set a suitable timeout to play around with */ 164 timeout.tv_sec = 1; 165 timeout.tv_usec = 0; 169 timeout.tv_sec = curl_timeo / 1000; 170 if(timeout.tv_sec > 1) 171 timeout.tv_sec = 1; 173 timeout.tv_usec = (curl_timeo % 1000) * 1000; 202 /* Note that on some platforms 'timeout' may be modified by select(). 204 rc = select(maxfd+1, &fdread, &fdwrite, &fdexcep, &timeout); [all...] |
/external/curl/tests/libtest/ |
H A D | lib555.c | 117 struct timeval timeout; local 121 timeout.tv_sec = 0; 122 timeout.tv_usec = 100000L; /* 100 ms */ 143 select_test(maxfd+1, &fdread, &fdwrite, &fdexcep, &timeout);
|
/external/guava/guava/src/com/google/common/collect/ |
H A D | ForwardingBlockingDeque.java | 65 public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException { argument 66 return delegate().offerFirst(e, timeout, unit); 70 public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException { argument 71 return delegate().offerLast(e, timeout, unit); 85 public E pollFirst(long timeout, TimeUnit unit) throws InterruptedException { argument 86 return delegate().pollFirst(timeout, unit); 90 public E pollLast(long timeout, TimeUnit unit) throws InterruptedException { argument 91 return delegate().pollLast(timeout, unit); 100 public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { argument 101 return delegate().offer(e, timeout, uni 110 poll(long timeout, TimeUnit unit) argument [all...] |
H A D | Queues.java | 249 * timeout. 254 * @param timeout how long to wait before giving up, in units of {@code unit} 255 * @param unit a {@code TimeUnit} determining how to interpret the timeout parameter 261 long timeout, TimeUnit unit) throws InterruptedException { 265 * execute Queue#drainTo is not added *on top* of waiting for the timeout (which could make 266 * the timeout arbitrarily inaccurate, given a queue that is slow to drain). 268 long deadline = System.nanoTime() + unit.toNanos(timeout); 295 * @param timeout how long to wait before giving up, in units of {@code unit} 296 * @param unit a {@code TimeUnit} determining how to interpret the timeout parameter 301 int numElements, long timeout, TimeUni 260 drain(BlockingQueue<E> q, Collection<? super E> buffer, int numElements, long timeout, TimeUnit unit) argument 300 drainUninterruptibly(BlockingQueue<E> q, Collection<? super E> buffer, int numElements, long timeout, TimeUnit unit) argument [all...] |