Package org.apache.cassandra.locator

Class InetAddressAndPort

java.lang.Object

java.net.SocketAddress

java.net.InetSocketAddress

org.apache.cassandra.locator.InetAddressAndPort

All Implemented Interfaces:

Serializable, Comparable<InetAddressAndPort>

public final class InetAddressAndPort
extends InetSocketAddress
implements Comparable<InetAddressAndPort>, Serializable

A class to replace the usage of InetAddress to identify hosts in the cluster. Opting for a full replacement class so that in the future if we change the nature of the identifier the refactor will be easier in that we don't have to change the type just the methods. Because an IP might contain multiple C* instances the identification must be done using the IP + port. InetSocketAddress is undesirable for a couple of reasons. It's not comparable, it's toString() method doesn't correctly bracket IPv6, it doesn't handle optional default values, and a couple of other minor behaviors that are slightly less troublesome like handling the need to sometimes return a port and sometimes not.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	InetAddressAndPort.FwdFrmSerializer	Serializer for handling FWD_FRM message parameters.
static final class	InetAddressAndPort.Serializer	As of version 4.0 the endpoint description includes a port number as an unsigned short

Field Summary

Fields

Modifier and Type	Field	Description
final byte[]	addressBytes

Method Summary

Modifier and Type	Method	Description
int	compareTo(InetAddressAndPort o)
static List<InetAddressAndPort>	getAllByName(String name)
static List<InetAddressAndPort>	getAllByNameOverrideDefaults(String name, Integer port)
static InetAddressAndPort	getByAddress(byte[] address)
static InetAddressAndPort	getByAddress(InetAddress address)
static InetAddressAndPort	getByAddress(InetSocketAddress address)
static InetAddressAndPort	getByAddressOverrideDefaults(InetAddress address, byte[] addressBytes, Integer port)
static InetAddressAndPort	getByAddressOverrideDefaults(InetAddress address, Integer port)
static InetAddressAndPort	getByName(String name)
static InetAddressAndPort	getByNameOverrideDefaults(String name, Integer port)
String	getHostAddress(boolean withPort)
String	getHostAddressAndPort()
String	getHostAddressAndPortForJMX()	Return a version of getHostAddressAndPort suitable for use in JMX object names without requiring any escaping.
String	getHostName(boolean withPort)
static InetAddressAndPort	getLocalHost()
static InetAddressAndPort	getLoopbackAddress()
static String	hostAddress(InetSocketAddress address, boolean withPort)
static String	hostAddressAndPort(InetSocketAddress address)
static void	initializeDefaultPort(int port)
static Set<InetAddressAndPort>	parseHosts(String value, boolean failOnError)	Parses a comma-separated list of hosts to a set of InetAddressAndPort
static List<String>	stringify(Iterable<InetAddressAndPort> endpoints)
static List<String>	stringify(Iterable<InetAddressAndPort> endpoints, boolean withPort)
String	toString()
String	toString(boolean withPort)
static String	toString(InetAddress address, int port)	Format an InetAddressAndPort in the same style as InetAddress.toString.
static String	toString(InetSocketAddress address)
static String	toString(InetSocketAddress address, boolean withPort)
InetAddressAndPort	withPort(int port)

Methods inherited from class java.net.InetSocketAddress

createUnresolved, equals, getAddress, getHostName, getHostString, getPort, hashCode, isUnresolved

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

addressBytes

public final byte[] addressBytes

Method Details

withPort

public InetAddressAndPort withPort(int port)

compareTo

public int compareTo(InetAddressAndPort o)

Specified by:

compareTo in interface Comparable<InetAddressAndPort>

getHostAddressAndPort

public String getHostAddressAndPort()

getHostAddressAndPortForJMX

public String getHostAddressAndPortForJMX()

Return a version of getHostAddressAndPort suitable for use in JMX object names without requiring any escaping. Replaces each character invalid for JMX names with an underscore.

Returns:

String with JMX-safe representation of the IP address and port

getHostAddress

public String getHostAddress(boolean withPort)

getHostName

public String getHostName(boolean withPort)

hostAddressAndPort

public static String hostAddressAndPort(InetSocketAddress address)

hostAddress

public static String hostAddress(InetSocketAddress address,
 boolean withPort)

toString

public String toString()

Overrides:

toString in class InetSocketAddress

toString

public String toString(boolean withPort)

toString

public static String toString(InetSocketAddress address)

toString

public static String toString(InetSocketAddress address,
 boolean withPort)

toString

public static String toString(InetAddress address,
 int port)

Format an InetAddressAndPort in the same style as InetAddress.toString. The string returned is of the form: hostname / literal IP address : port (without the whitespace). Literal IPv6 addresses will be wrapped with [ ] to make the port number clear. If the host name is unresolved, no reverse name service lookup is performed. The hostname part will be represented by an empty string.

Parameters:

address - InetAddress to convert String

port - Port number to convert to String

Returns:

String representation of the IP address and port

getByName

public static InetAddressAndPort getByName(String name)
                                    throws UnknownHostException

Throws:

UnknownHostException

getAllByName

public static List<InetAddressAndPort> getAllByName(String name)
                                             throws UnknownHostException

Throws:

UnknownHostException

getAllByNameOverrideDefaults

public static List<InetAddressAndPort> getAllByNameOverrideDefaults(String name,
 Integer port)
                                                             throws UnknownHostException

Parameters:

name - Hostname + optional ports string

port - Port to connect on, overridden by values in hostname string, defaults to DatabaseDescriptor default if not specified anywhere.

Throws:

UnknownHostException

getByNameOverrideDefaults

public static InetAddressAndPort getByNameOverrideDefaults(String name,
 Integer port)
                                                    throws UnknownHostException

Parameters:

name - Hostname + optional ports string

port - Port to connect on, overridden by values in hostname string, defaults to DatabaseDescriptor default if not specified anywhere.

Throws:

UnknownHostException

getByAddress

public static InetAddressAndPort getByAddress(byte[] address)
                                       throws UnknownHostException

Throws:

UnknownHostException

getByAddress

public static InetAddressAndPort getByAddress(InetAddress address)

getByAddress

public static InetAddressAndPort getByAddress(InetSocketAddress address)

getByAddressOverrideDefaults

public static InetAddressAndPort getByAddressOverrideDefaults(InetAddress address,
 Integer port)

getByAddressOverrideDefaults

public static InetAddressAndPort getByAddressOverrideDefaults(InetAddress address,
 byte[] addressBytes,
 Integer port)

getLoopbackAddress

public static InetAddressAndPort getLoopbackAddress()

getLocalHost

public static InetAddressAndPort getLocalHost()

initializeDefaultPort

public static void initializeDefaultPort(int port)

stringify

public static List<String> stringify(Iterable<InetAddressAndPort> endpoints)

stringify

public static List<String> stringify(Iterable<InetAddressAndPort> endpoints,
 boolean withPort)

parseHosts

public static Set<InetAddressAndPort> parseHosts(String value,
 boolean failOnError)

Parses a comma-separated list of hosts to a set of InetAddressAndPort

Parameters:

value - the comma-separated list of hosts to parse

failOnError - whether to fail when encountering an invalid hostname

Returns:

the set of parsed InetAddressAndPort