Package org.apache.cassandra.locator

Class InetAddressAndPort.Serializer

java.lang.Object

org.apache.cassandra.locator.InetAddressAndPort.Serializer

All Implemented Interfaces:

IVersionedAsymmetricSerializer<InetAddressAndPort,InetAddressAndPort>, IVersionedSerializer<InetAddressAndPort>

Enclosing class:

InetAddressAndPort

public static final class InetAddressAndPort.Serializer
extends java.lang.Object
implements IVersionedSerializer<InetAddressAndPort>

As of version 4.0 the endpoint description includes a port number as an unsigned short This serializer matches the 3.0 CompactEndpointSerializationHelper, encoding the number of address bytes in a single byte before the address itself.

Field Summary

Fields

Modifier and Type	Field	Description
static InetAddressAndPort.Serializer	inetAddressAndPortSerializer
static int	MAXIMUM_SIZE

Method Summary

Modifier and Type	Method	Description
InetAddressAndPort	deserialize(DataInputPlus in, int version)	Deserialize into the specified DataInputStream instance.
InetAddressAndPort	extract(java.nio.ByteBuffer buf, int position)	Extract InetAddressAndPort from the provided ByteBuffer without altering its state.
void	serialize(java.net.InetSocketAddress endpoint, DataOutputPlus out, int version)
void	serialize(InetAddressAndPort endpoint, DataOutputPlus out, int version)	Serialize the specified type into the specified DataOutputStream instance.
long	serializedSize(java.net.InetSocketAddress from, int version)
long	serializedSize(InetAddressAndPort from, int version)	Calculate serialized size of object without actually serializing.

Methods inherited from class java.lang.Object

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

Field Detail

MAXIMUM_SIZE

public static final int MAXIMUM_SIZE

See Also:

Constant Field Values

inetAddressAndPortSerializer

public static final InetAddressAndPort.Serializer inetAddressAndPortSerializer

Method Detail

serialize

public void serialize(InetAddressAndPort endpoint,
                      DataOutputPlus out,
                      int version)
               throws java.io.IOException

Description copied from interface: IVersionedAsymmetricSerializer

Serialize the specified type into the specified DataOutputStream instance.

Specified by:

serialize in interface IVersionedAsymmetricSerializer<InetAddressAndPort,InetAddressAndPort>

Parameters:

endpoint - type that needs to be serialized

out - DataOutput into which serialization needs to happen.

version - protocol version

Throws:

java.io.IOException - if serialization fails

serialize

public void serialize(java.net.InetSocketAddress endpoint,
                      DataOutputPlus out,
                      int version)
               throws java.io.IOException

Throws:

java.io.IOException

deserialize

public InetAddressAndPort deserialize(DataInputPlus in,
                                      int version)
                               throws java.io.IOException

Description copied from interface: IVersionedAsymmetricSerializer

Deserialize into the specified DataInputStream instance.

Specified by:

deserialize in interface IVersionedAsymmetricSerializer<InetAddressAndPort,InetAddressAndPort>

Parameters:

in - DataInput from which deserialization needs to happen.

version - protocol version

Returns:

the type that was deserialized

Throws:

java.io.IOException - if deserialization fails

extract

public InetAddressAndPort extract(java.nio.ByteBuffer buf,
                                  int position)
                           throws java.io.IOException

Extract InetAddressAndPort from the provided ByteBuffer without altering its state.

Throws:

java.io.IOException

serializedSize

public long serializedSize(InetAddressAndPort from,
                           int version)

Description copied from interface: IVersionedAsymmetricSerializer

Calculate serialized size of object without actually serializing.

Specified by:

serializedSize in interface IVersionedAsymmetricSerializer<InetAddressAndPort,InetAddressAndPort>

Parameters:

from - object to calculate serialized size

version - protocol version

Returns:

serialized size of object t

serializedSize

public long serializedSize(java.net.InetSocketAddress from,
                           int version)