/openjdk7/jdk/src/share/demo/jvmti/waiters/ |
H A D | Agent.hpp | 67 jthread thread, jobject object, jlong timeout);
|
H A D | Thread.cpp | 90 jthread thread, jobject object, jlong timeout) 89 monitor_wait(jvmtiEnv* jvmti, JNIEnv *env, jthread thread, jobject object, jlong timeout) argument
|
/openjdk7/jdk/src/share/classes/sun/net/www/protocol/https/ |
H A D | HttpsURLConnectionImpl.java | 510 public void setConnectTimeout(int timeout) { argument 511 delegate.setConnectTimeout(timeout); 518 public void setReadTimeout(int timeout) { argument 519 delegate.setReadTimeout(timeout);
|
/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | AsynchronousChannelGroupImpl.java | 200 final Future<?> schedule(Runnable task, long timeout, TimeUnit unit) { argument 202 return timeoutExecutor.schedule(task, timeout, unit); 205 // no timeout scheduled as group is terminating 306 public final boolean awaitTermination(long timeout, TimeUnit unit) argument 309 return pool.executor().awaitTermination(timeout, unit);
|
H A D | CompletedFuture.java | 74 public V get(long timeout, TimeUnit unit) throws ExecutionException { argument
|
/openjdk7/jdk/src/windows/classes/sun/nio/ch/ |
H A D | WindowsSelectorImpl.java | 118 private long timeout; //timeout for poll field in class:WindowsSelectorImpl 138 protected int doSelect(long timeout) throws IOException { argument 141 this.timeout = timeout; // set selector timeout 298 readFds, writeFds, exceptFds, timeout); 307 readFds, writeFds, exceptFds, timeout); 311 int[] readFds, int[] writeFds, int[] exceptFds, long timeout); 310 poll0(long pollAddress, int numfds, int[] readFds, int[] writeFds, int[] exceptFds, long timeout) argument
|
H A D | WindowsAsynchronousSocketChannelImpl.java | 546 // release waiters if not already released by timeout 569 // release waiters if not already released by timeout 583 * Invoked if timeout expires before it is cancelled 585 void timeout() { method in class:WindowsAsynchronousSocketChannelImpl.ReadTask 605 long timeout, 623 // schedule timeout 624 if (timeout > 0L) { 627 readTask.timeout(); 629 }, timeout, unit); 803 // release waiters if not already released by timeout 602 implRead(boolean isScatteringRead, ByteBuffer dst, ByteBuffer[] dsts, long timeout, TimeUnit unit, A attachment, CompletionHandler<V,? super A> handler) argument 842 void timeout() { method in class:WindowsAsynchronousSocketChannelImpl.WriteTask 859 implWrite(boolean gatheringWrite, ByteBuffer src, ByteBuffer[] srcs, long timeout, TimeUnit unit, A attachment, CompletionHandler<V,? super A> handler) argument [all...] |
/openjdk7/jdk/src/macosx/native/sun/awt/splashscreen/ |
H A D | splashscreen_sys.m | 274 int timeout = -1; 284 timeout = splash->time + splash->frames[splash->currentFrame].delay 286 if (timeout < 0) { 287 timeout = 0; 291 rc = poll(pfd, 1, timeout);
|
/openjdk7/jdk/src/solaris/native/java/net/ |
H A D | Inet4AddressImpl.c | 591 * Send a ICMP_ECHO_REQUEST packet every second until either the timeout 596 ping4(JNIEnv *env, jint fd, struct sockaddr_in* him, jint timeout, argument 670 tmout2 = timeout > 1000 ? 1000 : timeout; 699 timeout -= 1000; 700 } while (timeout >0); 713 jint timeout, 769 return ping4(env, fd, &him, timeout, netif, ttl); 842 timeout = NET_Wait(env, fd, NET_WAIT_CONNECT, timeout); 711 Java_java_net_Inet4AddressImpl_isReachable0(JNIEnv *env, jobject this, jbyteArray addrArray, jint timeout, jbyteArray ifArray, jint ttl) argument [all...] |
H A D | PlainSocketImpl.c | 150 psi_timeoutID = (*env)->GetFieldID(env, cls, "timeout", "I"); 257 jint timeout) 300 if (timeout <= 0) { 358 * A timeout was specified. We put the socket into non-blocking 360 * established, fail, or timeout. 381 * timeout occurs. poll/select needs to handle EINTR in 394 connect_rv = NET_Poll(&pfd, 1, timeout); 401 t.tv_sec = timeout / 1000; 402 t.tv_usec = (timeout % 1000) * 1000; 422 * The poll was interrupted so adjust timeout an 255 Java_java_net_PlainSocketImpl_socketConnect(JNIEnv *env, jobject this, jobject iaObj, jint port, jint timeout) argument 655 jint timeout = (*env)->GetIntField(env, this, psi_timeoutID); local [all...] |
/openjdk7/jdk/src/share/classes/java/awt/image/ |
H A D | PixelGrabber.java | 221 * abort, error or timeout 232 * delivered or until the specified timeout has elapsed. This method 238 * as timeout expires. 245 * abort, error or timeout 262 long timeout; 264 timeout = 0; 266 timeout = end - System.currentTimeMillis(); 267 if (timeout <= 0) { 271 wait(timeout);
|
/openjdk7/jdk/src/windows/native/java/net/ |
H A D | DualStackPlainSocketImpl.c | 50 // implement read timeout with select. 141 (JNIEnv *env, jclass clazz, jint fd, jint timeout) { 151 t.tv_sec = timeout / 1000; 152 t.tv_usec = (timeout % 1000) * 1000; 155 * Wait for timeout, connection established or 309 (JNIEnv *env, jclass clazz, jint fd, jint timeout) { 312 rv = NET_Timeout(fd, timeout); 140 Java_java_net_DualStackPlainSocketImpl_waitForConnect(JNIEnv *env, jclass clazz, jint fd, jint timeout) argument 308 Java_java_net_DualStackPlainSocketImpl_waitForNewConnection(JNIEnv *env, jclass clazz, jint fd, jint timeout) argument
|
H A D | DualStackPlainDatagramSocketImpl.c | 238 jint timeout, jboolean connected, jboolean peek) { 278 if (timeout) { 282 rv = NET_Timeout(fd, timeout); 318 } else if (timeout) { 319 /* Adjust timeout */ 321 timeout -= (jint)(newTime - prevTime); 322 if (timeout <= 0) { 236 Java_java_net_DualStackPlainDatagramSocketImpl_socketReceiveOrPeekData(JNIEnv *env, jclass clazz, jint fd, jobject dpObj, jint timeout, jboolean connected, jboolean peek) argument
|
H A D | TwoStacksPlainDatagramSocketImpl.c | 393 pdsi_timeoutID = (*env)->GetFieldID(env, cls, "timeout", "I"); 800 jint timeout = (*env)->GetIntField(env, this, pdsi_timeoutID); local 836 * If a timeout has been specified then we select on the socket 837 * waiting for a read event or a timeout. 839 if (timeout) { 842 ret = NET_Timeout (fd, timeout); 848 NET_ThrowCurrent(env, "timeout in datagram socket peek"); 880 * If a timeout was specified then we need to adjust it because 881 * we may have used up some of the timeout befor the icmp port 884 if (timeout) { 924 jint timeout = (*env)->GetIntField(env, this, pdsi_timeoutID); local 1195 jint timeout = (*env)->GetIntField(env, this, pdsi_timeoutID); local [all...] |
H A D | net_util_md.c | 538 NET_Timeout(int fd, long timeout) { argument 542 t.tv_sec = timeout / 1000; 543 t.tv_usec = (timeout % 1000) * 1000; 554 * If timeout = -1, it blocks forever. 563 NET_Timeout2(int fd, int fd1, long timeout, int *fdret) { argument 567 if (timeout == -1) { 570 t.tv_sec = timeout / 1000; 571 t.tv_usec = (timeout % 1000) * 1000; 579 return 0; /* timeout */ 961 * Wrapper for select/poll with timeout o 973 NET_Wait(JNIEnv *env, jint fd, jint flags, jint timeout) argument [all...] |
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
H A D | UnixAsynchronousSocketChannelImpl.java | 379 Future<?> timeout = readTimer; 418 if (timeout != null) 419 timeout.cancel(false); 474 long timeout, 528 if (timeout > 0L) { 529 this.readTimer = port.schedule(readTimeoutTask, timeout, unit); 669 long timeout, 711 if (timeout > 0L) { 712 this.writeTimer = port.schedule(writeTimeoutTask, timeout, unit); 471 implRead(boolean isScatteringRead, ByteBuffer dst, ByteBuffer[] dsts, long timeout, TimeUnit unit, A attachment, CompletionHandler<V,? super A> handler) argument 666 implWrite(boolean isGatheringWrite, ByteBuffer src, ByteBuffer[] srcs, long timeout, TimeUnit unit, A attachment, CompletionHandler<V,? super A> handler) argument
|
/openjdk7/jdk/src/share/back/ |
H A D | transport.c | 42 long timeout; member in struct:TransportInfo 311 rc = (*t)->Accept(t, info->timeout, 0); 318 * If accept fails it probably means a timeout, or another fatal error 323 EXIT_ERROR(JVMTI_ERROR_NONE, "could not connect, timeout or fatal error"); 411 long timeout) 452 info->timeout = timeout; 526 err = (*trans)->Attach(trans, address, timeout, 0); 410 transport_startTransport(jboolean isServer, char *name, char *address, long timeout) argument
|
/openjdk7/jdk/src/share/classes/sun/net/www/protocol/ftp/ |
H A D | FtpURLConnection.java | 619 public void setConnectTimeout(int timeout) { argument 620 if (timeout < 0) { 623 connectTimeout = timeout; 632 public void setReadTimeout(int timeout) { argument 633 if (timeout < 0) { 636 readTimeout = timeout;
|
/openjdk7/jdk/src/share/classes/java/util/concurrent/locks/ |
H A D | ReentrantLock.java | 386 * <pre>if (lock.tryLock() || lock.tryLock(timeout, unit) ) { ... } 433 * @param timeout the time to wait for the lock 434 * @param unit the time unit of the timeout argument 443 public boolean tryLock(long timeout, TimeUnit unit) argument 445 return sync.tryAcquireNanos(1, unit.toNanos(timeout));
|
/openjdk7/jdk/src/share/classes/com/sun/jndi/ldap/pool/ |
H A D | Pool.java | 71 * timeout is set as the PoolCleaner removes expired connections periodically. 107 * is removed or until 'timeout' ms has elapsed. 110 * @param timeout the number of milliseconds to wait before giving up 117 public PooledConnection getPooledConnection(Object id, long timeout, argument 147 return conns.get(timeout, factory); // get one connection from list
|
/openjdk7/jdk/src/macosx/classes/sun/nio/ch/ |
H A D | KQueueSelectorImpl.java | 94 protected int doSelect(long timeout) argument 103 entries = kqueueWrapper.poll(timeout);
|
/openjdk7/jdk/test/java/awt/event/MouseEvent/MouseClickTest/ |
H A D | MouseClickTest.java | 154 long timeout) 159 eventCount.wait(timeout); 153 waitForCondition(final AtomicInteger eventCount, int EXPECTED_EVENT_COUNT, long timeout) argument
|
/openjdk7/jdk/test/java/lang/management/ThreadMXBean/ |
H A D | MyOwnSynchronizer.java | 147 public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException { argument 148 return sync.tryAcquireNanos(1, unit.toNanos(timeout));
|
/openjdk7/jdk/test/java/util/concurrent/ThreadPoolExecutor/ |
H A D | ScheduledTickleService.java | 157 public V get(long timeout, TimeUnit unit) argument 159 return task.get(timeout, unit);
|
/openjdk7/jdk/test/java/util/concurrent/locks/Lock/ |
H A D | FlakyMutex.java | 127 public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException { argument 128 return sync.tryAcquireNanos(1, unit.toNanos(timeout));
|