Package org.apache.ignite.internal.cluster

Class DistributedTransactionConfiguration

java.lang.Object

org.apache.ignite.internal.cluster.DistributedTransactionConfiguration

public class DistributedTransactionConfiguration
extends Object

Distributed transaction configuration.

Constructor Summary

Constructors

Constructor	Description
DistributedTransactionConfiguration(GridKernalContext ctx, IgniteLogger log, DistributePropertyListener<Long> longOperationsDumpTimeoutLsnr, DistributePropertyListener<Integer> collisionsDumpIntervalLsnr)

Method Summary

Modifier and Type	Method	Description
Integer	collisionsDumpInterval()
Long	longOperationsDumpTimeout()
Integer	longTransactionTimeDumpSamplesPerSecondLimit()
Long	longTransactionTimeDumpThreshold()
Double	transactionTimeDumpSamplesCoefficient()
Boolean	txOwnerDumpRequestsAllowed()
GridFutureAdapter<?>	updateCollisionsDumpIntervalAsync(int collisionsDumpInterval)	Cluster wide update of collisionsDumpInterval.
void	updateCollisionsDumpIntervalLocal(int collisionsDumpInterval)	Local update of collisionsDumpInterval.
GridFutureAdapter<?>	updateLongOperationsDumpTimeoutAsync(long timeout)	Cluster wide update of longOperationsDumpTimeout.
void	updateLongOperationsDumpTimeoutLocal(long timeout)	Local update of longOperationsDumpTimeout.
GridFutureAdapter<?>	updateLongTransactionTimeDumpSamplesPerSecondLimitAsync(int limit)	Cluster wide update of longTransactionTimeDumpSamplesPerSecondLimit.
void	updateLongTransactionTimeDumpSamplesPerSecondLimitLocal(int limit)	Local update of longTransactionTimeDumpSamplesPerSecondLimit.
GridFutureAdapter<?>	updateLongTransactionTimeDumpThresholdAsync(long longTransactionTimeDumpThreshold)	Cluster wide update of longTransactionTimeDumpThreshold.
void	updateLongTransactionTimeDumpThresholdLocal(long longTransactionTimeDumpThreshold)	Local update of longTransactionTimeDumpThreshold.
GridFutureAdapter<?>	updateTransactionTimeDumpSamplesCoefficientAsync(double transactionTimeDumpSamplesCoefficient)	Cluster wide update of transactionTimeDumpSamplesCoefficient.
void	updateTransactionTimeDumpSamplesCoefficientLocal(double transactionTimeDumpSamplesCoefficient)	Local update of transactionTimeDumpSamplesCoefficient.
GridFutureAdapter<?>	updateTxOwnerDumpRequestsAllowedAsync(boolean allowed)	Cluster wide update of txOwnerDumpRequestsAllowed.
void	updateTxOwnerDumpRequestsAllowedLocal(boolean allowed)	Local update of txOwnerDumpRequestsAllowed.

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedTransactionConfiguration

public DistributedTransactionConfiguration(GridKernalContext ctx,
                                           IgniteLogger log,
                                           DistributePropertyListener<Long> longOperationsDumpTimeoutLsnr,
                                           DistributePropertyListener<Integer> collisionsDumpIntervalLsnr)

Parameters:

ctx - Kernal context.

log - Log.

longOperationsDumpTimeoutLsnr - Listener of longOperationsDumpTimeout change event.

collisionsDumpIntervalLsnr - Listener of collisionsDumpInterval change event.

Method Detail

updateLongOperationsDumpTimeoutAsync

public GridFutureAdapter<?> updateLongOperationsDumpTimeoutAsync(long timeout)
                                                          throws IgniteCheckedException

Cluster wide update of longOperationsDumpTimeout.

Parameters:

timeout - New value of longOperationsDumpTimeout.

Returns:

Future for longOperationsDumpTimeout update operation.

Throws:

IgniteCheckedException - If failed during cluster wide update.

updateLongOperationsDumpTimeoutLocal

public void updateLongOperationsDumpTimeoutLocal(long timeout)

Local update of longOperationsDumpTimeout.

Parameters:

timeout - New value of longOperationsDumpTimeout.

longOperationsDumpTimeout

public Long longOperationsDumpTimeout()

Returns:

Long operations dump timeout. See longOperationsDumpTimeout.

updateLongTransactionTimeDumpThresholdAsync

public GridFutureAdapter<?> updateLongTransactionTimeDumpThresholdAsync(long longTransactionTimeDumpThreshold)
                                                                 throws IgniteCheckedException

Cluster wide update of longTransactionTimeDumpThreshold.

Parameters:

longTransactionTimeDumpThreshold - New value of threshold timeout in milliseconds.

Returns:

Future for longTransactionTimeDumpThreshold update operation.

