com.sleepycat.je.rep.stream

Class OutputWireRecord

java.lang.Object

com.sleepycat.je.rep.stream.WireRecord

com.sleepycat.je.rep.stream.OutputWireRecord

public class OutputWireRecord
extends WireRecord

Format for log entries sent across the wire for replication. In most cases, the bytes are read directly from the log and never need to be serialized into the backing object. Note that the ByteBuffer held within the OutputWireRecord has a limited lifetime. Often it's just sliced, rather than copied from the underlying buffer.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.nio.ByteBuffer	entryBuffer
protected EnvironmentImpl	envImpl

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

header

Constructor Summary

Constructors

Constructor and Description
OutputWireRecord(EnvironmentImpl envImpl, InputWireRecord input)
OutputWireRecord(EnvironmentImpl envImpl, LogEntryHeader header, java.nio.ByteBuffer readerBuffer) Make a OutputWireRecord from FileReader output for sending out.
OutputWireRecord(EnvironmentImpl envImpl, LogItem logItem) Creates an OutputWireRecord from a log item.

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	dump() Dump the contents.
long	getCommitTxnId()
byte	getEntryType()
long	getTimeStamp()
VLSN	getVLSN()
(package private) int	getWireSize() Support for reading and writing FeedRecords to network.
boolean	match(InputWireRecord input) Used at syncup, when comparing records received from the feeder against local records.
boolean	match(OutputWireRecord otherRecord) For unit tests.
java.lang.String	toString()
boolean	verifyNegativeSequences(java.lang.String debugTag)
(package private) void	writeToWire(java.nio.ByteBuffer messageBuffer)

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

Field Detail

entryBuffer

protected final java.nio.ByteBuffer entryBuffer

envImpl

protected final EnvironmentImpl envImpl

Constructor Detail

OutputWireRecord

OutputWireRecord(EnvironmentImpl envImpl,
                LogEntryHeader header,
                java.nio.ByteBuffer readerBuffer)

Make a OutputWireRecord from FileReader output for sending out.

OutputWireRecord

OutputWireRecord(EnvironmentImpl envImpl,
                LogItem logItem)

Creates an OutputWireRecord from a log item. This constructor is used when a Feeder can bypass access to the log because the log item is available in the log item cache associated with the VLSNIndex.

OutputWireRecord

OutputWireRecord(EnvironmentImpl envImpl,
                InputWireRecord input)

Method Detail

getEntryType

public byte getEntryType()

Returns:

the log entry type for this record.

match

public boolean match(InputWireRecord input)
              throws DatabaseException

Used at syncup, when comparing records received from the feeder against local records.

Returns:

true if this OutputWireRecord has the same logical contents as the InputWireRecord. The comparison will disregard portions of the logEntry that may be different, such at timestamps on a Commit entry. Must be called before the entryBuffer that backs this OutputWireRecord is reused.

Throws:

DatabaseException

match

public boolean match(OutputWireRecord otherRecord)
              throws DatabaseException

For unit tests.

Returns:

true if this OutputWireRecord has the same logical contents as "other".

Throws:

DatabaseException

getVLSN

public VLSN getVLSN()

dump

public java.lang.String dump()
                      throws DatabaseException

Dump the contents.

Throws:

DatabaseException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getWireSize

int getWireSize()

Support for reading and writing FeedRecords to network.

writeToWire

void writeToWire(java.nio.ByteBuffer messageBuffer)

getCommitTxnId

public long getCommitTxnId()
                    throws DatabaseException

Throws:

DatabaseException

getTimeStamp

public long getTimeStamp()
                  throws DatabaseException

Throws:

DatabaseException

verifyNegativeSequences

public boolean verifyNegativeSequences(java.lang.String debugTag)