/openjdk7/jdk/src/share/classes/com/sun/jmx/remote/internal/ |
H A D | ArrayNotificationBuffer.java | 223 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 D | ClientNotifForwarder.java | 123 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 D | DnsClient.java | 82 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 D | advancedThresholdPolicy.cpp | 109 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 D | Inet4AddressImpl.c | 591 * 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 D | Inet6AddressImpl.c | 448 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 D | PlainSocketImpl.c | 150 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 D | bsd_close.c | 331 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 D | linux_close.c | 313 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 D | socket_md.c | 62 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 D | PlainSocketImpl.java | 171 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 D | WindowsAsynchronousSocketChannelImpl.java | 546 // 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 D | Inet6AddressImpl.c | 354 * 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 D | BrokenConnectionTest.java | 696 public void setSoTimeout(int timeout) throws SocketException { argument 697 ss.setSoTimeout(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/transport/socket/ |
H A D | socketTransport.c | 139 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 D | DevPollArrayWrapper.java | 218 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 D | UnixAsynchronousSocketChannelImpl.java | 379 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 D | Poller.c | 631 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 D | HToolkit.java | 320 protected boolean syncNativeQueue(final long timeout) { argument
|
/openjdk7/jdk/src/share/classes/java/net/ |
H A D | AbstractPlainSocketImpl.java | 47 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 D | InetAddress.java | 415 * 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 D | Socket.java | 532 * 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 D | URLConnection.java | 366 * @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 D | ForkJoinTask.java | 301 * 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);
|