IgniteCacheDatabaseSharedManager (Ignite 2.11.0)

java.lang.Object
- org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter
- - org.apache.ignite.internal.processors.cache.persistence.IgniteCacheDatabaseSharedManager

All Implemented Interfaces:

GridCacheSharedManager, CheckpointLockStateChecker, IgniteChangeGlobalStateSupport

Direct Known Subclasses:

GridCacheDatabaseSharedManager
```
public class IgniteCacheDatabaseSharedManager
extends GridCacheSharedManagerAdapter
implements IgniteChangeGlobalStateSupport, CheckpointLockStateChecker
```

Field Summary

Fields
Modifier and Type	Field and Description
`static String`	`DATA_REGION_PAGE_LIST_VIEW` System view name for page lists.
`static String`	`DATA_REGION_PAGE_LIST_VIEW_DESC` System view description for page lists.
`protected Map<String,DataRegion>`	`dataRegionMap`
`protected boolean`	`dataRegionsInitialized`
`protected DataRegion`	`dfltDataRegion`
`protected Map<String,CacheFreeList>`	`freeListMap`
`static Set<String>`	`INTERNAL_DATA_REGION_NAMES` DataRegionConfiguration names reserved for various internal needs.
`protected boolean`	`reuseMemory` `True` to reuse memory on deactive.
`static String`	`SYSTEM_DATA_REGION_NAME` DataRegionConfiguration name reserved for internal caches.

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter
cctx, diagnosticLog, log

Constructor Summary

Constructors
Constructor and Description

IgniteCacheDatabaseSharedManager()

