org.apache.ignite.internal

Class TransactionsMXBeanImpl

java.lang.Object

org.apache.ignite.internal.TransactionsMXBeanImpl

All Implemented Interfaces:

TransactionsMXBean

public class TransactionsMXBeanImpl
extends Object
implements TransactionsMXBean

TransactionsMXBean implementation.

Constructor Summary

Constructors

Constructor and Description
TransactionsMXBeanImpl(GridKernalContext ctx)

Method Summary

Modifier and Type	Method and Description
void	cancel(String xid) Kills transactions by the xid.
String	getActiveTransactions(Long minDuration, Integer minSize, String prj, String consistentIds, String xid, String lbRegex, Integer limit, String order, boolean detailed, boolean kill)
long	getLongOperationsDumpTimeout() Returns a timeout (in millis) for printing long-running transactions as well as transactions that cannot receive locks for all their keys for a long time.
long	getLongTransactionTimeDumpThreshold() Returns threshold timeout in milliseconds for long transactions, if transaction exceeds it, it will be dumped in log with information about how much time did it spent in system time (time while aquiring locks, preparing, commiting, etc.)
double	getTransactionTimeDumpSamplesCoefficient() Returns the coefficient for samples of completed transactions that will be dumped in log.
int	getTransactionTimeDumpSamplesPerSecondLimit() Returns the limit of samples of completed transactions that will be dumped in log per second, if TransactionsMXBean.getTransactionTimeDumpSamplesCoefficient() is above 0.0.
int	getTxKeyCollisionsInterval()
boolean	getTxOwnerDumpRequestsAllowed() Shows if dump requests from local node to near node are allowed, when long running transaction is found.
long	getTxTimeoutOnPartitionMapExchange() Gets transaction timeout on partition map exchange.
void	setLongOperationsDumpTimeout(long timeout) Setting a timeout (in millis) for printing long-running transactions as well as transactions that cannot receive locks for all their keys for a long time.
void	setLongTransactionTimeDumpThreshold(long threshold) Sets threshold timeout in milliseconds for long transactions, if transaction exceeds it, it will be dumped in log with information about how much time did it spent in system time (time while aquiring locks, preparing, commiting, etc.)
void	setTransactionTimeDumpSamplesCoefficient(double coefficient) Sets the coefficient for samples of completed transactions that will be dumped in log.
void	setTransactionTimeDumpSamplesPerSecondLimit(int limit) Sets the limit of samples of completed transactions that will be dumped in log per second, if TransactionsMXBean.getTransactionTimeDumpSamplesCoefficient() is above 0.0.
void	setTxKeyCollisionsInterval(int timeout) Set timeout interval for tx key contention analysis.
void	setTxOwnerDumpRequestsAllowed(boolean allowed) Sets if dump requests from local node to near node are allowed, when long running transaction is found.
void	setTxTimeoutOnPartitionMapExchange(long timeout) Sets transaction timeout on partition map exchange.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionsMXBeanImpl

public TransactionsMXBeanImpl(GridKernalContext ctx)

Parameters:

ctx - Context.

Method Detail

getActiveTransactions

public String getActiveTransactions(Long minDuration,
                                    Integer minSize,
                                    String prj,
                                    String consistentIds,
                                    String xid,
                                    String lbRegex,
                                    Integer limit,
                                    String order,
                                    boolean detailed,
                                    boolean kill)

Specified by:

getActiveTransactions in interface TransactionsMXBean

Parameters:

minDuration - Minimum duration.

minSize - Minimum size.

prj - Projection.

consistentIds - Consistent ids.

xid - Xid.

lbRegex - Label regex.

limit - Limit.

order - Order.

detailed - Detailed.

kill - Kill.

Returns:

If detailed flag is set - description of each transaction, else transactions count.

cancel

public void cancel(String xid)

Kills transactions by the xid.

Specified by:

cancel in interface TransactionsMXBean

Parameters:

xid - Transaction xid.

See Also:

TransactionView.xid()

getTxTimeoutOnPartitionMapExchange

public long getTxTimeoutOnPartitionMapExchange()

Gets transaction timeout on partition map exchange.

Specified by:

getTxTimeoutOnPartitionMapExchange in interface TransactionsMXBean

Returns:

Transaction timeout on partition map exchange in milliseconds.

See Also:

TransactionConfiguration.getTxTimeoutOnPartitionMapExchange()

setTxTimeoutOnPartitionMapExchange

public void setTxTimeoutOnPartitionMapExchange(long timeout)

Sets transaction timeout on partition map exchange.

If not set, default value is TransactionConfiguration.TX_TIMEOUT_ON_PARTITION_MAP_EXCHANGE which means transactions will never be rolled back on partition map exchange.

Specified by:

setTxTimeoutOnPartitionMapExchange in interface TransactionsMXBean

Parameters:

