org.apache.ignite.internal.processors.cache.distributed.dht.topology

Class GridDhtLocalPartition

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheConcurrentMapImpl

org.apache.ignite.internal.processors.cache.distributed.dht.topology.GridDhtLocalPartition

All Implemented Interfaces:

Comparable<GridDhtLocalPartition>, GridReservable, GridCacheConcurrentMap

public class GridDhtLocalPartition
extends GridCacheConcurrentMapImpl
implements Comparable<GridDhtLocalPartition>, GridReservable

Key partition.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.processors.cache.GridCacheConcurrentMap

GridCacheConcurrentMap.CacheMapHolder

Field Summary

Fields

Modifier and Type	Field and Description
static int	DFLT_ATOMIC_CACHE_DELETE_HISTORY_SIZE
static int	DFLT_CACHE_REMOVE_ENTRIES_TTL
static int	MAX_DELETE_QUEUE_SIZE Maximum size for delete queue.

Constructor Summary

Constructors

Constructor and Description
GridDhtLocalPartition(GridCacheSharedContext ctx, CacheGroupContext grp, int id, boolean recovery)

Method Summary

Modifier and Type	Method and Description
boolean	addReservation(GridDhtPartitionsReservation r) Adds group reservation to this partition.
boolean	backup(AffinityTopologyVersion topVer)
void	beforeApplyBatch(boolean last) Called before next batch is about to be applied during rebalance.
protected long	clearAll(EvictionContext evictionCtx) Removes all entries and rows from this partition.
IgniteInternalFuture<?>	clearAsync() Initiates a partition clearing attempt.
void	clearDeferredDeletes() Removes all deferred delete requests from rmvQueue.
int	compareTo(@NotNull GridDhtLocalPartition part)
long	createTime()
IgniteCacheOffheapManager.CacheDataStore	dataStore()
void	decrementPublicSize(@Nullable GridCacheConcurrentMap.CacheMapHolder hld, GridCacheEntryEx e) Decrements public size.
void	dumpDebugInfo(SB buf) Collects detailed info about the partition.
protected GridCacheConcurrentMap.CacheMapHolder	entriesMap(GridCacheContext cctx)
protected @Nullable GridCacheConcurrentMap.CacheMapHolder	entriesMapIfExists(Integer cacheId)
boolean	equals(Object o)
GridLongList	finalizeUpdateCounters() Flushes pending update counters closing all possible gaps.
void	finishEviction() Moves partition state to EVICTED if possible.
long	fullSize()
long	getAndIncrementUpdateCounter(long delta) Increments cache update counter on primary node.
CacheGroupContext	group() Returns group context.
int	hashCode()
int	id()
void	incrementPublicSize(@Nullable GridCacheConcurrentMap.CacheMapHolder hld, GridCacheEntryEx e) Increments public size.
long	initialUpdateCounter()
int	internalSize() Returns the number of key-value mappings in this map.
boolean	isClearing()
boolean	isEmpty()
boolean	markLost()
boolean	moving() Forcibly moves partition to a MOVING state.
long	nextUpdateCounter(int cacheId, AffinityTopologyVersion topVer, boolean primary, boolean init, @Nullable Long primaryCntr) Returns new update counter for primary node or passed counter for backup node.
long	nextUpdateCounter(int cacheId, IgniteInternalTx tx, @Nullable Long primaryCntr) Used for transactions.
void	onCacheStopped(int cacheId)
void	onDeferredDelete(int cacheId, KeyCacheObject key, GridCacheVersion ver)
void	onRemoved(GridDhtCacheEntry entry)
void	onUnlock() On partition unlock callback.
boolean	own()
boolean	primary(AffinityTopologyVersion topVer)
int	publicSize(int cacheId) Returns the number of publicly available key-value mappings in this map.
void	release() Releases previously reserved partition.
protected void	release(int sizeChange, GridCacheConcurrentMap.CacheMapHolder hld, GridCacheEntryEx e)
void	removeReservation(GridDhtPartitionsReservation r)
IgniteInternalFuture<?>	rent() Initiates partition eviction process and returns an eviction future.
int	reservations()
boolean	reserve() Reserves the partition so it won't be cleared or evicted.
long	reservedCounter()
void	resetInitialUpdateCounter() Reset partition initial update counter.
void	resetUpdateCounter() Reset partition update counter.
void	restoreState(GridDhtPartitionState stateToRestore)
void	setState(GridDhtPartitionState toState) For testing purposes only.
GridDhtPartitionState	state()
String	toString()
void	tryContinueClearing() Continue clearing if it was delayed before due to reservation and topology version not changed.
long	updateCounter()
void	updateCounter(long val)
boolean	updateCounter(long start, long delta) Updates MVCC cache update counter on backup node.
boolean	valid()

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheConcurrentMapImpl

entries, entrySet, getEntry, putEntryIfObsoleteOrAbsent, putEntryIfObsoleteOrAbsent, removeEntry

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

