org.infinispan.distribution

Class L1ManagerImpl

java.lang.Object

org.infinispan.distribution.L1ManagerImpl

All Implemented Interfaces:

L1Manager, RemoteValueRetrievedListener

public class L1ManagerImpl
extends Object
implements L1Manager, RemoteValueRetrievedListener

Constructor Summary

Constructors

Constructor and Description
L1ManagerImpl()

Method Summary

Modifier and Type	Method and Description
void	addRequestor(Object key, Address origin) Records a request that will be cached in another nodes L1
Future<Object>	flushCache(Collection<Object> keys, Address origin, boolean assumeOriginKeptEntryInL1)
Future<Object>	flushCacheWithSimpleFuture(Collection<Object> keys, Object retval, Address origin, boolean assumeOriginKeptEntryInL1)
void	init(Configuration configuration, RpcManager rpcManager, CommandsFactory commandsFactory, ExecutorService asyncTransportExecutor, ScheduledExecutorService scheduledExecutor, TimeService timeService)
void	registerL1WriteSynchronizer(Object key, L1WriteSynchronizer sync) Registers the given write synchronizer to be notified whenever a remote value is looked up for the given key.
void	remoteValueFound(InternalCacheEntry ice) Invoked when a remote value is found from a remote source
void	start()
void	stop()
void	unregisterL1WriteSynchronizer(Object key, L1WriteSynchronizer sync) Unregister the given write synchronizer if present.

Methods inherited from class java.lang.Object

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

Constructor Detail

L1ManagerImpl

public L1ManagerImpl()

Method Detail

init

public void init(Configuration configuration,
                 RpcManager rpcManager,
                 CommandsFactory commandsFactory,
                 ExecutorService asyncTransportExecutor,
                 ScheduledExecutorService scheduledExecutor,
                 TimeService timeService)

start

public void start()

stop

public void stop()

addRequestor

public void addRequestor(Object key,
                         Address origin)

Description copied from interface: L1Manager

Records a request that will be cached in another nodes L1

Specified by:

addRequestor in interface L1Manager

flushCacheWithSimpleFuture

public Future<Object> flushCacheWithSimpleFuture(Collection<Object> keys,
                                                 Object retval,
                                                 Address origin,
                                                 boolean assumeOriginKeptEntryInL1)

Specified by:

flushCacheWithSimpleFuture in interface L1Manager

flushCache

public Future<Object> flushCache(Collection<Object> keys,
                                 Address origin,
                                 boolean assumeOriginKeptEntryInL1)

Specified by:

flushCache in interface L1Manager

registerL1WriteSynchronizer

public void registerL1WriteSynchronizer(Object key,
                                        L1WriteSynchronizer sync)

Description copied from interface: L1Manager

Registers the given write synchronizer to be notified whenever a remote value is looked up for the given key. If the synchronizer is no longer needed to be signaled, the user should unregister it using L1Manager.unregisterL1WriteSynchronizer(Object, org.infinispan.interceptors.distribution.L1WriteSynchronizer)

Specified by:

registerL1WriteSynchronizer in interface L1Manager

Parameters:

key - The key that that when looked up will trigger the synchronizer

sync - The synchronizer to run the update when the key is looked up

unregisterL1WriteSynchronizer

public void unregisterL1WriteSynchronizer(Object key,
                                          L1WriteSynchronizer sync)

Description copied from interface: L1Manager

Unregister the given write synchronizer if present. Note the synchronizer is only unregistered if it matches using instance equality (==) due to possibly concurrent usage of write synchronizers

Specified by:

unregisterL1WriteSynchronizer in interface L1Manager

Parameters:

key - The key to unregister the given synchronizer for.

sync - The synchronizer to be removed if it is still present.

remoteValueFound

public void remoteValueFound(InternalCacheEntry ice)

Description copied from interface: RemoteValueRetrievedListener

Invoked when a remote value is found from a remote source

Specified by:

remoteValueFound in interface RemoteValueRetrievedListener

Parameters:

ice - The cache entry that was found