Searched defs:timeout (Results 151 - 175 of 227) sorted by relevance

12345678910

/openjdk7/jdk/src/share/classes/com/sun/jmx/remote/internal/
H A DArrayNotificationBuffer.java223 long timeout,
228 timeout, maxNotifications);
277 * no longer than <code>timeout</code>, and will return no more
282 * timeout.</p>
289 * @param timeout the maximum time to wait. May be 0 to indicate
302 long timeout,
318 || startSequenceNumber < 0 || timeout < 0
327 startSequenceNumber + "; timeout=" + timeout +
338 /* Determine the end time corresponding to the timeout valu
221 fetchNotifications(NotificationBufferFilter filter, long startSequenceNumber, long timeout, int maxNotifications) argument
300 fetchNotifications(NotificationBufferFilter filter, long startSequenceNumber, long timeout, int maxNotifications) argument
[all...]
H A DClientNotifForwarder.java123 timeout = EnvHelp.getFetchTimeout(env);
146 long timeout)
589 timeout);
619 timeout. This allows us to skip sequence numbers for
865 private final long timeout; field in class:ClientNotifForwarder
144 fetchNotifs(long clientSequenceNumber, int maxNotifications, long timeout) argument
/openjdk7/jdk/src/share/classes/com/sun/jndi/dns/
H A DDnsClient.java82 private int timeout; // initial timeout on UDP queries in ms field in class:DnsClient
98 * "timeout" is the initial timeout interval (in ms) for UDP queries,
101 public DnsClient(String[] servers, int timeout, int retries) argument
103 this.timeout = timeout;
185 // each server in order. If no answer, double the timeout
207 // given timeout, check if the response was enqueued
299 // A network timeout o
[all...]
/openjdk7/hotspot/src/share/vm/runtime/
H A DadvancedThresholdPolicy.cpp109 bool AdvancedThresholdPolicy::is_stale(jlong t, jlong timeout, methodOop m) { argument
112 if (delta_t > timeout && delta_s > timeout) {
/openjdk7/jdk/src/solaris/native/java/net/
H A DInet4AddressImpl.c591 * Send a ICMP_ECHO_REQUEST packet every second until either the timeout
596 ping4(JNIEnv *env, jint fd, struct sockaddr_in* him, jint timeout, argument
670 tmout2 = timeout > 1000 ? 1000 : timeout;
699 timeout -= 1000;
700 } while (timeout >0);
713 jint timeout,
769 return ping4(env, fd, &him, timeout, netif, ttl);
842 timeout = NET_Wait(env, fd, NET_WAIT_CONNECT, timeout);
711 Java_java_net_Inet4AddressImpl_isReachable0(JNIEnv *env, jobject this, jbyteArray addrArray, jint timeout, jbyteArray ifArray, jint ttl) argument
[all...]
H A DInet6AddressImpl.c448 ping6(JNIEnv *env, jint fd, struct sockaddr_in6* him, jint timeout, argument
520 tmout2 = timeout > 1000 ? 1000 : timeout;
547 timeout -= 1000;
548 } while (timeout > 0);
563 jint timeout,
589 timeout,
632 return ping6(env, fd, &him6, timeout, netif, ttl);
699 timeout = NET_Wait(env, fd, NET_WAIT_CONNECT, timeout);
560 Java_java_net_Inet6AddressImpl_isReachable0(JNIEnv *env, jobject this, jbyteArray addrArray, jint scope, jint timeout, jbyteArray ifArray, jint ttl, jint if_scope) argument
[all...]
H A DPlainSocketImpl.c150 psi_timeoutID = (*env)->GetFieldID(env, cls, "timeout", "I");
257 jint timeout)
300 if (timeout <= 0) {
358 * A timeout was specified. We put the socket into non-blocking
360 * established, fail, or timeout.
381 * timeout occurs. poll/select needs to handle EINTR in
394 connect_rv = NET_Poll(&pfd, 1, timeout);
401 t.tv_sec = timeout / 1000;
402 t.tv_usec = (timeout % 1000) * 1000;
422 * The poll was interrupted so adjust timeout an
255 Java_java_net_PlainSocketImpl_socketConnect(JNIEnv *env, jobject this, jobject iaObj, jint port, jint timeout) argument
655 jint timeout = (*env)->GetIntField(env, this, psi_timeoutID); local
[all...]
H A Dbsd_close.c331 int NET_Poll(struct pollfd *ufds, unsigned int nfds, int timeout) { argument
332 BLOCKING_IO_RETURN_INT( ufds[0].fd, poll(ufds, nfds, timeout) );
336 fd_set *exceptfds, struct timeval *timeout) {
338 select(s, readfds, writefds, exceptfds, timeout) );
343 * Wrapper for select(s, timeout). We are using select() on Mac OS due to Bug 7131399.
344 * Auto restarts with adjusted timeout if interrupted by
347 int NET_Timeout(int s, long timeout) { argument
361 * Pick up current time as may need to adjust timeout
363 if (timeout > 0) {
368 t.tv_sec = timeout / 100
335 NET_Select(int s, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout) argument
[all...]
H A Dlinux_close.c313 int NET_Poll(struct pollfd *ufds, unsigned int nfds, int timeout) { argument
314 BLOCKING_IO_RETURN_INT( ufds[0].fd, poll(ufds, nfds, timeout) );
318 fd_set *exceptfds, struct timeval *timeout) {
320 select(s, readfds, writefds, exceptfds, timeout) );
325 * Wrapper for poll(s, timeout).
326 * Auto restarts with adjusted timeout if interrupted by
329 int NET_Timeout(int s, long timeout) { argument
343 * Pick up current time as may need to adjust timeout
345 if (timeout > 0) {
363 rv = poll(&pfd, 1, timeout);
317 NET_Select(int s, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout) argument
[all...]
/openjdk7/jdk/src/solaris/transport/socket/
H A Dsocket_md.c62 dbgsysFinishConnect(int fd, long timeout) { argument
63 int rv = dbgsysPoll(fd, 0, 1, timeout);
245 dbgsysPoll(int fd, jboolean rd, jboolean wr, long timeout) { argument
259 rv = poll(&fds[0], 1, timeout);
/openjdk7/jdk/src/windows/classes/java/net/
H A DPlainSocketImpl.java171 protected void connect(SocketAddress address, int timeout) throws IOException { argument
172 impl.connect(address, timeout);
183 synchronized void doConnect(InetAddress address, int port, int timeout) throws IOException { argument
184 impl.doConnect(address, port, timeout);
300 void socketConnect(InetAddress address, int port, int timeout) argument
302 impl.socketConnect(address, port, timeout);
/openjdk7/jdk/src/windows/classes/sun/nio/ch/
H A DWindowsAsynchronousSocketChannelImpl.java546 // release waiters if not already released by timeout
569 // release waiters if not already released by timeout
583 * Invoked if timeout expires before it is cancelled
585 void timeout() { method in class:WindowsAsynchronousSocketChannelImpl.ReadTask
605 long timeout,
623 // schedule timeout
624 if (timeout > 0L) {
627 readTask.timeout();
629 }, timeout, unit);
803 // release waiters if not already released by timeout
602 implRead(boolean isScatteringRead, ByteBuffer dst, ByteBuffer[] dsts, long timeout, TimeUnit unit, A attachment, CompletionHandler<V,? super A> handler) argument
842 void timeout() { method in class:WindowsAsynchronousSocketChannelImpl.WriteTask
859 implWrite(boolean gatheringWrite, ByteBuffer src, ByteBuffer[] srcs, long timeout, TimeUnit unit, A attachment, CompletionHandler<V,? super A> handler) argument
[all...]
/openjdk7/jdk/src/windows/native/java/net/
H A DInet6AddressImpl.c354 * Send a ICMP_ECHO_REQUEST packet every second until either the timeout
359 ping6(JNIEnv *env, jint fd, struct SOCKADDR_IN6* him, jint timeout, argument
410 * or the timeout expired.
459 tmout2 = timeout > 1000 ? 1000 : timeout;
486 timeout -= 1000;
488 } while (timeout > 0);
504 jint timeout,
532 timeout,
583 return ping6(env, fd, &him6, timeout, neti
501 Java_java_net_Inet6AddressImpl_isReachable0(JNIEnv *env, jobject this, jbyteArray addrArray, jint scope, jint timeout, jbyteArray ifArray, jint ttl, jint if_scope) argument
[all...]
/openjdk7/jdk/test/javax/management/remote/mandatory/connection/
H A DBrokenConnectionTest.java696 public void setSoTimeout(int timeout) throws SocketException { argument
697 ss.setSoTimeout(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/transport/socket/
H A DsocketTransport.c139 handshake(int fd, jlong timeout) { argument
144 if (timeout > 0) {
152 if (timeout > 0) {
153 rv = dbgsysPoll(fd, JNI_TRUE, JNI_FALSE, (long)timeout);
155 setLastError(0, "timeout during handshake");
171 if (timeout > 0) {
332 * Use a default handshake timeout if not specified - this avoids an indefinite
341 * If there is an accept timeout then we put the socket in non-blocking
379 * is a handshake timeout set then it will go into non-blocking mode
394 * timeout the
[all...]
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/
H A DDevPollArrayWrapper.java218 int poll(long timeout) throws IOException { argument
220 updated = poll0(pollArrayAddress, NUM_POLLFDS, timeout, wfd);
316 private native int poll0(long pollAddress, int numfds, long timeout, argument
H A DUnixAsynchronousSocketChannelImpl.java379 Future<?> timeout = readTimer;
418 if (timeout != null)
419 timeout.cancel(false);
474 long timeout,
528 if (timeout > 0L) {
529 this.readTimer = port.schedule(readTimeoutTask, timeout, unit);
669 long timeout,
711 if (timeout > 0L) {
712 this.writeTimer = port.schedule(writeTimeoutTask, timeout, unit);
471 implRead(boolean isScatteringRead, ByteBuffer dst, ByteBuffer[] dsts, long timeout, TimeUnit unit, A attachment, CompletionHandler<V,? super A> handler) argument
666 implWrite(boolean isGatheringWrite, ByteBuffer src, ByteBuffer[] srcs, long timeout, TimeUnit unit, A attachment, CompletionHandler<V,? super A> handler) argument
/openjdk7/jdk/src/solaris/demo/jni/Poller/
H A DPoller.c631 jintArray jfds, jshortArray jrevents, jlong timeout)
647 useEvents = poll(NULL,0L,timeout);
658 dopoll.dp_timeout = timeout;
700 useEvents = poll(ioeh->pfd,ioeh->last_index, timeout);
702 useEvents = poll(ioeh->pfd,ioeh->last_index, timeout);
621 Java_Poller_nativeWait(JNIEnv *env, jobject obj, jint handle, jint maxEvents, jintArray jfds, jshortArray jrevents, jlong timeout) argument
/openjdk7/jdk/src/share/classes/sun/awt/
H A DHToolkit.java320 protected boolean syncNativeQueue(final long timeout) { argument
/openjdk7/jdk/src/share/classes/java/net/
H A DAbstractPlainSocketImpl.java47 int timeout; // timeout in millisec field in class:AbstractPlainSocketImpl
126 connectToAddress(address, port, timeout);
151 connectToAddress(address, port, timeout);
164 * @param timeout the timeout value in milliseconds, or zero for no timeout.
170 protected void connect(SocketAddress address, int timeout) argument
182 connectToAddress(this.address, port, timeout);
196 private void connectToAddress(InetAddress address, int port, int timeout) throw argument
330 doConnect(InetAddress address, int port, int timeout) argument
692 socketConnect(InetAddress address, int port, int timeout) argument
[all...]
H A DInetAddress.java415 * The timeout value, in milliseconds, indicates the maximum amount of time
420 * @param timeout the time, in milliseconds, before the call aborts
423 * @throws IllegalArgumentException if <code>timeout</code> is negative.
426 public boolean isReachable(int timeout) throws IOException { argument
427 return isReachable(null, 0 , timeout);
445 * The timeout value, in milliseconds, indicates the maximum amount of time
454 * @param timeout the time, in milliseconds, before the call aborts
455 * @throws IllegalArgumentException if either <code>timeout</code>
462 int timeout) throws IOException {
465 if (timeout <
461 isReachable(NetworkInterface netif, int ttl, int timeout) argument
[all...]
H A DSocket.java532 * Connects this socket to the server with a specified timeout value.
533 * A timeout of zero is interpreted as an infinite timeout. The connection
537 * @param timeout the timeout value to be used in milliseconds.
539 * @throws SocketTimeoutException if timeout expires before connecting
548 public void connect(SocketAddress endpoint, int timeout) throws IOException { argument
552 if (timeout < 0)
553 throw new IllegalArgumentException("connect: timeout can't be negative");
579 impl.connect(epoint, timeout);
1095 setSoTimeout(int timeout) argument
[all...]
H A DURLConnection.java366 * @throws SocketTimeoutException if the timeout expires before
377 * Sets a specified timeout value, in milliseconds, to be used
379 * by this URLConnection. If the timeout expires before the
381 * java.net.SocketTimeoutException is raised. A timeout of zero is
382 * interpreted as an infinite timeout.
385 * the specified timeout. To see the connect timeout set, please
388 * @param timeout an <code>int</code> that specifies the connect
389 * timeout value in milliseconds
390 * @throws IllegalArgumentException if the timeout paramete
396 setConnectTimeout(int timeout) argument
439 setReadTimeout(int timeout) argument
[all...]
/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DForkJoinTask.java301 * Blocks a non-worker-thread until completion or interruption or timeout.
950 * @param timeout the maximum time to wait
951 * @param unit the time unit of the timeout argument
960 public final V get(long timeout, TimeUnit unit) argument
965 long nanos = unit.toNanos(timeout);
982 long millis = unit.toMillis(timeout);

Completed in 80 milliseconds

12345678910