timeout - Transaction timeout on partition map exchange in milliseconds.

See Also:

TransactionConfiguration.setTxTimeoutOnPartitionMapExchange(long)

getTxOwnerDumpRequestsAllowed

public boolean getTxOwnerDumpRequestsAllowed()

Shows if dump requests from local node to near node are allowed, when long running transaction is found. If allowed, the compute request to near node will be made to get thread dump of transaction owner thread.

Specified by:

getTxOwnerDumpRequestsAllowed in interface TransactionsMXBean

Returns:

true if allowed, false otherwise.

setTxOwnerDumpRequestsAllowed

public void setTxOwnerDumpRequestsAllowed(boolean allowed)

Sets if dump requests from local node to near node are allowed, when long running transaction is found. If allowed, the compute request to near node will be made to get thread dump of transaction owner thread.

Specified by:

setTxOwnerDumpRequestsAllowed in interface TransactionsMXBean

Parameters:

allowed - whether to allow

getLongTransactionTimeDumpThreshold

public long getLongTransactionTimeDumpThreshold()

Returns threshold timeout in milliseconds for long transactions, if transaction exceeds it, it will be dumped in log with information about how much time did it spent in system time (time while aquiring locks, preparing, commiting, etc.) and user time (time when client node runs some code while holding transaction). Returns 0 if not set. No transactions are dumped in log if this parameter is not set.

Specified by:

getLongTransactionTimeDumpThreshold in interface TransactionsMXBean

Returns:

Threshold.

setLongTransactionTimeDumpThreshold

public void setLongTransactionTimeDumpThreshold(long threshold)

Sets threshold timeout in milliseconds for long transactions, if transaction exceeds it, it will be dumped in log with information about how much time did it spent in system time (time while aquiring locks, preparing, commiting, etc.) and user time (time when client node runs some code while holding transaction). Can be set to 0 - no transactions will be dumped in log in this case.

Specified by:

setLongTransactionTimeDumpThreshold in interface TransactionsMXBean

Parameters:

threshold - Threshold.

getTransactionTimeDumpSamplesCoefficient

public double getTransactionTimeDumpSamplesCoefficient()

Returns the coefficient for samples of completed transactions that will be dumped in log.

Specified by:

getTransactionTimeDumpSamplesCoefficient in interface TransactionsMXBean

Returns:

Coefficient current value.

setTransactionTimeDumpSamplesCoefficient

public void setTransactionTimeDumpSamplesCoefficient(double coefficient)

Sets the coefficient for samples of completed transactions that will be dumped in log.

Specified by:

setTransactionTimeDumpSamplesCoefficient in interface TransactionsMXBean

Parameters:

coefficient - Coefficient.

getTransactionTimeDumpSamplesPerSecondLimit

public int getTransactionTimeDumpSamplesPerSecondLimit()

Returns the limit of samples of completed transactions that will be dumped in log per second, if TransactionsMXBean.getTransactionTimeDumpSamplesCoefficient() is above 0.0. Must be integer value greater than 0.

Specified by:

getTransactionTimeDumpSamplesPerSecondLimit in interface TransactionsMXBean

Returns:

Limit value.

setTransactionTimeDumpSamplesPerSecondLimit

public void setTransactionTimeDumpSamplesPerSecondLimit(int limit)

Sets the limit of samples of completed transactions that will be dumped in log per second, if TransactionsMXBean.getTransactionTimeDumpSamplesCoefficient() is above 0.0. Must be integer value greater than 0.

Specified by:

setTransactionTimeDumpSamplesPerSecondLimit in interface TransactionsMXBean

Parameters:

limit - Limit value.

setLongOperationsDumpTimeout

public void setLongOperationsDumpTimeout(long timeout)

Setting a timeout (in millis) for printing long-running transactions as well as transactions that cannot receive locks for all their keys for a long time. Set less than or equal 0 to disable.

Specified by:

setLongOperationsDumpTimeout in interface TransactionsMXBean

Parameters:

timeout - Timeout.

getLongOperationsDumpTimeout

public long getLongOperationsDumpTimeout()

Returns a timeout (in millis) for printing long-running transactions as well as transactions that cannot receive locks for all their keys for a long time. Returns 0 or less if not set.

Specified by:

getLongOperationsDumpTimeout in interface TransactionsMXBean

Returns:

Timeout.

setTxKeyCollisionsInterval

public void setTxKeyCollisionsInterval(int timeout)

Set timeout interval for tx key contention analysis.

Specified by:

setTxKeyCollisionsInterval in interface TransactionsMXBean

Parameters:

timeout - Interval in millis.

getTxKeyCollisionsInterval

public int getTxKeyCollisionsInterval()

Specified by:

getTxKeyCollisionsInterval in interface TransactionsMXBean

Returns:

Current interval in millis.

toString

public String toString()

Overrides:

toString in class Object