Constructors
Constructor and Description
`IgniteCacheDatabaseSharedManager()`

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`DataRegion`	`addDataRegion(DataStorageConfiguration dataStorageCfg, DataRegionConfiguration dataRegionCfg, boolean trackable)`
`protected DataRegion`	`addDataRegion(DataStorageConfiguration dataStorageCfg, DataRegionConfiguration dataRegionCfg, boolean trackable, PageReadWriteManager pmPageMgr)`
`void`	`beforeExchange(GridDhtPartitionsExchangeFuture discoEvt)`
`protected @Nullable File`	`buildAllocPath(DataRegionConfiguration plc)` Builds allocation path for memory mapped file to be used with PageMemory.
`protected File`	`buildPath(String path, String consId)`
`protected void`	`checkPageSize(DataStorageConfiguration memCfg)`
`boolean`	`checkpointLockIsHeldByThread()`
`void`	`checkpointReadLock()` No-op for non-persistent storage.
`long`	`checkpointReadLockTimeout()`
`void`	`checkpointReadLockTimeout(long val)` No-op for non-persistent storage.
`void`	`checkpointReadUnlock()` No-op for non-persistent storage.
`protected void`	`checkRegionEvictionProperties(DataRegionConfiguration regCfg, DataStorageConfiguration dbCfg)`
`void`	`cleanupCheckpointDirectory()` Clean checkpoint directory `CheckpointMarkersStorage.cpDir`.
`void`	`cleanupRestoredCaches()` Method will perform cleanup cache page memory and each cache partition store.
`void`	`cleanupTempCheckpointDirectory()` No-op for non-persistent storage.
`protected PageEvictionTracker`	`createPageEvictionTracker(DataRegionConfiguration plc, PageMemory pageMem)`
`protected PageMemory`	`createPageMemory(DirectMemoryProvider memProvider, DataStorageConfiguration memCfg, DataRegionConfiguration memPlcCfg, DataRegionMetricsImpl memMetrics, boolean trackable, PageReadWriteManager pmPageMgr)` Creates PageMemory with given size and memory provider.
`@Nullable DataRegion`	`dataRegion(@Nullable String memPlcName)` Getting data region by name.
`protected DataRegionMetricsProvider`	`dataRegionMetricsProvider(DataRegionConfiguration dataRegCfg)` Provide that can be used to compute some metrics for provided data region.
`Collection<DataRegion>`	`dataRegions()` Getting registered data regions.
`void`	`dumpStatistics(IgniteLogger log)`
`void`	`ensureFreeSpace(DataRegion memPlc)` See `GridCacheMapEntry#ensureFreeSpace()`
`void`	`ensureFreeSpaceForInsert(DataRegion region, int dataRowSize)` Checks that the given `region` has enough space for putting a new entry.
`@Nullable CheckpointProgress`	`forceCheckpoint(String reason)` Schedule a new checkpoint.
`<R> @Nullable CheckpointProgress`	`forceNewCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)` Schedule a new checkpoint.
`Collection<GridCacheContext>`	`forceRebuildIndexes(Collection<GridCacheContext> contexts)` Initiate an asynchronous forced index rebuild for caches.
`FreeList`	`freeList(String memPlcName)`
`protected IgniteOutClosure<Long>`	`freeSpaceProvider(DataRegionConfiguration dataRegCfg)` Deprecated. use `dataRegionMetricsProvider(DataRegionConfiguration)` instead.
`protected List<DatabaseLifecycleListener>`	`getDatabaseListeners(GridKernalContext kctx)`
`protected void`	`initAndStartRegions(DataStorageConfiguration cfg)`
`protected void`	`initDataRegions(DataStorageConfiguration memCfg)`
`protected void`	`initDataRegions0(DataStorageConfiguration memCfg)`
`protected void`	`initPageMemoryDataStructures(DataStorageConfiguration dbCfg)`
`void`	`lastCheckpointInapplicableForWalRebalance(int grpId)` Marks last checkpoint as inapplicable for WAL rebalance for given group `grpId`.
`@Nullable WALPointer`	`lastCheckpointMarkWalPointer()`
`WALPointer`	`latestWalPointerReservedForPreloading()` Returns the latest WAL pointer that reserved for preloading or `null`.
`Collection<DataRegionMetrics>`	`memoryMetrics()`
`@Nullable DataRegionMetrics`	`memoryMetrics(String dataRegionName)`
`MetaStorage`	`metaStorage()`
`void`	`notifyMetaStorageSubscribersOnReadyForRead()` Notifies `MetastorageLifecycleListener` that `MetaStorage` is ready for read.
`void`	`onActivate(GridKernalContext kctx)` Called when cluster performing activation.
`void`	`onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps)`
`void`	`onDeActivate(GridKernalContext kctx)` Called when cluster performing deactivation.
`void`	`onStateRestored(AffinityTopologyVersion topVer)` Called when all partitions have been fully restored and pre-created on node start.
`int`	`pageSize()`
`DataStorageMetrics`	`persistentStoreMetrics()`
`void`	`prepareCachesStop()` Needed action before any cache will stop
`void`	`rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)`
`protected <T> void`	`registerMetricsMBean(IgniteConfiguration cfg, String groupName, String dataRegionName, T impl, Class<T> clazz)`
`protected void`	`registerMetricsMBeans(IgniteConfiguration cfg)` Registers MBeans for all DataRegionMetrics configured in this instance.
`void`	`releaseHistoryForExchange()` Release reserved update history.
`void`	`releaseHistoryForPreloading()` Release reserved update history.
`Map<Integer,Map<Integer,Long>>`	`reserveHistoryForExchange()` Reserve update history for exchange.
`boolean`	`reserveHistoryForPreloading(Map<T2<Integer,Integer>,Long> reservationMap)` Reserve update history for preloading.
`ReuseList`	`reuseList(String memPlcName)`
`protected void`	`setPageSize(int pageSize)` Method for fake (standalone) context initialization.
`protected void`	`start0()`
`void`	`startMemoryRestore(GridKernalContext kctx, TimeBag startTimer)` Perform memory restore before `GridDiscoveryManager` start.
`protected void`	`stop0(boolean cancel)`
`boolean`	`supportsMemoryReuse(DataRegionConfiguration plcCfg)`
`String`	`systemDateRegionName()`
`protected void`	`unregisterMetricsMBean(IgniteConfiguration cfg, String groupName, String name)`
`void`	`waitForCheckpoint(String reason)` Waits until current state is checkpointed.
`<R> void`	`waitForCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)` Waits until current state is checkpointed and execution listeners after finish.
`@Nullable IgniteInternalFuture`	`wakeupForCheckpoint(String reason)`
`boolean`	`walEnabled(int grpId, boolean local)`
`void`	`walEnabled(int grpId, boolean enabled, boolean local)` Marks cache group as with disabled WAL.

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter
context, isStopping, kernalStartInfo, kernalStopInfo, log, onDisconnected, onKernalStart, onKernalStart0, onKernalStop, onKernalStop0, onReconnected, printMemoryStats, start, startInfo, stop, stopInfo, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - SYSTEM_DATA_REGION_NAME
```
public static final String SYSTEM_DATA_REGION_NAME
```
    DataRegionConfiguration name reserved for internal caches.
    
    See Also:
    
    Constant Field Values
  - INTERNAL_DATA_REGION_NAMES
