Class SocketInitiator

java.lang.Object

com.neovisionaries.ws.client.SocketInitiator

public class SocketInitiator
extends Object

Lets multiple sockets race the given IP addresses until one has been established. This follows RFC 6555 (Happy Eyeballs).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	SocketInitiator.Signal	A wait signal will be awaited by a SocketInitiator.SocketRacer before it starts to connect.
private class	SocketInitiator.SocketFuture	The socket future is shared across all SocketInitiator.SocketRacer threads and aggregates the results.
private class	SocketInitiator.SocketRacer	This thread connects to a socket and notifies a SocketInitiator.SocketFuture shared across all racer threads when it is done.

Field Summary

Fields

Modifier and Type	Field	Description
private final Address	mAddress
private final int	mConnectTimeout
private final int	mFallbackDelay
private final DualStackMode	mMode
private final String[]	mServerNames
private final SocketFactory	mSocketFactory

Constructor Summary

Constructors

Constructor	Description
SocketInitiator(SocketFactory socketFactory, Address address, int connectTimeout, String[] serverNames, DualStackMode mode, int fallbackDelay)

Method Summary

Modifier and Type	Method	Description
Socket	establish(InetAddress[] addresses)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

mSocketFactory

private final SocketFactory mSocketFactory

mAddress

private final Address mAddress

mConnectTimeout

private final int mConnectTimeout

mServerNames

private final String[] mServerNames

mMode

private final DualStackMode mMode

mFallbackDelay

private final int mFallbackDelay

Constructor Details

SocketInitiator

public SocketInitiator(SocketFactory socketFactory,
 Address address,
 int connectTimeout,
 String[] serverNames,
 DualStackMode mode,
 int fallbackDelay)

Method Details

establish

public Socket establish(InetAddress[] addresses)
                 throws Exception

Throws:

Exception