org.corfudb.protocols.wireprotocol

Class LogData

java.lang.Object

org.corfudb.protocols.wireprotocol.LogData

All Implemented Interfaces:

Comparable<ILogData>, ICorfuPayload<LogData>, ILogData, IMetadata

public class LogData
extends Object
implements ICorfuPayload<LogData>, IMetadata, ILogData

Created by mwei on 8/15/16.

Nested Class Summary

Nested classes/interfaces inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

ICorfuPayload.PayloadConstructor<T>

Nested classes/interfaces inherited from interface org.corfudb.protocols.wireprotocol.ILogData

ILogData.SerializationHandle

Nested classes/interfaces inherited from interface org.corfudb.protocols.wireprotocol.IMetadata

IMetadata.DataRank, IMetadata.LogUnitMetadataType

Field Summary

Fields

Modifier and Type	Field and Description
static LogData	EMPTY
static int	NOT_KNOWN

Fields inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

constructorMap, lookup

Fields inherited from interface org.corfudb.protocols.wireprotocol.IMetadata

metadataTypeMap

Constructor Summary

Constructors

Constructor and Description
LogData(io.netty.buffer.ByteBuf buf) Return the payload.
LogData(DataType type) Constructor for generating LogData.
LogData(DataType type, Object object) Constructor for generating LogData.

Method Summary

Modifier and Type	Method and Description
void	acquireBuffer()
byte[]	byteArrayFromBuf(io.netty.buffer.ByteBuf buf) Return a byte array from buffer.
void	checkMaxWriteSize(int limit) Verify that max payload is enforced for the specified limit.
void	doSerialize(io.netty.buffer.ByteBuf buf)
boolean	equals(Object o) LogData are considered equals if clientId and threadId are equal.
static LogData	getEmpty(long address)
static LogData	getHole(long address)
Object	getPayload(CorfuRuntime runtime) Return the payload.
int	getSizeEstimate() Get an estimate of how large this entry is in memory.
static LogData	getTrimmed(long address)
void	releaseBuffer()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

enumMapFromBuffer, fromBuffer, fromBuffer, listFromBuffer, mapFromBuffer, rangeFromBuffer, rangeSetFromBuffer, serialize, setFromBuffer

Methods inherited from interface org.corfudb.protocols.wireprotocol.ILogData

compareTo, getBackpointer, getLogEntry, getSerializedForm, getSerializedSize, getType, hasBackpointer, isEmpty, isFirstEntry, isHole, isLogEntry, isTrimmed, setId, useToken

Methods inherited from interface org.corfudb.protocols.wireprotocol.IMetadata

clearCommit, containsStream, getBackpointerMap, getCheckpointedStreamId, getCheckpointedStreamStartLogAddress, getCheckpointId, getCheckpointType, getClientId, getEpoch, getGlobalAddress, getMetadataMap, getRank, getStreams, getThreadId, getToken, hasCheckpointMetadata, setBackpointerMap, setCheckpointedStreamId, setCheckpointedStreamStartLogAddress, setCheckpointId, setCheckpointType, setClientId, setCommit, setEpoch, setGlobalAddress, setRank, setThreadId

Field Detail

EMPTY

public static final LogData EMPTY

NOT_KNOWN

public static final int NOT_KNOWN

See Also:

Constant Field Values

Constructor Detail

LogData

public LogData(io.netty.buffer.ByteBuf buf)

Return the payload.

LogData

public LogData(DataType type)

Constructor for generating LogData.

Parameters:

type - The type of log data to instantiate.

LogData

public LogData(DataType type,
               Object object)

Constructor for generating LogData.

Parameters:

type - The type of log data to instantiate.

object - The actual data/value

Method Detail

getTrimmed

public static LogData getTrimmed(long address)

getHole

public static LogData getHole(long address)

getEmpty

public static LogData getEmpty(long address)

getPayload

public Object getPayload(CorfuRuntime runtime)

Return the payload.

Specified by:

getPayload in interface ILogData

releaseBuffer

public void releaseBuffer()

Specified by:

releaseBuffer in interface ILogData

acquireBuffer

public void acquireBuffer()

Specified by:

acquireBuffer in interface ILogData

getSizeEstimate

public int getSizeEstimate()

Description copied from interface: ILogData

Get an estimate of how large this entry is in memory.

Specified by:

getSizeEstimate in interface ILogData

Returns:

An estimate on the size of this object, in bytes.

byteArrayFromBuf

public byte[] byteArrayFromBuf(io.netty.buffer.ByteBuf buf)

Return a byte array from buffer.

Parameters:

buf - The buffer to read from

doSerialize

public void doSerialize(io.netty.buffer.ByteBuf buf)

Specified by:

doSerialize in interface ICorfuPayload<LogData>

equals

public boolean equals(Object o)

LogData are considered equals if clientId and threadId are equal. Here, it means or both of them are null or both of them are the same.

Overrides:

equals in class Object

Parameters:

o -

Returns:

toString

public String toString()

Overrides:

toString in class Object

checkMaxWriteSize

public void checkMaxWriteSize(int limit)

Verify that max payload is enforced for the specified limit.

Parameters:

limit - Max write limit.