```
public static Set<String> INTERNAL_DATA_REGION_NAMES
```
    DataRegionConfiguration names reserved for various internal needs.
  - DATA_REGION_PAGE_LIST_VIEW
```
public static final String DATA_REGION_PAGE_LIST_VIEW
```
    System view name for page lists.
    
    See Also:
    
    Constant Field Values
  - DATA_REGION_PAGE_LIST_VIEW_DESC
```
public static final String DATA_REGION_PAGE_LIST_VIEW_DESC
```
    System view description for page lists.
    
    See Also:
    
    Constant Field Values
  - reuseMemory
```
protected final boolean reuseMemory
```
    True to reuse memory on deactive.
  - dataRegionMap
```
protected final Map<String,DataRegion> dataRegionMap
```
  - dataRegionsInitialized
```
protected volatile boolean dataRegionsInitialized
```
  - dfltDataRegion
```
protected DataRegion dfltDataRegion
```
  - freeListMap
```
protected Map<String,CacheFreeList> freeListMap
```
- Constructor Detail
  - IgniteCacheDatabaseSharedManager
```
public IgniteCacheDatabaseSharedManager()
```
- Method Detail
  - start0
```
protected void start0()
               throws IgniteCheckedException
```
    Overrides:
    
    start0 in class GridCacheSharedManagerAdapter
    
    Throws:
    
    IgniteCheckedException - If failed.
  - registerMetricsMBean
```
protected <T> void registerMetricsMBean(IgniteConfiguration cfg,
                                        String groupName,
                                        String dataRegionName,
                                        T impl,
                                        Class<T> clazz)
```
    Parameters:
    
    cfg - Ignite configuration.
    
    groupName - Name of group.
    
    dataRegionName - Metrics MBean name.
    
    impl - Metrics implementation.
    
    clazz - Metrics class type.
  - unregisterMetricsMBean
```
protected void unregisterMetricsMBean(IgniteConfiguration cfg,
                                      String groupName,
                                      String name)
```
    Parameters:
    
    cfg - Ignite configuration.
    
    groupName - Name of group.
    
    name - Name of MBean.
  - registerMetricsMBeans
```
protected void registerMetricsMBeans(IgniteConfiguration cfg)
```
    Registers MBeans for all DataRegionMetrics configured in this instance.
    
    Parameters:
    
    cfg - Ignite configuration.
  - initPageMemoryDataStructures
```
protected void initPageMemoryDataStructures(DataStorageConfiguration dbCfg)
                                     throws IgniteCheckedException
```
    Parameters:
    
    dbCfg - Database config.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - pageSize
```
public int pageSize()
```
    Returns:
    
    Size of page used for PageMemory regions.
  - initDataRegions
```
protected void initDataRegions(DataStorageConfiguration memCfg)
                        throws IgniteCheckedException
```
    Parameters:
    
    memCfg - Database config.
    
    Throws:
    
    IgniteCheckedException - If failed to initialize swap path.
  - initDataRegions0
```
protected void initDataRegions0(DataStorageConfiguration memCfg)
                         throws IgniteCheckedException
```
    Parameters:
    
    memCfg - Database config.
    
    Throws:
    
    IgniteCheckedException - If failed to initialize swap path.
  - getDatabaseListeners
```
protected List<DatabaseLifecycleListener> getDatabaseListeners(GridKernalContext kctx)
```
    Parameters:
    
    kctx - Kernal context.
    
    Returns:
    
    Database lifecycle listeners.
  - addDataRegion
```
public DataRegion addDataRegion(DataStorageConfiguration dataStorageCfg,
                                DataRegionConfiguration dataRegionCfg,
                                boolean trackable)
                         throws IgniteCheckedException
```
    Parameters:
    
    dataStorageCfg - Database config.
    
    dataRegionCfg - Data region config.
    
    Throws:
    
    IgniteCheckedException - If failed to initialize swap path.
  - addDataRegion
