Searched refs:timeout (Results 1 - 25 of 98) sorted by relevance

1234

/libcore/luni/src/main/java/java/util/concurrent/
H A DBlockingDeque.java282 * @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 DBlockingQueue.java211 * @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 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.java129 * @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 DTransferQueue.java80 * 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 DCountDownLatch.java240 * @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 DExecutorService.java162 * 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 DTimeUnit.java29 * 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 DSemaphore.java378 * @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 DMailToURLConnection.java118 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 DPollArrayWrapper.c46 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 Dlinux_close.cpp163 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 DInet4AddressImpl.c65 * 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 DSocketInputStream.c56 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 DInetAddressImpl.java66 boolean isReachable(InetAddress addr, int timeout, NetworkInterface netif, argument
H A DSocketInputStream.java88 * @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 DAbstractPlainSocketImpl.java50 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 DSelectorImpl.java79 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 DPollArrayWrapper.java116 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 DServerSocketAdaptor.java48 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 DSocketAdaptor.java61 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 DNetworkClient.java43 /* 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 DKeepAliveStreamCleaner.java56 // 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 DFinalizerReference.java85 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 DReferenceQueue.java159 * 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...]

Completed in 1313 milliseconds

1234