Searched refs:timeout (Results 76 - 100 of 271) sorted by relevance

1234567891011

/openjdk7/jdk/src/share/classes/sun/rmi/transport/proxy/
H A DWrappedSocket.java162 * 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 DsysSocket.h40 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 DPollSelectorImpl.java65 protected int doSelect(long timeout) argument
73 pollWrapper.poll(totalChannels, 0, timeout);
/openjdk7/jdk/src/share/classes/sun/nio/ch/
H A DAsynchronousSocketChannelImpl.java70 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 DMediaTracker.java426 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 DCache.java109 * 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 DConnections.java128 * @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 DDualStackPlainSocketImpl.java70 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 DProcessAttachingConnector.java52 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 DGenericListeningConnector.java46 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 DKQueueArrayWrapper.java198 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 DMonitorEventTest.java46 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 DAdaptDatagramSocket.java91 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 DAdaptServerSocket.java78 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 DCounterMonitorTest.java62 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 DAsynchronousChannelGroup.java328 * <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 DKQueueArrayWrapper.c130 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 DMonitor.cpp105 void Monitor::timeout() function in class:Monitor
/openjdk7/jdk/src/share/native/com/sun/tools/jdi/
H A DSharedMemoryTransport.c80 (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 DPlainSocketImpl.java56 native void socketConnect(InetAddress address, int port, int timeout) argument
/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DExecutorCompletionService.java200 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 DKQueue.c78 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 DsysShmem.h45 int sysEventWait(sys_process_t otherProcess, sys_event_t event, long timeout);
/openjdk7/hotspot/src/os/bsd/vm/
H A Dos_bsd.inline.hpp213 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 Dos_linux.inline.hpp217 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)

Completed in 106 milliseconds

1234567891011