```
protected DataRegion addDataRegion(DataStorageConfiguration dataStorageCfg,
                                   DataRegionConfiguration dataRegionCfg,
                                   boolean trackable,
                                   PageReadWriteManager pmPageMgr)
                            throws IgniteCheckedException
```
    Parameters:
    
    dataStorageCfg - Database config.
    
    dataRegionCfg - Data region config.
    
    pmPageMgr - Page manager.
    
    Throws:
    
    IgniteCheckedException - If failed to initialize swap path.
  - freeSpaceProvider
```
@Deprecated
protected IgniteOutClosure<Long> freeSpaceProvider(DataRegionConfiguration dataRegCfg)
```
    Deprecated. use dataRegionMetricsProvider(DataRegionConfiguration) instead.
    
    Closure that can be used to compute fill factor for provided data region.
    
    Parameters:
    
    dataRegCfg - Data region configuration.
    
    Returns:
    
    Closure.
  - dataRegionMetricsProvider
```
protected DataRegionMetricsProvider dataRegionMetricsProvider(DataRegionConfiguration dataRegCfg)
```
    Provide that can be used to compute some metrics for provided data region.
    
    Parameters:
    
    dataRegCfg - Data region configuration.
    
    Returns:
    
    DataRegionMetricsProvider.
  - checkPageSize
```
protected void checkPageSize(DataStorageConfiguration memCfg)
```
    Parameters:
    
    memCfg - Memory config.
  - checkRegionEvictionProperties
```
protected void checkRegionEvictionProperties(DataRegionConfiguration regCfg,
                                             DataStorageConfiguration dbCfg)
                                      throws IgniteCheckedException
```
    Parameters:
    
    regCfg - DataRegionConfiguration to validate.
    
    dbCfg - Memory configuration.
    
    Throws:
    
    IgniteCheckedException - If config is invalid.
  - dumpStatistics
```
public void dumpStatistics(IgniteLogger log)
```
    Parameters:
    
    log - Logger.
  - dataRegions
```
public Collection<DataRegion> dataRegions()
```
    Getting registered data regions.
    
    Returns:
    
    Collection of all configured policies.
  - memoryMetrics
```
public Collection<DataRegionMetrics> memoryMetrics()
```
    Returns:
    
    DataRegionMetrics for all MemoryPolicies configured in Ignite instance.
  - persistentStoreMetrics
```
public DataStorageMetrics persistentStoreMetrics()
```
    Returns:
    
    DataStorageMetrics if persistence is enabled or null otherwise.
  - memoryMetrics
```
@Nullable
public @Nullable DataRegionMetrics memoryMetrics(String dataRegionName)
```
    Parameters:
    
    dataRegionName - Name of DataRegion to obtain DataRegionMetrics for.
    
    Returns:
    
    DataRegionMetrics snapshot for specified DataRegion or null if no DataRegion is configured for specified name.
  - dataRegion
```
@Nullable
public @Nullable DataRegion dataRegion(@Nullable
                                                 @Nullable String memPlcName)
                                          throws IgniteCheckedException
```
    Getting data region by name.
    
    Parameters:
    
    memPlcName - Data region name. In case of null, default data region will be returned.
    
    Returns:
    
    DataRegion instance associated with a given DataRegionConfiguration, or null if there are no registered data regions.
    
    Throws:
    
    IgniteCheckedException - in case of request for unknown DataRegion.
  - freeList
```
public FreeList freeList(String memPlcName)
```
    Parameters:
    
    memPlcName - DataRegionConfiguration name.
    
    Returns:
    
    FreeList instance associated with a given DataRegionConfiguration.
  - reuseList
```
public ReuseList reuseList(String memPlcName)
```
    Parameters:
    
    memPlcName - DataRegionConfiguration name.
    
    Returns:
    
    ReuseList instance associated with a given DataRegionConfiguration.
  - stop0
```
protected void stop0(boolean cancel)
```
    Overrides:
    
    stop0 in class GridCacheSharedManagerAdapter
    
    Parameters:
    
    cancel - Cancel flag.
  - checkpointLockIsHeldByThread
```
public boolean checkpointLockIsHeldByThread()
```
    Specified by:
    
    checkpointLockIsHeldByThread in interface CheckpointLockStateChecker
    
    Returns:
    
    true if checkpoint lock is held by current thread
  - checkpointReadLock
