org.corfudb.protocols.logprotocol

Class LogEntry

java.lang.Object

org.corfudb.protocols.logprotocol.LogEntry

All Implemented Interfaces:

ICorfuSerializable

Direct Known Subclasses:

CheckpointEntry, MultiObjectSMREntry, MultiSMREntry, SMREntry

public class LogEntry
extends Object
implements ICorfuSerializable

Created by mwei on 1/8/16.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LogEntry.LogEntryType

Field Summary

Fields

Modifier and Type	Field and Description
protected CorfuRuntime	runtime The runtime to use.

Constructor Summary

Constructors

Constructor and Description
LogEntry(LogEntry.LogEntryType type) Constructor for generating LogEntries.

Method Summary

Modifier and Type	Method and Description
static ICorfuSerializable	deserialize(io.netty.buffer.ByteBuf b, CorfuRuntime rt) The base LogEntry format is very simple.
boolean	isMutation(UUID stream) Returns whether the entry changes the contents of the stream.
void	serialize(io.netty.buffer.ByteBuf b) Serialize the given LogEntry into a given byte buffer.

Methods inherited from class java.lang.Object

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

Field Detail

runtime

protected CorfuRuntime runtime

The runtime to use.

Constructor Detail

LogEntry

public LogEntry(LogEntry.LogEntryType type)

Constructor for generating LogEntries.

Parameters:

type - The type of log entry to instantiate.

Method Detail

deserialize

public static ICorfuSerializable deserialize(io.netty.buffer.ByteBuf b,
                                             CorfuRuntime rt)

The base LogEntry format is very simple. The first byte represents the type of entry, and the rest of the format is dependent on the the entry type.

Parameters:

b - The buffer to deserialize.

Returns:

A LogEntry.

serialize

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

Serialize the given LogEntry into a given byte buffer.

Specified by:

serialize in interface ICorfuSerializable

Parameters:

b - The buffer to serialize into.

isMutation

public boolean isMutation(UUID stream)

Returns whether the entry changes the contents of the stream. For example, an aborted transaction does not change the content of the stream.

Returns:

True, if the entry changes the contents of the stream, False otherwise.