DFLT_ATOMIC_CACHE_DELETE_HISTORY_SIZE

public static final int DFLT_ATOMIC_CACHE_DELETE_HISTORY_SIZE

See Also:

IgniteSystemProperties.IGNITE_ATOMIC_CACHE_DELETE_HISTORY_SIZE, Constant Field Values

MAX_DELETE_QUEUE_SIZE

public static final int MAX_DELETE_QUEUE_SIZE

Maximum size for delete queue.

DFLT_CACHE_REMOVE_ENTRIES_TTL

public static final int DFLT_CACHE_REMOVE_ENTRIES_TTL

See Also:

IgniteSystemProperties.IGNITE_CACHE_REMOVED_ENTRIES_TTL, Constant Field Values

Constructor Detail

GridDhtLocalPartition

public GridDhtLocalPartition(GridCacheSharedContext ctx,
                             CacheGroupContext grp,
                             int id,
                             boolean recovery)

Parameters:

ctx - Context.

grp - Cache group.

id - Partition ID.

recovery - Flag indicates that partition is created during recovery phase.

Method Detail

internalSize

public int internalSize()

Returns the number of key-value mappings in this map. It does not include entries from underlying data store.

Specified by:

internalSize in interface GridCacheConcurrentMap

Returns:

the number of key-value mappings in this map.

entriesMap

protected GridCacheConcurrentMap.CacheMapHolder entriesMap(GridCacheContext cctx)

Specified by:

entriesMap in class GridCacheConcurrentMapImpl

Parameters:

cctx - Cache context.

Returns:

Map for given cache ID.

entriesMapIfExists

@Nullable
protected @Nullable GridCacheConcurrentMap.CacheMapHolder entriesMapIfExists(Integer cacheId)

Specified by:

entriesMapIfExists in class GridCacheConcurrentMapImpl

Parameters:

cacheId - Cache ID.

Returns:

Map for given cache ID.

dataStore

public IgniteCacheOffheapManager.CacheDataStore dataStore()

Returns:

Data store.

addReservation

public boolean addReservation(GridDhtPartitionsReservation r)

Adds group reservation to this partition.

Parameters:

r - Reservation.

Returns:

false If such reservation already added.

removeReservation

public void removeReservation(GridDhtPartitionsReservation r)

Parameters:

r - Reservation.

id

public int id()

Returns:

Partition ID.

createTime

public long createTime()

Returns:

Create time.

state

public GridDhtPartitionState state()

Returns:

Partition state.

reservations

public int reservations()

Returns:

Reservations.

isEmpty

public boolean isEmpty()

Returns:

True if partition is empty.

valid

public boolean valid()

Returns:

If partition is moving or owning or renting.

onRemoved

public void onRemoved(GridDhtCacheEntry entry)

Parameters:

entry - Entry to remove.

onDeferredDelete

public void onDeferredDelete(int cacheId,
                             KeyCacheObject key,
                             GridCacheVersion ver)

Parameters:

cacheId - cacheId Cache ID.

key - Removed key.

ver - Removed version.

reserve

public boolean reserve()

Reserves the partition so it won't be cleared or evicted. Only MOVING, OWNING and LOST partitions can be reserved.

Specified by:

reserve in interface GridReservable

Overrides:

reserve in class GridCacheConcurrentMapImpl

Returns:

True if reserved.

release

public void release()

Releases previously reserved partition.

Specified by:

release in interface GridReservable

Overrides:

release in class GridCacheConcurrentMapImpl

release

protected void release(int sizeChange,
                       GridCacheConcurrentMap.CacheMapHolder hld,
                       GridCacheEntryEx e)

Overrides:

release in class GridCacheConcurrentMapImpl

Parameters:

sizeChange - Size delta.

hld - Map holder.

e - Map entry.

restoreState

public void restoreState(GridDhtPartitionState stateToRestore)

Parameters:

stateToRestore - State to restore.

setState

public void setState(GridDhtPartitionState toState)

For testing purposes only.

Parameters:

toState - State to set.

own

public boolean own()

Returns:

True if transitioned to OWNING state.

moving

public boolean moving()

Forcibly moves partition to a MOVING state.

Returns:

True if a partition was switched to MOVING state.

markLost

public boolean markLost()

Returns:

True if partition state changed.

rent

public IgniteInternalFuture<?> rent()

Initiates partition eviction process and returns an eviction future. Future will be completed when a partition is moved to EVICTED state (possibly not yet physically deleted). If partition has reservations, eviction will be delayed and continued after all reservations will be released.

Returns:

Future to signal that this node is no longer an owner or backup or null if corresponding partition state is RENTING or EVICTED.

tryContinueClearing

public void tryContinueClearing()

Continue clearing if it was delayed before due to reservation and topology version not changed.

clearAsync

public IgniteInternalFuture<?> clearAsync()