```
public void checkpointReadLock()
```
    No-op for non-persistent storage.
  - checkpointReadUnlock
```
public void checkpointReadUnlock()
```
    No-op for non-persistent storage.
  - checkpointReadLockTimeout
```
public long checkpointReadLockTimeout()
```
    Returns:
    
    0 for non-persistent storage.
  - checkpointReadLockTimeout
```
public void checkpointReadLockTimeout(long val)
```
    No-op for non-persistent storage.
  - cleanupRestoredCaches
```
public void cleanupRestoredCaches()
```
    Method will perform cleanup cache page memory and each cache partition store.
  - cleanupCheckpointDirectory
```
public void cleanupCheckpointDirectory()
                                throws IgniteCheckedException
```
    Clean checkpoint directory CheckpointMarkersStorage.cpDir. The operation is necessary when local node joined to baseline topology with different consistentId.
    
    Throws:
    
    IgniteCheckedException
  - cleanupTempCheckpointDirectory
```
public void cleanupTempCheckpointDirectory()
                                    throws IgniteCheckedException
```
    No-op for non-persistent storage.
    
    Throws:
    
    IgniteCheckedException
  - wakeupForCheckpoint
```
@Nullable
public @Nullable IgniteInternalFuture wakeupForCheckpoint(String reason)
```
  - lastCheckpointMarkWalPointer
```
@Nullable
public @Nullable WALPointer lastCheckpointMarkWalPointer()
```
    Returns:
    
    Last checkpoint mark WAL pointer.
  - forceCheckpoint
```
@Nullable
public @Nullable CheckpointProgress forceCheckpoint(String reason)
```
    Schedule a new checkpoint.
    Note: if a checkpoint is already running and the locks have not been taken yet, then a new checkpoint will not be forced.
    
    Parameters:
    
    reason - Reason.
  - forceNewCheckpoint
```
@Nullable
public <R> @Nullable CheckpointProgress forceNewCheckpoint(String reason,
                                                                     IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)
```
    Schedule a new checkpoint.
    
    Parameters:
    
    reason - Reason.
    
    lsnr - Listener which will be called on scheduled checkpoint finish.
  - waitForCheckpoint
```
public void waitForCheckpoint(String reason)
                       throws IgniteCheckedException
```
    Waits until current state is checkpointed.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - waitForCheckpoint
```
public <R> void waitForCheckpoint(String reason,
                                  IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)
                           throws IgniteCheckedException
```
    Waits until current state is checkpointed and execution listeners after finish.
    
    Parameters:
    
    reason - Reason for checkpoint wakeup if it would be required.
    
    lsnr - Listeners which should be called in checkpoint thread after current checkpoint finished.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - beforeExchange
```
public void beforeExchange(GridDhtPartitionsExchangeFuture discoEvt)
                    throws IgniteCheckedException
```
    Parameters:
    
    discoEvt - Before exchange for the given discovery event.
    
    Throws:
    
    IgniteCheckedException
  - startMemoryRestore
```
public void startMemoryRestore(GridKernalContext kctx,
                               TimeBag startTimer)
                        throws IgniteCheckedException
```
    Perform memory restore before GridDiscoveryManager start.
    
    Parameters:
    
    kctx - Current kernal context.
    
    startTimer - Holder of start time of stages.
    
    Throws:
    
    IgniteCheckedException - If fails.
  - onStateRestored
```
public void onStateRestored(AffinityTopologyVersion topVer)
                     throws IgniteCheckedException
```
    Called when all partitions have been fully restored and pre-created on node start.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - rebuildIndexesIfNeeded
```
public void rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)
```
    Parameters:
    
    fut - Partition exchange future.
  - forceRebuildIndexes
```
public Collection<GridCacheContext> forceRebuildIndexes(Collection<GridCacheContext> contexts)
```
    Initiate an asynchronous forced index rebuild for caches.
    
    Parameters:
    
    contexts - Cache contexts.
    
    Returns:
    
    Cache contexts for which index rebuilding is not initiated by this call because they are already in the process of rebuilding.
  - prepareCachesStop
```
public void prepareCachesStop()
```
    Needed action before any cache will stop
  - onCacheGroupsStopped
```
public void onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps)
```
    Parameters:
    
    stoppedGrps - A collection of tuples (cache group, destroy flag).
  - reserveHistoryForExchange
