com.hazelcast.map.impl.mapstore.writebehind

Class TxnReservedCapacityCounterImpl

java.lang.Object

com.hazelcast.map.impl.mapstore.writebehind.TxnReservedCapacityCounterImpl

All Implemented Interfaces:

TxnReservedCapacityCounter

public class TxnReservedCapacityCounterImpl
extends Object
implements TxnReservedCapacityCounter

This class represents capacity counters for write behind queueing. Basically, we have 2 capacity counters. One is node-wide capacity counter, other one is record-store's reserved capacity counter. Depending on the context we operate on a single counter or both. Note that record-store's reserved capacity counter is only used with transactions and when MapStoreConfig.writeCoalescing is off. Every record-store has its own counter instance.

See Also:

TxnReservedCapacityCounter

Field Summary

Fields inherited from interface com.hazelcast.map.impl.mapstore.writebehind.TxnReservedCapacityCounter

EMPTY_COUNTER

Constructor Summary

Constructors

Constructor and Description
TxnReservedCapacityCounterImpl(NodeWideUsedCapacityCounter nodeWideUsedCapacityCounter)

Method Summary

Modifier and Type	Method and Description
void	decrement(UUID txnId) Decrements 2 counters for supplied txnId.
void	decrementOnlyReserved(UUID txnId) Decrements capacity count for a transaction.
Map<UUID,Long>	getReservedCapacityCountPerTxnId() Returns reserved capacity counts of all transactions which happened on this record store.
boolean	hasReservedCapacity(UUID txnId)
void	increment(UUID txnId, boolean backup) Increments 2 counters for supplied txnId.
void	putAll(Map<UUID,Long> reservedCapacityPerTxnId) Increments 2 counters with supplied txn reserved capacity counts.
void	releaseAllReservations() Releases all reserved capacity info on this counter.

Methods inherited from class java.lang.Object

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

Constructor Detail

TxnReservedCapacityCounterImpl

public TxnReservedCapacityCounterImpl(NodeWideUsedCapacityCounter nodeWideUsedCapacityCounter)

Method Detail

increment

public void increment(@Nonnull
                      UUID txnId,
                      boolean backup)

Increments 2 counters for supplied txnId. One is record-store's reserved capacity counter and other one is node-wide capacity counter. When node-wide capacity counter is exceeded preconfigured node-wide limit this method throws ReachedMaxSizeException

Specified by:

increment in interface TxnReservedCapacityCounter

Parameters:

txnId - id of transaction

backup - set true if counter increment operation is on a backup partition, otherwise set false

Throws:

ReachedMaxSizeException - (only when backup is false)

putAll

public void putAll(@Nonnull
                   Map<UUID,Long> reservedCapacityPerTxnId)

Increments 2 counters with supplied txn reserved capacity counts. One is record-store's reserved capacity counter and other one is node-wide capacity counter. Note that this method is only used with migrations and it doesn't throw ReachedMaxSizeException.

Specified by:

putAll in interface TxnReservedCapacityCounter

Parameters:

reservedCapacityPerTxnId - reserved capacities per txnId

hasReservedCapacity

public boolean hasReservedCapacity(@Nonnull
                                   UUID txnId)

Specified by:

hasReservedCapacity in interface TxnReservedCapacityCounter

Parameters:

txnId - id of transaction

Returns:

true if txnId has reserved capacity, otherwise return false

decrement

public void decrement(@Nonnull
                      UUID txnId)

Decrements 2 counters for supplied txnId. One is record-store's reserved capacity counter and other one is node-wide capacity counter.

Specified by:

decrement in interface TxnReservedCapacityCounter

Parameters:

txnId - id of transaction

decrementOnlyReserved

public void decrementOnlyReserved(@Nonnull
                                  UUID txnId)

Description copied from interface: TxnReservedCapacityCounter

Decrements capacity count for a transaction.

Specified by:

decrementOnlyReserved in interface TxnReservedCapacityCounter

Parameters:

txnId - id of transaction

releaseAllReservations

public void releaseAllReservations()

Description copied from interface: TxnReservedCapacityCounter

Releases all reserved capacity info on this counter.

Specified by:

releaseAllReservations in interface TxnReservedCapacityCounter

getReservedCapacityCountPerTxnId

public Map<UUID,Long> getReservedCapacityCountPerTxnId()

Description copied from interface: TxnReservedCapacityCounter

Returns reserved capacity counts of all transactions which happened on this record store.

Specified by:

getReservedCapacityCountPerTxnId in interface TxnReservedCapacityCounter

Returns:

reserved capacities per txnId