Package org.apache.cassandra.locator

Class InetAddressAndPort.FwdFrmSerializer

java.lang.Object

org.apache.cassandra.locator.InetAddressAndPort.FwdFrmSerializer

All Implemented Interfaces:

IVersionedAsymmetricSerializer<InetAddressAndPort,InetAddressAndPort>, IVersionedSerializer<InetAddressAndPort>

Enclosing class:

InetAddressAndPort

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

Serializer for handling FWD_FRM message parameters. Pre-4.0 deserialization is a special case in the message

Field Summary

Fields

Modifier and Type	Field	Description
static InetAddressAndPort.FwdFrmSerializer	fwdFrmSerializer

Method Summary

Modifier and Type	Method	Description
InetAddressAndPort	deserialize(DataInputPlus in, int version)	Deserialize into the specified DataInputStream instance.
InetAddressAndPort	pre40DeserializeWithLength(DataInputPlus in, int version, int length)
void	serialize(InetAddressAndPort endpoint, DataOutputPlus out, int version)	Serialize the specified type into the specified DataOutputStream instance.
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

fwdFrmSerializer

public static final InetAddressAndPort.FwdFrmSerializer fwdFrmSerializer

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

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

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

pre40DeserializeWithLength

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

Throws:

java.io.IOException