/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);
|
/openjdk7/jdk/src/share/transport/socket/ |
H A D | sysSocket.h | 40 int dbgsysFinishConnect(int fd, long timeout); 60 int dbgsysPoll(int fd, jboolean rd, jboolean wr, long timeout);
|
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
H A D | PollSelectorImpl.java | 65 protected int doSelect(long timeout) argument 73 pollWrapper.poll(totalChannels, 0, timeout);
|
/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | AsynchronousSocketChannelImpl.java | 70 private boolean readKilled; // further reading disallowed due to timeout 76 private boolean writeKilled; // further writing disallowed due to timeout 217 long timeout, 226 long timeout, 248 throw new IllegalStateException("Reading not allowed due to timeout or cancellation"); 275 return implRead(isScatteringRead, dst, dsts, timeout, unit, att, handler); 287 long timeout, 296 read(false, dst, null, timeout, unit, attachment, handler); 303 long timeout, 317 read(true, null, bufs, timeout, uni 214 implRead(boolean isScatteringRead, ByteBuffer dst, ByteBuffer[] dsts, long timeout, TimeUnit unit, A attachment, CompletionHandler<V,? super A> handler) argument 223 read(boolean isScatteringRead, ByteBuffer dst, ByteBuffer[] dsts, long timeout, TimeUnit unit, A att, CompletionHandler<V,? super A> handler) argument 286 read(ByteBuffer dst, long timeout, TimeUnit unit, A attachment, CompletionHandler<Integer,? super A> handler) argument 300 read(ByteBuffer[] dsts, int offset, int length, long timeout, TimeUnit unit, A attachment, CompletionHandler<Long,? super A> handler) argument 323 implWrite(boolean isGatheringWrite, ByteBuffer src, ByteBuffer[] srcs, long timeout, TimeUnit unit, A attachment, CompletionHandler<V,? super A> handler) argument 332 write(boolean isGatheringWrite, ByteBuffer src, ByteBuffer[] srcs, long timeout, TimeUnit unit, A att, CompletionHandler<V,? super A> handler) argument 390 write(ByteBuffer src, long timeout, TimeUnit unit, A attachment, CompletionHandler<Integer,? super A> handler) argument 402 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/awt/ |
H A D | MediaTracker.java | 426 long timeout; 428 timeout = 0; 430 timeout = end - System.currentTimeMillis(); 431 if (timeout <= 0) { 435 wait(timeout); 658 long timeout; 660 timeout = 0; 662 timeout = end - System.currentTimeMillis(); 663 if (timeout <= 0) { 667 wait(timeout); [all...] |
/openjdk7/jdk/src/share/classes/sun/security/util/ |
H A D | Cache.java | 109 * Set the timeout(in seconds). 111 public abstract void setTimeout(int timeout); argument 131 public static Cache newSoftMemoryCache(int size, int timeout) { argument 132 return new MemoryCache(true, size, timeout); 155 public static Cache newHardMemoryCache(int size, int timeout) { argument 156 return new MemoryCache(false, size, timeout); 234 public void setTimeout(int timeout) { argument 424 public synchronized void setTimeout(int timeout) { argument 426 lifetime = timeout > 0 ? timeout * 100 [all...] |
/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/src/windows/classes/java/net/ |
H A D | DualStackPlainSocketImpl.java | 70 void socketConnect(InetAddress address, int port, int timeout) argument 78 if (timeout <= 0) { 85 waitForConnect(nativefd, timeout); 130 if (timeout <= 0) { 135 waitForNewConnection(nativefd, timeout); 180 if (opt == SO_TIMEOUT) { // timeout implemented through select. 274 static native void waitForConnect(int fd, int timeout) throws IOException; argument 284 static native void waitForNewConnection(int fd, int timeout) throws IOException; argument
|
/openjdk7/jdk/src/share/classes/com/sun/tools/jdi/ |
H A D | ProcessAttachingConnector.java | 52 static final String ARG_TIMEOUT = "timeout"; 67 getString("generic_attaching.timeout.label"), // use generic keys to keep 68 getString("generic_attaching.timeout"), // resource bundle small 89 int timeout = 0; 91 timeout = Integer.decode(t).intValue(); 141 Connection connection = ts.attach(address, timeout, 0);
|
H A D | GenericListeningConnector.java | 46 static final String ARG_TIMEOUT = "timeout"; 54 * encapsulates a transport service, has a "timeout" connector argument, 78 getString("generic_listening.timeout.label"), 79 getString("generic_listening.timeout"), 89 * when sub-classing - the resulting connector will a "timeout" connector 98 * have "address" and "timeout" connector arguments. 143 int timeout = 0; 145 timeout = Integer.decode(ts).intValue(); 151 connection = transportService.accept(listener, timeout, 0); 161 connection = transportService.accept(listener, timeout, [all...] |
/openjdk7/jdk/src/macosx/classes/sun/nio/ch/ |
H A D | KQueueArrayWrapper.java | 198 int poll(long timeout) { argument 200 int updated = kevent0(kq, keventArrayAddress, NUM_KEVENTS, timeout); 213 long timeout); 212 kevent0(int kq, long keventAddress, int keventCount, long 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/DatagramChannel/ |
H A D | AdaptDatagramSocket.java | 91 int timeout, boolean shouldTimeout, 117 if (timeout > 0) 118 ds.setSoTimeout(timeout); 119 out.println("timeout: " + ds.getSoTimeout()); 90 test(InetSocketAddress dst, int timeout, boolean shouldTimeout, boolean connect) argument
|
/openjdk7/jdk/test/java/nio/channels/ServerSocketChannel/ |
H A D | AdaptServerSocket.java | 78 static void test(int clientDally, int timeout, boolean shouldTimeout) argument 87 if (timeout != 0) 88 sso.setSoTimeout(timeout); 89 out.println("timeout: " + sso.getSoTimeout());
|
/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. " +
|
/openjdk7/jdk/src/share/classes/java/nio/channels/ |
H A D | AsynchronousChannelGroup.java | 328 * <p> This method blocks until the group has terminated, or the timeout 331 * @param timeout 334 * The time unit of the timeout argument 337 * timeout elapsed before termination 342 public abstract boolean awaitTermination(long timeout, TimeUnit unit) argument
|
/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/share/demo/jvmti/waiters/ |
H A D | Monitor.cpp | 105 void Monitor::timeout() function in class:Monitor
|
/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/solaris/classes/java/net/ |
H A D | PlainSocketImpl.java | 56 native void socketConnect(InetAddress address, int port, int timeout) argument
|
/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | ExecutorCompletionService.java | 200 public Future<V> poll(long timeout, TimeUnit unit) argument 202 return completionQueue.poll(timeout, unit);
|
/openjdk7/jdk/src/solaris/native/sun/nio/ch/ |
H A D | KQueue.c | 78 struct timespec timeout = {0, 0}; local 82 RESTARTABLE(kevent(kqfd, &changes[0], 1, NULL, 0, &timeout), res);
|
/openjdk7/jdk/src/share/transport/shmem/ |
H A D | sysShmem.h | 45 int sysEventWait(sys_process_t otherProcess, sys_event_t event, long 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)
|