Searched defs:timeout (Results 1 - 25 of 50) sorted by relevance

12

/libcore/luni/src/main/java/java/nio/channels/
H A DSelector.java113 * 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 DCompletionService.java85 * @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 DFuture.java128 * @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 DTransferQueue.java81 * 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 DAbstractExecutorService.java192 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 DBlockingQueue.java210 * @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 DCountDownLatch.java239 * @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 DExecutorCompletionService.java171 public Future<V> poll(long timeout, TimeUnit unit) argument
173 return completionQueue.poll(timeout, unit);
H A DExecutorService.java161 * 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 DCyclicBarrier.java88 * 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 DBlockingDeque.java275 * @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 DDelayQueue.java138 * @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 DSemaphore.java372 * @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 DExecutors.java183 * 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 DFutureTask.java169 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 DLinkedBlockingQueue.java340 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 DAbstractSessionContext.java42 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 DOpenSSLSocketImplWrapper.java43 public void connect(SocketAddress sockaddr, int timeout) argument
H A DSSLSocketWrapper.java64 public void connect(SocketAddress sockaddr, int timeout) argument
/libcore/luni/src/main/java/java/net/
H A DSocketImpl.java252 * 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 DDatagramSocket.java218 * 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 DServerSocket.java181 * 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 DSelectorTest.java273 // 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 DSelectorImpl.java151 @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 DConnection.java789 * @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

Completed in 816 milliseconds

12