Package org.infinispan.container.offheap

Class BoundedOffHeapDataContainer

java.lang.Object

org.infinispan.container.impl.AbstractDelegatingDataContainer<K,V>

org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

org.infinispan.container.offheap.SegmentedBoundedOffHeapDataContainer

org.infinispan.container.offheap.BoundedOffHeapDataContainer

All Implemented Interfaces:

Iterable<InternalCacheEntry<WrappedBytes,WrappedBytes>>, DataContainer<WrappedBytes,WrappedBytes>, org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

public class BoundedOffHeapDataContainer
extends SegmentedBoundedOffHeapDataContainer

Since:

9.4

Author:

wburns

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.container.DataContainer

DataContainer.ComputeAction<K,V>

Field Summary

Fields

Modifier and Type	Field	Description
protected List<Consumer<Iterable<InternalCacheEntry<WrappedBytes,WrappedBytes>>>>	listeners

Fields inherited from class org.infinispan.container.offheap.SegmentedBoundedOffHeapDataContainer

allocator, currentSize, dataContainer, evictionManager, firstAddress, lastAddress, lruLock, maxSize, offHeapEntryFactory, passivator, useCount

Constructor Summary

Constructors

Constructor	Description
BoundedOffHeapDataContainer(int addressCount, long maxSize, EvictionType type)

Method Summary

Modifier and Type	Method	Description
void	addRemovalListener(Consumer<Iterable<InternalCacheEntry<WrappedBytes,WrappedBytes>>> listener)	Adds a listener that is invoked whenever InternalDataContainer.removeSegments(IntSet) is invoked providing a way for the listener to see what actual entries were removed from the container.
void	addSegments(IntSet segments)	Sets what segments this data container should be using.
InternalCacheEntry<WrappedBytes,WrappedBytes>	compute(int segment, WrappedBytes key, DataContainer.ComputeAction<WrappedBytes,WrappedBytes> action)	Same as DataContainer.compute(Object, ComputeAction) except that the segment of the key can provided to update entries without calculating the segment for the given key.
InternalCacheEntry<WrappedBytes,WrappedBytes>	compute(WrappedBytes key, DataContainer.ComputeAction<WrappedBytes,WrappedBytes> action)	Computes the new value for the key.
boolean	containsKey(int segment, Object k)	Same as DataContainer.containsKey(Object) except that the segment of the key can provided to lookup if the entry exists without calculating the segment for the given key.
boolean	containsKey(Object k)	Tests whether an entry exists in the container
void	evict(int segment, WrappedBytes key)	Same as DataContainer.evict(Object) except that the segment of the key can provided to remove the entry without calculating the segment for the given key.
void	evict(WrappedBytes key)	Atomically, it removes the key from DataContainer and passivates it to persistence.
InternalCacheEntry<WrappedBytes,WrappedBytes>	get(int segment, Object k)	Same as DataContainer.get(Object) except that the segment of the key can provided to lookup entries without calculating the segment for the given key
InternalCacheEntry<WrappedBytes,WrappedBytes>	get(Object k)	Retrieves a cached entry
protected OffHeapConcurrentMap	getMapThatContainsKey(byte[] key)
Iterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	iterator(IntSet segments)	Same as DataContainer.iterator() except that only entries that map to the provided segments are returned via the iterator.
Iterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	iteratorIncludingExpired(IntSet segments)	Same as DataContainer.iteratorIncludingExpired() except that only entries that map to the provided segments are returned via the iterator.
InternalCacheEntry<WrappedBytes,WrappedBytes>	peek(int segment, Object k)	Same as DataContainer.peek(Object) except that the segment of the key can provided to lookup entries without calculating the segment for the given key
InternalCacheEntry<WrappedBytes,WrappedBytes>	peek(Object k)	Retrieves a cache entry in the same way as DataContainer.get(Object)} except that it does not update or reorder any of the internal constructs.
void	put(int segment, WrappedBytes key, WrappedBytes value, Metadata metadata, long createdTimestamp, long lastUseTimestamp)	Same as DataContainer.put(Object, Object, Metadata) except that the segment of the key can provided to write/lookup entries without calculating the segment for the given key.
void	put(WrappedBytes key, WrappedBytes value, Metadata metadata)	Puts an entry in the cache along with metadata adding information such lifespan of entry, max idle time, version information...etc.
InternalCacheEntry<WrappedBytes,WrappedBytes>	remove(int segment, Object k)	Same as DataContainer.remove(Object) except that the segment of the key can provided to remove the entry without calculating the segment for the given key.
InternalCacheEntry<WrappedBytes,WrappedBytes>	remove(Object k)	Removes an entry from the cache
void	removeRemovalListener(Object listener)	Removes a previously registered listener via InternalDataContainer.addRemovalListener(Consumer).
void	removeSegments(IntSet segments)	Removes and un-associates the given segments.
Spliterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	spliterator(IntSet segments)	Same as DataContainer.spliterator() except that only entries that map to the provided segments are returned via this spliterator.
Spliterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	spliteratorIncludingExpired(IntSet segments)	Same as DataContainer.spliteratorIncludingExpired() except that only entries that map to the provided segments are returned via this spliterator.
void	start()

