/openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
H A D | DevPollSelectorImpl.java | 76 protected int doSelect(long timeout) argument 84 pollWrapper.poll(timeout);
|
H A D | EPollSelectorImpl.java | 73 protected int doSelect(long timeout) throws IOException { argument 79 pollWrapper.poll(timeout);
|
H A D | EventPortSelectorImpl.java | 64 protected int doSelect(long timeout) throws IOException { argument 71 entries = pollWrapper.poll(timeout);
|
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/transport/ |
H A D | SelectorImpl.java | 66 private long timeout; field in class:SelectorImpl 81 timeout = 60000; 90 public void setTimeout(long timeout) argument 92 this.timeout = timeout; 97 return timeout; 267 if (timeout == 0 && orb.transportDebugFlag) { 273 n = selector.select(timeout); 287 if (timeout == 0 && orb.transportDebugFlag) { 313 if (timeout [all...] |
/openjdk7/jdk/src/share/classes/java/nio/channels/ |
H A D | AsynchronousSocketChannel.java | 98 * methods defined by this class allow a timeout to be specified when initiating 99 * a read or write operation. If the timeout elapses before an operation completes 101 * InterruptedByTimeoutException}. A timeout may leave the channel, or the 109 * unspecified runtime exception to be thrown. When a timeout elapses then the 113 * open. All methods that accept timeout parameters treat values less than or 114 * equal to zero to mean that the I/O operation does not timeout. 356 * <p> If a timeout is specified and the timeout elapses before the operation 358 * InterruptedByTimeoutException}. Where a timeout occurs, and the 370 * @param timeout 388 read(ByteBuffer dst, long timeout, TimeUnit unit, A attachment, CompletionHandler<Integer,? super A> handler) argument 494 read(ByteBuffer[] dsts, int offset, int length, long timeout, TimeUnit unit, A attachment, CompletionHandler<Long,? super A> handler) argument 541 write(ByteBuffer src, long timeout, TimeUnit unit, A attachment, CompletionHandler<Integer,? super A> handler) argument 641 write(ByteBuffer[] srcs, int offset, int length, long timeout, TimeUnit unit, A attachment, CompletionHandler<Long,? super A> handler) argument [all...] |
/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | BlockingDeque.java | 304 * @param timeout how long to wait before giving up, in units of 307 * <tt>timeout</tt> parameter 317 boolean offerFirst(E e, long timeout, TimeUnit unit) argument 326 * @param timeout how long to wait before giving up, in units of 329 * <tt>timeout</tt> parameter 339 boolean offerLast(E e, long timeout, TimeUnit unit) argument 365 * @param timeout how long to wait before giving up, in units of 368 * <tt>timeout</tt> parameter 373 E pollFirst(long timeout, TimeUnit unit) argument 381 * @param timeout ho 389 pollLast(long timeout, TimeUnit unit) argument 506 offer(E e, long timeout, TimeUnit unit) argument 557 poll(long timeout, TimeUnit unit) argument [all...] |
H A D | DelayQueue.java | 165 * @param timeout This parameter is ignored as the method never blocks 170 public boolean offer(E e, long timeout, TimeUnit unit) { argument 245 public E poll(long timeout, TimeUnit unit) throws InterruptedException { argument 246 long nanos = unit.toNanos(timeout);
|
H A D | Semaphore.java | 406 * @param timeout the maximum time to wait for a permit 407 * @param unit the time unit of the {@code timeout} argument 412 public boolean tryAcquire(long timeout, TimeUnit unit) argument 414 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); 578 * @param timeout the maximum time to wait for the permits 579 * @param unit the time unit of the {@code timeout} argument 585 public boolean tryAcquire(int permits, long timeout, TimeUnit unit) argument 588 return sync.tryAcquireSharedNanos(permits, unit.toNanos(timeout));
|
/openjdk7/jdk/src/share/classes/com/sun/jndi/ldap/pool/ |
H A D | Connections.java | 128 * @param timeout if > 0, msec to wait until connection is available 137 synchronized PooledConnection get(long timeout, argument 140 long start = (timeout > 0 ? System.currentTimeMillis() : 0); 141 long waittime = timeout; 145 if (timeout > 0 && waittime <= 0) { 148 timeout + "ms"); 162 if (timeout > 0) { 164 waittime = timeout - (now - start);
|
/openjdk7/jdk/test/java/awt/KeyboardFocusmanager/TypeAhead/ |
H A D | TestDialogTypeAhead.java | 263 public synchronized void doWait(int timeout) throws InterruptedException { argument 268 wait(timeout);
|
/openjdk7/jdk/test/java/lang/management/ManagementFactory/ |
H A D | ThreadMXBeanProxy.java | 233 public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException { argument 234 return sync.tryAcquireNanos(1, unit.toNanos(timeout));
|
/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/src/share/demo/jvmti/waiters/ |
H A D | waiters.cpp | 214 jthread thread, jobject object, jlong timeout) 219 object, timeout); 213 monitor_wait(jvmtiEnv* jvmti, JNIEnv *env, jthread thread, jobject object, jlong timeout) argument
|
/openjdk7/jdk/src/share/native/com/sun/tools/jdi/ |
H A D | SharedMemoryTransport.c | 80 (JNIEnv *env, jobject thisObject, jlong id, jlong timeout) 86 rc = shmemBase_accept(transport, (long)timeout, &connection); 105 (JNIEnv *env, jobject thisObject, jstring address, jlong timeout) 119 rc = shmemBase_attach(addrChars, (long)timeout, &connection); 79 Java_com_sun_tools_jdi_SharedMemoryTransportService_accept0(JNIEnv *env, jobject thisObject, jlong id, jlong timeout) argument 104 Java_com_sun_tools_jdi_SharedMemoryTransportService_attach0(JNIEnv *env, jobject thisObject, jstring address, jlong timeout) argument
|
/openjdk7/jdk/src/share/classes/sun/security/krb5/internal/ |
H A D | NetClient.java | 39 int timeout) throws IOException { 41 return new TCPClient(hostname, port, timeout); 43 return new UDPClient(hostname, port, timeout); 60 TCPClient(String hostname, int port, int timeout) argument 63 tcpSocket.connect(new InetSocketAddress(hostname, port), timeout); 66 tcpSocket.setSoTimeout(timeout); 187 UDPClient(String hostname, int port, int timeout) argument 192 dgSocket.setSoTimeout(timeout); 38 getInstance(String protocol, String hostname, int port, int timeout) argument
|
/openjdk7/jdk/src/share/classes/sun/security/ssl/ |
H A D | SSLSessionContextImpl.java | 51 private int timeout; // timeout in seconds field in class:SSLSessionContextImpl 58 timeout = 86400; // default, 24 hours 61 sessionCache = Cache.newSoftMemoryCache(cacheLimit, timeout); 62 sessionHostPortCache = Cache.newSoftMemoryCache(cacheLimit, timeout); 93 * Sets the timeout limit for cached <code>SSLSession</code> objects 95 * Note that after reset the timeout, the cached session before 96 * should be timed within the shorter one of the old timeout and the 97 * new timeout. 105 if (timeout ! [all...] |
/openjdk7/jdk/test/java/util/concurrent/Phaser/ |
H A D | Basic.java | 162 final long timeout, 168 if (timeout < 0) 172 timeout, 335 for (long timeout : new long[] { 0L, 5L }) { 337 Awaiter a1 = awaiter(phaser, timeout, SECONDS); a1.start(); 161 awaiter(final Phaser phaser, final long timeout, final TimeUnit unit) argument
|
/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));
|
/openjdk7/jdk/test/javax/management/remote/mandatory/connection/ |
H A D | MultiThreadDeadLockTest.java | 49 print("Specify a server idle timeout to make a server close an idle connection."); 50 env.put("jmx.remote.x.server.connection.timeout", serverTimeout); 55 env.put("jmx.remote.x.notification.fetch.timeout", serverTimeout); 85 print("Sleep 3 times of server idle timeout: "+serverTimeout+ 143 public boolean waitDone(long timeout) { argument 147 UserThread.class.wait(timeout);
|
/openjdk7/jdk/test/javax/management/remote/mandatory/notif/ |
H A D | NotificationBufferDeadlockTest.java | 284 public boolean waiting(long timeout) { argument 286 long toWait = timeout; 296 toWait = timeout -
|
/openjdk7/jdk/test/sun/misc/IoTrace/ |
H A D | IoTraceBase.java | 39 private int timeout; field in class:IoTraceBase 47 timeout = 0; 82 int timeout, long bytesRead) { 86 this.timeout = timeout; 150 if (timeout != t) { 151 throw new Exception("Expected " + t + " timeout, got: " + timeout); 81 socketReadEnd(Object context, InetAddress address, int port, int timeout, long bytesRead) argument
|
/openjdk7/jdk/src/share/classes/sun/net/ |
H A D | NetworkClient.java | 43 /* Default value of read timeout, if not specified (infinity) */ 46 /* Default value of connect timeout, if not specified (infinity) */ 173 // Then no timeout. 235 public void setConnectTimeout(int timeout) { argument 236 connectTimeout = timeout; 244 * Sets the read timeout. 247 * protect against negative timeout values being set. This implemenation, 249 * read timeout. 251 * This method may be invoked with the default timeout value when the 252 * protocol handler is trying to reset the timeout afte 256 setReadTimeout(int timeout) argument [all...] |
/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | PendingFuture.java | 191 public V get(long timeout, TimeUnit unit) argument 197 if (!latch.await(timeout, unit)) throw new TimeoutException();
|
/openjdk7/jdk/src/share/classes/sun/rmi/transport/proxy/ |
H A D | HttpSendSocket.java | 310 * Enable/disable SO_TIMEOUT with the specified timeout 313 public synchronized void setSoTimeout(int timeout) throws SocketException argument
|
/openjdk7/jdk/src/solaris/classes/java/net/ |
H A D | PlainSocketImpl.java | 56 native void socketConnect(InetAddress address, int port, int timeout) argument
|