/dalvik/libcore/concurrent/src/main/java/java/util/concurrent/ |
H A D | TimeUnit.java | 23 * the following code will timeout in 50 milliseconds if the {@link 29 * while this code will timeout in 50 seconds: 35 * Note however, that there is no guarantee that a particular timeout 234 * This is a convenience method that converts timeout arguments 241 * <pre> public synchronized Object poll(long timeout, TimeUnit unit) throws InterruptedException { 243 * unit.timedWait(this, timeout); 249 * @param timeout the maximum time to wait. If less than 254 public void timedWait(Object obj, long timeout) argument 256 if (timeout > 0) { 257 long ms = toMillis(timeout); 273 timedJoin(Thread thread, long timeout) argument 291 sleep(long timeout) argument [all...] |
H A D | BlockingQueue.java | 211 * @param timeout how long to wait before giving up, in units of 214 * <tt>timeout</tt> parameter 224 boolean offer(E e, long timeout, TimeUnit unit) argument 240 * @param timeout how long to wait before giving up, in units of 243 * <tt>timeout</tt> parameter 248 E poll(long timeout, TimeUnit unit) argument
|
H A D | CompletionService.java | 87 * @param timeout how long to wait before giving up, in units of 90 * <tt>timeout</tt> parameter 96 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; argument
|
H A D | Future.java | 130 * @param timeout the maximum time to wait 131 * @param unit the time unit of the timeout argument 140 V get(long timeout, TimeUnit unit) argument
|
H A D | CountDownLatch.java | 244 * @param timeout the maximum time to wait 245 * @param unit the time unit of the {@code timeout} argument 251 public boolean await(long timeout, TimeUnit unit) argument 253 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout));
|
H A D | ExecutorService.java | 176 * request, or the timeout occurs, or the current thread is 179 * @param timeout the maximum time to wait 180 * @param unit the time unit of the timeout argument 182 * <tt>false</tt> if the timeout elapsed before termination 185 boolean awaitTermination(long timeout, TimeUnit unit) argument 267 * when all complete or the timeout expires, whichever happens first. 277 * @param timeout the maximum time to wait 278 * @param unit the time unit of the timeout argument 292 long timeout, TimeUnit unit) 319 * an exception), if any do before the given timeout elapse 291 invokeAll(Collection<Callable<T>> tasks, long timeout, TimeUnit unit) argument 338 invokeAny(Collection<Callable<T>> tasks, long timeout, TimeUnit unit) argument [all...] |
H A D | Semaphore.java | 374 * @param timeout the maximum time to wait for a permit 375 * @param unit the time unit of the {@code timeout} argument 380 public boolean tryAcquire(long timeout, TimeUnit unit) argument 382 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); 546 * @param timeout the maximum time to wait for the permits 547 * @param unit the time unit of the {@code timeout} argument 553 public boolean tryAcquire(int permits, long timeout, TimeUnit unit) argument 556 return sync.tryAcquireSharedNanos(permits, unit.toNanos(timeout));
|
H A D | ExecutorCompletionService.java | 165 public Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException { argument 166 return completionQueue.poll(timeout, unit);
|
H A D | Executors.java | 143 * properties but different details (for example, timeout parameters) 604 public boolean awaitTermination(long timeout, TimeUnit unit) argument 606 return e.awaitTermination(timeout, unit); 622 long timeout, TimeUnit unit) 624 return e.invokeAll(tasks, timeout, unit); 631 long timeout, TimeUnit unit) 633 return e.invokeAny(tasks, timeout, unit); 621 invokeAll(Collection<Callable<T>> tasks, long timeout, TimeUnit unit) argument 630 invokeAny(Collection<Callable<T>> tasks, long timeout, TimeUnit unit) argument
|
H A D | CyclicBarrier.java | 85 * point prematurely because of interruption, failure, or timeout, all 341 * <li>The specified timeout elapses; or 380 * @param timeout the time to wait for the barrier 381 * @param unit the time unit of the timeout parameter 387 * @throws TimeoutException if the specified timeout elapses 394 public int await(long timeout, TimeUnit unit) argument 398 return dowait(true, unit.toNanos(timeout)); 405 * barrier due to interruption or timeout since
|
/dalvik/libcore/luni/src/main/java/java/lang/ref/ |
H A D | ReferenceQueue.java | 85 * process. Waits for a reference to become available or the given timeout 88 * @param timeout 93 * becomes available within the timeout period 99 public synchronized Reference<? extends T> remove(long timeout) throws IllegalArgumentException, argument 101 if (timeout < 0) { 105 if (timeout == 0L) { 111 long wakeupTime = now + timeout + 1L;
|
/dalvik/libcore/luni/src/test/java/com/google/coretests/ |
H A D | CoreTestResult.java | 41 * The timeout the user specified for this test run. 82 * Creates a new CoreTestResult with the given flags and timeout. 84 public CoreTestResult(int flags, int timeout) { argument 88 fTimeout = timeout; 143 CoreTestTimeout timeout = new CoreTestTimeout("Test timed out"); 144 timeout.setStackTrace(trace); 145 addError(test, timeout);
|
/dalvik/libcore/dalvik/src/main/native/ |
H A D | dalvik_system_TouchDex.cpp | 160 int cc, count, dexCount, timeout; local 165 * Adjust the timeout based on how many DEX files we have to 173 * sort of spoils the timeout calculation. We establish a minimum 174 * timeout for single apps. 176 * The timeout calculation doesn't work at all right when a 178 * this point it's probably safe to just remove the timeout. 180 * The timeout is in 1/10ths of a second. 188 timeout = timeoutMult * dexCount; 189 if (timeout < kMinTimeout) 190 timeout [all...] |
/dalvik/libcore/luni/src/main/java/org/apache/harmony/luni/platform/ |
H A D | OSNetworkSystem.java | 68 FileDescriptor fdnewSocket, int timeout) throws IOException { 69 acceptSocketImpl(fdServer, newSocket, fdnewSocket, timeout); 73 SocketImpl newSocket, FileDescriptor fdnewSocket, int timeout) 78 // SocketImpl newSocket, FileDescriptor fdnewSocket, int timeout) 80 // acceptStreamSocketImpl(fdServer, newSocket, fdnewSocket, timeout); 84 // SocketImpl newSocket, FileDescriptor fdnewSocket, int timeout) 128 int aport, int timeout, int trafficClass, InetAddress inetAddress) 130 connectStreamWithTimeoutSocketImpl(aFD, aport, timeout, trafficClass, 135 int aport, int timeout, int trafficClass, InetAddress inetAddress) 140 public int connectWithTimeout(FileDescriptor fd, int timeout, argument 67 accept(FileDescriptor fdServer, SocketImpl newSocket, FileDescriptor fdnewSocket, int timeout) argument 72 acceptSocketImpl(FileDescriptor fdServer, SocketImpl newSocket, FileDescriptor fdnewSocket, int timeout) argument 127 connectStreamWithTimeoutSocket(FileDescriptor aFD, int aport, int timeout, int trafficClass, InetAddress inetAddress) argument 134 connectStreamWithTimeoutSocketImpl(FileDescriptor aFD, int aport, int timeout, int trafficClass, InetAddress inetAddress) argument 147 connectWithTimeoutSocketImpl(FileDescriptor aFD, int timeout, int trafficClass, InetAddress hostname, int port, int step, byte[] context) argument 350 read(FileDescriptor fd, byte[] data, int offset, int count, int timeout) argument 361 readSocketImpl(FileDescriptor aFD, byte[] data, int offset, int count, int timeout) argument 382 readDirect(FileDescriptor fd, int address, int count, int timeout) argument 387 readSocketDirectImpl(FileDescriptor aFD, int address, int count, int timeout) argument 480 select(FileDescriptor[] readFDs, FileDescriptor[] writeFDs, int numReadable, int numWritable, long timeout, int[] flags) argument 500 selectImpl(FileDescriptor[] readfd, FileDescriptor[] writefd, int cread, int cwirte, int[] flags, long timeout) argument [all...] |
H A D | INetworkSystem.java | 52 FileDescriptor fdnewSocket, int timeout) throws IOException; 58 int timeout) throws IOException; 61 int timeout) throws IOException; 86 public int connectWithTimeout(FileDescriptor aFD, int timeout, argument 134 // int count, int timeout) throws IOException; 149 // SocketImpl newSocket, FileDescriptor fdnewSocket, int timeout) 163 int timeout, int trafficClass, InetAddress inetAddress) 191 * @param timeout 192 * timeout in milliseconds 204 int numReadable, int numWritable, long timeout, in 51 accept(FileDescriptor fdServer, SocketImpl newSocket, FileDescriptor fdnewSocket, int timeout) argument 57 read(FileDescriptor aFD, byte[] data, int offset, int count, int timeout) argument 60 readDirect(FileDescriptor aFD, int address, int count, int timeout) argument 162 connectStreamWithTimeoutSocket(FileDescriptor aFD, int aport, int timeout, int trafficClass, InetAddress inetAddress) argument 203 select(FileDescriptor[] readFDs, FileDescriptor[] writeFDs, int numReadable, int numWritable, long timeout, int[] flags) argument [all...] |
/dalvik/libcore/nio/src/main/java/java/nio/channels/ |
H A D | Selector.java | 115 * the calling thread is interrupted or the specified {@code timeout} 118 * @param timeout 119 * the non-negative timeout in millisecond; 0 will block forever 125 * if the given timeout argument is less than zero. 129 public abstract int select(long timeout) throws IOException; argument
|
/dalvik/libcore/x-net/src/main/java/org/apache/harmony/xnet/provider/jsse/ |
H A D | AbstractSessionContext.java | 35 volatile int timeout; field in class:AbstractSessionContext 47 * @param timeout for cache entries 50 int timeout) { 53 this.timeout = timeout; 78 return timeout; 49 AbstractSessionContext(SSLParameters parameters, int maximumSize, int timeout) argument
|
H A D | OpenSSLSocketImpl.java | 70 private int timeout = 0; field in class:OpenSSLSocketImpl 72 private int handshakeTimeout = -1; // -1 = same as timeout; 0 = infinite 237 this.timeout = socket.getSoTimeout(); 305 // Temporarily use a different timeout for the handshake process 306 int savedTimeout = timeout; 376 // Restore the original timeout now that the handshake is complete 506 private native int nativeread(int timeout) throws IOException; argument 507 private native int nativeread(byte[] b, int off, int len, int timeout) throws IOException; argument 532 return OpenSSLSocketImpl.this.nativeread(timeout); 542 return OpenSSLSocketImpl.this.nativeread(b, off, len, timeout); 898 setSoTimeout(int timeout) argument 910 setHandshakeTimeout(int timeout) argument [all...] |
/dalvik/libcore/nio/src/test/java/org/apache/harmony/nio/tests/java/nio/channels/ |
H A D | SelectorTest.java | 323 notes = "Verifies select(long) method for Selector registered with SelectionKeys.OP_ACCEPT, SelectionKeys.OP_CONNECT, SelectionKeys.OP_READ, SelectionKeys.OP_WRITE keys and different timeout's values.", 376 notes = "Verifies that select(timeout) doesn't block.", 381 // make sure select(timeout) doesn't block 520 private void assert_select_SelectorClosed(SelectType type, int timeout) argument 525 selectOnce(type, timeout); 532 private void assert_select_OP_ACCEPT(SelectType type, int timeout) argument 539 int count = blockingSelect(type, timeout); 547 count = selectOnce(type, timeout); 566 private void assert_select_OP_CONNECT(SelectType type, int timeout) argument 573 int count = blockingSelect(type, timeout); 602 assert_select_OP_READ(SelectType type, int timeout) argument 675 assert_select_OP_WRITE(SelectType type, int timeout) argument 710 blockingSelect(SelectType type, int timeout) argument 725 selectOnce(SelectType type, int timeout) argument [all...] |
/dalvik/libcore/luni/src/main/java/java/net/ |
H A D | Socket.java | 572 * Gets the timeout for this socket during which a reading operation shall 576 * or {@code 0} which represents an infinite timeout. 680 * timeout in seconds. The timeout value for this option is silently limited 685 * @param timeout 686 * the linger timeout value in seconds. 691 public void setSoLinger(boolean on, int timeout) throws SocketException { argument 693 if (on && timeout < 0) { 702 if (timeout > 65535) { 703 timeout 725 setSoTimeout(int timeout) argument 1018 connect(SocketAddress remoteAddr, int timeout) argument [all...] |
H A D | InetAddress.java | 756 * @param timeout 757 * timeout in milliseconds before the test fails if no connection 764 * if timeout is less than zero. 766 public boolean isReachable(int timeout) throws IOException { argument 767 return isReachable(null, 0, timeout); 780 * @param timeout 781 * timeout in milliseconds before the test fails if no connection 788 * if ttl or timeout is less than zero. 791 final int timeout) throws IOException { 792 if (0 > ttl || 0 > timeout) { 790 isReachable(NetworkInterface netif, final int ttl, final int timeout) argument 827 isReachableByMultiThread(NetworkInterface netif, final int ttl, final int timeout) argument 938 isReachableByTCP(InetAddress dest, InetAddress source, int timeout) argument [all...] |
/dalvik/vm/alloc/ |
H A D | HeapWorker.c | 488 struct timespec timeout; local 491 timeout.tv_sec = 0; 492 timeout.tv_nsec = 0; 501 clock_gettime(CLOCK_MONOTONIC, &timeout); 502 timeout.tv_sec += timeoutSec; 505 timeout.tv_sec = now.tv_sec + timeoutSec; 506 timeout.tv_nsec = now.tv_usec * 1000; 510 gcHeap->heapWorkerNextTrim = timeout;
|
/dalvik/libcore/sql/src/main/java/SQLite/JDBC2y/ |
H A D | JDBCStatement.java | 53 conn.timeout = seconds * 1000; 54 if (conn.timeout < 0) { 55 conn.timeout = 120000; 56 } else if (conn.timeout < 1000) { 57 conn.timeout = 5000; 62 return conn.timeout;
|
/dalvik/libcore/nio/src/main/java/org/apache/harmony/nio/internal/ |
H A D | SelectorImpl.java | 220 public int select(long timeout) throws IOException { argument 221 if (timeout < 0) { 224 return selectInternal((0 == timeout) ? SELECT_BLOCK : timeout); 235 private int selectInternal(long timeout) throws IOException { argument 241 boolean isBlock = (SELECT_NOW != timeout); 262 readableFDs, writableFDs, readableKeysCount, writableKeysCount, timeout, flags);
|
/dalvik/libcore/luni/src/main/java/org/apache/harmony/luni/net/ |
H A D | PlainSocketImpl.java | 229 * @param timeout 230 * a timeout where supported. 0 means no timeout 234 private void connect(InetAddress anAddr, int aPort, int timeout) argument 243 if (timeout == 0) { 247 timeout, trafficClass, normalAddr); 389 int applicationServerPort, int timeout) throws IOException { 391 if (timeout == 0) { 396 socksGetServerPort(), timeout, trafficClass, 530 protected void connect(SocketAddress remoteAddr, int timeout) argument 388 socksConnect(InetAddress applicationServerAddress, int applicationServerPort, int timeout) argument [all...] |