org.gridgain.grid.kernal.managers.swapspace

Class GridSwapSpaceManager

java.lang.Object

org.gridgain.grid.kernal.managers.GridManagerAdapter<GridSwapSpaceSpi>

org.gridgain.grid.kernal.managers.swapspace.GridSwapSpaceManager

All Implemented Interfaces:

GridComponent, GridManager

public class GridSwapSpaceManager
extends GridManagerAdapter<GridSwapSpaceSpi>

Field Summary

Fields inherited from class org.gridgain.grid.kernal.managers.GridManagerAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridSwapSpaceManager(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear(String spaceName)
<K> GridCloseableIterator<K>	keysIterator(String spaceName, ClassLoader ldr) Gets iterator over space entries.
protected void	onKernalStop0(boolean cancel)
GridCloseableIterator<Map.Entry<byte[],byte[]>>	rawIterator(String spaceName) Gets iterator over space entries.
GridCloseableIterator<Map.Entry<byte[],byte[]>>	rawIterator(String spaceName, int part)
byte[]	read(String spaceName, GridSwapKey key, ClassLoader ldr) Reads value from swap.
<T> T	read(String spaceName, Object key, ClassLoader ldr) Reads value from swap.
<T> T	readValue(String spaceName, GridSwapKey key, ClassLoader ldr) Reads value from swap.
void	remove(String spaceName, GridSwapKey key, GridInClosure<byte[]> c, ClassLoader ldr) Removes value from swap.
void	remove(String spaceName, Object key, GridInClosure<byte[]> c, ClassLoader ldr) Removes value from swap.
void	removeAll(String spaceName, Collection<GridSwapKey> keys, GridBiInClosure<GridSwapKey,byte[]> c, ClassLoader ldr) Removes value from swap.
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.
long	swapKeys(String spaceName) Gets number of swap entries (keys).
long	swapSize(String spaceName) Gets size in bytes for swap space.
void	write(String spaceName, GridSwapKey key, byte[] val, ClassLoader ldr) Writes value to swap.
void	write(String spaceName, Object key, Object val, ClassLoader ldr) Writes value to swap.
<K,V> void	writeAll(String spaceName, Iterable<GridCacheBatchSwapEntry<K,V>> swapped, ClassLoader ldr) Writes batch to swap.

Methods inherited from class org.gridgain.grid.kernal.managers.GridManagerAdapter

addSpiAttributes, assertParameter, collectDiscoveryData, enabled, getSpi, getSpi, getSpis, onDiscoveryDataReceived, onKernalStart, onKernalStart0, onKernalStop, printMemoryStats, startInfo, startSpi, stopInfo, stopSpi, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridSwapSpaceManager

public GridSwapSpaceManager(GridKernalContext ctx)

Parameters:

ctx - Grid kernal context.

Method Detail

start

public void start()
           throws GridException

Starts grid component.

Throws:

GridException - Throws in case of any errors.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridManagerAdapter<GridSwapSpaceSpi>

Parameters:

cancel - Cancel flag.

stop

public void stop(boolean cancel)
          throws GridException

Stops grid component.

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

Throws:

GridException - Thrown in case of any errors.

read

@Nullable
public byte[] read(@Nullable
                   String spaceName,
                   GridSwapKey key,
                   @Nullable
                   ClassLoader ldr)
            throws GridException

Reads value from swap.

Parameters:

spaceName - Space name.

key - Key.

ldr - Class loader (optional).

Returns:

Value.

Throws:

GridException - If failed.

read

@Nullable
public <T> T read(@Nullable
                  String spaceName,
                  Object key,
                  @Nullable
                  ClassLoader ldr)
       throws GridException

Reads value from swap.

Parameters:

spaceName - Space name.

key - Key.

ldr - Class loader (optional).

Returns:

Value.

Throws:

GridException - If failed.

readValue

@Nullable
public <T> T readValue(@Nullable
                       String spaceName,
                       GridSwapKey key,
                       @Nullable
                       ClassLoader ldr)
            throws GridException

Reads value from swap.

Parameters:

spaceName - Space name.

key - Swap key.

ldr - Class loader (optional).

Returns:

Value.

Throws:

GridException - If failed.

write

public void write(@Nullable
         String spaceName,
         GridSwapKey key,
         byte[] val,
         @Nullable
         ClassLoader ldr)
           throws GridException

Writes value to swap.

Parameters:

spaceName - Space name.

key - Key.

val - Value.

ldr - Class loader (optional).

Throws:

GridException - If failed.

writeAll

public <K,V> void writeAll(String spaceName,
                  Iterable<GridCacheBatchSwapEntry<K,V>> swapped,
                  @Nullable
                  ClassLoader ldr)
              throws GridException

Writes batch to swap.

Parameters:

spaceName - Space name.

swapped - Swapped entries.

ldr - Class loader (optional).

Throws:

GridException - If failed.

write

public void write(@Nullable
         String spaceName,
         Object key,
         @Nullable
         Object val,
         @Nullable
         ClassLoader ldr)
           throws GridException

Writes value to swap.

Parameters:

spaceName - Space name.

key - Key.

val - Value.

ldr - Class loader (optional).

Throws:

GridException - If failed.

remove

public void remove(@Nullable
          String spaceName,
          GridSwapKey key,
          @Nullable
          GridInClosure<byte[]> c,
          @Nullable
          ClassLoader ldr)
            throws GridException

Removes value from swap.

Parameters:

spaceName - Space name.

key - Key.

c - Optional closure that takes removed value and executes after actual removing. If there was no value in storage the closure is executed given null value as parameter.

ldr - Class loader (optional).

Throws:

GridException - If failed.

removeAll

public void removeAll(@Nullable
             String spaceName,
             Collection<GridSwapKey> keys,
             GridBiInClosure<GridSwapKey,byte[]> c,
             @Nullable
             ClassLoader ldr)
               throws GridException

Removes value from swap.

Parameters:

spaceName - Space name.

keys - Collection of keys.

c - Optional closure that takes removed value and executes after actual removing. If there was no value in storage the closure is executed given null value as parameter.

ldr - Class loader (optional).

Throws:

GridException - If failed.

remove

public void remove(@Nullable
          String spaceName,
          Object key,
          @Nullable
          GridInClosure<byte[]> c,
          @Nullable
          ClassLoader ldr)
            throws GridException

Removes value from swap.

Parameters:

spaceName - Space name.

key - Key.

c - Optional closure that takes removed value and executes after actual removing. If there was no value in storage the closure is executed given null value as parameter.

ldr - Class loader (optional).

Throws:

GridException - If failed.

swapSize

public long swapSize(@Nullable
            String spaceName)
              throws GridException

Gets size in bytes for swap space.

Parameters:

spaceName - Space name.

Returns:

Swap size.

Throws:

GridException - If failed.

swapKeys

public long swapKeys(@Nullable
            String spaceName)
              throws GridException

Gets number of swap entries (keys).

Parameters:

spaceName - Space name.

Returns:

Number of stored entries in swap space.

Throws:

GridException - If failed.

clear

public void clear(@Nullable
         String spaceName)
           throws GridException

Parameters:

spaceName - Space name.

Throws:

GridException - If failed.

rawIterator

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

Gets iterator over space entries.

Parameters:

spaceName - Space name.

Returns:

Iterator over space entries or null if space is unknown.

Throws:

GridSpiException - If failed.

GridException

rawIterator

@Nullable
public GridCloseableIterator<Map.Entry<byte[],byte[]>> rawIterator(@Nullable
                                                                   String spaceName,
                                                                   int part)
                                                            throws GridException

Throws:

GridException

keysIterator

@Nullable
public <K> GridCloseableIterator<K> keysIterator(@Nullable
                                                 String spaceName,
                                                 @Nullable
                                                 ClassLoader ldr)
                                      throws GridException

Gets iterator over space entries.

Parameters:

spaceName - Space name.

ldr - Class loader.

Returns:

Iterator over space entries or null if space is unknown.

Throws:

GridSpiException - If failed.

GridException