Package org.infinispan.context.impl

Class SingleKeyNonTxInvocationContext

java.lang.Object
org.infinispan.context.impl.SingleKeyNonTxInvocationContext
All Implemented Interfaces:
Cloneable, EntryLookup, InvocationContext
public final class SingleKeyNonTxInvocationContext extends Object implements InvocationContext
Author:
Mircea Markus, Sanne Grinovero

  • Constructor Details

    • SingleKeyNonTxInvocationContext

      public SingleKeyNonTxInvocationContext(Address origin)

  • Method Details

    • isOriginLocal

      public boolean isOriginLocal()
      Description copied from interface: InvocationContext
      Returns true if the call was originated locally, false if it is the result of a remote rpc.
      Specified by:
      isOriginLocal in interface InvocationContext

    • isInTxScope

      public boolean isInTxScope()
      Description copied from interface: InvocationContext
      Returns true if this call is performed in the context of an transaction, false otherwise.
      Specified by:
      isInTxScope in interface InvocationContext

    • getLockOwner

      public Object getLockOwner()
      Description copied from interface: InvocationContext
      Returns the in behalf of which locks will be acquired.
      Specified by:
      getLockOwner in interface InvocationContext

    • setLockOwner

      public void setLockOwner(Object lockOwner)
      Description copied from interface: InvocationContext
      Sets the object to be used by lock owner.
      Specified by:
      setLockOwner in interface InvocationContext

    • clone

      public InvocationContext clone()
      Description copied from interface: InvocationContext
      Clones the invocation context.
      Specified by:
      clone in interface InvocationContext
      Overrides:
      clone in class Object
      Returns:
      A cloned instance of this invocation context instance

    • getLockedKeys

      public Set<Object> getLockedKeys()
      Description copied from interface: InvocationContext
      Returns the set of keys that are locked for writing.
      Specified by:
      getLockedKeys in interface InvocationContext

    • clearLockedKeys

      public void clearLockedKeys()
      Specified by:
      clearLockedKeys in interface InvocationContext

    • addLockedKey

      public void addLockedKey(Object key)
      Description copied from interface: InvocationContext
      Tracks the given key as locked by this invocation context.
      Specified by:
      addLockedKey in interface InvocationContext

    • lookupEntry

      public CacheEntry lookupEntry(Object key)
      Description copied from interface: EntryLookup
      Retrieves an entry from the collection of looked up entries in the current scope.

      Specified by:
      lookupEntry in interface EntryLookup
      Parameters:
      key - key to look up
      Returns:
      an entry, or null if it cannot be found.

    • isKeyEquals

      public boolean isKeyEquals(Object key)

    • getLookedUpEntries

      public Map<Object,CacheEntry> getLookedUpEntries()
      Description copied from interface: EntryLookup
      Retrieves a map of entries looked up within the current scope.

      Note: The key inside the CacheEntry may be null if the key does not exist in the cache.

      Specified by:
      getLookedUpEntries in interface EntryLookup
      Returns:
      a map of looked up entries.

    • forEachEntry

      public void forEachEntry(BiConsumer<Object,CacheEntry> action)
      Description copied from interface: EntryLookup
      Execute an action for each entry in the context. Includes invalid entries, which have a null value and may also report a null key.
      Specified by:
      forEachEntry in interface EntryLookup

    • forEachValue

      public void forEachValue(BiConsumer<Object,CacheEntry> action)
      Description copied from interface: EntryLookup
      Execute an action for each value in the context.

      Entries that do not have a value (because the key was removed, or it doesn't exist in the cache).

      Specified by:
      forEachValue in interface EntryLookup

    • publisher

      public <K, V> org.reactivestreams.Publisher<CacheEntry<K,V>> publisher()
      Description copied from interface: EntryLookup
      Returns a Publisher that when subscribed to provide all values that have a value in the given context.
      Specified by:
      publisher in interface EntryLookup
      Type Parameters:
      K - key type provided from user
      V - value type provided from user
      Returns:

    • lookedUpEntriesCount

      public int lookedUpEntriesCount()
      Specified by:
      lookedUpEntriesCount in interface EntryLookup
      Returns:
      The number of entries wrapped in the context, including invalid entries.

    • putLookedUpEntry

      public void putLookedUpEntry(Object key, CacheEntry e)
      Description copied from interface: EntryLookup
      Puts an entry in the registry of looked up entries in the current scope.

      Specified by:
      putLookedUpEntry in interface EntryLookup
      Parameters:
      key - key to store
      e - entry to store

    • removeLookedUpEntry

      public void removeLookedUpEntry(Object key)
      Specified by:
      removeLookedUpEntry in interface EntryLookup

    • getKey

      public Object getKey()

    • getCacheEntry

      public CacheEntry getCacheEntry()

    • getOrigin

      public Address getOrigin()
      Specified by:
      getOrigin in interface InvocationContext
      Returns:
      the origin of the command, or null if the command originated locally

    • hasLockedKey

      public boolean hasLockedKey(Object key)
      Description copied from interface: InvocationContext
      Returns true if the lock being tested is already held in the current scope, false otherwise.
      Specified by:
      hasLockedKey in interface InvocationContext
      Parameters:
      key - lock to test

    • isEntryRemovedInContext

      public boolean isEntryRemovedInContext(Object key)
      Specified by:
      isEntryRemovedInContext in interface InvocationContext

    • resetState

      public void resetState()

    • toString

      public String toString()
      Overrides:
      toString in class Object