Initiates a partition clearing attempt.

Returns:

A future what will be finished then a current clearing attempt is done.

finishEviction

public void finishEviction()

Moves partition state to EVICTED if possible.

isClearing

public boolean isClearing()

Returns:

True if clearing process is running at the moment on the partition.

onUnlock

public void onUnlock()

On partition unlock callback. Tries to continue delayed partition clearing.

primary

public boolean primary(AffinityTopologyVersion topVer)

Parameters:

topVer - Topology version.

Returns:

True if local node is primary for this partition.

backup

public boolean backup(AffinityTopologyVersion topVer)

Parameters:

topVer - Topology version.

Returns:

True if local node is backup for this partition.

nextUpdateCounter

public long nextUpdateCounter(int cacheId,
                              AffinityTopologyVersion topVer,
                              boolean primary,
                              boolean init,
                              @Nullable
                              @Nullable Long primaryCntr)

Returns new update counter for primary node or passed counter for backup node.

Used for non-tx cases.

Counter generation/update logic is delegated to counter implementation.

Parameters:

cacheId - ID of cache initiated counter update.

topVer - Topology version for current operation.

init - True if initial update.

Returns:

Next update index.

nextUpdateCounter

public long nextUpdateCounter(int cacheId,
                              IgniteInternalTx tx,
                              @Nullable
                              @Nullable Long primaryCntr)

Used for transactions.

Parameters:

cacheId - Cache id.

tx - Tx.

primaryCntr - Primary counter.

updateCounter

public long updateCounter()

Returns:

Current update counter (LWM).

reservedCounter

public long reservedCounter()

Returns:

Current reserved counter (HWM).

updateCounter

public void updateCounter(long val)

Parameters:

val - Update counter value.

initialUpdateCounter

public long initialUpdateCounter()

Returns:

Initial update counter.

getAndIncrementUpdateCounter

public long getAndIncrementUpdateCounter(long delta)

Increments cache update counter on primary node.

Parameters:

delta - Value to be added to update counter.

Returns:

Update counter value before update.

updateCounter

public boolean updateCounter(long start,
                             long delta)

Updates MVCC cache update counter on backup node.

Parameters:

start - Start position

delta - Delta.

resetUpdateCounter

public void resetUpdateCounter()

Reset partition update counter.

resetInitialUpdateCounter

public void resetInitialUpdateCounter()

Reset partition initial update counter.

fullSize

public long fullSize()

Returns:

Total size of all caches.

clearAll

protected long clearAll(EvictionContext evictionCtx)
                 throws NodeStoppingException

Removes all entries and rows from this partition.

Returns:

Number of rows cleared from page memory.

Throws:

NodeStoppingException - If node stopping.

clearDeferredDeletes

public void clearDeferredDeletes()

Removes all deferred delete requests from rmvQueue.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

compareTo

public int compareTo(@NotNull
                     @NotNull GridDhtLocalPartition part)

Specified by:

compareTo in interface Comparable<GridDhtLocalPartition>

toString

public String toString()

Overrides:

toString in class Object

publicSize

public int publicSize(int cacheId)

Returns the number of publicly available key-value mappings in this map. It excludes entries that are marked as deleted. It also does not include entries from underlying data store.

Specified by:

publicSize in interface GridCacheConcurrentMap

Parameters:

cacheId - Cache ID.

Returns:

the number of publicly available key-value mappings in this map.

incrementPublicSize

public void incrementPublicSize(@Nullable
                                @Nullable GridCacheConcurrentMap.CacheMapHolder hld,
                                GridCacheEntryEx e)

Increments public size.

Specified by:

incrementPublicSize in interface GridCacheConcurrentMap

Parameters:

hld - Cache map (passed as optimization to avoid cache map lookup for shared groups).

e - Entry that caused public size change.

decrementPublicSize

public void decrementPublicSize(@Nullable
                                @Nullable GridCacheConcurrentMap.CacheMapHolder hld,
                                GridCacheEntryEx e)

Decrements public size.

Specified by:

decrementPublicSize in interface GridCacheConcurrentMap

Parameters:

hld - Cache map (passed as optimization to avoid cache map lookup for shared groups).

e - Entry that caused public size change.

group

public CacheGroupContext group()

Returns group context.

Returns:

Group context.

onCacheStopped

public void onCacheStopped(int cacheId)

Parameters:

cacheId - Cache ID.

finalizeUpdateCounters

public GridLongList finalizeUpdateCounters()

Flushes pending update counters closing all possible gaps.

Returns:

Even-length array of pairs [start, end] for each gap.

beforeApplyBatch

public void beforeApplyBatch(boolean last)

Called before next batch is about to be applied during rebalance. Currently used for tests.

Parameters:

last - True if last batch for partition.

dumpDebugInfo

public void dumpDebugInfo(SB buf)

Collects detailed info about the partition.

Parameters:

buf - Buffer.