org.apache.ignite.internal.processors.cache

Class PartitionTxUpdateCounterDebugWrapper

java.lang.Object

org.apache.ignite.internal.processors.cache.PartitionTxUpdateCounterImpl

org.apache.ignite.internal.processors.cache.PartitionTxUpdateCounterDebugWrapper

All Implemented Interfaces:

Iterable<long[]>, PartitionUpdateCounter

public class PartitionTxUpdateCounterDebugWrapper
extends PartitionTxUpdateCounterImpl

Update counter implementation useful for debugging.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.PartitionTxUpdateCounterImpl

MAX_MISSED_UPDATES, reserveCntr

Constructor Summary

Constructors

Constructor and Description
PartitionTxUpdateCounterDebugWrapper(CacheGroupContext grp, int partId)

Method Summary

Modifier and Type	Method and Description
GridLongList	finalizeUpdateCounters() Flushes pending update counters closing all possible gaps.
void	init(long initUpdCntr, @Nullable byte[] cntrUpdData) Restores update counter state.
long	next() Increment LWM by 1.
long	next(long delta) Increment LWM by delta.
long	reserve(long delta) Increment HWM by delta.
void	update(long val) Sets update counter to absolute value.
boolean	update(long start, long delta) Applies counter update out of range.
void	updateInitial(long start, long delta)

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

empty, equals, get, getBytes, highestAppliedCounter, initial, iterator, reserved, reset, sequential, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

PartitionTxUpdateCounterDebugWrapper

public PartitionTxUpdateCounterDebugWrapper(CacheGroupContext grp,
                                            int partId)

Parameters:

grp - Group.

partId - Part id.

Method Detail

init

public void init(long initUpdCntr,
                 @Nullable
                 @Nullable byte[] cntrUpdData)

Restores update counter state.

Specified by:

init in interface PartitionUpdateCounter

Overrides:

init in class PartitionTxUpdateCounterImpl

Parameters:

initUpdCntr - LWM.

cntrUpdData - Counter updates raw data.

updateInitial

public void updateInitial(long start,
                          long delta)

Specified by:

updateInitial in interface PartitionUpdateCounter

Overrides:

updateInitial in class PartitionTxUpdateCounterImpl

Parameters:

start - Counter.

delta - Delta.

next

public long next()

Increment LWM by 1.

Specified by:

next in interface PartitionUpdateCounter

Overrides:

next in class PartitionTxUpdateCounterImpl

Returns:

Next update counter. For tx mode called by DataStreamerImpl IsolatedUpdater.

next

public long next(long delta)

Increment LWM by delta.

Specified by:

next in interface PartitionUpdateCounter

Overrides:

next in class PartitionTxUpdateCounterImpl

Parameters:

delta - Delta.

Returns:

New LWM.

update

public void update(long val)
            throws IgniteCheckedException

Sets update counter to absolute value. All missed updates will be discarded.

Specified by:

update in interface PartitionUpdateCounter

Overrides:

update in class PartitionTxUpdateCounterImpl

Parameters:

val - Absolute value.

Throws:

IgniteCheckedException - if counter cannot be set to passed value due to incompatibility with current state.

finalizeUpdateCounters

public GridLongList finalizeUpdateCounters()

Flushes pending update counters closing all possible gaps.

Specified by:

finalizeUpdateCounters in interface PartitionUpdateCounter

Overrides:

finalizeUpdateCounters in class PartitionTxUpdateCounterImpl

Returns:

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

reserve

public long reserve(long delta)

Increment HWM by delta.

Specified by:

reserve in interface PartitionUpdateCounter

Overrides:

reserve in class PartitionTxUpdateCounterImpl

Parameters:

delta - Delta.

Returns:

New HWM.

update

public boolean update(long start,
                      long delta)

Applies counter update out of range. Update ranges must not intersect.

Specified by:

update in interface PartitionUpdateCounter

Overrides:

update in class PartitionTxUpdateCounterImpl

Parameters:

start - Start (<= lwm).

delta - Delta.

Returns:

True if update was actually applied.