/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | LinkedTransferQueue.java | 276 * timeout). The relative complexity of using one monolithic 402 * empirically to balance these under various timeout scenarios. 600 * @param nanos timeout in nanosecs, used only if mode is TIMED 693 * @param timed if true, wait only until timeout elapses 694 * @param nanos timeout in nanosecs, used only if timed is true 695 * @return matched item, or e if unmatched on interrupt or timeout 1051 public boolean offer(E e, long timeout, TimeUnit unit) { argument 1115 * before the timeout elapses. 1127 public boolean tryTransfer(E e, long timeout, TimeUnit unit) argument 1129 if (xfer(e, true, TIMED, unit.toNanos(timeout)) 1144 poll(long timeout, TimeUnit unit) argument [all...] |
H A D | ScheduledThreadPoolExecutor.java | 1038 public boolean offer(Runnable e, long timeout, TimeUnit unit) { argument 1105 public RunnableScheduledFuture poll(long timeout, TimeUnit unit) argument 1107 long nanos = unit.toNanos(timeout);
|
H A D | SynchronousQueue.java | 130 * 3. Support for cancellation via timeout and interrupts, 173 * @param timed if this operation should timeout 174 * @param nanos the timeout, in nanoseconds 176 * the operation failed due to timeout or interrupt -- 407 * @param nanos timeout value 427 * timeouts. (So, on timeout, one last check for match is 734 * @param nanos timeout value 893 public boolean offer(E o, long timeout, TimeUnit unit) argument 896 if (transferer.transfer(o, true, unit.toNanos(timeout)) != null) 941 public E poll(long timeout, TimeUni argument [all...] |
H A D | ForkJoinPool.java | 875 * of work). On timeout, if ctl has not changed, terminate the 1053 * complete or timeout 1989 * request, or the timeout occurs, or the current thread is 1992 * @param timeout the maximum time to wait 1993 * @param unit the time unit of the timeout argument 1995 * {@code false} if the timeout elapsed before termination 1998 public boolean awaitTermination(long timeout, TimeUnit unit) argument 2000 long nanos = unit.toNanos(timeout);
|
H A D | ThreadPoolExecutor.java | 515 * Threads use this timeout when there are more than corePoolSize 1457 public boolean awaitTermination(long timeout, TimeUnit unit) argument 1459 long nanos = unit.toNanos(timeout);
|
/openjdk7/jdk/src/share/classes/com/sun/jmx/snmp/daemon/ |
H A D | CommunicatorServer.java | 274 * @param timeout Time in ms to wait for the connector to start. 275 * If <code>timeout</code> is positive, wait for at most 276 * the specified time. An infinite timeout can be specified 277 * by passing a <code>timeout</code> value equals 280 * If timeout is negative or zero, returns as soon as possible 284 * timeout expires. 286 public void start(long timeout) argument 322 if (timeout > 0) waitForStart(timeout); 486 * <p>Waits until the communicator is started or timeout expire 502 waitForStart(long timeout) argument [all...] |
/openjdk7/jdk/src/share/classes/com/sun/jndi/dns/ |
H A D | DnsContext.java | 60 private int timeout; // initial timeout on UDP queries in ms field in class:DnsContext 67 // the defaults for the initial timeout (in ms) and the number of 73 "com.sun.jndi.dns.timeout.initial"; 74 private static final String RETRIES = "com.sun.jndi.dns.timeout.retries"; 139 timeout = ctx.timeout; 176 if (timeout != val) { 177 timeout = val; 210 if (timeout ! [all...] |
/openjdk7/jdk/src/share/classes/com/sun/net/ssl/internal/www/protocol/https/ |
H A D | HttpsURLConnectionOldImpl.java | 480 public void setConnectTimeout(int timeout) { argument 481 delegate.setConnectTimeout(timeout); 488 public void setReadTimeout(int timeout) { argument 489 delegate.setReadTimeout(timeout);
|
/openjdk7/jdk/src/share/classes/com/sun/tools/jdi/ |
H A D | EventSetImpl.java | 317 private long timeout; field in class:EventSetImpl.MonitorWaitEventImpl 322 this.timeout = evt.timeout; 333 public long timeout() { method in class:EventSetImpl.MonitorWaitEventImpl 334 return timeout;
|
/openjdk7/hotspot/src/os/bsd/vm/ |
H A D | os_bsd.inline.hpp | 213 inline int os::timeout(int fd, long timeout) { argument 226 int res = ::poll(&pfd, 1, timeout); 232 if(timeout >= 0) { 235 timeout -= newtime - prevtime; 236 if(timeout <= 0)
|
/openjdk7/hotspot/src/os/linux/vm/ |
H A D | os_linux.inline.hpp | 217 inline int os::timeout(int fd, long timeout) { argument 230 int res = ::poll(&pfd, 1, timeout); 236 if(timeout >= 0) { 239 timeout -= newtime - prevtime; 240 if(timeout <= 0)
|
/openjdk7/hotspot/src/share/vm/runtime/ |
H A D | mutex.cpp | 744 // 3. wait for either notification or timeout 755 // But if a thread in wait() encounters a timeout it will need to dequeue itself 769 // on the WaitSet; release the outer lock; wait for either notification or timeout; 796 // Wait for either notification or timeout 808 // 1. Still on the WaitSet. This can happen if we exited the loop by timeout. 836 WasOnWaitSet = 1 ; // We were *not* notified but instead encountered timeout 844 // because of a timeout. ESelf is not resident on any list and is not OnDeck 860 return WasOnWaitSet != 0 ; // return true IFF timeout 1085 bool Monitor::wait(bool no_safepoint_check, long timeout, bool as_suspend_equivalent) { argument 1111 wait_status = IWait (Self, timeout) ; [all...] |
/openjdk7/jdk/src/solaris/native/sun/awt/splashscreen/ |
H A D | splashscreen_sys.c | 558 int timeout = -1; local 571 timeout = splash->time + splash->frames[splash->currentFrame].delay 573 if (timeout < 0) { 574 timeout = 0; 578 rc = poll(pfd, 2, timeout);
|
/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
|
/openjdk7/jdk/src/windows/native/java/net/ |
H A D | TwoStacksPlainSocketImpl.c | 116 psi_timeoutID = (*env)->GetFieldID(env, cls, "timeout", "I"); 191 jint timeout) 261 if (timeout <= 0) { 287 t.tv_sec = timeout / 1000; 288 t.tv_usec = (timeout % 1000) * 1000; 579 jint timeout = (*env)->GetIntField(env, this, psi_timeoutID); local 628 if (timeout) { 629 t.tv_sec = timeout/1000; 630 t.tv_usec = (timeout%1000)*1000; 669 if (timeout) { 189 Java_java_net_TwoStacksPlainSocketImpl_socketConnect(JNIEnv *env, jobject this, jobject iaObj, jint port, jint timeout) argument 888 jint timeout; local [all...] |
/openjdk7/jdk/src/windows/transport/socket/ |
H A D | socket_md.c | 138 int dbgsysFinishConnect(int fd, long timeout) { argument 143 t.tv_sec = timeout / 1000; 144 t.tv_usec = (timeout % 1000) * 1000; 153 return SYS_ERR; /* timeout */ 350 dbgsysPoll(int fd, jboolean rd, jboolean wr, long timeout) { argument 355 t.tv_sec = timeout / 1000; 356 t.tv_usec = (timeout % 1000) * 1000;
|
/openjdk7/jdk/test/java/awt/regtesthelpers/ |
H A D | Util.java | 211 * The method returns when the above conditions are fullfilled or when the timeout 215 * @param timeout the maximum time to wait in milliseconds 220 public static boolean waitForConditionEx(final AtomicBoolean condition, long timeout) argument 226 condition.wait(timeout); 227 if (System.currentTimeMillis() - startTime >= timeout ) { 239 public static boolean waitForCondition(final AtomicBoolean condition, long timeout) { argument 241 return waitForConditionEx(condition, timeout); 248 * The same as {@code waitForConditionEx(AtomicBoolean, long)} but without a timeout.
|
/openjdk7/jdk/src/share/classes/sun/security/smartcardio/ |
H A D | PCSC.java | 82 (long contextId, long timeout, int[] currentState, String[] readerNames) 81 SCardGetStatusChange(long contextId, long timeout, int[] currentState, String[] readerNames) argument
|
/openjdk7/jdk/src/share/classes/sun/net/ftp/ |
H A D | FtpClient.java | 171 * Sets the default timeout value to use when connecting to the server, 173 * @param timeout the timeout value, in milliseconds, to use for the connect 174 * operation. A value of zero or less, means use the default timeout. 178 public abstract FtpClient setConnectTimeout(int timeout); argument 181 * Returns the current default connection timeout value. 183 * @return the value, in milliseconds, of the current connect timeout. 189 * Sets the timeout value to use when reading from the server, 191 * @param timeout the timeout valu 195 setReadTimeout(int timeout) argument 254 connect(SocketAddress dest, int timeout) argument [all...] |
/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/javax/management/remote/rmi/ |
H A D | RMIConnectionImpl.java | 1262 long timeout) 1267 +", timeout=" + timeout); 1269 if (maxNotifications < 0 || timeout < 0) 1277 // terminated (timeout elapsed). 1285 final long t = timeout; 1339 public RMIServerCommunicatorAdmin(long timeout) { argument 1340 super(timeout); 1260 fetchNotifications(long clientSequenceNumber, int maxNotifications, long timeout) argument
|
H A D | RMIConnector.java | 1332 long timeout) 1340 timeout); 1330 fetchNotifs(long clientSequenceNumber, int maxNotifications, long timeout) argument
|
/openjdk7/jdk/src/macosx/classes/sun/lwawt/macosx/ |
H A D | LWCToolkit.java | 333 * The method returns true if some events were processed during that timeout. 337 protected boolean syncNativeQueue(long timeout) { argument 338 return nativeSyncQueue(timeout); 706 private native boolean nativeSyncQueue(long timeout); argument
|
/openjdk7/jdk/src/share/back/ |
H A D | debugInit.c | 91 long timeout; member in struct:TransportSpec 587 transport->address, transport->timeout); 891 "timeout=<timeout value> for listen/attach in milliseconds n\n" 909 " - A timeout value of 0 (the default) is no timeout.\n" 1112 } else if (strcmp(buf, "timeout") == 0) { 1114 errmsg = "timeout specified without transport"; 1121 currentTransport->timeout = atol(current);
|
H A D | eventHandler.c | 1128 jlong timeout) 1149 info.u.monitor.timeout = timeout; 1126 cbMonitorWait(jvmtiEnv *jvmti_env, JNIEnv *env, jthread thread, jobject object, jlong timeout) argument
|