Home
last modified time | relevance | path

Searched refs:timeout (Results 1 – 25 of 143) sorted by relevance

123456

/libcore/ojluni/src/main/java/java/nio/channels/
DSelector.java398 public abstract int select(long timeout) throws IOException; in select() argument
482 public int select(Consumer<SelectionKey> action, long timeout) in select() argument
485 if (timeout < 0) in select()
487 return doSelect(Objects.requireNonNull(action), timeout); in select()
559 private int doSelect(Consumer<SelectionKey> action, long timeout) in doSelect() argument
567 if (timeout < 0) { in doSelect()
570 numKeySelected = select(timeout); in doSelect()
DAsynchronousSocketChannel.java407 long timeout, in read() argument
517 long timeout, in read() argument
564 long timeout, in write() argument
668 long timeout, in write() argument
/libcore/ojluni/src/main/native/
Dlinux_close.cpp171 int NET_Poll(struct pollfd *ufds, unsigned int nfds, int timeout) { in NET_Poll() argument
172 BLOCKING_IO_RETURN_INT( ufds[0].fd, poll(ufds, nfds, timeout) ); in NET_Poll()
176 fd_set *exceptfds, struct timeval *timeout) { in NET_Select() argument
178 select(s, readfds, writefds, exceptfds, timeout) ); in NET_Select()
192 int NET_Timeout(int s, long timeout) { in NET_Timeout() argument
209 if (timeout > 0) { in NET_Timeout()
229 rv = poll(&pfd, 1, timeout); in NET_Timeout()
240 if (timeout > 0) { in NET_Timeout()
243 timeout -= newtime - prevtime; in NET_Timeout()
244 if (timeout <= 0) { in NET_Timeout()
DPollArrayWrapper.c42 ipoll(struct pollfd fds[], unsigned int nfds, int timeout) in ipoll() argument
45 int remaining = timeout; in ipoll()
74 jlong timeout) in Java_sun_nio_ch_PollArrayWrapper_poll0() argument
81 if (timeout <= 0) { /* Indefinite or no wait */ in Java_sun_nio_ch_PollArrayWrapper_poll0()
82 RESTARTABLE (poll(a, numfds, timeout), err); in Java_sun_nio_ch_PollArrayWrapper_poll0()
84 err = ipoll(a, numfds, timeout); in Java_sun_nio_ch_PollArrayWrapper_poll0()
Dnet_util_md.h44 extern int NET_Timeout(int s, long timeout);
60 fd_set *exceptfds, struct timeval *timeout);
62 extern int NET_Poll(struct pollfd *ufds, unsigned int nfds, int timeout);
118 extern jint NET_Wait(JNIEnv *env, jint fd, jint flags, jint timeout);
/libcore/ojluni/src/main/java/java/util/concurrent/
DBlockingDeque.java315 boolean offerFirst(E e, long timeout, TimeUnit unit) in offerFirst() argument
337 boolean offerLast(E e, long timeout, TimeUnit unit) in offerLast() argument
371 E pollFirst(long timeout, TimeUnit unit) in pollFirst() argument
387 E pollLast(long timeout, TimeUnit unit) in pollLast() argument
504 boolean offer(E e, long timeout, TimeUnit unit) in offer() argument
555 E poll(long timeout, TimeUnit unit) in poll() argument
DTimeUnit.java403 public void timedWait(Object obj, long timeout) in timedWait() argument
405 if (timeout > 0) { in timedWait()
406 long ms = toMillis(timeout); in timedWait()
407 int ns = excessNanos(timeout, ms); in timedWait()
423 public void timedJoin(Thread thread, long timeout) in timedJoin() argument
425 if (timeout > 0) { in timedJoin()
426 long ms = toMillis(timeout); in timedJoin()
427 int ns = excessNanos(timeout, ms); in timedJoin()
442 public void sleep(long timeout) throws InterruptedException { in sleep() argument
443 if (timeout > 0) { in sleep()
[all …]
DExecutorService.java200 boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() argument
309 long timeout, TimeUnit unit) in invokeAll() argument
358 long timeout, TimeUnit unit) in invokeAny() argument
DSemaphore.java413 public boolean tryAcquire(long timeout, TimeUnit unit) in tryAcquire() argument
415 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); in tryAcquire()
589 public boolean tryAcquire(int permits, long timeout, TimeUnit unit) in tryAcquire() argument
592 return sync.tryAcquireSharedNanos(permits, unit.toNanos(timeout)); in tryAcquire()
/libcore/ojluni/src/main/java/sun/nio/ch/
DSelectorImpl.java78 protected abstract int doSelect(long timeout) throws IOException; in doSelect() argument
80 private int lockAndDoSelect(long timeout) throws IOException { in lockAndDoSelect() argument
86 return doSelect(timeout); in lockAndDoSelect()
92 public int select(long timeout) in select() argument
95 if (timeout < 0) in select()
97 return lockAndDoSelect((timeout == 0) ? -1 : timeout); in select()
DServerSocketAdaptor.java48 private volatile int timeout = 0; field in ServerSocketAdaptor
99 if (timeout == 0) { in accept()
111 long to = timeout; in accept()
152 public void setSoTimeout(int timeout) throws SocketException { in setSoTimeout() argument
153 this.timeout = timeout; in setSoTimeout()
157 return timeout; in getSoTimeout()
DSocketAdaptor.java59 private volatile int timeout = 0; field in SocketAdaptor
85 public void connect(SocketAddress remote, int timeout) throws IOException { in connect() argument
88 if (timeout < 0) in connect()
97 if (timeout == 0) { in connect()
113 long to = timeout; in connect()
208 if (timeout == 0) in read()
216 long to = timeout; in read()
354 public void setSoTimeout(int timeout) throws SocketException { in setSoTimeout() argument
355 if (timeout < 0) in setSoTimeout()
357 this.timeout = timeout; in setSoTimeout()
[all …]
DAsynchronousSocketChannelImpl.java218 long timeout, in implRead() argument
227 long timeout, in read() argument
276 return implRead(isScatteringRead, dst, dsts, timeout, unit, att, handler); in read()
288 long timeout, in read() argument
297 read(false, dst, null, timeout, unit, attachment, handler); in read()
304 long timeout, in read() argument
318 read(true, null, bufs, timeout, unit, attachment, handler); in read()
327 long timeout, in implWrite() argument
336 long timeout, in write() argument
382 return implWrite(isGatheringWrite, src, srcs, timeout, unit, att, handler); in write()
[all …]
DPollArrayWrapper.java114 int poll(int numfds, int offset, long timeout) { in poll() argument
116 numfds, timeout); in poll()
123 private native int poll0(long pollAddress, int numfds, long timeout); in poll0() argument
/libcore/ojluni/src/main/java/java/net/
DAbstractPlainSocketImpl.java52 int timeout; // timeout in millisec field in AbstractPlainSocketImpl
156 connectToAddress(address, port, timeout); in connect()
181 connectToAddress(address, port, timeout); in connect()
200 protected void connect(SocketAddress address, int timeout) in connect() argument
212 connectToAddress(this.address, port, timeout); in connect()
226 private void connectToAddress(InetAddress address, int port, int timeout) throws IOException { in connectToAddress() argument
228 doConnect(InetAddress.getLocalHost(), port, timeout); in connectToAddress() local
230 doConnect(address, port, timeout); in connectToAddress()
306 timeout = (Integer) val; in setOption()
315 return new Integer(timeout); in getOption()
[all …]
DSocketInputStream.java98 int timeout) in socketRead0() argument
116 int timeout) in socketRead() argument
118 return socketRead0(fd, b, off, len, timeout); in socketRead()
146 int read(byte b[], int off, int length, int timeout) throws IOException { in read() argument
173 n = socketRead(fd, b, off, length, timeout); in read()
DInetAddress.java479 public boolean isReachable(int timeout) throws IOException { in isReachable() argument
480 return isReachable(null, 0 , timeout); in isReachable()
519 int timeout) throws IOException { in isReachable() argument
522 if (timeout < 0) in isReachable()
525 return impl.isReachable(this, timeout, netif, ttl); in isReachable()
532 public boolean isReachableByICMP(int timeout) throws IOException { in isReachableByICMP() argument
533 return ((Inet6AddressImpl) impl).icmpEcho(this, timeout, null, 0); in isReachableByICMP()
/libcore/ojluni/src/main/java/sun/net/
DNetworkClient.java235 public void setConnectTimeout(int timeout) {
236 connectTimeout = timeout;
256 public void setReadTimeout(int timeout) {
257 if (timeout == DEFAULT_READ_TIMEOUT)
258 timeout = defaultSoTimeout;
260 if (serverSocket != null && timeout >= 0) {
262 serverSocket.setSoTimeout(timeout);
267 readTimeout = timeout;
/libcore/ojluni/src/main/java/java/lang/ref/
DReferenceQueue.java196 public Reference<? extends T> remove(long timeout) in remove() argument
199 if (timeout < 0) { in remove()
205 long start = (timeout == 0) ? 0 : System.nanoTime(); in remove()
207 lock.wait(timeout); in remove()
210 if (timeout != 0) { in remove()
212 timeout -= (end - start) / 1000_000; in remove()
213 if (timeout <= 0) return null; in remove()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/
DSelectorTest.java455 private void assert_select_SelectorClosed(SelectType type, int timeout)
460 selectOnce(type, timeout);
467 private void assert_select_OP_ACCEPT(SelectType type, int timeout)
474 int count = blockingSelect(type, timeout);
482 count = selectOnce(type, timeout);
501 private void assert_select_OP_CONNECT(SelectType type, int timeout)
508 int count = blockingSelect(type, timeout);
516 count = selectOnce(type, timeout);
537 private void assert_select_OP_READ(SelectType type, int timeout)
558 int count = blockingSelect(type, timeout);
[all …]
/libcore/luni/src/main/java/java/lang/ref/
DFinalizerReference.java93 public static void finalizeAllEnqueued(long timeout) throws InterruptedException { in finalizeAllEnqueued() argument
102 sentinel.awaitFinalization(timeout); in finalizeAllEnqueued()
161 synchronized void awaitFinalization(long timeout) throws InterruptedException { in awaitFinalization() argument
163 final long endTime = startTime + timeout; // May wrap. in awaitFinalization()
166 if (timeout != 0) { in awaitFinalization()
/libcore/ojluni/src/main/java/java/lang/
DProcess.java186 public boolean waitFor(long timeout, TimeUnit unit) in waitFor() argument
190 long rem = unit.toNanos(timeout); in waitFor()
201 rem = unit.toNanos(timeout) - (System.nanoTime() - startTime); in waitFor()
/libcore/luni/src/test/java/libcore/java/sql/
DDriverManagerTest.java37 int timeout = 9999; in testSetLoginTimeout() local
38 DriverManager.setLoginTimeout(timeout); in testSetLoginTimeout()
39 assertEquals(timeout, DriverManager.getLoginTimeout()); in testSetLoginTimeout()
/libcore/ojluni/src/main/java/sun/security/util/
DCache.java116 public abstract void setTimeout(int timeout); in setTimeout() argument
136 public static <K,V> Cache<K,V> newSoftMemoryCache(int size, int timeout) { in newSoftMemoryCache() argument
137 return new MemoryCache<>(true, size, timeout); in newSoftMemoryCache()
161 public static <K,V> Cache<K,V> newHardMemoryCache(int size, int timeout) { in newHardMemoryCache() argument
162 return new MemoryCache<>(false, size, timeout); in newHardMemoryCache()
240 public void setTimeout(int timeout) { in setTimeout() argument
466 public synchronized void setTimeout(int timeout) { in setTimeout() argument
468 lifetime = timeout > 0 ? timeout * 1000L : 0L; in setTimeout()
471 System.out.println("** lifetime reset to " + timeout); in setTimeout()
/libcore/luni/src/test/java/libcore/java/net/
DServerSocketConcurrentCloseTest.java211 public boolean awaitStart(long timeout, TimeUnit timeUnit) throws InterruptedException { in awaitStart() argument
212 return startLatch.await(timeout, timeUnit); in awaitStart()
248 public boolean awaitStart(long timeout, TimeUnit timeUnit) throws InterruptedException { in awaitStart() argument
249 return startLatch.await(timeout, timeUnit); in awaitStart()
252 public boolean awaitShutdown(long timeout, TimeUnit timeUnit) throws InterruptedException { in awaitShutdown() argument
253 return shutdownLatch.await(timeout, timeUnit); in awaitShutdown()

123456