org.apache.ignite.internal.processors.cache

Class GridCacheSwapManager

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

org.apache.ignite.internal.processors.cache.GridCacheSwapManager

All Implemented Interfaces:

GridCacheManager

public class GridCacheSwapManager
extends GridCacheManagerAdapter

Handles all swap operations.

Field Summary

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

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheSwapManager(boolean enabled)

Method Summary

Methods

Modifier and Type	Method and Description
void	addOffHeapListener(int part, GridCacheSwapListener lsnr)
void	addSwapListener(int part, GridCacheSwapListener lsnr)
void	clearSwap() Clears swap.
boolean	containsKey(KeyCacheObject key, int part)
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry>>	iterator(int part) Gets offheap and swap iterator over partition.
<K,V> Iterator<Map.Entry<K,V>>	lazyOffHeapIterator(boolean keepBinary)
<K,V> Iterator<Map.Entry<K,V>>	lazySwapIterator(boolean keepBinary)
long	offHeapAllocatedSize() Gets memory size allocated in off-heap.
boolean	offHeapEnabled()
long	offHeapEntriesCount() Gets number of elements in off-heap
int	offheapEntriesCount(boolean primary, boolean backup, AffinityTopologyVersion topVer)
long	offheapEntriesCount(int partId)
<K,V> Iterator<javax.cache.Cache.Entry<K,V>>	offheapIterator(boolean primary, boolean backup, AffinityTopologyVersion topVer, boolean keepBinary)
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry>>	offHeapIterator(int part) Gets offheap iterator over partition.
Iterator<KeyCacheObject>	offHeapKeyIterator(boolean primary, boolean backup, AffinityTopologyVersion topVer)
int	onUndeploy(ClassLoader ldr)
GridCloseableIterator<Map.Entry<byte[],byte[]>>	rawIterator() Gets offheap and swap iterator over partition.
<T> GridCloseableIterator<T>	rawOffHeapIterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c, Integer part, boolean primary, boolean backup)
GridCloseableIterator<Map.Entry<byte[],byte[]>>	rawOffHeapIterator(Integer part, boolean primary, boolean backup)
GridCloseableIterator<Map.Entry<byte[],byte[]>>	rawSwapIterator(boolean primary, boolean backup)
GridCloseableIterator<Map.Entry<byte[],byte[]>>	rawSwapIterator(boolean primary, boolean backup, AffinityTopologyVersion topVer)
GridCloseableIterator<Map.Entry<byte[],byte[]>>	rawSwapIterator(int part)
Collection<GridCacheBatchSwapEntry>	readAndRemove(Collection<? extends KeyCacheObject> keys)
GridCacheSwapEntry	readOffheapBeforeRemove(KeyCacheObject key, byte[] keyBytes, int part) Reads value from offheap and unswaps it for indexing.
CacheObject	readValue(KeyCacheObject key, boolean readOffheap, boolean readSwap)
void	remove(KeyCacheObject key, int part)
void	removeOffHeapListener(int part, GridCacheSwapListener lsnr)
void	removeSwapListener(int part, GridCacheSwapListener lsnr)
String	spaceName()
void	start0()
protected void	stop0(boolean cancel)
boolean	swapEnabled()
int	swapEntriesCount(boolean primary, boolean backup, AffinityTopologyVersion topVer)
long	swapEntriesCount(int partId)
<K,V> Iterator<javax.cache.Cache.Entry<K,V>>	swapIterator(boolean primary, boolean backup, AffinityTopologyVersion topVer, boolean keepBinary)
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry>>	swapIterator(int part) Gets swap space iterator over partition.
Iterator<KeyCacheObject>	swapKeyIterator(boolean primary, boolean backup, AffinityTopologyVersion topVer)
long	swapKeys() Gets number of swap entries (keys).
long	swapSize()
CacheObject	unmarshalSwapEntryValue(byte[] bytes)
void	unwindOffheapEvicts()
void	writeToSwap(int part, KeyCacheObject key, byte[] entry) Writes given bytes to swap.

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

context, kernalStartInfo, kernalStopInfo, log, onDisconnected, onKernalStart, onKernalStart0, onKernalStop, onKernalStop0, printMemoryStats, start, startInfo, stop, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheSwapManager

public GridCacheSwapManager(boolean enabled)

Parameters:

enabled - Flag to indicate if swap is enabled.

Method Detail

start0

public void start0()
            throws IgniteCheckedException

Overrides:

start0 in class GridCacheManagerAdapter

Throws:

IgniteCheckedException - If failed.

stop0

protected void stop0(boolean cancel)

Overrides:

stop0 in class GridCacheManagerAdapter

Parameters:

cancel - Cancel flag.

unwindOffheapEvicts

public void unwindOffheapEvicts()

swapEnabled

public boolean swapEnabled()

Returns:

True if swap store is enabled.

offHeapEnabled

public boolean offHeapEnabled()

Returns:

True if off-heap cache is enabled.

swapSize

public long swapSize()
              throws IgniteCheckedException

Returns:

Swap size.

