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.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
com.bigdata.rwstore | |
com.bigdata.rwstore.sector |
Modifier and Type | Method and Description |
---|---|
IRootBlockView |
PrepareRequest.getRootBlock() |
Modifier and Type | Method and Description |
---|---|
void |
QuorumService.installRootBlocks(IRootBlockView rootBlock0,
IRootBlockView rootBlock1)
Install root blocks on the local service.
|
void |
QuorumServiceBase.logRootBlock(IRootBlockView rootBlock)
Log the root block for the commit point that closes the current write set
onto the
HALogWriter . |
void |
QuorumPipeline.logRootBlock(IRootBlockView rootBlock)
Log the root block for the commit point that closes the current write set
onto the
HALogWriter . |
Constructor and Description |
---|
PrepareRequest(IHANotifyReleaseTimeResponse consensusReleaseTime,
IJoinedAndNonJoinedServices gatherJoinedAndNonJoinedServices,
IJoinedAndNonJoinedServices prepareJoinedAndNonJoinedServices,
IRootBlockView rootBlock,
long timeout,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
IRootBlockView |
IHALogReader.getClosingRootBlock()
The
IRootBlockView for the committed state AFTER the write set
contained in the HA log file has been applied. |
IRootBlockView |
IHALogReader.getOpeningRootBlock()
The
IRootBlockView for the committed state BEFORE the write set
contained in the HA log file has been applied. |
Modifier and Type | Method and Description |
---|---|
void |
IHALogWriter.close(IRootBlockView rbv)
Writes the closing rootblock to the log file and closes the
file to further writes.
|
void |
HALogFile.HALogWriter.close(IRootBlockView rbv) |
HALogFile |
HALogManager.createLog(IRootBlockView rbv) |
Constructor and Description |
---|
HALogFile(IRootBlockView rbv,
com.bigdata.ha.althalog.HALogManager.IHALogManagerCallback callback)
This constructor is called by the log manager to create the file.
|
Modifier and Type | Method and Description |
---|---|
IRootBlockView |
HALogReader.getClosingRootBlock() |
IRootBlockView |
IHALogReader.getClosingRootBlock()
The
IRootBlockView for the committed state AFTER the write set
contained in the HA log file has been applied. |
IRootBlockView |
HALogReader.getOpeningRootBlock()
The
IRootBlockView for the committed state BEFORE the write set
contained in the HA log file. |
IRootBlockView |
IHALogReader.getOpeningRootBlock()
The
IRootBlockView for the committed state BEFORE the write set
contained in the HA log file. |
Modifier and Type | Method and Description |
---|---|
void |
HALogWriter.closeHALog(IRootBlockView rootBlock)
Write the final root block on the HA log and close the file.
|
void |
IHALogWriter.closeHALog(IRootBlockView rootBlock)
Write the final root block on the HA log and close the file.
|
void |
HALogWriter.createLog(IRootBlockView rootBlock)
Open an HA log file for the write set starting with the given root block.
|
Modifier and Type | Method and Description |
---|---|
IRootBlockView |
IHALogRootBlocksResponse.getCloseRootBlock()
The root block that closes the HA Log file for the specified commit
point.
|
IRootBlockView |
HALogRootBlocksResponse.getCloseRootBlock() |
IRootBlockView |
IHALogRootBlocksResponse.getOpenRootBlock()
The root block that opens the HA Log file for the specified commit point.
|
IRootBlockView |
HALogRootBlocksResponse.getOpenRootBlock() |
IRootBlockView |
IHASnapshotResponse.getRootBlock()
The root block associated with the snapshot.
|
IRootBlockView |
HA2PhasePrepareMessage.getRootBlock() |
IRootBlockView |
IHARootBlockResponse.getRootBlock()
The root block from the remote service.
|
IRootBlockView |
HARootBlockResponse.getRootBlock() |
IRootBlockView |
HASnapshotResponse.getRootBlock() |
IRootBlockView |
IHA2PhasePrepareMessage.getRootBlock()
The new root block.
|
IRootBlockView |
IHASendStoreResponse.getRootBlock0()
Root block ZERO (0) for the service whose backing store was sent
down the write pipeline in response to the request.
|
IRootBlockView |
HASendStoreResponse.getRootBlock0() |
IRootBlockView |
IHASendStoreResponse.getRootBlock1()
Root block ONE (1) for the service whose backing store was sent
down the write pipeline in response to the request.
|
IRootBlockView |
HASendStoreResponse.getRootBlock1() |
Constructor and Description |
---|
HA2PhasePrepareMessage(IHANotifyReleaseTimeResponse consensusReleaseTime,
boolean isGatherService,
boolean isJoinedService,
IRootBlockView rootBlock,
long timeout,
TimeUnit unit) |
HALogRootBlocksResponse(IRootBlockView openRootBlock,
IRootBlockView closeRootBlock) |
HARootBlockResponse(IRootBlockView rootBlock) |
HASendStoreResponse(IRootBlockView rootBlock0,
IRootBlockView rootBlock1,
long byteCount,
long blockCount) |
HASnapshotResponse(IRootBlockView rootBlock) |
Modifier and Type | Class and Description |
---|---|
class |
RootBlockView
A view onto a root block of the
Journal . |
Modifier and Type | Field and Description |
---|---|
IRootBlockView |
FileMetadata.rootBlock
The current root block.
|
IRootBlockView |
RootBlockUtility.rootBlock
The current root block.
|
IRootBlockView |
RootBlockUtility.rootBlock0
The 1st root block.
|
IRootBlockView |
RootBlockUtility.rootBlock1
The 2nd root block.
|
Modifier and Type | Method and Description |
---|---|
IRootBlockView |
IRootBlockView.asRootBlock(boolean rootBlock0)
Return a version of the caller's root block that is flagged as either
rootBlock0 or rootBlock1 as indicated by the argument.
|
IRootBlockView |
RootBlockView.asRootBlock(boolean rootBlock0) |
IRootBlockView |
RootBlockUtility.chooseRootBlock()
Return the chosen root block.
|
static IRootBlockView |
RootBlockUtility.chooseRootBlock(IRootBlockView rootBlock0,
IRootBlockView rootBlock1)
Return the chosen root block.
|
static IRootBlockView |
RootBlockUtility.chooseRootBlock(IRootBlockView rootBlock0,
IRootBlockView rootBlock1,
boolean alternateRootBlock,
boolean ignoreBadRootBlock)
Return the chosen root block.
|
IRootBlockView |
ICommitTimeEntry.getRootBlock()
Return the
IRootBlockView of the snapshot. |
IRootBlockView |
ISnapshotResult.getRootBlock()
The current root block for the snapshot.
|
protected IRootBlockView[] |
AbstractJournal.getRootBlocks()
Return both root blocks (atomically - used by HA).
|
IRootBlockView |
JournalDelegate.getRootBlockView() |
IRootBlockView |
AbstractJournal.getRootBlockView()
Return a read-only view of the current root block.
|
IRootBlockView |
IAtomicStore.getRootBlockView()
Return a read-only view of the current root block.
|
IRootBlockView |
AbstractJournal.getRootBlockViewWithLock()
Variant of
AbstractJournal.getRootBlockView() that takes the internal lock in
order to provide an appropriate synchronization barrier when installing
new root blocks onto an empty journal in HA. |
Modifier and Type | Method and Description |
---|---|
static IRootBlockView |
RootBlockUtility.chooseRootBlock(IRootBlockView rootBlock0,
IRootBlockView rootBlock1)
Return the chosen root block.
|
static IRootBlockView |
RootBlockUtility.chooseRootBlock(IRootBlockView rootBlock0,
IRootBlockView rootBlock1,
boolean alternateRootBlock,
boolean ignoreBadRootBlock)
Return the chosen root block.
|
void |
AbstractJournal.doLocalCommit(IRootBlockView rootBlock)
Local commit protocol (HA, offline).
|
protected void |
AbstractJournal.doLocalCommit(QuorumService<HAGlue> localService,
IRootBlockView rootBlock)
Local commit protocol (HA).
|
File |
ISnapshotFactory.getSnapshotFile(IRootBlockView rbv)
Return the
File on which the snapshot will be written. |
File |
BasicSnapshotFactory.getSnapshotFile(IRootBlockView rbv)
For the default implementation don't append the commit point to the file.
|
protected void |
AbstractJournal.installRootBlocks(IRootBlockView rootBlock0,
IRootBlockView rootBlock1)
Install identical root blocks on the journal.
|
void |
WORMStrategy.postHACommit(IRootBlockView rootBlock) |
void |
IHABufferStrategy.postHACommit(IRootBlockView rootBlock)
Provides a trigger for synchronization of transient state after a commit.
|
void |
RWStrategy.postHACommit(IRootBlockView rootBlock) |
boolean |
IBufferStrategy.requiresCommit(IRootBlockView block)
A method that removes assumptions of how a specific strategy determines
whether a transaction commit is required.
|
boolean |
AbstractBufferStrategy.requiresCommit(IRootBlockView block) |
boolean |
RWStrategy.requiresCommit(IRootBlockView block)
A method that removes assumptions of how a specific strategy determines
whether a transaction commit is required.
|
void |
WORMStrategy.resetFromHARootBlock(IRootBlockView rootBlock) |
void |
IHABufferStrategy.resetFromHARootBlock(IRootBlockView rootBlock)
Reload from the current root block - CAUTION : THIS IS NOT A
RESET / ABORT.
|
void |
RWStrategy.resetFromHARootBlock(IRootBlockView rootBlock) |
protected void |
AbstractJournal.BasicHA.validateNewRootBlock(boolean isLeader,
IRootBlockView oldRB,
IRootBlockView newRB)
Validate the new root block against the current root block.
|
void |
WORMStrategy.writeRootBlock(IRootBlockView rootBlock,
ForceEnum forceOnCommit) |
void |
DiskOnlyStrategy.writeRootBlock(IRootBlockView rootBlock,
ForceEnum forceOnCommit)
Deprecated.
|
void |
TransientBufferStrategy.writeRootBlock(IRootBlockView rootBlock,
ForceEnum forceOnCommit) |
void |
DiskBackedBufferStrategy.writeRootBlock(IRootBlockView rootBlock,
ForceEnum forceOnCommit) |
void |
IBufferStrategy.writeRootBlock(IRootBlockView rootBlock,
ForceEnum forceOnCommitEnum)
Write the root block onto stable storage (ie, flush it through to disk).
|
void |
RWStrategy.writeRootBlock(IRootBlockView rootBlock,
ForceEnum forceOnCommit) |
Modifier and Type | Method and Description |
---|---|
AbstractJournal.ISnapshotData |
AbstractJournal.snapshotAllocationData(AtomicReference<IRootBlockView> rbv)
With lock held to ensure that there is no concurrent commit, copy
key data atomically to ensure recovered snapshot is consistent with
the commit state when the snapshot is taken.
|
Constructor and Description |
---|
RootBlockUtility(IRootBlockView rb0,
IRootBlockView rb1) |
Modifier and Type | Method and Description |
---|---|
void |
RWStore.postHACommit(IRootBlockView rbv)
Called from
AbstractJournal commit2Phase to ensure that a
downstream HA quorum member ensures it is able to read committed data
that has been streamed directly to the backing store. |
void |
RWStore.resetFromHARootBlock(IRootBlockView rootBlock)
Low level routine used when we replace the root blocks of an empty
journal in HA with those from the leader.
|
void |
RWStore.writeRootBlock(IRootBlockView rootBlock,
ForceEnum forceOnCommit)
This can be called as part of the HA downstream replication.
|
Modifier and Type | Method and Description |
---|---|
boolean |
MemStrategy.requiresCommit(IRootBlockView block) |
void |
MemStrategy.writeRootBlock(IRootBlockView rootBlock,
ForceEnum forceOnCommitEnum) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.