```
public Map<Integer,Map<Integer,Long>> reserveHistoryForExchange()
```
    Reserve update history for exchange.
    
    Returns:
    
    Reserved update counters per cache and partition.
  - releaseHistoryForExchange
```
public void releaseHistoryForExchange()
```
    Release reserved update history.
  - reserveHistoryForPreloading
```
public boolean reserveHistoryForPreloading(Map<T2<Integer,Integer>,Long> reservationMap)
```
    Reserve update history for preloading.
    
    Parameters:
    
    reservationMap - Map contains of counters for partitions of groups.
    
    Returns:
    
    True if successfully reserved.
  - releaseHistoryForPreloading
```
public void releaseHistoryForPreloading()
```
    Release reserved update history.
  - latestWalPointerReservedForPreloading
```
public WALPointer latestWalPointerReservedForPreloading()
```
    Returns the latest WAL pointer that reserved for preloading or null.
    
    Returns:
    
    WAL pointer or null if nothing reserved.
  - ensureFreeSpaceForInsert
```
public void ensureFreeSpaceForInsert(DataRegion region,
                                     int dataRowSize)
                              throws IgniteOutOfMemoryException
```
    Checks that the given region has enough space for putting a new entry. This method makes sense then and only then the data region is not persisted DataRegionConfiguration.isPersistenceEnabled() and page eviction is disabled DataPageEvictionMode.DISABLED. The non-persistent region should reserve a number of pages to support a free list AbstractFreeList. For example, removing a row from underlying store may require allocating a new data page in order to move a tracked page from one bucket to another one which does not have a free space for a new stripe. See AbstractFreeList.removeDataRowByLink(long, org.apache.ignite.internal.metric.IoStatisticsHolder). Therefore, inserting a new entry should be prevented in case of some threshold is exceeded.
    
    Parameters:
    
    region - Data region to be checked.
    
    dataRowSize - Size of data row to be inserted.
    
    Throws:
    
    IgniteOutOfMemoryException - In case of the given data region does not have enough free space for putting a new entry.
  - ensureFreeSpace
```
public void ensureFreeSpace(DataRegion memPlc)
                     throws IgniteCheckedException
```
    See GridCacheMapEntry#ensureFreeSpace()
    
    Parameters:
    
    memPlc - data region.
    
    Throws:
    
    IgniteCheckedException
  - supportsMemoryReuse
```
public boolean supportsMemoryReuse(DataRegionConfiguration plcCfg)
```
    Parameters:
    
    plcCfg - Policy config.
    
    Returns:
    
    True if policy supports memory reuse.
  - createPageEvictionTracker
```
protected PageEvictionTracker createPageEvictionTracker(DataRegionConfiguration plc,
                                                        PageMemory pageMem)
```
    Parameters:
    
    plc - data region Configuration.
    
    pageMem - Page memory.
  - buildAllocPath
```
@Nullable
protected @Nullable File buildAllocPath(DataRegionConfiguration plc)
                                           throws IgniteCheckedException
```
    Builds allocation path for memory mapped file to be used with PageMemory.
    
    Parameters:
    
    plc - DataRegionConfiguration.
    
    Throws:
    
    IgniteCheckedException - If resolving swap directory fails.
  - createPageMemory
```
protected PageMemory createPageMemory(DirectMemoryProvider memProvider,
                                      DataStorageConfiguration memCfg,
                                      DataRegionConfiguration memPlcCfg,
                                      DataRegionMetricsImpl memMetrics,
                                      boolean trackable,
                                      PageReadWriteManager pmPageMgr)
```
    Creates PageMemory with given size and memory provider.
    
    Parameters:
    
    memProvider - Memory provider.
    
    memCfg - Memory configuartion.
    
    memPlcCfg - data region configuration.
    
    memMetrics - DataRegionMetrics to collect memory usage metrics.
    
    pmPageMgr - Page manager.
    
    Returns:
    
    PageMemory instance.
  - buildPath
```
protected File buildPath(String path,
                         String consId)
                  throws IgniteCheckedException
```
    Parameters:
    
    path - Path to the working directory.
    
    consId - Consistent ID of the local node.
    
    Returns:
    
    DB storage path.
    
    Throws:
    
    IgniteCheckedException - If resolving swap directory fails.
  - onActivate