Methods inherited from class org.infinispan.container.offheap.SegmentedBoundedOffHeapDataContainer

capacity, delegate, evictionSize, getSize, stop

Methods inherited from class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer

clear, forEach, size, sizeIncludingExpired, touch

Methods inherited from class org.infinispan.container.impl.AbstractDelegatingDataContainer

clear, entrySet, executeTask, executeTask, forEach, iterator, iteratorIncludingExpired, keySet, resize, size, sizeIncludingExpired, spliterator, spliteratorIncludingExpired, values

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.container.DataContainer

clear, entrySet, executeTask, executeTask, iterator, iteratorIncludingExpired, keySet, resize, size, sizeIncludingExpired, spliterator, spliteratorIncludingExpired, values

Methods inherited from interface java.lang.Iterable

forEach

Field Detail

listeners

protected final List<Consumer<Iterable<InternalCacheEntry<WrappedBytes,WrappedBytes>>>> listeners

Constructor Detail

BoundedOffHeapDataContainer

public BoundedOffHeapDataContainer(int addressCount,
                                   long maxSize,
                                   EvictionType type)

Method Detail

start

public void start()

Overrides:

start in class SegmentedBoundedOffHeapDataContainer

getMapThatContainsKey

protected OffHeapConcurrentMap getMapThatContainsKey(byte[] key)

Overrides:

getMapThatContainsKey in class SegmentedBoundedOffHeapDataContainer

containsKey

public boolean containsKey(Object k)

Description copied from interface: DataContainer

Tests whether an entry exists in the container

Specified by:

containsKey in interface DataContainer<WrappedBytes,WrappedBytes>

Overrides:

containsKey in class org.infinispan.container.impl.AbstractDelegatingDataContainer<WrappedBytes,WrappedBytes>

Parameters:

k - key to test

Returns:

true if entry exists and has not expired; false otherwise

peek

public InternalCacheEntry<WrappedBytes,WrappedBytes> peek(Object k)

Description copied from interface: DataContainer

Retrieves a cache entry in the same way as DataContainer.get(Object)} except that it does not update or reorder any of the internal constructs. I.e., expiration does not happen, and in the case of the LRU container, the entry is not moved to the end of the chain.

This method should be used instead of DataContainer.get(Object)} when called while iterating through the data container using methods like DataContainer.iterator() to avoid changing the underlying collection's order.

Specified by:

peek in interface DataContainer<WrappedBytes,WrappedBytes>

Overrides:

peek in class org.infinispan.container.impl.AbstractDelegatingDataContainer<WrappedBytes,WrappedBytes>

Parameters:

k - key under which entry is stored

Returns:

entry, if it exists, or null if not

get

public InternalCacheEntry<WrappedBytes,WrappedBytes> get(Object k)

Description copied from interface: DataContainer

Retrieves a cached entry

Specified by:

get in interface DataContainer<WrappedBytes,WrappedBytes>

Specified by:

get in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

get in class org.infinispan.container.impl.AbstractDelegatingDataContainer<WrappedBytes,WrappedBytes>

Parameters:

k - key under which entry is stored

Returns:

entry, if it exists and has not expired, or null if not

compute

public InternalCacheEntry<WrappedBytes,WrappedBytes> compute(WrappedBytes key,
                                                                   DataContainer.ComputeAction<WrappedBytes,WrappedBytes> action)

Description copied from interface: DataContainer

