/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | BlockingDeque.java | 282 * @param timeout how long to wait before giving up, in units of 285 * {@code timeout} parameter 295 boolean offerFirst(E e, long timeout, TimeUnit unit) argument 304 * @param timeout how long to wait before giving up, in units of 307 * {@code timeout} parameter 317 boolean offerLast(E e, long timeout, TimeUnit unit) argument 343 * @param timeout how long to wait before giving up, in units of 346 * {@code timeout} parameter 351 E pollFirst(long timeout, TimeUnit unit) argument 359 * @param timeout ho 367 pollLast(long timeout, TimeUnit unit) argument 484 offer(E e, long timeout, TimeUnit unit) argument 535 poll(long timeout, TimeUnit unit) argument [all...] |
H A D | BlockingQueue.java | 211 * @param timeout how long to wait before giving up, in units of 214 * {@code timeout} 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 * {@code timeout} parameter 248 E poll(long timeout, TimeUnit unit) argument
|
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 | 129 * @param timeout the maximum time to wait 130 * @param unit the time unit of the timeout argument 139 V get(long timeout, TimeUnit unit) argument
|
H A D | TransferQueue.java | 80 * before the timeout elapses. 90 * @param timeout how long to wait before giving up, in units of 93 * {@code timeout} parameter 105 boolean tryTransfer(E e, long timeout, TimeUnit unit) argument
|
H A D | CountDownLatch.java | 240 * @param timeout the maximum time to wait 241 * @param unit the time unit of the {@code timeout} argument 247 public boolean await(long timeout, TimeUnit unit) argument 249 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout));
|
H A D | ExecutorService.java | 162 * request, or the timeout occurs, or the current thread is 165 * @param timeout the maximum time to wait 166 * @param unit the time unit of the timeout argument 168 * {@code false} if the timeout elapsed before termination 171 boolean awaitTermination(long timeout, TimeUnit unit) argument 254 * when all complete or the timeout expires, whichever happens first. 264 * @param timeout the maximum time to wait 265 * @param unit the time unit of the timeout argument 280 long timeout, TimeUnit unit) 308 * an exception), if any do before the given timeout elapse 279 invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument 328 invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument [all...] |
H A D | TimeUnit.java | 29 * the following code will timeout in 50 milliseconds if the {@link 36 * while this code will timeout in 50 seconds: 41 * Note however, that there is no guarantee that a particular timeout 302 * This is a convenience method that converts timeout arguments 310 * public synchronized Object poll(long timeout, TimeUnit unit) 313 * unit.timedWait(this, timeout); 319 * @param timeout the maximum time to wait. If less than 323 public void timedWait(Object obj, long timeout) argument 325 if (timeout > 0) { 326 long ms = toMillis(timeout); 343 timedJoin(Thread thread, long timeout) argument 362 sleep(long timeout) argument [all...] |
H A D | Semaphore.java | 378 * @param timeout the maximum time to wait for a permit 379 * @param unit the time unit of the {@code timeout} argument 384 public boolean tryAcquire(long timeout, TimeUnit unit) argument 386 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); 553 * @param timeout the maximum time to wait for the permits 554 * @param unit the time unit of the {@code timeout} argument 560 public boolean tryAcquire(int permits, long timeout, TimeUnit unit) argument 563 return sync.tryAcquireSharedNanos(permits, unit.toNanos(timeout));
|
/libcore/ojluni/src/main/java/sun/net/www/protocol/mailto/ |
H A D | MailToURLConnection.java | 118 public void setConnectTimeout(int timeout) { argument 119 if (timeout < 0) 121 connectTimeout = timeout; 130 public void setReadTimeout(int timeout) { argument 131 if (timeout < 0) 133 readTimeout = timeout;
|
/libcore/ojluni/src/main/native/ |
H A D | PollArrayWrapper.c | 46 ipoll(struct pollfd fds[], unsigned int nfds, int timeout) argument 49 int remaining = timeout; 78 jlong timeout) 85 if (timeout <= 0) { /* Indefinite or no wait */ 86 RESTARTABLE (poll(a, numfds, timeout), err); 88 err = ipoll(a, numfds, timeout); 76 Java_sun_nio_ch_PollArrayWrapper_poll0(JNIEnv *env, jobject this, jlong address, jint numfds, jlong timeout) argument
|
H A D | linux_close.cpp | 163 int NET_Poll(struct pollfd *ufds, unsigned int nfds, int timeout) { argument 164 BLOCKING_IO_RETURN_INT( ufds[0].fd, poll(ufds, nfds, timeout) ); 168 fd_set *exceptfds, struct timeval *timeout) { 170 select(s, readfds, writefds, exceptfds, timeout) ); 175 * Wrapper for poll(s, timeout). 176 * Auto restarts with adjusted timeout if interrupted by 184 int NET_Timeout(int s, long timeout) { argument 199 * Pick up current time as may need to adjust timeout 201 if (timeout > 0) { 221 rv = poll(&pfd, 1, timeout); 167 NET_Select(int s, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout) argument [all...] |
H A D | Inet4AddressImpl.c | 65 * Send a ICMP_ECHO_REQUEST packet every second until either the timeout 70 ping4(JNIEnv *env, jint fd, struct sockaddr_in* him, jint timeout, argument 146 tmout2 = timeout > 1000 ? 1000 : timeout; 177 timeout -= 1000; 178 } while (timeout >0); 192 jint timeout, 249 return ping4(env, fd, &him, timeout, netif, ttl); 328 timeout = NET_Wait(env, fd, NET_WAIT_CONNECT, timeout); 190 Inet4AddressImpl_isReachable0(JNIEnv *env, jobject this, jbyteArray addrArray, jint timeout, jbyteArray ifArray, jint ttl) 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/net/ |
H A D | InetAddressImpl.java | 66 boolean isReachable(InetAddress addr, int timeout, NetworkInterface netif, argument
|
H A D | SocketInputStream.java | 88 * @param timeout the read timeout in ms 95 int timeout) 123 int read(byte b[], int off, int length, int timeout) throws IOException { argument 151 n = socketRead0(fd, b, off, length, timeout); 159 timeout, n > 0 ? n : 0); 170 n = socketRead0(fd, b, off, length, timeout); 177 timeout, n > 0 ? n : 0); 93 socketRead0(FileDescriptor fd, byte b[], int off, int len, int timeout) argument
|
H A D | AbstractPlainSocketImpl.java | 50 int timeout; // timeout in millisec field in class:AbstractPlainSocketImpl 122 connectToAddress(address, port, timeout); 147 connectToAddress(address, port, timeout); 160 * @param timeout the timeout value in milliseconds, or zero for no timeout. 166 protected void connect(SocketAddress address, int timeout) argument 178 connectToAddress(this.address, port, timeout); 192 private void connectToAddress(InetAddress address, int port, int timeout) throw argument 326 doConnect(InetAddress address, int port, int timeout) argument 627 socketConnect(InetAddress address, int port, int timeout) argument [all...] |
/libcore/ojluni/src/main/java/sun/nio/ch/ |
H A D | SelectorImpl.java | 79 protected abstract int doSelect(long timeout) throws IOException; argument 81 private int lockAndDoSelect(long timeout) throws IOException { argument 87 return doSelect(timeout); 93 public int select(long timeout) argument 96 if (timeout < 0) 97 throw new IllegalArgumentException("Negative timeout"); 98 return lockAndDoSelect((timeout == 0) ? -1 : timeout);
|
H A D | PollArrayWrapper.java | 116 int poll(int numfds, int offset, long timeout) { argument 118 numfds, timeout); 125 private native int poll0(long pollAddress, int numfds, long timeout); argument
|
H A D | ServerSocketAdaptor.java | 48 private volatile int timeout = 0; field in class:ServerSocketAdaptor 99 if (timeout == 0) { 106 // Implement timeout with a selector 116 long to = timeout; 163 public void setSoTimeout(int timeout) throws SocketException { argument 164 this.timeout = timeout; 168 return timeout;
|
H A D | SocketAdaptor.java | 61 private volatile int timeout = 0; field in class:SocketAdaptor 86 public void connect(SocketAddress remote, int timeout) throws IOException { argument 89 if (timeout < 0) 90 throw new IllegalArgumentException("connect: timeout can't be negative"); 98 if (timeout == 0) { 109 // Implement timeout with a selector 118 long to = timeout; 219 if (timeout == 0) 222 // Implement timeout with a selector 233 long to = timeout; 381 setSoTimeout(int timeout) argument [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 implemenation, 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/ojluni/src/main/java/sun/net/www/http/ |
H A D | KeepAliveStreamCleaner.java | 56 // timeout for both socket and poll on the queue 99 long timeout = TIMEOUT; 101 this.wait(timeout); 105 if (elapsed > timeout) { 111 timeout -= elapsed;
|
/libcore/luni/src/main/java/java/lang/ref/ |
H A D | FinalizerReference.java | 85 public static void finalizeAllEnqueued(long timeout) throws InterruptedException { argument 94 sentinel.awaitFinalization(timeout); 147 synchronized void awaitFinalization(long timeout) throws InterruptedException { argument 149 final long endTime = startTime + timeout; 151 // 0 signifies no timeout. 152 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...] |