com.sleepycat.je.rep.stream

Class InputWireRecord

java.lang.Object

com.sleepycat.je.rep.stream.WireRecord

com.sleepycat.je.rep.stream.InputWireRecord

public class InputWireRecord
extends WireRecord

Format for messages received at across the wire for replication. Instead of sending a direct copy of the log entry as it is stored on the JE log files (LogEntryHeader + LogEntry), select parts of the header are sent. An InputWireRecord de-serializes the logEntry from the message bytes and releases any claim on the backing ByteBuffer.

Field Summary

Fields inherited from class com.sleepycat.je.rep.stream.WireRecord

header

Constructor Summary

Constructors

Constructor and Description
InputWireRecord(EnvironmentImpl envImpl, java.nio.ByteBuffer msgBuffer) Make a InputWireRecord from an incoming replication message buffer for applying at a replica.
InputWireRecord(EnvironmentImpl envImpl, byte entryType, int entryVersion, int itemSize, VLSN vlsn, java.nio.ByteBuffer entryBuffer) Unit test support.

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	dumpLogEntry() Convert the full version of the log entry to a string.
byte	getEntryType()
LogEntry	getLogEntry()
VLSN	getVLSN()
java.lang.String	toString()

Methods inherited from class com.sleepycat.je.rep.stream.WireRecord

instantiateEntry

Methods inherited from class java.lang.Object

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

Constructor Detail

InputWireRecord

InputWireRecord(EnvironmentImpl envImpl,
               java.nio.ByteBuffer msgBuffer)
          throws DatabaseException

Make a InputWireRecord from an incoming replication message buffer for applying at a replica.

Throws:

DatabaseException

InputWireRecord

InputWireRecord(EnvironmentImpl envImpl,
               byte entryType,
               int entryVersion,
               int itemSize,
               VLSN vlsn,
               java.nio.ByteBuffer entryBuffer)
          throws DatabaseException

Unit test support.

Throws:

DatabaseException

Method Detail

getVLSN

public VLSN getVLSN()

getEntryType

public byte getEntryType()

getLogEntry

public LogEntry getLogEntry()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

dumpLogEntry

public java.lang.String dumpLogEntry()

Convert the full version of the log entry to a string.