```
public void onActivate(GridKernalContext kctx)
                throws IgniteCheckedException
```
    Called when cluster performing activation.
    
    Specified by:
    
    onActivate in interface IgniteChangeGlobalStateSupport
    
    Parameters:
    
    kctx - Kernal context.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - initAndStartRegions
```
protected void initAndStartRegions(DataStorageConfiguration cfg)
                            throws IgniteCheckedException
```
    Parameters:
    
    cfg - Current data storage configuration.
    
    Throws:
    
    IgniteCheckedException - If fails.
  - onDeActivate
```
public void onDeActivate(GridKernalContext kctx)
```
    Called when cluster performing deactivation.
    
    Specified by:
    
    onDeActivate in interface IgniteChangeGlobalStateSupport
    
    Parameters:
    
    kctx - Kernal context.
  - systemDateRegionName
```
public String systemDateRegionName()
```
    Returns:
    
    Name of DataRegionConfiguration for internal caches.
  - setPageSize
```
protected void setPageSize(int pageSize)
```
    Method for fake (standalone) context initialization. Not to be called in production code
    
    Parameters:
    
    pageSize - configured page size
  - metaStorage
```
public MetaStorage metaStorage()
```
    Returns:
    
    MetaStorage
  - notifyMetaStorageSubscribersOnReadyForRead
```
public void notifyMetaStorageSubscribersOnReadyForRead()
                                                throws IgniteCheckedException
```
    Notifies MetastorageLifecycleListener that MetaStorage is ready for read. This method is called when all processors and managers have already started and right before discovery manager.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - walEnabled
```
public boolean walEnabled(int grpId,
                          boolean local)
```
    Parameters:
    
    grpId - Group ID.
    
    Returns:
    
    WAL enabled flag.
  - walEnabled
```
public void walEnabled(int grpId,
                       boolean enabled,
                       boolean local)
```
    Marks cache group as with disabled WAL.
    
    Parameters:
    
    grpId - Group id.
    
    enabled - flag.
  - lastCheckpointInapplicableForWalRebalance
```
public void lastCheckpointInapplicableForWalRebalance(int grpId)
```
    Marks last checkpoint as inapplicable for WAL rebalance for given group grpId.
    
    Parameters:
    
    grpId - Group id.

Class IgniteCacheDatabaseSharedManager

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

Constructor Summary

Method Summary

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

Methods inherited from class java.lang.Object

Field Detail

SYSTEM_DATA_REGION_NAME

INTERNAL_DATA_REGION_NAMES

DATA_REGION_PAGE_LIST_VIEW

DATA_REGION_PAGE_LIST_VIEW_DESC

reuseMemory

dataRegionMap

dataRegionsInitialized

dfltDataRegion

freeListMap

Constructor Detail

IgniteCacheDatabaseSharedManager

Method Detail

start0

registerMetricsMBean

unregisterMetricsMBean

registerMetricsMBeans

initPageMemoryDataStructures

pageSize

initDataRegions

initDataRegions0

getDatabaseListeners

addDataRegion

addDataRegion

freeSpaceProvider

dataRegionMetricsProvider

checkPageSize

checkRegionEvictionProperties

dumpStatistics

dataRegions

memoryMetrics

persistentStoreMetrics

memoryMetrics

dataRegion

freeList

reuseList

stop0

checkpointLockIsHeldByThread

checkpointReadLock

checkpointReadUnlock

checkpointReadLockTimeout

checkpointReadLockTimeout

cleanupRestoredCaches

cleanupCheckpointDirectory

cleanupTempCheckpointDirectory

wakeupForCheckpoint

lastCheckpointMarkWalPointer

forceCheckpoint

forceNewCheckpoint

waitForCheckpoint

waitForCheckpoint

beforeExchange

startMemoryRestore

onStateRestored

rebuildIndexesIfNeeded

forceRebuildIndexes

prepareCachesStop

onCacheGroupsStopped

reserveHistoryForExchange

releaseHistoryForExchange

reserveHistoryForPreloading

releaseHistoryForPreloading

latestWalPointerReservedForPreloading

ensureFreeSpaceForInsert

ensureFreeSpace

supportsMemoryReuse

createPageEvictionTracker

buildAllocPath

createPageMemory

buildPath

onActivate

initAndStartRegions

onDeActivate