Throws:

IgniteCheckedException - If failed.

swapEntriesCount

public int swapEntriesCount(boolean primary,
                   boolean backup,
                   AffinityTopologyVersion topVer)
                     throws IgniteCheckedException

Parameters:

primary - If true includes primary entries.

backup - If true includes backup entries.

topVer - Topology version.

Returns:

Number of swap entries.

Throws:

IgniteCheckedException - If failed.

swapEntriesCount

public long swapEntriesCount(int partId)
                      throws IgniteCheckedException

Parameters:

partId - Partition ID to get swap entries count for.

Returns:

Number of swap entries.

Throws:

IgniteCheckedException - If failed.

offheapEntriesCount

public int offheapEntriesCount(boolean primary,
                      boolean backup,
                      AffinityTopologyVersion topVer)
                        throws IgniteCheckedException

Parameters:

primary - If true includes primary entries.

backup - If true includes backup entries.

topVer - Topology version.

Returns:

Number of offheap entries.

Throws:

IgniteCheckedException - If failed.

offheapEntriesCount

public long offheapEntriesCount(int partId)
                         throws IgniteCheckedException

Parameters:

partId - Partition ID to get entries count for.

Returns:

Number of offheap entries.

Throws:

IgniteCheckedException - If failed.

swapKeys

public long swapKeys()
              throws IgniteCheckedException

Gets number of swap entries (keys).

Returns:

Swap keys count.

Throws:

IgniteCheckedException - If failed.

addSwapListener

public void addSwapListener(int part,
                   GridCacheSwapListener lsnr)

Parameters:

part - Partition.

lsnr - Listener.

removeSwapListener

public void removeSwapListener(int part,
                      GridCacheSwapListener lsnr)

Parameters:

part - Partition.

lsnr - Listener.

addOffHeapListener

public void addOffHeapListener(int part,
                      GridCacheSwapListener lsnr)

Parameters:

part - Partition.

lsnr - Listener.

removeOffHeapListener

public void removeOffHeapListener(int part,
                         GridCacheSwapListener lsnr)

Parameters:

part - Partition.

lsnr - Listener.

containsKey

public boolean containsKey(KeyCacheObject key,
                  int part)
                    throws IgniteCheckedException

Parameters:

key - Key to check.

part - Partition.

Returns:

True if key is contained.

Throws:

IgniteCheckedException - If failed.

readValue

@Nullable
public CacheObject readValue(KeyCacheObject key,
                             boolean readOffheap,
                             boolean readSwap)
                      throws IgniteCheckedException

Parameters:

key - Key to read swap entry for.

readOffheap - Read offheap flag.

readSwap - Read swap flag.

Returns:

Read value.

Throws:

IgniteCheckedException - If read failed.

readAndRemove

public Collection<GridCacheBatchSwapEntry> readAndRemove(Collection<? extends KeyCacheObject> keys)
                                                  throws IgniteCheckedException

Parameters:

keys - Collection of keys to remove from swap.

Returns:

Collection of swap entries.

Throws:

IgniteCheckedException - If failed,

readOffheapBeforeRemove

public GridCacheSwapEntry readOffheapBeforeRemove(KeyCacheObject key,
                                         byte[] keyBytes,
                                         int part)
                                           throws IgniteCheckedException

Reads value from offheap and unswaps it for indexing.

Parameters:

key - Key.

keyBytes - Key bytes.

part - Partition.

Returns:

Swap entry.

Throws:

IgniteCheckedException - If failed.

remove

public void remove(KeyCacheObject key,
          int part)
            throws IgniteCheckedException

Parameters:

key - Key to remove.

part - Partition.

Throws:

IgniteCheckedException - If failed.

writeToSwap

public void writeToSwap(int part,
               KeyCacheObject key,
               byte[] entry)
                 throws IgniteCheckedException

Writes given bytes to swap.

Parameters:

part - Partition.

key - Key. If null then it will be deserialized from keyBytes.

entry - Entry bytes.

Throws:

IgniteCheckedException - If failed.

clearSwap

public void clearSwap()
               throws IgniteCheckedException

Clears swap.

Throws:

IgniteCheckedException - If failed.

iterator

@Nullable
public GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry>> iterator(int part)
                                                                     throws IgniteCheckedException

Gets offheap and swap iterator over partition.

Parameters:

part - Partition to iterate over.

Returns:

Iterator over partition.

Throws:

IgniteCheckedException - If failed.

rawIterator

@Nullable
public GridCloseableIterator<Map.Entry<byte[],byte[]>> rawIterator()
                                                            throws IgniteCheckedException

Gets offheap and swap iterator over partition.

Returns:

Iterator over partition.

Throws:

IgniteCheckedException - If failed.

lazySwapIterator

public <K,V> Iterator<Map.Entry<K,V>> lazySwapIterator(boolean keepBinary)
                                          throws IgniteCheckedException

Parameters:

keepBinary - Keep binary flag.

Returns:

Lazy swap iterator.

Throws:

IgniteCheckedException - If failed.

offHeapKeyIterator

