/libcore/ojluni/src/main/java/java/util/concurrent/ |
H A D | BlockingDeque.java | 311 * @param timeout how long to wait before giving up, in units of 314 * {@code timeout} parameter 324 boolean offerFirst(E e, long timeout, TimeUnit unit) argument 333 * @param timeout how long to wait before giving up, in units of 336 * {@code timeout} parameter 346 boolean offerLast(E e, long timeout, TimeUnit unit) argument 372 * @param timeout how long to wait before giving up, in units of 375 * {@code timeout} parameter 380 E pollFirst(long timeout, TimeUnit unit) argument 388 * @param timeout ho 396 pollLast(long timeout, TimeUnit unit) argument 513 offer(E e, long timeout, TimeUnit unit) argument 564 poll(long timeout, TimeUnit unit) argument [all...] |
H A D | BlockingQueue.java | 240 * @param timeout how long to wait before giving up, in units of 243 * {@code timeout} parameter 253 boolean offer(E e, long timeout, TimeUnit unit) argument 269 * @param timeout how long to wait before giving up, in units of 272 * {@code timeout} parameter 277 E poll(long timeout, TimeUnit unit) argument
|
H A D | CompletionService.java | 114 * @param timeout how long to wait before giving up, in units of 117 * {@code timeout} parameter 123 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; argument
|
H A D | Future.java | 158 * @param timeout the maximum time to wait 159 * @param unit the time unit of the timeout argument 168 V get(long timeout, TimeUnit unit) argument
|
H A D | TransferQueue.java | 109 * before the timeout elapses. 119 * @param timeout how long to wait before giving up, in units of 122 * {@code timeout} parameter 134 boolean tryTransfer(E e, long timeout, TimeUnit unit) argument
|
H A D | CountDownLatch.java | 269 * @param timeout the maximum time to wait 270 * @param unit the time unit of the {@code timeout} argument 276 public boolean await(long timeout, TimeUnit unit) argument 278 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout));
|
H A D | ExecutorService.java | 191 * request, or the timeout occurs, or the current thread is 194 * @param timeout the maximum time to wait 195 * @param unit the time unit of the timeout argument 197 * {@code false} if the timeout elapsed before termination 200 boolean awaitTermination(long timeout, TimeUnit unit) argument 283 * when all complete or the timeout expires, whichever happens first. 293 * @param timeout the maximum time to wait 294 * @param unit the time unit of the timeout argument 309 long timeout, TimeUnit unit) 337 * an exception), if any do before the given timeout elapse 308 invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument 357 invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument [all...] |
H A D | TimeUnit.java | 54 * the following code will timeout in 50 milliseconds if the {@link 61 * while this code will timeout in 50 seconds: 66 * Note however, that there is no guarantee that a particular timeout 327 * This is a convenience method that converts timeout arguments 335 * public synchronized Object poll(long timeout, TimeUnit unit) 338 * unit.timedWait(this, timeout); 344 * @param timeout the maximum time to wait. If less than 348 public void timedWait(Object obj, long timeout) argument 350 if (timeout > 0) { 351 long ms = toMillis(timeout); 368 timedJoin(Thread thread, long timeout) argument 387 sleep(long timeout) argument [all...] |
/libcore/ojluni/src/main/native/ |
H A D | PollArrayWrapper.c | 42 ipoll(struct pollfd fds[], unsigned int nfds, int timeout) argument 45 int remaining = timeout; 74 jlong timeout) 81 if (timeout <= 0) { /* Indefinite or no wait */ 82 RESTARTABLE (poll(a, numfds, timeout), err); 84 err = ipoll(a, numfds, timeout); 72 Java_sun_nio_ch_PollArrayWrapper_poll0(JNIEnv *env, jobject this, jlong address, jint numfds, jlong timeout) argument
|
H A D | linux_close.cpp | 165 int NET_Poll(struct pollfd *ufds, unsigned int nfds, int timeout) { argument 166 BLOCKING_IO_RETURN_INT( ufds[0].fd, poll(ufds, nfds, timeout) ); 170 fd_set *exceptfds, struct timeval *timeout) { 172 select(s, readfds, writefds, exceptfds, timeout) ); 177 * Wrapper for poll(s, timeout). 178 * Auto restarts with adjusted timeout if interrupted by 186 int NET_Timeout(int s, long timeout) { argument 201 * Pick up current time as may need to adjust timeout 203 if (timeout > 0) { 223 rv = poll(&pfd, 1, timeout); 169 NET_Select(int s, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout) argument [all...] |
H A D | SocketInputStream.c | 56 jint off, jint len, jint timeout) 95 if (timeout) { 96 nread = NET_Timeout(fd, timeout); 54 SocketInputStream_socketRead0(JNIEnv *env, jobject this, jobject fdObj, jbyteArray data, jint off, jint len, jint timeout) argument
|
/libcore/ojluni/src/main/java/java/lang/ |
H A D | Process.java | 169 * terminated and the timeout value is less than, or equal to, zero, then 177 * @param timeout the maximum time to wait 178 * @param unit the time unit of the {@code timeout} argument 186 public boolean waitFor(long timeout, TimeUnit unit) argument 190 long rem = unit.toNanos(timeout); 201 rem = unit.toNanos(timeout) - (System.nanoTime() - startTime);
|
/libcore/ojluni/src/main/java/java/net/ |
H A D | InetAddressImpl.java | 76 boolean isReachable(InetAddress addr, int timeout, NetworkInterface netif, argument
|
H A D | SocketInputStream.java | 92 * @param timeout the read timeout in ms 99 int timeout) 110 * @param timeout the read timeout in ms 117 int timeout) 119 return socketRead0(fd, b, off, len, timeout); 147 int read(byte b[], int off, int length, int timeout) throws IOException { argument 176 n = socketRead(fd, b, off, length, timeout); 194 n = socketRead(fd, b, off, length, timeout); 97 socketRead0(FileDescriptor fd, byte b[], int off, int len, int timeout) argument 115 socketRead(FileDescriptor fd, byte b[], int off, int len, int timeout) argument [all...] |
H A D | AbstractPlainSocketImpl.java | 52 int timeout; // timeout in millisec field in class:AbstractPlainSocketImpl 156 connectToAddress(address, port, timeout); 181 connectToAddress(address, port, timeout); 194 * @param timeout the timeout value in milliseconds, or zero for no timeout. 200 protected void connect(SocketAddress address, int timeout) argument 212 connectToAddress(this.address, port, timeout); 226 private void connectToAddress(InetAddress address, int port, int timeout) throw argument 379 doConnect(InetAddress address, int port, int timeout) argument 766 socketConnect(InetAddress address, int port, int timeout) argument [all...] |
/libcore/ojluni/src/main/java/java/nio/file/ |
H A D | WatchService.java | 145 * @param timeout 148 * a {@code TimeUnit} determining how to interpret the timeout 159 WatchKey poll(long timeout, TimeUnit unit) argument
|
/libcore/ojluni/src/main/java/sun/nio/ch/ |
H A D | SelectorImpl.java | 78 protected abstract int doSelect(long timeout) throws IOException; argument 80 private int lockAndDoSelect(long timeout) throws IOException { argument 86 return doSelect(timeout); 92 public int select(long timeout) argument 95 if (timeout < 0) 96 throw new IllegalArgumentException("Negative timeout"); 97 return lockAndDoSelect((timeout == 0) ? -1 : timeout);
|
H A D | ServerSocketAdaptor.java | 48 private volatile int timeout = 0; field in class:ServerSocketAdaptor 99 if (timeout == 0) { 111 long to = timeout; 152 public void setSoTimeout(int timeout) throws SocketException { argument 153 this.timeout = timeout; 157 return timeout;
|
H A D | PollArrayWrapper.java | 114 int poll(int numfds, int offset, long timeout) { argument 116 numfds, timeout); 123 private native int poll0(long pollAddress, int numfds, long timeout); argument
|
H A D | SocketAdaptor.java | 57 private volatile int timeout = 0; field in class:SocketAdaptor 82 public void connect(SocketAddress remote, int timeout) throws IOException { argument 85 if (timeout < 0) 86 throw new IllegalArgumentException("connect: timeout can't be negative"); 94 if (timeout == 0) { 109 long to = timeout; 206 if (timeout == 0) 214 long to = timeout; 352 public void setSoTimeout(int timeout) throws SocketException { argument 353 if (timeout < [all...] |
/libcore/ojluni/src/main/java/sun/net/ |
H A D | NetworkClient.java | 43 /* Default value of read timeout, if not specified (infinity) */ 46 /* Default value of connect timeout, if not specified (infinity) */ 173 // Then no timeout. 235 public void setConnectTimeout(int timeout) { argument 236 connectTimeout = timeout; 244 * Sets the read timeout. 247 * protect against negative timeout values being set. This implementation, 249 * read timeout. 251 * This method may be invoked with the default timeout value when the 252 * protocol handler is trying to reset the timeout afte 256 setReadTimeout(int timeout) argument [all...] |
/libcore/luni/src/main/java/java/lang/ref/ |
H A D | FinalizerReference.java | 87 public static void finalizeAllEnqueued(long timeout) throws InterruptedException { argument 96 sentinel.awaitFinalization(timeout); 155 synchronized void awaitFinalization(long timeout) throws InterruptedException { argument 157 final long endTime = startTime + timeout; 159 // 0 signifies no timeout. 160 if (timeout != 0) {
|
/libcore/ojluni/src/main/java/java/lang/ref/ |
H A D | ReferenceQueue.java | 159 * one becomes available or the given timeout period expires. 162 * timeout as if by invoking the {@link Object#wait(long)} method. 164 * @param timeout If positive, block for up to <code>timeout</code> 169 * timeout period, otherwise <code>null</code> 172 * If the value of the timeout argument is negative 175 * If the timeout wait is interrupted 177 public Reference<? extends T> remove(long timeout) argument 180 if (timeout < 0) { 181 throw new IllegalArgumentException("Negative timeout valu [all...] |
/libcore/ojluni/src/main/java/java/nio/channels/ |
H A D | AsynchronousSocketChannel.java | 98 * methods defined by this class allow a timeout to be specified when initiating 99 * a read or write operation. If the timeout elapses before an operation completes 101 * InterruptedByTimeoutException}. A timeout may leave the channel, or the 109 * unspecified runtime exception to be thrown. When a timeout elapses then the 113 * open. All methods that accept timeout parameters treat values less than or 114 * equal to zero to mean that the I/O operation does not timeout. 367 * <p> If a timeout is specified and the timeout elapses before the operation 369 * InterruptedByTimeoutException}. Where a timeout occurs, and the 383 * @param timeout 401 read(ByteBuffer dst, long timeout, TimeUnit unit, A attachment, CompletionHandler<Integer,? super A> handler) argument 509 read(ByteBuffer[] dsts, int offset, int length, long timeout, TimeUnit unit, A attachment, CompletionHandler<Long,? super A> handler) argument 558 write(ByteBuffer src, long timeout, TimeUnit unit, A attachment, CompletionHandler<Integer,? super A> handler) argument 660 write(ByteBuffer[] srcs, int offset, int length, long timeout, TimeUnit unit, A attachment, CompletionHandler<Long,? super A> handler) argument [all...] |
H A D | Selector.java | 306 * thread is interrupted, or the given timeout period expires, whichever 310 * timeout as if by invoking the {@link Object#wait(long)} method. </p> 312 * @param timeout If positive, block for up to <tt>timeout</tt> 327 * If the value of the timeout argument is negative 329 public abstract int select(long timeout) argument
|