/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | CyclicBarrier.java | 114 * point prematurely because of interruption, failure, or timeout, all 370 * <li>The specified timeout elapses; or 409 * @param timeout the time to wait for the barrier 410 * @param unit the time unit of the timeout parameter 416 * @throws TimeoutException if the specified timeout elapses 423 public int await(long timeout, TimeUnit unit) argument 427 return dowait(true, unit.toNanos(timeout)); 434 * barrier due to interruption or timeout since
|
/openjdk7/jdk/src/share/classes/com/sun/jmx/remote/internal/ |
H A D | ServerCommunicatorAdmin.java | 33 public ServerCommunicatorAdmin(long timeout) { argument 37 "with the timeout "+timeout); 40 this.timeout = timeout; 43 if (timeout < Long.MAX_VALUE) { 46 t.setName("JMX server connection timeout " + t.getId()); 95 // tells the adminor to restart waiting with timeout 138 logtime("Admin: timeout=",timeout); 221 private long timeout; field in class:ServerCommunicatorAdmin [all...] |
/openjdk7/jdk/src/share/classes/com/sun/jndi/dns/ |
H A D | Resolver.java | 45 private int timeout; // initial timeout on UDP queries in ms field in class:Resolver 50 * Constructs a new Resolver given its servers and timeout parameters. 54 * "timeout" is the initial timeout interval (in ms) for UDP queries, 57 Resolver(String[] servers, int timeout, int retries) argument 59 this.timeout = timeout; 61 dnsClient = new DnsClient(servers, timeout, retries); 93 new DnsClient(findNameServers(zone, recursion), timeout, retrie [all...] |
/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/share/classes/com/sun/tools/jdi/ |
H A D | EventQueueImpl.java | 89 public EventSet remove(long timeout) throws InterruptedException { argument 90 if (timeout < 0) { 96 EventSetImpl fullEventSet = removeUnfiltered(timeout); 98 eventSet = null; // timeout 137 private TimerThread startTimerThread(long timeout) { argument 138 TimerThread thread = new TimerThread(timeout); 149 private EventSetImpl removeUnfiltered(long timeout) argument 168 * If a timeout was specified, create a thread to 169 * notify this one when a timeout 178 * a timeout fro 218 private long timeout; field in class:EventQueueImpl.TimerThread 220 TimerThread(long timeout) argument [all...] |
/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/src/macosx/native/sun/nio/ch/ |
H A D | KQueueArrayWrapper.c | 130 jlong timeout) 137 // Java timeout is in milliseconds. Convert to struct timespec. 138 // Java timeout == -1 : wait forever : timespec timeout of NULL 139 // Java timeout == 0 : return immediately : timespec timeout of zero 140 if (timeout >= 0) { 141 ts.tv_sec = timeout / 1000; 142 ts.tv_nsec = (timeout % 1000) * 1000000; //nanosec = 1 million millisec 128 Java_sun_nio_ch_KQueueArrayWrapper_kevent0(JNIEnv *env, jobject this, jint kq, jlong kevAddr, jint kevCount, jlong timeout) argument
|
/openjdk7/jdk/src/solaris/native/sun/nio/ch/ |
H A D | EPollArrayWrapper.c | 45 iepoll(int epfd, struct epoll_event *events, int numfds, jlong timeout) argument 48 int remaining = timeout; 56 int res = epoll_wait(epfd, events, numfds, timeout); 135 jlong timeout, jint epfd) 140 if (timeout <= 0) { /* Indefinite or no wait */ 141 RESTARTABLE(epoll_wait(epfd, events, numfds, timeout), res); 143 res = iepoll(epfd, events, numfds, timeout); 133 Java_sun_nio_ch_EPollArrayWrapper_epollWait(JNIEnv *env, jobject this, jlong address, jint numfds, jlong timeout, jint epfd) argument
|
H A D | PollArrayWrapper.c | 42 ipoll(struct pollfd fds[], unsigned int nfds, int timeout) argument 45 int remaining = timeout; 74 jlong timeout) 81 if (timeout <= 0) { /* Indefinite or no wait */ 82 RESTARTABLE (poll(a, numfds, timeout), err); 84 err = ipoll(a, numfds, timeout); 72 Java_sun_nio_ch_PollArrayWrapper_poll0(JNIEnv *env, jobject this, jlong address, jint numfds, jlong timeout) argument
|
H A D | SolarisEventPort.c | 111 jint port, jlong arrayAddress, jint max, jlong timeout) 119 if (timeout >= 0L) { 120 ts.tv_sec = timeout / 1000; 121 ts.tv_nsec = 1000000 * (timeout % 1000); 110 Java_sun_nio_ch_SolarisEventPort_port_1getn(JNIEnv* env, jclass clazz, jint port, jlong arrayAddress, jint max, jlong timeout) argument
|
/openjdk7/jdk/test/com/sun/jdi/ |
H A D | MonitorEventTest.java | 46 public static final long timeout = 30 * 6000; // milliseconds field in class:MonitorTestTarg 69 startingMonitor.wait(timeout); 85 t1.join(timeout);
|
/openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/ |
H A D | Basic.java | 742 static void testTimeout(final long timeout, final TimeUnit unit) throws Exception { argument 751 // this read should timeout if value is > 0 752 ch.read(dst, timeout, unit, null, new CompletionHandler<Integer,Void>() { 760 if (timeout > 0L) { 768 // after a timeout then further reading should throw unspecified runtime exception 776 throw new RuntimeException("RuntimeException expected after timeout."); 787 ch.write(genBuffer(), timeout, unit, ch, 791 ch.write(genBuffer(), timeout, unit, ch, this); 797 if (timeout > 0) { 805 // after a timeout the [all...] |
/openjdk7/jdk/src/share/demo/jvmti/waiters/ |
H A D | Agent.cpp | 193 jthread thread, jobject object, jlong timeout) 197 monitor_wait(jvmti, env, thread, object, timeout); 205 get_monitor(jvmti, env, object)->timeout(); 192 monitor_wait(jvmtiEnv* jvmti, JNIEnv *env, jthread thread, jobject object, jlong timeout) argument
|
/openjdk7/jdk/src/share/classes/sun/security/smartcardio/ |
H A D | PCSCTerminals.java | 154 public synchronized boolean waitForChange(long timeout) throws CardException { argument 155 if (timeout < 0) { 157 ("Timeout must not be negative: " + timeout); 167 if (timeout == 0) { 168 timeout = TIMEOUT_INFINITE; 187 status = SCardGetStatusChange(contextId, timeout, status, readerNames); 205 long timeout, boolean wantPresent) throws CardException { 210 if (timeout == 0) { 211 timeout = TIMEOUT_INFINITE; 214 // if timeout i 204 waitForCards(List<? extends CardTerminal> terminals, long timeout, boolean wantPresent) argument [all...] |
/openjdk7/jdk/test/javax/management/monitor/ |
H A D | CounterMonitorTest.java | 62 private int timeout = 5; field in class:CounterMonitorTest 208 * Wait until timeout reached 211 for (int i = 0; i < timeout; i++) { 212 echo("\tdoWait: Waiting for " + timeout + " seconds. " +
|
H A D | ThreadPoolTest.java | 32 * @run main/othervm/timeout=300 ThreadPoolTest 1 33 * @run main/othervm/timeout=300 ThreadPoolTest 2 34 * @run main/othervm/timeout=300 ThreadPoolTest 3 35 * @run main/othervm/timeout=300 -Djmx.x.monitor.maximum.pool.size=5 ThreadPoolTest 1 36 * @run main/othervm/timeout=300 -Djmx.x.monitor.maximum.pool.size=5 ThreadPoolTest 2 37 * @run main/othervm/timeout=300 -Djmx.x.monitor.maximum.pool.size=5 ThreadPoolTest 3 38 * @run main/othervm/timeout=300 -Djmx.x.monitor.maximum.pool.size=-5 ThreadPoolTest 1 39 * @run main/othervm/timeout=300 -Djmx.x.monitor.maximum.pool.size=-5 ThreadPoolTest 2 40 * @run main/othervm/timeout=300 -Djmx.x.monitor.maximum.pool.size=-5 ThreadPoolTest 3 215 public boolean waiting(long timeout) { argument [all...] |
/openjdk7/jdk/test/javax/management/proxy/ |
H A D | NotificationEmitterProxy.java | 52 public synchronized int waitfor(int max, long timeout) argument 55 while (count < max && timeout > 0) { 56 final long rest = timeout -
|
/openjdk7/jdk/test/javax/management/remote/mandatory/connection/ |
H A D | ConnectionTest.java | 141 // this was originally timeout 1ms, which was not enough 328 private static Notification waitForNotification(long timeout) argument 332 long remainingTime = timeout; 337 remainingTime = timeout - (System.currentTimeMillis() - startTime);
|
/openjdk7/jdk/test/sun/misc/IoTrace/ |
H A D | IoTraceAgent.java | 64 int timeout, long bytesRead) { 67 l.socketReadEnd(context, address, port, timeout, bytesRead); 63 socketReadEnd(Object context, InetAddress address, int port, int timeout, long bytesRead) argument
|
/openjdk7/jdk/src/share/classes/sun/net/www/protocol/mailto/ |
H A D | MailToURLConnection.java | 118 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;
|
/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | AbstractPollSelectorImpl.java | 83 protected abstract int doSelect(long timeout) throws IOException; argument
|
H A D | SelectorImpl.java | 79 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 D | ServerSocketAdaptor.java | 48 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;
|
/openjdk7/jdk/src/share/classes/sun/nio/fs/ |
H A D | AbstractWatchService.java | 104 public final WatchKey poll(long timeout, TimeUnit unit) argument 108 WatchKey key = pendingKeys.poll(timeout, unit);
|
/openjdk7/jdk/src/share/classes/sun/rmi/transport/proxy/ |
H A D | WrappedSocket.java | 162 * Enable/disable SO_TIMEOUT with the specified timeout 164 public synchronized void setSoTimeout(int timeout) throws SocketException argument 166 socket.setSoTimeout(timeout);
|