Computes the new value for the key.

See DataContainer.ComputeAction.compute(Object, org.infinispan.container.entries.InternalCacheEntry, InternalEntryFactory).

The key must be activate by invoking ActivationManager.onRemove(Object, boolean) or ActivationManager.onUpdate(Object, boolean) depending if the value returned by the DataContainer.ComputeAction is null or not respectively.

Note the entry provided to DataContainer.ComputeAction may be expired as these entries are not filtered as many other methods do.

Specified by:

compute in interface DataContainer<WrappedBytes,WrappedBytes>

Overrides:

compute in class SegmentedBoundedOffHeapDataContainer

Parameters:

key - The key.

action - The action that will compute the new value.

Returns:

The InternalCacheEntry associated to the key.

remove

public InternalCacheEntry<WrappedBytes,WrappedBytes> remove(Object k)

Description copied from interface: DataContainer

Removes an entry from the cache

The key must be activate by invoking ActivationManager.onRemove(Object, boolean).

Specified by:

remove in interface DataContainer<WrappedBytes,WrappedBytes>

Overrides:

remove in class org.infinispan.container.impl.AbstractDelegatingDataContainer<WrappedBytes,WrappedBytes>

Parameters:

k - key to remove

Returns:

entry removed, or null if it didn't exist or had expired

evict

public void evict(WrappedBytes key)

Description copied from interface: DataContainer

Atomically, it removes the key from DataContainer and passivates it to persistence.

The passivation must be done by invoking the method PassivationManager.passivate(org.infinispan.container.entries.InternalCacheEntry).

Specified by:

evict in interface DataContainer<WrappedBytes,WrappedBytes>

Overrides:

evict in class org.infinispan.container.impl.AbstractDelegatingDataContainer<WrappedBytes,WrappedBytes>

Parameters:

key - The key to evict.

put

public void put(WrappedBytes key,
                WrappedBytes value,
                Metadata metadata)

Description copied from interface: DataContainer

Puts an entry in the cache along with metadata adding information such lifespan of entry, max idle time, version information...etc.

The key must be activate by invoking ActivationManager.onUpdate(Object, boolean).

Specified by:

put in interface DataContainer<WrappedBytes,WrappedBytes>

Overrides:

put in class SegmentedBoundedOffHeapDataContainer

Parameters:

key - key under which to store entry

value - value to store

metadata - metadata of the entry

containsKey

public boolean containsKey(int segment,
                           Object k)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.containsKey(Object) except that the segment of the key can provided to lookup if the entry exists without calculating the segment for the given key.

Specified by:

containsKey in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

containsKey in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segment - segment for the key

k - key under which entry is stored

Returns:

true if entry exists and has not expired; false otherwise

peek

public InternalCacheEntry<WrappedBytes,WrappedBytes> peek(int segment,
                                                                Object k)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.peek(Object) except that the segment of the key can provided to lookup entries without calculating the segment for the given key

Specified by:

peek in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

peek in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segment - segment for the key

k - key under which entry is stored

Returns:

entry, if it exists, or null if not

get

public InternalCacheEntry<WrappedBytes,WrappedBytes> get(int segment,
                                                               Object k)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.get(Object) except that the segment of the key can provided to lookup entries without calculating the segment for the given key

Specified by:

get in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

get in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segment - segment for the key

k - key under which entry is stored

Returns:

entry, if it exists and has not expired, or null if not

compute

public InternalCacheEntry<WrappedBytes,WrappedBytes> compute(int segment,
                                                                   WrappedBytes key,
                                                                   DataContainer.ComputeAction<WrappedBytes,WrappedBytes> action)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.compute(Object, ComputeAction) except that the segment of the key can provided to update entries without calculating the segment for the given key.

Specified by:

compute in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

compute in class SegmentedBoundedOffHeapDataContainer

Parameters:

segment - segment for the key

key - The key.

action - The action that will compute the new value.

Returns:

The InternalCacheEntry associated to the key.

remove

public InternalCacheEntry<WrappedBytes,WrappedBytes> remove(int segment,
                                                                  Object k)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.remove(Object) except that the segment of the key can provided to remove the entry without calculating the segment for the given key.

Specified by:

remove in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

remove in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segment - segment for the key

k - key to remove

Returns:

entry removed, or null if it didn't exist or had expired

