/libcore/luni/src/main/java/java/nio/channels/ |
H A D | Selector.java | 113 * the calling thread is interrupted or the specified {@code timeout} 116 * @param timeout 117 * the non-negative timeout in millisecond; 0 will block forever 123 * if the given timeout argument is less than zero. 127 public abstract int select(long timeout) throws IOException; argument
|
/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | CompletionService.java | 85 * @param timeout how long to wait before giving up, in units of 88 * {@code timeout} parameter 94 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; argument
|
H A D | Future.java | 128 * @param timeout the maximum time to wait 129 * @param unit the time unit of the timeout argument 138 V get(long timeout, TimeUnit unit) argument
|
H A D | TransferQueue.java | 81 * before the timeout elapses. 91 * @param timeout how long to wait before giving up, in units of 94 * {@code timeout} parameter 106 boolean tryTransfer(E e, long timeout, TimeUnit unit) argument
|
H A D | AbstractExecutorService.java | 192 long timeout, TimeUnit unit) 194 return doInvokeAny(tasks, true, unit.toNanos(timeout)); 229 long timeout, TimeUnit unit) 233 long nanos = unit.toNanos(timeout); 191 invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument 228 invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument
|
H A D | BlockingQueue.java | 210 * @param timeout how long to wait before giving up, in units of 213 * {@code timeout} parameter 223 boolean offer(E e, long timeout, TimeUnit unit) argument 239 * @param timeout how long to wait before giving up, in units of 242 * {@code timeout} parameter 247 E poll(long timeout, TimeUnit unit) argument
|
H A D | CountDownLatch.java | 239 * @param timeout the maximum time to wait 240 * @param unit the time unit of the {@code timeout} argument 246 public boolean await(long timeout, TimeUnit unit) argument 248 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout));
|
H A D | ExecutorCompletionService.java | 171 public Future<V> poll(long timeout, TimeUnit unit) argument 173 return completionQueue.poll(timeout, unit);
|
H A D | ExecutorService.java | 161 * request, or the timeout occurs, or the current thread is 164 * @param timeout the maximum time to wait 165 * @param unit the time unit of the timeout argument 167 * {@code false} if the timeout elapsed before termination 170 boolean awaitTermination(long timeout, TimeUnit unit) argument 250 * when all complete or the timeout expires, whichever happens first. 260 * @param timeout the maximum time to wait 261 * @param unit the time unit of the timeout argument 275 long timeout, TimeUnit unit) 302 * an exception), if any do before the given timeout elapse 274 invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument 321 invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument [all...] |
H A D | CyclicBarrier.java | 88 * point prematurely because of interruption, failure, or timeout, all 344 * <li>The specified timeout elapses; or 383 * @param timeout the time to wait for the barrier 384 * @param unit the time unit of the timeout parameter 390 * @throws TimeoutException if the specified timeout elapses 397 public int await(long timeout, TimeUnit unit) argument 401 return dowait(true, unit.toNanos(timeout)); 408 * barrier due to interruption or timeout since
|
H A D | BlockingDeque.java | 275 * @param timeout how long to wait before giving up, in units of 278 * {@code timeout} parameter 288 boolean offerFirst(E e, long timeout, TimeUnit unit) argument 297 * @param timeout how long to wait before giving up, in units of 300 * {@code timeout} parameter 310 boolean offerLast(E e, long timeout, TimeUnit unit) argument 336 * @param timeout how long to wait before giving up, in units of 339 * {@code timeout} parameter 344 E pollFirst(long timeout, TimeUnit unit) argument 352 * @param timeout ho 360 pollLast(long timeout, TimeUnit unit) argument 477 offer(E e, long timeout, TimeUnit unit) argument 528 poll(long timeout, TimeUnit unit) argument [all...] |
H A D | DelayQueue.java | 138 * @param timeout This parameter is ignored as the method never blocks 143 public boolean offer(E e, long timeout, TimeUnit unit) { argument 219 public E poll(long timeout, TimeUnit unit) throws InterruptedException { argument 220 long nanos = unit.toNanos(timeout);
|
H A D | Semaphore.java | 372 * @param timeout the maximum time to wait for a permit 373 * @param unit the time unit of the {@code timeout} argument 378 public boolean tryAcquire(long timeout, TimeUnit unit) argument 380 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); 543 * @param timeout the maximum time to wait for the permits 544 * @param unit the time unit of the {@code timeout} argument 550 public boolean tryAcquire(int permits, long timeout, TimeUnit unit) argument 553 return sync.tryAcquireSharedNanos(permits, unit.toNanos(timeout));
|
H A D | Executors.java | 183 * properties but different details (for example, timeout parameters) 588 public boolean awaitTermination(long timeout, TimeUnit unit) argument 590 return e.awaitTermination(timeout, unit); 606 long timeout, TimeUnit unit) 608 return e.invokeAll(tasks, timeout, unit); 615 long timeout, TimeUnit unit) 617 return e.invokeAny(tasks, timeout, unit); 605 invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument 614 invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument
|
H A D | FutureTask.java | 169 public V get(long timeout, TimeUnit unit) argument 175 (s = awaitDone(true, unit.toNanos(timeout))) <= COMPLETING) 361 * Awaits completion or aborts on interrupt or timeout.
|
H A D | LinkedBlockingQueue.java | 340 public boolean offer(E e, long timeout, TimeUnit unit) argument 344 long nanos = unit.toNanos(timeout); 424 public E poll(long timeout, TimeUnit unit) throws InterruptedException { argument 427 long nanos = unit.toNanos(timeout);
|
/libcore/crypto/src/main/java/org/conscrypt/ |
H A D | AbstractSessionContext.java | 42 volatile int timeout; field in class:AbstractSessionContext 67 * @param timeout for cache entries 69 AbstractSessionContext(int maximumSize, int timeout) { argument 71 this.timeout = timeout; 119 return timeout; 145 timeout = seconds; 152 // timeout as part of their validity condition.
|
H A D | OpenSSLSocketImplWrapper.java | 43 public void connect(SocketAddress sockaddr, int timeout) argument
|
H A D | SSLSocketWrapper.java | 64 public void connect(SocketAddress sockaddr, int timeout) argument
|
/libcore/luni/src/main/java/java/net/ |
H A D | SocketImpl.java | 252 * by the {@code SocketAddress} object with the given timeout. This method 253 * will block indefinitely if the timeout is set to zero. 257 * @param timeout 258 * the timeout value in milliseconds. 262 protected abstract void connect(SocketAddress remoteAddr, int timeout) throws IOException; argument
|
H A D | DatagramSocket.java | 218 * Gets the socket {@link SocketOptions#SO_TIMEOUT receive timeout}. 232 * is truncated. This method blocks until a packet is received or a timeout 327 * Sets the {@link SocketOptions#SO_TIMEOUT read timeout} in milliseconds for this socket. 328 * This receive timeout defines the period the socket will block waiting to 330 * {@code 0} (default) is used to set an infinite timeout. To have effect 333 * @param timeout the timeout in milliseconds or 0 for no timeout. 337 public synchronized void setSoTimeout(int timeout) throws SocketException { argument 338 if (timeout < [all...] |
H A D | ServerSocket.java | 181 * Gets the socket {@link SocketOptions#SO_TIMEOUT accept timeout}. 227 * Sets the {@link SocketOptions#SO_TIMEOUT accept timeout} in milliseconds for this socket. 228 * This accept timeout defines the period the socket will block waiting to 230 * {@code 0} (default) is used to set an infinite timeout. To have effect 233 * @param timeout the timeout in milliseconds or 0 for no timeout. 237 public synchronized void setSoTimeout(int timeout) throws SocketException { argument 239 if (timeout < 0) { 240 throw new IllegalArgumentException("timeout < [all...] |
/libcore/harmony-tests/src/test/java/org/apache/harmony/nio/tests/java/nio/channels/ |
H A D | SelectorTest.java | 273 // make sure select(timeout) doesn't block 464 private void assert_select_SelectorClosed(SelectType type, int timeout) argument 469 selectOnce(type, timeout); 476 private void assert_select_OP_ACCEPT(SelectType type, int timeout) argument 483 int count = blockingSelect(type, timeout); 491 count = selectOnce(type, timeout); 510 private void assert_select_OP_CONNECT(SelectType type, int timeout) argument 517 int count = blockingSelect(type, timeout); 525 count = selectOnce(type, timeout); 546 private void assert_select_OP_READ(SelectType type, int timeout) argument 619 assert_select_OP_WRITE(SelectType type, int timeout) argument 654 blockingSelect(SelectType type, int timeout) argument 669 selectOnce(SelectType type, int timeout) argument [all...] |
/libcore/luni/src/main/java/java/nio/ |
H A D | SelectorImpl.java | 151 @Override public int select(long timeout) throws IOException { argument 152 if (timeout < 0) { 153 throw new IllegalArgumentException("timeout < 0: " + timeout); 155 // Our timeout is interpreted differently to Unix's --- 0 means block. See selectNow. 156 return selectInternal((timeout == 0) ? -1 : timeout); 163 private int selectInternal(long timeout) throws IOException { argument 169 boolean isBlocking = (timeout != 0); 179 rc = Libcore.os.poll(pollFds.array(), (int) timeout); [all...] |
/libcore/luni/src/main/java/java/sql/ |
H A D | Connection.java | 789 * @param timeout number of seconds to wait for a response before giving up and returning false, 791 * @throws SQLException if {@code timeout < 0} 793 public boolean isValid(int timeout) throws SQLException; argument
|