Package org.infinispan.distribution

Interface L1Manager

public interface L1Manager

Manages the L1 Cache, in particular recording anyone who is going to cache an a command that a node responds to so that a unicast invalidation can be sent later if needed.

Author:

Pete Muir

Method Summary

Modifier and Type	Method	Description
void	addRequestor(Object key, org.infinispan.remoting.transport.Address requestor)	Records a request that will be cached in another nodes L1
CompletableFuture<?>	flushCache(Collection<Object> key, org.infinispan.remoting.transport.Address origin, boolean assumeOriginKeptEntryInL1)
void	registerL1WriteSynchronizer(Object key, org.infinispan.interceptors.distribution.L1WriteSynchronizer sync)	Registers the given write synchronizer to be notified whenever a remote value is looked up for the given key.
void	unregisterL1WriteSynchronizer(Object key, org.infinispan.interceptors.distribution.L1WriteSynchronizer sync)	Unregister the given write synchronizer if present.

Method Detail

addRequestor

void addRequestor(Object key,
                  org.infinispan.remoting.transport.Address requestor)

Records a request that will be cached in another nodes L1

flushCache

CompletableFuture<?> flushCache(Collection<Object> key,
                                org.infinispan.remoting.transport.Address origin,
                                boolean assumeOriginKeptEntryInL1)

registerL1WriteSynchronizer

void registerL1WriteSynchronizer(Object key,
                                 org.infinispan.interceptors.distribution.L1WriteSynchronizer sync)

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 unregisterL1WriteSynchronizer(Object, org.infinispan.interceptors.distribution.L1WriteSynchronizer)

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

void unregisterL1WriteSynchronizer(Object key,
                                   org.infinispan.interceptors.distribution.L1WriteSynchronizer sync)

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

Parameters:

key - The key to unregister the given synchronizer for.

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