/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | AbstractIdleService.java | 157 @Override public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException { argument 158 delegate.awaitRunning(timeout, unit); 171 @Override public final void awaitTerminated(long timeout, TimeUnit unit) throws TimeoutException { argument 172 delegate.awaitTerminated(timeout, unit);
|
H A D | ForwardingExecutorService.java | 48 public boolean awaitTermination(long timeout, TimeUnit unit) argument 50 return delegate().awaitTermination(timeout, unit); 61 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 63 return delegate().invokeAll(tasks, timeout, unit); 74 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 76 return delegate().invokeAny(tasks, timeout, unit); 60 invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument 73 invokeAny( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument
|
H A D | Uninterruptibles.java | 36 * continues to block until the result is available or the timeout elapses, 45 // Implementation Note: As of 3-7-11, the logic for each blocking/timeout 73 * await(timeout, unit)} uninterruptibly. 76 long timeout, TimeUnit unit) { 79 long remainingNanos = unit.toNanos(timeout); 151 * {@code future.}{@link Future#get(long, TimeUnit) get(timeout, unit)} 163 Future<V> future, long timeout, TimeUnit unit) 167 long remainingNanos = unit.toNanos(timeout); 189 * timedJoin(toJoin, timeout)} uninterruptibly. 192 long timeout, TimeUni 75 awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit) argument 162 getUninterruptibly( Future<V> future, long timeout, TimeUnit unit) argument 191 joinUninterruptibly(Thread toJoin, long timeout, TimeUnit unit) argument 295 tryAcquireUninterruptibly( Semaphore semaphore, long timeout, TimeUnit unit) argument 306 tryAcquireUninterruptibly( Semaphore semaphore, int permits, long timeout, TimeUnit unit) argument [all...] |
H A D | WrappingExecutorService.java | 121 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 123 return delegate.invokeAll(wrapTasks(tasks), timeout, unit); 134 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 136 return delegate.invokeAny(wrapTasks(tasks), timeout, unit); 162 public final boolean awaitTermination(long timeout, TimeUnit unit) argument 164 return delegate.awaitTermination(timeout, unit); 120 invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument 133 invokeAny( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | AbstractListeningExecutorServiceTest.java | 108 public boolean awaitTermination(long timeout, TimeUnit unit) { argument
|
H A D | InterruptionUtil.java | 120 Thread thread, long timeout, TimeUnit unit) { 123 long remainingNanos = unit.toNanos(timeout); 119 joinUninterruptibly( Thread thread, long timeout, TimeUnit unit) argument
|
/external/iptables/include/linux/netfilter/ |
H A D | xt_set.h | 62 __u32 timeout; member in struct:xt_set_info_target_v2
|
/external/junit/src/org/junit/internal/runners/ |
H A D | MethodRoadie.java | 45 long timeout= fTestMethod.getTimeout(); 46 if (timeout > 0) 47 runWithTimeout(timeout); 55 private void runWithTimeout(final long timeout) { argument 69 boolean terminated= service.awaitTermination(timeout, 75 addFailure(new Exception(String.format("test timed out after %d milliseconds", timeout)));
|
/external/junit/src/org/junit/internal/runners/statements/ |
H A D | FailOnTimeout.java | 13 public FailOnTimeout(Statement originalStatement, long timeout) { argument 15 fTimeout= timeout;
|
/external/kernel-headers/original/uapi/linux/netfilter/ |
H A D | xt_set.h | 62 __u32 timeout; member in struct:xt_set_info_target_v2 81 __u32 timeout; member in struct:xt_set_info_target_v3
|
/external/ksoap2/ksoap2-j2se/src/main/java/org/ksoap2/transport/ |
H A D | HttpTransportSE.java | 74 * @param timeout 75 * timeout for connection and Read Timeouts (milliseconds) 77 public HttpTransportSE(String url, int timeout) { argument 78 super(url, timeout); 81 public HttpTransportSE(Proxy proxy, String url, int timeout) { argument 82 super(proxy, url, timeout); 90 * @param timeout 91 * timeout for connection and Read Timeouts (milliseconds) 95 public HttpTransportSE(String url, int timeout, int contentLength) { argument 96 super(url, timeout); 99 HttpTransportSE(Proxy proxy, String url, int timeout, int contentLength) argument [all...] |
H A D | ServiceConnectionSE.java | 57 * @param timeout the connection and read timeout for the http connection in milliseconds 60 public ServiceConnectionSE(String url, int timeout) throws IOException { argument 61 this(null, url, timeout); 64 public ServiceConnectionSE(Proxy proxy, String url, int timeout) throws IOException { argument 71 connection.setConnectTimeout(timeout); 72 connection.setReadTimeout(timeout); // even if we connect fine we want to time out if we cant read anything..
|
/external/libdrm/tests/vbltest/ |
H A D | vbltest.c | 163 struct timeval timeout = { .tv_sec = 3, .tv_usec = 0 }; local 169 ret = select(fd + 1, &fds, NULL, NULL, &timeout);
|
/external/libmicrohttpd/src/examples/ |
H A D | mhd2spdy.c | 69 struct timeval timeout; local 126 timeout.tv_sec = 0; 127 timeout.tv_usec = 0; 142 timeout.tv_sec = 5; 145 timeout.tv_sec = timeoutlong / 1000; 146 timeout.tv_usec = (timeoutlong % 1000) * 1000; 167 PRINT_INFO2("MHD timeout %lld %lld", (unsigned long long)timeout.tv_sec, (unsigned long long)timeout.tv_usec); 171 ret = select(maxfd+1, &rs, &ws, &es, &timeout); [all...] |
/external/libusb/libusb/ |
H A D | sync.c | 62 * \param timeout timeout (in millseconds) that this function should wait 64 * timeout, use value 0. 74 unsigned char *data, uint16_t wLength, unsigned int timeout) 96 ctrl_transfer_cb, &completed, timeout); 155 int *transferred, unsigned int timeout, unsigned char type) 165 bulk_transfer_cb, &completed, timeout); 227 * Also check <tt>transferred</tt> when dealing with a timeout error code. 229 * underlying O/S requirements, meaning that the timeout may expire after 231 * that may have been transferred; do not assume that timeout condition 72 libusb_control_transfer(libusb_device_handle *dev_handle, uint8_t bmRequestType, uint8_t bRequest, uint16_t wValue, uint16_t wIndex, unsigned char *data, uint16_t wLength, unsigned int timeout) argument 153 do_sync_bulk_transfer(struct libusb_device_handle *dev_handle, unsigned char endpoint, unsigned char *buffer, int length, int *transferred, unsigned int timeout, unsigned char type) argument 255 libusb_bulk_transfer(struct libusb_device_handle *dev_handle, unsigned char endpoint, unsigned char *data, int length, int *transferred, unsigned int timeout) argument 304 libusb_interrupt_transfer( struct libusb_device_handle *dev_handle, unsigned char endpoint, unsigned char *data, int length, int *transferred, unsigned int timeout) argument [all...] |
/external/libweave/src/notification/ |
H A D | xmpp_iq_stanza_handler.cc | 19 // Default timeout for <iq> requests to the server. If the response hasn't been 71 base::TimeDelta timeout, 77 if (timeout < base::TimeDelta::Max()) { 82 timeout); 135 // Request has not been processed yes, so a real timeout occurred. 66 SendRequestWithCustomTimeout( const std::string& type, const std::string& from, const std::string& to, const std::string& body, base::TimeDelta timeout, const ResponseCallback& response_callback, const TimeoutCallback& timeout_callback) argument
|
/external/mesa3d/src/gallium/state_trackers/egl/common/ |
H A D | egl_g3d_sync.c | 42 egl_g3d_wait_sync_condvar(struct egl_g3d_sync *gsync, EGLTimeKHR timeout) argument 51 /* No timed wait. Always treat timeout as EGL_FOREVER_KHR */ 96 egl_g3d_wait_fence_sync(struct egl_g3d_sync *gsync, EGLTimeKHR timeout) argument 120 ret = egl_g3d_wait_sync_condvar(gsync, timeout); 223 EGLint flags, EGLTimeKHR timeout) 238 if (timeout) { 244 ret = egl_g3d_wait_sync_condvar(gsync, timeout); 247 ret = egl_g3d_wait_fence_sync(gsync, timeout); 222 egl_g3d_client_wait_sync(_EGLDriver *drv, _EGLDisplay *dpy, _EGLSync *sync, EGLint flags, EGLTimeKHR timeout) argument
|
/external/okhttp/okio/okio/src/test/java/okio/ |
H A D | GzipSourceTest.java | 225 @Override public Timeout timeout() { method in class:GzipSourceTest.ExhaustableSource 226 return source.timeout();
|
/external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/ |
H A D | ShadowAsyncTask.java | 71 public Result get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { argument 72 return future.get(timeout, unit);
|
H A D | ShadowPowerManager.java | 43 public synchronized void acquire(long timeout) { argument
|
/external/sl4a/Common/src/com/googlecode/android_scripting/facade/wifi/ |
H A D | HttpFacade.java | 164 public void httpSetServerTimeout(@RpcParameter(name = "timeout") Integer timeout) argument 166 mServerSocket.setSoTimeout(timeout); 167 mServerTimeout = timeout; 171 // The optional timeout parameter is in unit of second. 173 @RpcParameter(name = "timeout") @RpcOptional Integer timeout) { 186 if (timeout != null) { 187 pingCmdString = pingCmdString + "-W " + timeout + " "; 172 pingHost(@pcParametername = �) String hostString, @RpcParameter(name = �) @RpcOptional Integer timeout) argument
|
/external/testng/src/main/java/org/testng/internal/thread/ |
H A D | ThreadUtil.java | 35 * @param timeout a maximum timeout to wait for tasks finalization
39 long timeout, boolean triggerAtOnce) {
43 Utils.log("ThreadUtil", 2, "Starting executor timeOut:" + timeout + "ms"
47 timeout, TimeUnit.MILLISECONDS,
71 if (timeout != 0) {
72 pooledExecutor.invokeAll(callables, timeout, TimeUnit.MILLISECONDS);
38 execute(List<? extends Runnable> tasks, int threadPoolSize, long timeout, boolean triggerAtOnce) argument
|
/external/toybox/lib/ |
H A D | net.c | 46 int xpoll(struct pollfd *fds, int nfds, int timeout) argument 51 if (0>(i = poll(fds, nfds, timeout))) { 54 else if (timeout>0) timeout--;
|
/external/toybox/toys/other/ |
H A D | netcat.c | 20 -w SECONDS timeout for connection 64 static void timeout(int signum) function 73 xsignal(SIGALRM, seconds ? timeout : SIG_DFL); 195 // We have a connection. Disarm timeout.
|
/external/tpm2/ |
H A D | Ticket.c | 89 UINT64 timeout, // IN: timeout 108 // Adding timeout 109 CryptUpdateDigestInt(&hmacState, sizeof(UINT64), &timeout); 86 TicketComputeAuth( TPM_ST type, TPMI_RH_HIERARCHY hierarchy, UINT64 timeout, TPM2B_DIGEST *cpHashA, TPM2B_NONCE *policyRef, TPM2B_NAME *entityName, TPMT_TK_AUTH *ticket ) argument
|