org.infinispan.container.offheap

Class SegmentedBoundedOffHeapDataContainer

java.lang.Object

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

org.infinispan.container.offheap.SegmentedBoundedOffHeapDataContainer

All Implemented Interfaces:

Iterable<InternalCacheEntry<WrappedBytes,WrappedBytes>>, DataContainer<WrappedBytes,WrappedBytes>, InternalDataContainer<WrappedBytes,WrappedBytes>

Direct Known Subclasses:

BoundedOffHeapDataContainer

public class SegmentedBoundedOffHeapDataContainer
extends AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

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 and Description
protected OffHeapMemoryAllocator	allocator
protected long	currentSize
protected DefaultSegmentedDataContainer	dataContainer
protected EvictionManager	evictionManager
protected long	firstAddress
protected long	lastAddress
protected Lock	lruLock
protected long	maxSize
protected int	numSegments
protected OffHeapEntryFactory	offHeapEntryFactory
protected DataOperationOrderer	orderer
protected ComponentRef<PassivationManager>	passivator
protected boolean	useCount

Constructor Summary

Constructors

Constructor and Description
SegmentedBoundedOffHeapDataContainer(int numSegments, long maxSize, EvictionType type)

Method Summary

Modifier and Type	Method and Description
long	capacity() Returns the capacity of the underlying container.
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.
protected InternalDataContainer<WrappedBytes,WrappedBytes>	delegate()
long	evictionSize() Returns how large the eviction size is currently.
protected OffHeapConcurrentMap	getMapThatContainsKey(byte[] key)
long	getSize(long address)
void	put(int segment, WrappedBytes key, WrappedBytes value, Metadata metadata, PrivateMetadata internalMetadata, 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.
void	start()
void	stop()

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

addRemovalListener, addSegments, clear, clear, containsKey, containsKey, evict, evict, forEach, forEach, get, get, iterator, iterator, iteratorIncludingExpired, iteratorIncludingExpired, peek, peek, remove, remove, removeRemovalListener, removeSegments, resize, size, size, sizeIncludingExpired, sizeIncludingExpired, spliterator, spliterator, spliteratorIncludingExpired, spliteratorIncludingExpired, touch

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.impl.InternalDataContainer

cleanUp, publisher

Field Detail

allocator

protected OffHeapMemoryAllocator allocator

offHeapEntryFactory

protected OffHeapEntryFactory offHeapEntryFactory

evictionManager

protected EvictionManager evictionManager

passivator

protected ComponentRef<PassivationManager> passivator

orderer

protected DataOperationOrderer orderer

maxSize

protected final long maxSize

lruLock

protected final Lock lruLock

useCount

protected final boolean useCount

numSegments

protected final int numSegments

currentSize

protected volatile long currentSize

firstAddress

protected long firstAddress

lastAddress

protected long lastAddress

dataContainer

protected DefaultSegmentedDataContainer dataContainer

Constructor Detail

SegmentedBoundedOffHeapDataContainer

public SegmentedBoundedOffHeapDataContainer(int numSegments,
                                            long maxSize,
                                            EvictionType type)

Method Detail

start

public void start()

stop

public void stop()

delegate

protected InternalDataContainer<WrappedBytes,WrappedBytes> delegate()

Specified by:

delegate in class AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

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.activateAsync(Object, int) boolean)}.

Specified by:

put in interface DataContainer<WrappedBytes,WrappedBytes>

Overrides:

put in class AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

key - key under which to store entry

value - value to store

metadata - metadata of the entry

put

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

Description copied from interface: 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 InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

put in class AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

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

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 activated by invoking ActivationManager.activateAsync(Object, int).

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 AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Parameters:

key - The key.

action - The action that will compute the new value.

Returns:

The InternalCacheEntry associated to the key.

compute

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

Description copied from interface: 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 InternalDataContainer<WrappedBytes,WrappedBytes>

Overrides:

compute in class AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

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.

getMapThatContainsKey

protected OffHeapConcurrentMap getMapThatContainsKey(byte[] key)

getSize

public long getSize(long address)

capacity

public long capacity()

Description copied from interface: DataContainer

Returns the capacity of the underlying container. This is only supported if the container is bounded. An UnsupportedOperationException is thrown otherwise.

Specified by:

capacity in interface DataContainer<WrappedBytes,WrappedBytes>

Overrides:

capacity in class AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Returns:

evictionSize

public long evictionSize()

Description copied from interface: DataContainer

Returns how large the eviction size is currently. This is only supported if the container is bounded. An UnsupportedOperationException is thrown otherwise. This value will always be lower than the value returned from DataContainer.capacity()

Specified by:

evictionSize in interface DataContainer<WrappedBytes,WrappedBytes>

Overrides:

evictionSize in class AbstractDelegatingInternalDataContainer<WrappedBytes,WrappedBytes>

Returns:

how large the counted eviction is