public Iterator<KeyCacheObject> offHeapKeyIterator(boolean primary,
                                          boolean backup,
                                          AffinityTopologyVersion topVer)

Returns:

Iterator over off-heap keys.

swapKeyIterator

public Iterator<KeyCacheObject> swapKeyIterator(boolean primary,
                                       boolean backup,
                                       AffinityTopologyVersion topVer)
                                         throws IgniteCheckedException

Returns:

Iterator over off-heap keys.

Throws:

IgniteCheckedException

lazyOffHeapIterator

public <K,V> Iterator<Map.Entry<K,V>> lazyOffHeapIterator(boolean keepBinary)

Parameters:

keepBinary - Keep binary flag.

Returns:

Lazy off-heap iterator.

offHeapEntriesCount

public long offHeapEntriesCount()

Gets number of elements in off-heap

Returns:

Number of elements or 0 if off-heap is disabled.

offHeapAllocatedSize

public long offHeapAllocatedSize()

Gets memory size allocated in off-heap.

Returns:

Allocated memory size or 0 if off-heap is disabled.

offHeapIterator

@Nullable
public GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry>> offHeapIterator(int part)
                                                                            throws IgniteCheckedException

Gets offheap iterator over partition.

Parameters:

part - Partition to iterate over.

Returns:

Iterator over partition.

Throws:

IgniteCheckedException - If failed.

rawOffHeapIterator

public <T> GridCloseableIterator<T> rawOffHeapIterator(CX2<T2<Long,Integer>,T2<Long,Integer>,T> c,
                                              @Nullable
                                              Integer part,
                                              boolean primary,
                                              boolean backup)

Parameters:

c - Key/value closure.

part - Partition.

primary - Include primaries.

backup - Include backups.

Returns:

Off-heap iterator.

rawOffHeapIterator

public GridCloseableIterator<Map.Entry<byte[],byte[]>> rawOffHeapIterator(@Nullable
                                                                 Integer part,
                                                                 boolean primary,
                                                                 boolean backup)

Parameters:

part - Partition.

primary - Include primaries.

backup - Include backups.

Returns:

Raw off-heap iterator.

swapIterator

@Nullable
public GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry>> swapIterator(int part)
                                                                         throws IgniteCheckedException

Gets swap space iterator over partition.

Parameters:

part - Partition to iterate over.

Returns:

Iterator over partition.

Throws:

IgniteCheckedException - If failed.

rawSwapIterator

public GridCloseableIterator<Map.Entry<byte[],byte[]>> rawSwapIterator(boolean primary,
                                                              boolean backup)
                                                                throws IgniteCheckedException

Parameters:

primary - Include primaries.

backup - Include backups.

Returns:

Raw off-heap iterator.

Throws:

IgniteCheckedException - If failed.

rawSwapIterator

public GridCloseableIterator<Map.Entry<byte[],byte[]>> rawSwapIterator(boolean primary,
                                                              boolean backup,
                                                              AffinityTopologyVersion topVer)
                                                                throws IgniteCheckedException

Parameters:

primary - Include primaries.

backup - Include backups.

topVer - Affinity topology version.

Returns:

Raw off-heap iterator.

Throws:

IgniteCheckedException - If failed.

rawSwapIterator

public GridCloseableIterator<Map.Entry<byte[],byte[]>> rawSwapIterator(int part)
                                                                throws IgniteCheckedException

Parameters:

part - Partition.

Returns:

Raw off-heap iterator.

Throws:

IgniteCheckedException - If failed.

swapIterator

public <K,V> Iterator<javax.cache.Cache.Entry<K,V>> swapIterator(boolean primary,
                                                        boolean backup,
                                                        AffinityTopologyVersion topVer,
                                                        boolean keepBinary)
                                                    throws IgniteCheckedException

Parameters:

primary - If true includes primary entries.

backup - If true includes backup entries.

topVer - Topology version.

keepBinary - Keep binary flag.

Returns:

Swap entries iterator.

Throws:

IgniteCheckedException - If failed.

offheapIterator

public <K,V> Iterator<javax.cache.Cache.Entry<K,V>> offheapIterator(boolean primary,
                                                           boolean backup,
                                                           AffinityTopologyVersion topVer,
                                                           boolean keepBinary)
                                                       throws IgniteCheckedException

Parameters:

primary - If true includes primary entries.

backup - If true includes backup entries.

topVer - Topology version.

keepBinary - Keep binary flag.

Returns:

Offheap entries iterator.

Throws:

IgniteCheckedException - If failed.

onUndeploy

public int onUndeploy(ClassLoader ldr)

Parameters:

ldr - Undeployed class loader.

Returns:

Undeploy count.

spaceName

public String spaceName()

Returns:

Swap space name.

unmarshalSwapEntryValue

public CacheObject unmarshalSwapEntryValue(byte[] bytes)
                                    throws IgniteCheckedException

Parameters:

bytes - Bytes to unmarshal.

Returns:

Unmarshalled values.

Throws:

IgniteCheckedException - If failed.