Throws:

IgniteCheckedException - If failed during cluster wide update.

updateLongTransactionTimeDumpThresholdLocal

public void updateLongTransactionTimeDumpThresholdLocal(long longTransactionTimeDumpThreshold)

Local update of longTransactionTimeDumpThreshold.

Parameters:

longTransactionTimeDumpThreshold - New value of longTransactionTimeDumpThreshold.

longTransactionTimeDumpThreshold

public Long longTransactionTimeDumpThreshold()

Returns:

Threshold timeout for long transactions. See longTransactionTimeDumpThreshold for more information.

updateTransactionTimeDumpSamplesCoefficientAsync

public GridFutureAdapter<?> updateTransactionTimeDumpSamplesCoefficientAsync(double transactionTimeDumpSamplesCoefficient)
                                                                      throws IgniteCheckedException

Cluster wide update of transactionTimeDumpSamplesCoefficient.

Parameters:

transactionTimeDumpSamplesCoefficient - New coefficient for samples of completed transactions that will be dumped in log.

Returns:

Future for transactionTimeDumpSamplesCoefficient update operation.

Throws:

IgniteCheckedException - If failed during cluster wide update.

updateTransactionTimeDumpSamplesCoefficientLocal

public void updateTransactionTimeDumpSamplesCoefficientLocal(double transactionTimeDumpSamplesCoefficient)

Local update of transactionTimeDumpSamplesCoefficient.

Parameters:

transactionTimeDumpSamplesCoefficient - New coefficient for samples of completed transactions that will be dumped in log.

transactionTimeDumpSamplesCoefficient

public Double transactionTimeDumpSamplesCoefficient()

Returns:

The coefficient for samples of completed transactions that will be dumped in log. See transactionTimeDumpSamplesCoefficient.

updateLongTransactionTimeDumpSamplesPerSecondLimitAsync

public GridFutureAdapter<?> updateLongTransactionTimeDumpSamplesPerSecondLimitAsync(int limit)
                                                                             throws IgniteCheckedException

Cluster wide update of longTransactionTimeDumpSamplesPerSecondLimit.

Parameters:

limit - New limit of samples of completed transactions that will be dumped in log per second.

Returns:

Future for longTransactionTimeDumpSamplesPerSecondLimit update operation.

Throws:

IgniteCheckedException - If failed during cluster wide update.

updateLongTransactionTimeDumpSamplesPerSecondLimitLocal

public void updateLongTransactionTimeDumpSamplesPerSecondLimitLocal(int limit)

Local update of longTransactionTimeDumpSamplesPerSecondLimit.

Parameters:

limit - New limit of samples of completed transactions that will be dumped in log per second.

longTransactionTimeDumpSamplesPerSecondLimit

public Integer longTransactionTimeDumpSamplesPerSecondLimit()

Returns:

Limit of samples of completed transactions that will be dumped in log per second. See longTransactionTimeDumpSamplesPerSecondLimit for more information.

updateCollisionsDumpIntervalAsync

public GridFutureAdapter<?> updateCollisionsDumpIntervalAsync(int collisionsDumpInterval)
                                                       throws IgniteCheckedException

Cluster wide update of collisionsDumpInterval.

Parameters:

collisionsDumpInterval - New collisions dump interval.

Returns:

Future for collisionsDumpInterval update operation.

Throws:

IgniteCheckedException - If failed during cluster wide update.

updateCollisionsDumpIntervalLocal

public void updateCollisionsDumpIntervalLocal(int collisionsDumpInterval)

Local update of collisionsDumpInterval.

Parameters:

collisionsDumpInterval - New collisions dump interval.

collisionsDumpInterval

public Integer collisionsDumpInterval()

Returns:

Collisions dump interval. See collisionsDumpInterval.

updateTxOwnerDumpRequestsAllowedAsync

public GridFutureAdapter<?> updateTxOwnerDumpRequestsAllowedAsync(boolean allowed)
                                                           throws IgniteCheckedException

Cluster wide update of txOwnerDumpRequestsAllowed.

Parameters:

allowed - Allowance to dump requests from local node to near node, when long running transaction is found.

Returns:

Future for txOwnerDumpRequestsAllowed update operation.

Throws:

IgniteCheckedException - If failed during cluster wide update.

updateTxOwnerDumpRequestsAllowedLocal

public void updateTxOwnerDumpRequestsAllowedLocal(boolean allowed)

Local update of txOwnerDumpRequestsAllowed.

Parameters:

allowed - Allowance to dump requests from local node to near node, when long running transaction is found.

txOwnerDumpRequestsAllowed

public Boolean txOwnerDumpRequestsAllowed()

Returns:

Allowance to dump requests from local node to near node, when long running transaction is found. See txOwnerDumpRequestsAllowed for more information.