org.corfudb.protocols.wireprotocol

Class CorfuMsg

java.lang.Object

org.corfudb.protocols.wireprotocol.CorfuMsg

Direct Known Subclasses:

CorfuPayloadMsg, JSONPayloadMsg, LayoutMsg

public class CorfuMsg
extends Object

Created by mwei on 9/15/15.

Constructor Summary

Constructors

Constructor and Description
CorfuMsg(CorfuMsgType type) Constructor which generates a message based only the message type.

Method Summary

Modifier and Type	Method and Description
void	copyBaseFields(CorfuMsg msg) Copy the base fields over to this message.
static CorfuMsg	deserialize(io.netty.buffer.ByteBuf buffer) Take the given bytebuffer and deserialize it into a message.
void	fromBuffer(io.netty.buffer.ByteBuf buffer) Parse the rest of the message from the buffer.
void	release() Release the underlying buffer, if present.
void	serialize(io.netty.buffer.ByteBuf buffer) Serialize the message into the given bytebuffer.

Methods inherited from class java.lang.Object

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

Constructor Detail

CorfuMsg

public CorfuMsg(CorfuMsgType type)

Constructor which generates a message based only the message type. Typically used for generating error messages, since sendmessage will populate the rest of the fields.

Parameters:

type - The type of message to send.

Method Detail

deserialize

public static CorfuMsg deserialize(io.netty.buffer.ByteBuf buffer)

Take the given bytebuffer and deserialize it into a message.

Parameters:

buffer - The buffer to deserialize.

Returns:

The corresponding message.

serialize

public void serialize(io.netty.buffer.ByteBuf buffer)

Serialize the message into the given bytebuffer.

Parameters:

buffer - The buffer to serialize to.

fromBuffer

public void fromBuffer(io.netty.buffer.ByteBuf buffer)

Parse the rest of the message from the buffer. Classes that extend CorfuMsg should parse their fields in this method.

copyBaseFields

public void copyBaseFields(CorfuMsg msg)

Copy the base fields over to this message.

release

public void release()

Release the underlying buffer, if present.