Package org.apache.ignite.internal.persistence.wal

Class WalManagerImpl

java.lang.Object

org.apache.ignite.internal.persistence.wal.WalManagerImpl

All Implemented Interfaces:

WalManager

public final class WalManagerImpl
extends Object
implements WalManager

The default implementation of WalManager interface.

Constructor Summary

Constructors

Constructor	Description
WalManagerImpl(Path path, int maxPendingChainSize, boolean forceSync, int pageSize, DataRegionManager dataRegionManager, StoreConfigurationStore storeConfigurationStore, IgniteLogger logger)

Method Summary

Modifier and Type	Method	Description
void	finishCheckpoint()	Finishes a checkpoint.
void	finishLogicalOperations(OperationExecutor logicalOperationExecutor, OperationSerializer logicalOperationSerializer)	Finishes interrupted logical operations.
boolean	isLastCheckpointInterrupted()	Checks if the last checkpoint was interrupted.
void	logicalOperation(Object descriptor, OperationSerializer logicalOperationSerializer)	Logs logical operation.
void	physicalOperation(PhysicalOperationDescriptor descriptor)	Logs physical operation.
long	size()	Gets size.
void	start()	Starts the log manager.
void	startCheckpoint()	Starts a checkpoint.
void	stop(boolean onError)	Stops the log manager.
void	terminate()	For test purposes only.

Methods inherited from class java.lang.Object

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

Constructor Details

WalManagerImpl

public WalManagerImpl(Path path,
 int maxPendingChainSize,
 boolean forceSync,
 int pageSize,
 DataRegionManager dataRegionManager,
 StoreConfigurationStore storeConfigurationStore,
 IgniteLogger logger)

Parameters:

path - The path of the log. May not be null.

maxPendingChainSize - The maximum pending chain size in bytes. Must be greater than 0.

forceSync - The flag indicating whether to force file synchronization.

maxPartitionSize - The maximum partition size in bytes. Must be greater than 0.

dataRegionManager - The data region manager. May not be null.

storeConfigurationStore - The store configuration store. May not be null.

logger - The logger. May not be null.

Method Details

startCheckpoint

public void startCheckpoint()
                     throws IgniteCheckedException

Description copied from interface: WalManager

Starts a checkpoint.

Specified by:

startCheckpoint in interface WalManager

Throws:

IgniteCheckedException - in case of a failure.

finishCheckpoint

public void finishCheckpoint()
                      throws IgniteCheckedException

Description copied from interface: WalManager

Finishes a checkpoint.

Specified by:

finishCheckpoint in interface WalManager

Throws:

IgniteCheckedException - in case of a failure.

isLastCheckpointInterrupted

public boolean isLastCheckpointInterrupted()
                                    throws IgniteCheckedException

Description copied from interface: WalManager

Checks if the last checkpoint was interrupted.

Specified by:

isLastCheckpointInterrupted in interface WalManager

Returns:

true if the last checkpoint was interrupted, false otherwise.

Throws:

IgniteCheckedException - in case of a failure.

logicalOperation

public void logicalOperation(Object descriptor,
 OperationSerializer logicalOperationSerializer)
                      throws IgniteCheckedException

Description copied from interface: WalManager

Logs logical operation.

Specified by:

logicalOperation in interface WalManager

Parameters:

descriptor - The descriptor of the operation. May not be null.

logicalOperationSerializer - The logical operation serializer. May not be null.

Throws:

IgniteCheckedException - in case of a failure.

physicalOperation

public void physicalOperation(PhysicalOperationDescriptor descriptor)
                       throws IgniteCheckedException

Description copied from interface: WalManager

Logs physical operation.

Specified by:

physicalOperation in interface WalManager

Parameters:

descriptor - The descriptor of the operation. May not be null.

Throws:

IgniteCheckedException - in case of a failure.

finishLogicalOperations

public void finishLogicalOperations(OperationExecutor logicalOperationExecutor,
 OperationSerializer logicalOperationSerializer)
                             throws IgniteCheckedException

Description copied from interface: WalManager

Finishes interrupted logical operations.

Specified by:

finishLogicalOperations in interface WalManager

Parameters:

logicalOperationExecutor - The logical operation executor. May not be null.

logicalOperationSerializer - The logical operation serializer. May not be null.

Throws:

IgniteCheckedException - in case of a failure.

size

public long size()
          throws IgniteCheckedException

Description copied from interface: WalManager

Gets size.

Specified by:

size in interface WalManager

Returns:

Size in bytes.

Throws:

IgniteCheckedException - in case of a failure.

start

public void start()
           throws IgniteCheckedException

Description copied from interface: WalManager

Starts the log manager.

Specified by:

start in interface WalManager

Throws:

IgniteCheckedException - in case of a failure.

stop

public void stop(boolean onError)

Description copied from interface: WalManager

Stops the log manager.

Specified by:

stop in interface WalManager

Parameters:

onError - The flag indicating whether closing was requested on error.

terminate

public void terminate()

For test purposes only.