evict

public void evict(int segment,
                  WrappedBytes key)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.evict(Object) except that the segment of the key can provided to remove the entry without calculating the segment for the given key.

Specified by:

evict in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

evict in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segment - segment for the key

key - The key to evict.

put

public void put(int segment,
                WrappedBytes key,
                WrappedBytes value,
                Metadata metadata,
                long createdTimestamp,
                long lastUseTimestamp)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.put(Object, Object, Metadata) except that the segment of the key can provided to write/lookup entries without calculating the segment for the given key.

Note: The timestamps ignored if the entry already exists in the data container.

Specified by:

put in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

put in class SegmentedBoundedOffHeapDataContainer

Parameters:

segment - segment for the key

key - key under which to store entry

value - value to store

metadata - metadata of the entry

createdTimestamp - creation timestamp, or -1 to use the current time

lastUseTimestamp - last use timestamp, or -1 to use the current time

spliterator

public Spliterator<InternalCacheEntry<WrappedBytes,WrappedBytes>> spliterator(IntSet segments)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.spliterator() except that only entries that map to the provided segments are returned via this spliterator. The spliterator will not return expired entries.

Specified by:

spliterator in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

spliterator in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segments - segments of entries to return

Returns:

spliterator containing entries mapping to those segments that aren't expired

spliteratorIncludingExpired

public Spliterator<InternalCacheEntry<WrappedBytes,WrappedBytes>> spliteratorIncludingExpired(IntSet segments)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.spliteratorIncludingExpired() except that only entries that map to the provided segments are returned via this spliterator. The spliterator will return expired entries as well.

Specified by:

spliteratorIncludingExpired in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

spliteratorIncludingExpired in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segments - segments of entries to use

Returns:

spliterator containing entries mapping to those segments that could be expired

iterator

public Iterator<InternalCacheEntry<WrappedBytes,WrappedBytes>> iterator(IntSet segments)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.iterator() except that only entries that map to the provided segments are returned via the iterator. The iterator will not return expired entries.

Specified by:

iterator in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

iterator in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segments - segments of entries to use

Returns:

iterator that returns all entries mapped to the given segments

iteratorIncludingExpired

public Iterator<InternalCacheEntry<WrappedBytes,WrappedBytes>> iteratorIncludingExpired(IntSet segments)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Same as DataContainer.iteratorIncludingExpired() except that only entries that map to the provided segments are returned via the iterator. The iterator can return expired entries.

Specified by:

iteratorIncludingExpired in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

iteratorIncludingExpired in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segments - segments of entries to use

Returns:

iterator that returns all entries mapped to the given segments that could be expired

addRemovalListener

public void addRemovalListener(Consumer<Iterable<InternalCacheEntry<WrappedBytes,WrappedBytes>>> listener)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Adds a listener that is invoked whenever InternalDataContainer.removeSegments(IntSet) is invoked providing a way for the listener to see what actual entries were removed from the container.

Specified by:

addRemovalListener in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

addRemovalListener in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

listener - listener that invoked of removed entries

removeRemovalListener

public void removeRemovalListener(Object listener)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Removes a previously registered listener via InternalDataContainer.addRemovalListener(Consumer).

Specified by:

removeRemovalListener in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

removeRemovalListener in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

listener - the listener to remove

addSegments

public void addSegments(IntSet segments)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Sets what segments this data container should be using. Already associated segments are unaffected by this and takes a union of existing and new segments.

Specified by:

addSegments in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

addSegments in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segments - segments to associate with this container

removeSegments

public void removeSegments(IntSet segments)

Description copied from interface: org.infinispan.container.impl.InternalDataContainer

Removes and un-associates the given segments. This will notify any listeners registered via InternalDataContainer.addRemovalListener(Consumer) of entries that were removed due to no longer being associated with this container. There is no guarantee if the consumer is invoked once or multiple times for a given group of segments and could be in any order.

When this method is invoked an implementation is free to remove any entries that don't map to segments currently associated with this container. Note that entries that were removed due to their segments never being associated with this container do not notify listeners registered via InternalDataContainer.addRemovalListener(Consumer).

Specified by:

removeSegments in interface org.infinispan.container.impl.InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

removeSegments in class org.infinispan.container.impl.AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

segments - segments that should no longer be associated with this container