Home
last modified time | relevance | path

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

123

/libcore/luni/src/main/java/java/util/concurrent/
DBlockingDeque.java291 boolean offerFirst(E e, long timeout, TimeUnit unit) in offerFirst() argument
313 boolean offerLast(E e, long timeout, TimeUnit unit) in offerLast() argument
347 E pollFirst(long timeout, TimeUnit unit) in pollFirst() argument
363 E pollLast(long timeout, TimeUnit unit) in pollLast() argument
476 boolean offer(E e, long timeout, TimeUnit unit) in offer() argument
527 E poll(long timeout, TimeUnit unit) in poll() argument
DTimeUnit.java286 public void timedWait(Object obj, long timeout) in timedWait() argument
288 if (timeout > 0) { in timedWait()
289 long ms = toMillis(timeout); in timedWait()
290 int ns = excessNanos(timeout, ms); in timedWait()
305 public void timedJoin(Thread thread, long timeout) in timedJoin() argument
307 if (timeout > 0) { in timedJoin()
308 long ms = toMillis(timeout); in timedJoin()
309 int ns = excessNanos(timeout, ms); in timedJoin()
323 public void sleep(long timeout) throws InterruptedException { in sleep() argument
324 if (timeout > 0) { in sleep()
[all …]
DExecutorService.java184 boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() argument
291 long timeout, TimeUnit unit) in invokeAll() argument
338 long timeout, TimeUnit unit) in invokeAny() argument
DBlockingQueue.java224 boolean offer(E e, long timeout, TimeUnit unit) in offer() argument
248 E poll(long timeout, TimeUnit unit) in poll() argument
DSemaphore.java379 public boolean tryAcquire(long timeout, TimeUnit unit) in tryAcquire() argument
381 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); in tryAcquire()
552 public boolean tryAcquire(int permits, long timeout, TimeUnit unit) in tryAcquire() argument
555 return sync.tryAcquireSharedNanos(permits, unit.toNanos(timeout)); in tryAcquire()
DCountDownLatch.java251 public boolean await(long timeout, TimeUnit unit) in await() argument
253 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); in await()
DLinkedBlockingDeque.java372 public boolean offerFirst(E e, long timeout, TimeUnit unit) in offerFirst() argument
375 long nanos = unit.toNanos(timeout); in offerFirst()
394 public boolean offerLast(E e, long timeout, TimeUnit unit) in offerLast() argument
397 long nanos = unit.toNanos(timeout); in offerLast()
476 public E pollFirst(long timeout, TimeUnit unit) in pollFirst() argument
478 long nanos = unit.toNanos(timeout); in pollFirst()
494 public E pollLast(long timeout, TimeUnit unit) in pollLast() argument
496 long nanos = unit.toNanos(timeout); in pollLast()
621 public boolean offer(E e, long timeout, TimeUnit unit) in offer() argument
623 return offerLast(e, timeout, unit); in offer()
[all …]
DFuture.java140 V get(long timeout, TimeUnit unit) in get() argument
DAbstractExecutorService.java200 long timeout, TimeUnit unit) in invokeAny() argument
202 return doInvokeAny(tasks, true, unit.toNanos(timeout)); in invokeAny()
236 long timeout, TimeUnit unit) in invokeAll() argument
240 long nanos = unit.toNanos(timeout); in invokeAll()
DExecutorCompletionService.java171 public Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException { in poll() argument
172 return completionQueue.poll(timeout, unit); in poll()
DCompletionService.java96 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; in poll() argument
DExecutors.java607 public boolean awaitTermination(long timeout, TimeUnit unit)
609 return e.awaitTermination(timeout, unit);
625 long timeout, TimeUnit unit)
627 return e.invokeAll(tasks, timeout, unit);
634 long timeout, TimeUnit unit)
636 return e.invokeAny(tasks, timeout, unit);
/libcore/luni/src/main/java/java/lang/ref/
DReferenceQueue.java99 public synchronized Reference<? extends T> remove(long timeout) throws IllegalArgumentException, in remove() argument
101 if (timeout < 0) { in remove()
105 if (timeout == 0L) { in remove()
111 long wakeupTime = now + timeout + 1L; in remove()
/libcore/dalvik/src/main/native/
Ddalvik_system_TouchDex.cpp159 int cc, count, dexCount, timeout; in dalvik_system_TouchDex_trampoline() local
187 timeout = timeoutMult * dexCount; in dalvik_system_TouchDex_trampoline()
188 if (timeout < kMinTimeout) in dalvik_system_TouchDex_trampoline()
189 timeout = kMinTimeout; in dalvik_system_TouchDex_trampoline()
196 (int) pid, timeout / 10.0); in dalvik_system_TouchDex_trampoline()
197 for (count = 0; count < timeout; count++) { in dalvik_system_TouchDex_trampoline()
211 if (count == timeout) { in dalvik_system_TouchDex_trampoline()
/libcore/luni/src/test/java/com/google/coretests/
DCoreTestResult.java84 public CoreTestResult(int flags, int timeout) { in CoreTestResult() argument
88 fTimeout = timeout; in CoreTestResult()
143 CoreTestTimeout timeout = new CoreTestTimeout("Test timed out"); in runProtected() local
144 timeout.setStackTrace(trace); in runProtected()
145 addError(test, timeout); in runProtected()
/libcore/luni/src/test/java/org/apache/harmony/nio/tests/java/nio/channels/
DSelectorTest.java515 private void assert_select_SelectorClosed(SelectType type, int timeout) in assert_select_SelectorClosed() argument
520 selectOnce(type, timeout); in assert_select_SelectorClosed()
527 private void assert_select_OP_ACCEPT(SelectType type, int timeout) in assert_select_OP_ACCEPT() argument
534 int count = blockingSelect(type, timeout); in assert_select_OP_ACCEPT()
542 count = selectOnce(type, timeout); in assert_select_OP_ACCEPT()
561 private void assert_select_OP_CONNECT(SelectType type, int timeout) in assert_select_OP_CONNECT() argument
568 int count = blockingSelect(type, timeout); in assert_select_OP_CONNECT()
576 count = selectOnce(type, timeout); in assert_select_OP_CONNECT()
597 private void assert_select_OP_READ(SelectType type, int timeout) in assert_select_OP_READ() argument
618 int count = blockingSelect(type, timeout); in assert_select_OP_READ()
[all …]
/libcore/luni/src/main/java/org/apache/harmony/luni/platform/
DOSNetworkSystem.java46 public native void connect(FileDescriptor fd, InetAddress inetAddress, int port, int timeout) in connect() argument
51 public native boolean isConnected(FileDescriptor fd, int timeout) throws IOException; in isConnected() argument
79 int numReadable, int numWritable, long timeout, int[] flags) in select() argument
90 return selectImpl(readFDs, writeFDs, numReadable, numWritable, flags, timeout); in select()
95 long timeout); in selectImpl() argument
DINetworkSystem.java50 public boolean isConnected(FileDescriptor fd, int timeout) throws IOException; in isConnected() argument
74 public void connect(FileDescriptor fd, InetAddress inetAddress, int port, int timeout) in connect() argument
110 int numReadable, int numWritable, long timeout, int[] flags) in select() argument
/libcore/luni/src/main/java/java/net/
DInetAddress.java733 public boolean isReachable(int timeout) throws IOException { in isReachable() argument
734 return isReachable(null, 0, timeout); in isReachable()
758 final int timeout) throws IOException { in isReachable() argument
759 if (ttl < 0 || timeout < 0) { in isReachable()
763 return isReachableByTCP(this, null, timeout); in isReachable()
765 return isReachableByMultiThread(networkInterface, ttl, timeout); in isReachable()
774 final int ttl, final int timeout) in isReachableByMultiThread() argument
822 threadReached = isReachableByTCP(addr, InetAddress.this, timeout); in isReachableByMultiThread()
862 private boolean isReachableByTCP(InetAddress destination, InetAddress source, int timeout) in isReachableByTCP() argument
871 NETIMPL.connect(fd, destination, 7, timeout); in isReachableByTCP()
DSocket.java626 public void setSoLinger(boolean on, int timeout) throws SocketException { in setSoLinger() argument
629 if (on && timeout < 0) { in setSoLinger()
633 impl.setOption(SocketOptions.SO_LINGER, Integer.valueOf(timeout)); in setSoLinger()
650 public synchronized void setSoTimeout(int timeout) throws SocketException { in setSoTimeout() argument
652 if (timeout < 0) { in setSoTimeout()
655 impl.setOption(SocketOptions.SO_TIMEOUT, Integer.valueOf(timeout)); in setSoTimeout()
947 public void connect(SocketAddress remoteAddr, int timeout) throws IOException { in connect() argument
949 if (timeout < 0) { in connect()
983 impl.connect(remoteAddr, timeout); in connect()
DURLConnection.java1028 public void setConnectTimeout(int timeout) { in setConnectTimeout() argument
1029 if (timeout < 0) { in setConnectTimeout()
1032 this.connectTimeout = timeout; in setConnectTimeout()
1056 public void setReadTimeout(int timeout) { in setReadTimeout() argument
1057 if (timeout < 0) { in setReadTimeout()
1060 this.readTimeout = timeout; in setReadTimeout()
/libcore/luni/src/main/java/org/apache/harmony/xnet/provider/jsse/
DAbstractSessionContext.java43 volatile int timeout; field in AbstractSessionContext
65 AbstractSessionContext(int maximumSize, int timeout) { in AbstractSessionContext() argument
67 this.timeout = timeout; in AbstractSessionContext()
115 return timeout; in getSessionTimeout()
141 timeout = seconds; in setSessionTimeout()
/libcore/luni/src/main/java/org/apache/harmony/nio/internal/
DSelectorImpl.java183 @Override public int select(long timeout) throws IOException { in select() argument
184 if (timeout < 0) { in select()
187 return selectInternal((0 == timeout) ? SELECT_BLOCK : timeout); in select()
194 private int selectInternal(long timeout) throws IOException { in selectInternal() argument
200 boolean isBlock = (SELECT_NOW != timeout); in selectInternal()
221 … readableFDs, writableFDs, readableKeysCount, writableKeysCount, timeout, flags); in selectInternal()
/libcore/luni/src/test/java/tests/java/sql/
DQueryTimeoutTest.java225 private int timeout; field in QueryTimeoutTest.StatementExecutor
231 int timeout) { in StatementExecutor() argument
234 this.timeout = timeout; in StatementExecutor()
237 if (timeout > 0) { in StatementExecutor()
239 statement.setQueryTimeout(timeout); in StatementExecutor()
462 int timeout = (i % 2 == 0) ? TIMEOUT : 0; in testTimeoutWithExec() local
463 executors[i] = new StatementExecutor(statements[i], false, timeout); in testTimeoutWithExec()
491 int timeout = (i % 2 == 0) ? TIMEOUT : 0; in testTimeoutWithExec() local
492 if (timeout > 0) { in testTimeoutWithExec()
/libcore/luni/src/main/java/org/apache/harmony/luni/net/
DPlainSocketImpl.java198 private void connect(InetAddress anAddr, int aPort, int timeout) throws IOException {
204 netImpl.connect(fd, normalAddr, aPort, timeout);
291 int applicationServerPort, int timeout) throws IOException {
293 netImpl.connect(fd, socksGetServerAddress(), socksGetServerPort(), timeout);
434 protected void connect(SocketAddress remoteAddr, int timeout)
437 connect(inetAddr.getAddress(), inetAddr.getPort(), timeout);

123