Package org.apache.ignite.internal.processors.cache.persistence.wal.filehandle

Class FileHandleManagerImpl

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.wal.filehandle.FileHandleManagerImpl

All Implemented Interfaces:

FileHandleManager

public class FileHandleManagerImpl
extends Object
implements FileHandleManager

Manager for FileWriteHandleImpl.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	FileHandleManagerImpl.WALWriter	WAL writer worker.

Field Summary

Fields

Modifier and Type	Field	Description
protected GridCacheSharedContext	cctx	Context.
static long	DFLT_WAL_SEGMENT_SYNC_TIMEOUT	Default wal segment sync timeout.

Constructor Summary

Constructors

Constructor	Description
FileHandleManagerImpl(GridCacheSharedContext cctx, DataStorageMetricsImpl metrics, boolean mmap, RecordSerializer serializer, Supplier<FileWriteHandle> currentHandleSupplier, WALMode mode, int walBufferSize, long maxWalSegmentSize, long fsyncDelay)

Method Summary

Modifier and Type	Method	Description
WALPointer	flush(WALPointer ptr, boolean explicitFsync)
FileWriteHandle	initHandle(SegmentIO fileIO, long position, RecordSerializer serializer)	Initialize FileWriteHandle for first time.
FileWriteHandle	nextHandle(SegmentIO fileIO, RecordSerializer serializer)	Create next file handle.
void	onDeactivate()	On deactivate.
void	resumeLogging()	Resume logging.

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_WAL_SEGMENT_SYNC_TIMEOUT

public static final long DFLT_WAL_SEGMENT_SYNC_TIMEOUT

Default wal segment sync timeout.

See Also:

Constant Field Values

cctx

protected final GridCacheSharedContext cctx

Context.

Constructor Detail

FileHandleManagerImpl

public FileHandleManagerImpl(GridCacheSharedContext cctx,
                             DataStorageMetricsImpl metrics,
                             boolean mmap,
                             RecordSerializer serializer,
                             Supplier<FileWriteHandle> currentHandleSupplier,
                             WALMode mode,
                             int walBufferSize,
                             long maxWalSegmentSize,
                             long fsyncDelay)

Parameters:

cctx - Context.

metrics - Data storage metrics.

mmap - Mmap.

serializer - Serializer.

currentHandleSupplier - Current handle supplier.

mode - WAL mode.

walBufferSize - WAL buffer size.

maxWalSegmentSize - Max WAL segment size.

fsyncDelay - Fsync delay.

Method Detail

initHandle

public FileWriteHandle initHandle(SegmentIO fileIO,
                                  long position,
                                  RecordSerializer serializer)
                           throws IOException

Initialize FileWriteHandle for first time.

Specified by:

initHandle in interface FileHandleManager

Parameters:

fileIO - FileIO.

position - Init position.

serializer - Serializer for file handle.

Returns:

Created file handle.

Throws:

IOException - if creation was not success.

nextHandle

public FileWriteHandle nextHandle(SegmentIO fileIO,
                                  RecordSerializer serializer)
                           throws IOException

Create next file handle.

Specified by:

nextHandle in interface FileHandleManager

Parameters:

fileIO - FileIO.

serializer - Serializer for file handle.

Returns:

Created file handle.

Throws:

IOException - if creation was not success.

onDeactivate

public void onDeactivate()
                  throws IgniteCheckedException

On deactivate.

Specified by:

onDeactivate in interface FileHandleManager

Throws:

IgniteCheckedException - if fail.

resumeLogging

public void resumeLogging()

Resume logging.

Specified by:

resumeLogging in interface FileHandleManager

flush

public WALPointer flush(WALPointer ptr,
                        boolean explicitFsync)
                 throws IgniteCheckedException,
                        StorageException

Specified by:

flush in interface FileHandleManager

Parameters:

ptr - Pointer until need to flush.

explicitFsync - true if fsync required.

Returns:

Last WAL position which was flushed to WAL segment file. May be greater than or equal to a ptr. May be null, it means nothing has been flushed.

Throws:

IgniteCheckedException - if fail.

StorageException - if storage was fail.