org.gridgain.grid.kernal.processors.cache

Class GridCachePreloaderAdapter<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.GridCachePreloaderAdapter<K,V>

All Implemented Interfaces:

GridCachePreloader<K,V>

Direct Known Subclasses:

GridDhtPreloader

public class GridCachePreloaderAdapter<K,V>
extends Object
implements GridCachePreloader<K,V>

Adapter for preloading which always assumes that preloading finished.

Field Summary

Fields

Modifier and Type	Field and Description
protected GridCacheAffinityFunction	aff Affinity.
protected GridCacheContext<K,V>	cctx Cache context.
protected GridLogger	log Logger.
protected GridPredicate<GridCacheEntryInfo<K,V>>	preloadPred Preload predicate.

Constructor Summary

Constructors

Constructor and Description
GridCachePreloaderAdapter(GridCacheContext<K,V> cctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	forcePreload() Force preload process.
void	onKernalStart() Kernal start callback.
void	onKernalStop() Kernal stop callback.
GridPredicate<GridCacheEntryInfo<K,V>>	preloadPredicate()
void	preloadPredicate(GridPredicate<GridCacheEntryInfo<K,V>> preloadPred)
GridFuture<Object>	request(Collection<? extends K> keys, long topVer) Requests that preloader sends the request for the key.
void	start() Starts preloading.
GridFuture<?>	startFuture()
void	stop() Stops preloading.
GridFuture<?>	syncFuture()
void	unwindUndeploys() Unwinds undeploys.

Methods inherited from class java.lang.Object

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

Field Detail

cctx

protected final GridCacheContext<K,V> cctx

Cache context.

log

protected final GridLogger log

Logger.

aff

protected final GridCacheAffinityFunction aff

Affinity.

preloadPred

protected GridPredicate<GridCacheEntryInfo<K,V>> preloadPred

Preload predicate.

Constructor Detail

GridCachePreloaderAdapter

public GridCachePreloaderAdapter(GridCacheContext<K,V> cctx)

Parameters:

cctx - Cache context.

Method Detail

start

public void start()
           throws GridException

Starts preloading.

Specified by:

start in interface GridCachePreloader<K,V>

Throws:

GridException - If start failed.

stop

public void stop()

Stops preloading.

Specified by:

stop in interface GridCachePreloader<K,V>

onKernalStart

public void onKernalStart()
                   throws GridException

Kernal start callback.

Specified by:

onKernalStart in interface GridCachePreloader<K,V>

Throws:

GridException - If failed.

onKernalStop

public void onKernalStop()

Kernal stop callback.

Specified by:

onKernalStop in interface GridCachePreloader<K,V>

forcePreload

public void forcePreload()

Force preload process.

Specified by:

forcePreload in interface GridCachePreloader<K,V>

preloadPredicate

public void preloadPredicate(GridPredicate<GridCacheEntryInfo<K,V>> preloadPred)

Specified by:

preloadPredicate in interface GridCachePreloader<K,V>

Parameters:

preloadPred - Preload predicate.

preloadPredicate

public GridPredicate<GridCacheEntryInfo<K,V>> preloadPredicate()

Specified by:

preloadPredicate in interface GridCachePreloader<K,V>

Returns:

Preload predicate. If not null, will evaluate each preloaded entry during send and receive, and if predicate evaluates to false, entry will be skipped.

startFuture

public GridFuture<?> startFuture()

Specified by:

startFuture in interface GridCachePreloader<K,V>

Returns:

Future which will complete when preloader is safe to use.

syncFuture

public GridFuture<?> syncFuture()

Specified by:

syncFuture in interface GridCachePreloader<K,V>

Returns:

Future which will complete when preloading is finished.

unwindUndeploys

public void unwindUndeploys()

Unwinds undeploys.

Specified by:

unwindUndeploys in interface GridCachePreloader<K,V>

request

public GridFuture<Object> request(Collection<? extends K> keys,
                         long topVer)

Requests that preloader sends the request for the key.

Specified by:

request in interface GridCachePreloader<K,V>

Parameters:

keys - Keys to request.

topVer - Topology version, -1 if not required.

Returns:

Future to complete when all keys are preloaded.