Uses of Interface
com.bigdata.ha.msg.IHAWriteMessage

Packages that use IHAWriteMessage

Package	Description
com.bigdata.ha	This package extends com.bigdata.quorum to define local and Remote interfaces for highly available services.
com.bigdata.ha.althalog
com.bigdata.ha.halog
com.bigdata.ha.msg	Interfaces and implementations for HA message objects.
com.bigdata.io.writecache	Low-level write cache service.
com.bigdata.journal	The journal is an append-only persistence capable data structure supporting atomic commit, named indices, and transactions.
com.bigdata.rwstore

Uses of IHAWriteMessage in com.bigdata.ha

Methods in com.bigdata.ha with parameters of type IHAWriteMessage

Modifier and Type	Method and Description
protected abstract void	QuorumServiceBase.handleReplicatedWrite(IHASyncRequest req, IHAWriteMessage msg, ByteBuffer data) Core implementation handles the message and payload when received on a service.
protected abstract void	QuorumPipelineImpl.handleReplicatedWrite(IHASyncRequest req, IHAWriteMessage msg, ByteBuffer data) Core implementation handles the message and payload when received on a service.
protected abstract void	QuorumServiceBase.incReceive(IHASyncRequest req, IHAWriteMessage msg, int nreads, int rdlen, int rem) Core implementation of callback for monitoring progress of replicated writes.
protected abstract void	QuorumPipelineImpl.incReceive(IHASyncRequest req, IHAWriteMessage msg, int nreads, int rdlen, int rem) Notify that some payload bytes have been incrementally received for an IHAMessage.
void	QuorumServiceBase.logWriteCacheBlock(IHAWriteMessage msg, ByteBuffer data) Log the IHAWriteMessage and the associated data (if necessary).
void	QuorumPipeline.logWriteCacheBlock(IHAWriteMessage msg, ByteBuffer data) Log the IHAWriteMessage and the associated data (if necessary).
Future<Void>	QuorumServiceBase.receiveAndReplicate(IHASyncRequest req, IHASendState snd, IHAWriteMessage msg)
Future<Void>	QuorumPipelineImpl.receiveAndReplicate(IHASyncRequest req, IHASendState snd, IHAWriteMessage msg)
Future<Void>	HAPipelineGlue.receiveAndReplicate(IHASyncRequest req, IHASendState snd, IHAWriteMessage msg) Accept metadata describing an NIO buffer transfer along the write pipeline.
Future<Void>	QuorumPipeline.receiveAndReplicate(IHASyncRequest req, IHASendState snd, IHAWriteMessage msg) Return a Future for a task which will replicate an NIO buffer along the write pipeline.
Future<Void>	QuorumServiceBase.replicate(IHASyncRequest req, IHAWriteMessage msg, ByteBuffer b)
Future<Void>	QuorumPipelineImpl.replicate(IHASyncRequest req, IHAWriteMessage msg, ByteBuffer b)
Future<Void>	QuorumPipeline.replicate(IHASyncRequest req, IHAWriteMessage msg, ByteBuffer b) Return a Future for a task which will replicate an NIO buffer along the write pipeline.

Uses of IHAWriteMessage in com.bigdata.ha.althalog

Methods in com.bigdata.ha.althalog that return IHAWriteMessage

Modifier and Type	Method and Description
IHAWriteMessage	IHALogReader.processNextBuffer(ByteBuffer clientBuffer) Attempts to read the next IHAWriteMessage and then the expected buffer, that is read into the client buffer.

Methods in com.bigdata.ha.althalog with parameters of type IHAWriteMessage

Modifier and Type	Method and Description
void	IHALogWriter.write(IHAWriteMessage msg, ByteBuffer data) Writes the message to the file and the associated data if the backing store is not a WORM.
void	HALogFile.HALogWriter.write(IHAWriteMessage msg, ByteBuffer data)

Uses of IHAWriteMessage in com.bigdata.ha.halog

Methods in com.bigdata.ha.halog that return IHAWriteMessage

Modifier and Type	Method and Description
IHAWriteMessage	HALogReader.processNextBuffer(ByteBuffer clientBuffer)
IHAWriteMessage	IHALogReader.processNextBuffer(ByteBuffer clientBuffer) Attempts to read the next IHAWriteMessage and then the expected buffer, that is read into the client buffer.
static IHAWriteMessage	HALogReader.processNextBuffer(RandomAccessFile raf, IReopenChannel<FileChannel> reopener, StoreTypeEnum storeType, ByteBuffer clientBuffer)

Methods in com.bigdata.ha.halog with parameters of type IHAWriteMessage

Modifier and Type	Method and Description
void	HALogWriter.writeOnHALog(IHAWriteMessage msg, ByteBuffer data) Write the message and the data on the live HALog.
void	IHALogWriter.writeOnHALog(IHAWriteMessage msg, ByteBuffer data) Write the message and the data on the live HALog.

Uses of IHAWriteMessage in com.bigdata.ha.msg

Classes in com.bigdata.ha.msg that implement IHAWriteMessage

Modifier and Type	Class and Description
class	HAWriteMessage A message carrying RMI metadata about a payload which will be replicated using a socket-level transfer facility.

Uses of IHAWriteMessage in com.bigdata.io.writecache

Methods in com.bigdata.io.writecache that return IHAWriteMessage

Modifier and Type	Method and Description
IHAWriteMessage	WriteCache.HAPackage.getMessage()

Uses of IHAWriteMessage in com.bigdata.journal

Methods in com.bigdata.journal with parameters of type IHAWriteMessage

Modifier and Type	Method and Description
Future<Void>	AbstractJournal.BasicHA.receiveAndReplicate(IHASyncRequest req, IHASendState snd, IHAWriteMessage msg)
Future<Void>	WORMStrategy.sendHALogBuffer(IHALogRequest req, IHAWriteMessage msg, IBufferAccess b)
Future<Void>	IHABufferStrategy.sendHALogBuffer(IHALogRequest req, IHAWriteMessage msg, IBufferAccess b) Send an IHAWriteMessage and the associated raw buffer through the write pipeline.
Future<Void>	RWStrategy.sendHALogBuffer(IHALogRequest req, IHAWriteMessage msg, IBufferAccess b)
void	WORMStrategy.writeRawBuffer(HARebuildRequest req, IHAWriteMessage msg, ByteBuffer transfer)
void	IHABufferStrategy.writeRawBuffer(HARebuildRequest req, IHAWriteMessage msg, ByteBuffer transfer) Used to support the rebuild protocol
void	RWStrategy.writeRawBuffer(HARebuildRequest req, IHAWriteMessage msg, ByteBuffer transfer)
void	WORMStrategy.writeRawBuffer(IHAWriteMessage msg, IBufferAccess b)
void	IHABufferStrategy.writeRawBuffer(IHAWriteMessage msg, IBufferAccess b) Write a buffer containing data replicated from the master onto the local persistence store.
void	RWStrategy.writeRawBuffer(IHAWriteMessage msg, IBufferAccess b)

Uses of IHAWriteMessage in com.bigdata.rwstore

Methods in com.bigdata.rwstore with parameters of type IHAWriteMessage

Modifier and Type	Method and Description
Future<Void>	RWStore.sendHALogBuffer(IHALogRequest req, IHAWriteMessage msg, IBufferAccess buf)
void	RWStore.writeRawBuffer(IHAWriteMessage msg, IBufferAccess b)