com.bigdata.journal
Interface IHABufferStrategy

All Superinterfaces:

IAddressManager, IBufferStrategy, ICounterSetAccess, IMRMW, IMROW, IRawStore

All Known Implementing Classes:

RWStrategy, WORMStrategy

public interface IHABufferStrategy
extends IBufferStrategy

A highly available IBufferStrategy.

Version:

$Id: IHABufferStrategy.java 4644 2011-06-08 20:00:21Z thompsonbry $

Author:

Bryan Thompson

Field Summary

Fields inherited from interface com.bigdata.rawstore.IAddressManager

NULL

Method Summary

ByteBuffer	readFromLocalStore(long addr) Read from the local store in support of failover reads on nodes in a highly available Quorum.
void	setExtentForLocalStore(long extent) Extend local store for a highly available Quorum.
void	writeRawBuffer(HAWriteMessage msg, IBufferAccess b) Write a buffer containing data replicated from the master onto the local persistence store.

Methods inherited from interface com.bigdata.journal.IBufferStrategy

abort, closeForWrites, commit, getAddressManager, getBufferMode, getCounters, getExtent, getHeaderSize, getInitialExtent, getMaximumExtent, getMaxRecordSize, getMetaBitsAddr, getMetaStartAddr, getNextOffset, getOffsetBits, getUserExtent, readRootBlock, requiresCommit, transferTo, truncate, useChecksums, writeRootBlock

Methods inherited from interface com.bigdata.rawstore.IRawStore

close, delete, deleteResources, destroy, force, getFile, getResourceMetadata, getUUID, isFullyBuffered, isOpen, isReadOnly, isStable, read, size, write

Methods inherited from interface com.bigdata.rawstore.IAddressManager

getByteCount, getOffset, getPhysicalAddress, toAddr, toString

Method Detail

writeRawBuffer

void writeRawBuffer(HAWriteMessage msg,
                    IBufferAccess b)
                    throws IOException,
                           InterruptedException

Write a buffer containing data replicated from the master onto the local persistence store.

Throws:

InterruptedException

IOException

readFromLocalStore

ByteBuffer readFromLocalStore(long addr)
                              throws InterruptedException

Read from the local store in support of failover reads on nodes in a highly available Quorum.

Throws:

InterruptedException

setExtentForLocalStore

void setExtentForLocalStore(long extent)
                            throws IOException,
                                   InterruptedException

Extend local store for a highly available Quorum.

Throws:

InterruptedException

IOException