| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package org.apache.ignite.internal.cluster; |
| |
| import org.apache.ignite.IgniteCheckedException; |
| import org.apache.ignite.IgniteLogger; |
| import org.apache.ignite.internal.GridKernalContext; |
| import org.apache.ignite.internal.processors.configuration.distributed.DistributePropertyListener; |
| import org.apache.ignite.internal.processors.configuration.distributed.DistributedChangeableProperty; |
| import org.apache.ignite.internal.processors.configuration.distributed.DistributedConfigurationLifecycleListener; |
| import org.apache.ignite.internal.processors.configuration.distributed.DistributedPropertyDispatcher; |
| import org.apache.ignite.internal.processors.metastorage.ReadableDistributedMetaStorage; |
| import org.apache.ignite.internal.util.future.GridFutureAdapter; |
| |
| import static org.apache.ignite.IgniteSystemProperties.IGNITE_DUMP_TX_COLLISIONS_INTERVAL; |
| import static org.apache.ignite.IgniteSystemProperties.IGNITE_LONG_OPERATIONS_DUMP_TIMEOUT; |
| import static org.apache.ignite.IgniteSystemProperties.IGNITE_LONG_TRANSACTION_TIME_DUMP_THRESHOLD; |
| import static org.apache.ignite.IgniteSystemProperties.IGNITE_TRANSACTION_TIME_DUMP_SAMPLES_COEFFICIENT; |
| import static org.apache.ignite.IgniteSystemProperties.IGNITE_TRANSACTION_TIME_DUMP_SAMPLES_PER_SECOND_LIMIT; |
| import static org.apache.ignite.IgniteSystemProperties.IGNITE_TX_OWNER_DUMP_REQUESTS_ALLOWED; |
| import static org.apache.ignite.IgniteSystemProperties.getBoolean; |
| import static org.apache.ignite.IgniteSystemProperties.getFloat; |
| import static org.apache.ignite.IgniteSystemProperties.getInteger; |
| import static org.apache.ignite.IgniteSystemProperties.getLong; |
| import static org.apache.ignite.internal.IgniteKernal.DFLT_LONG_OPERATIONS_DUMP_TIMEOUT; |
| import static org.apache.ignite.internal.cluster.DistributedConfigurationUtils.makeUpdateListener; |
| import static org.apache.ignite.internal.cluster.DistributedConfigurationUtils.setDefaultValue; |
| import static org.apache.ignite.internal.processors.configuration.distributed.DistributedBooleanProperty.detachedBooleanProperty; |
| import static org.apache.ignite.internal.processors.configuration.distributed.DistributedDoubleProperty.detachedDoubleProperty; |
| import static org.apache.ignite.internal.processors.configuration.distributed.DistributedIntegerProperty.detachedIntegerProperty; |
| import static org.apache.ignite.internal.processors.configuration.distributed.DistributedLongProperty.detachedLongProperty; |
| |
| /** |
| * Distributed transaction configuration. |
| */ |
| public class DistributedTransactionConfiguration { |
| /** Property update message. */ |
| private static final String PROPERTY_UPDATE_MESSAGE = |
| "Transactions parameter '%s' was changed from '%s' to '%s'"; |
| |
| /** Default value of {@link #longOperationsDumpTimeout}. */ |
| private final long dfltLongOpsDumpTimeout = |
| getLong(IGNITE_LONG_OPERATIONS_DUMP_TIMEOUT, DFLT_LONG_OPERATIONS_DUMP_TIMEOUT); |
| |
| /** Default value of {@link #longTransactionTimeDumpThreshold}. */ |
| private final long dfltLongTransactionTimeDumpThreshold = |
| getLong(IGNITE_LONG_TRANSACTION_TIME_DUMP_THRESHOLD, 0); |
| |
| /** Default value of {@link #transactionTimeDumpSamplesCoefficient}. */ |
| private final double dfltTransactionTimeDumpSamplesCoefficient = |
| getFloat(IGNITE_TRANSACTION_TIME_DUMP_SAMPLES_COEFFICIENT, 0.0f); |
| |
| /** Default value of {@link #longTransactionTimeDumpSamplesPerSecondLimit}. */ |
| private final int dfltLongTransactionTimeDumpSamplesPerSecondLimit = |
| getInteger(IGNITE_TRANSACTION_TIME_DUMP_SAMPLES_PER_SECOND_LIMIT, 5); |
| |
| /** Default value of {@link #collisionsDumpInterval}. */ |
| private final int dfltCollisionsDumpInterval = |
| getInteger(IGNITE_DUMP_TX_COLLISIONS_INTERVAL, 1000); |
| |
| /** Default value of {@link #txOwnerDumpRequestsAllowed}. */ |
| private final boolean dfltTxOwnerDumpRequestsAllowed = |
| getBoolean(IGNITE_TX_OWNER_DUMP_REQUESTS_ALLOWED, true); |
| |
| /** |
| * 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. |
| */ |
| private final DistributedChangeableProperty<Boolean> txOwnerDumpRequestsAllowed = |
| detachedBooleanProperty("txOwnerDumpRequestsAllowed", |
| "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."); |
| |
| /** Long operations dump timeout. */ |
| private final DistributedChangeableProperty<Long> longOperationsDumpTimeout = |
| detachedLongProperty("longOperationsDumpTimeout", "Cache operations that take more time than value " + |
| "of this property in milliseconds will be output to log. Set to 0 to disable."); |
| |
| /** |
| * Threshold timeout 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 and not |
| * waiting it). Equals 0 if not set. |
| */ |
| private final DistributedChangeableProperty<Long> longTransactionTimeDumpThreshold = |
| detachedLongProperty("longTransactionTimeDumpThreshold", |
| "Threshold timeout 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 acquiring " + |
| "locks, preparing, committing, etc) and user time (time when client node runs some code while holding " + |
| "transaction and not waiting it). Equals 0 if not set."); |
| |
| /** The coefficient for samples of completed transactions that will be dumped in log. */ |
| private final DistributedChangeableProperty<Double> transactionTimeDumpSamplesCoefficient = |
| detachedDoubleProperty("transactionTimeDumpSamplesCoefficient", |
| "The coefficient for samples of completed transactions that will be dumped " + |
| "in log. Must be float value between 0.0 and 1.0 inclusive."); |
| |
| /** |
| * The limit of samples of completed transactions that will be dumped in log per second, if |
| * {@link #transactionTimeDumpSamplesCoefficient} is above <code>0.0</code>. Must be integer value |
| * greater than <code>0</code>. |
| */ |
| private final DistributedChangeableProperty<Integer> longTransactionTimeDumpSamplesPerSecondLimit = |
| detachedIntegerProperty("longTransactionTimeDumpSamplesPerSecondLimit", |
| "The limit of samples of completed transactions that will be dumped in log per second, if " + |
| IGNITE_TRANSACTION_TIME_DUMP_SAMPLES_COEFFICIENT + " is above 0.0. Must be integer value " + |
| "greater than 0."); |
| |
| /** Collisions dump interval. */ |
| private final DistributedChangeableProperty<Integer> collisionsDumpInterval = |
| detachedIntegerProperty("collisionsDumpInterval", |
| "When above zero, prints tx key collisions once per interval. Each transaction besides " + |
| "OPTIMISTIC SERIALIZABLE capture locks on all enlisted keys, for some reasons per key lock queue may rise. " + |
| "This property sets the interval in milliseconds during which statistics are collected."); |
| |
| /** |
| * @param ctx Kernal context. |
| * @param log Log. |
| * @param longOperationsDumpTimeoutLsnr Listener of {@link #longOperationsDumpTimeout} change event. |
| * @param collisionsDumpIntervalLsnr Listener of {@link #collisionsDumpInterval} change event. |
| */ |
| public DistributedTransactionConfiguration( |
| GridKernalContext ctx, |
| IgniteLogger log, |
| DistributePropertyListener<Long> longOperationsDumpTimeoutLsnr, |
| DistributePropertyListener<Integer> collisionsDumpIntervalLsnr |
| ) { |
| ctx.internalSubscriptionProcessor().registerDistributedConfigurationListener( |
| new DistributedConfigurationLifecycleListener() { |
| @Override public void onReadyToRegister(DistributedPropertyDispatcher dispatcher) { |
| txOwnerDumpRequestsAllowed.addListener(makeUpdateListener(PROPERTY_UPDATE_MESSAGE, log)); |
| longOperationsDumpTimeout.addListener(makeUpdateListener(PROPERTY_UPDATE_MESSAGE, log)); |
| longTransactionTimeDumpThreshold.addListener(makeUpdateListener(PROPERTY_UPDATE_MESSAGE, log)); |
| transactionTimeDumpSamplesCoefficient.addListener(makeUpdateListener(PROPERTY_UPDATE_MESSAGE, log)); |
| longTransactionTimeDumpSamplesPerSecondLimit.addListener(makeUpdateListener(PROPERTY_UPDATE_MESSAGE, log)); |
| collisionsDumpInterval.addListener(makeUpdateListener(PROPERTY_UPDATE_MESSAGE, log)); |
| longOperationsDumpTimeout.addListener(longOperationsDumpTimeoutLsnr); |
| collisionsDumpInterval.addListener(collisionsDumpIntervalLsnr); |
| |
| dispatcher.registerProperties(txOwnerDumpRequestsAllowed, longOperationsDumpTimeout, |
| longTransactionTimeDumpThreshold, transactionTimeDumpSamplesCoefficient, |
| longTransactionTimeDumpSamplesPerSecondLimit, collisionsDumpInterval); |
| } |
| |
| @Override public void onReadyToWrite() { |
| if (ReadableDistributedMetaStorage.isSupported(ctx)) { |
| setDefaultValue( |
| longOperationsDumpTimeout, |
| dfltLongOpsDumpTimeout, |
| log); |
| setDefaultValue( |
| longTransactionTimeDumpThreshold, |
| dfltLongTransactionTimeDumpThreshold, |
| log); |
| setDefaultValue( |
| transactionTimeDumpSamplesCoefficient, |
| dfltTransactionTimeDumpSamplesCoefficient, |
| log); |
| setDefaultValue( |
| longTransactionTimeDumpSamplesPerSecondLimit, |
| dfltLongTransactionTimeDumpSamplesPerSecondLimit, |
| log); |
| setDefaultValue( |
| collisionsDumpInterval, |
| dfltCollisionsDumpInterval, |
| log); |
| setDefaultValue( |
| txOwnerDumpRequestsAllowed, |
| dfltTxOwnerDumpRequestsAllowed, |
| log); |
| } |
| else { |
| log.warning("Distributed metastorage is not supported. " + |
| "All distributed transaction configuration parameters are unavailable. " + |
| "Default values will be set."); |
| |
| longOperationsDumpTimeout.localUpdate(dfltLongOpsDumpTimeout); |
| longTransactionTimeDumpThreshold.localUpdate(dfltLongTransactionTimeDumpThreshold); |
| transactionTimeDumpSamplesCoefficient.localUpdate(dfltTransactionTimeDumpSamplesCoefficient); |
| longTransactionTimeDumpSamplesPerSecondLimit.localUpdate(dfltLongTransactionTimeDumpSamplesPerSecondLimit); |
| collisionsDumpInterval.localUpdate(dfltCollisionsDumpInterval); |
| txOwnerDumpRequestsAllowed.localUpdate(dfltTxOwnerDumpRequestsAllowed); |
| } |
| } |
| } |
| ); |
| } |
| |
| /** |
| * Cluster wide update of {@link #longOperationsDumpTimeout}. |
| * |
| * @param timeout New value of {@link #longOperationsDumpTimeout}. |
| * @return Future for {@link #longOperationsDumpTimeout} update operation. |
| * @throws IgniteCheckedException If failed during cluster wide update. |
| */ |
| public GridFutureAdapter<?> updateLongOperationsDumpTimeoutAsync(long timeout) throws IgniteCheckedException { |
| return longOperationsDumpTimeout.propagateAsync(timeout); |
| } |
| |
| /** |
| * Local update of {@link #longOperationsDumpTimeout}. |
| * |
| * @param timeout New value of {@link #longOperationsDumpTimeout}. |
| */ |
| public void updateLongOperationsDumpTimeoutLocal(long timeout) { |
| longOperationsDumpTimeout.localUpdate(timeout); |
| } |
| |
| /** |
| * @return Long operations dump timeout. See {@link #longOperationsDumpTimeout}. |
| */ |
| public Long longOperationsDumpTimeout() { |
| return longOperationsDumpTimeout.getOrDefault(dfltLongOpsDumpTimeout); |
| } |
| |
| /** |
| * Cluster wide update of {@link #longTransactionTimeDumpThreshold}. |
| * |
| * @param longTransactionTimeDumpThreshold New value of threshold timeout in milliseconds. |
| * @return Future for {@link #longTransactionTimeDumpThreshold} update operation. |
| * @throws IgniteCheckedException If failed during cluster wide update. |
| */ |
| public GridFutureAdapter<?> updateLongTransactionTimeDumpThresholdAsync(long longTransactionTimeDumpThreshold) |
| throws IgniteCheckedException { |
| return this.longTransactionTimeDumpThreshold.propagateAsync(longTransactionTimeDumpThreshold); |
| } |
| |
| /** |
| * Local update of {@link #longTransactionTimeDumpThreshold}. |
| * |
| * @param longTransactionTimeDumpThreshold New value of {@link #longTransactionTimeDumpThreshold}. |
| */ |
| public void updateLongTransactionTimeDumpThresholdLocal(long longTransactionTimeDumpThreshold) { |
| this.longTransactionTimeDumpThreshold.localUpdate(longTransactionTimeDumpThreshold); |
| } |
| |
| /** |
| * @return Threshold timeout for long transactions. See {@link #longTransactionTimeDumpThreshold} |
| * for more information. |
| */ |
| public Long longTransactionTimeDumpThreshold() { |
| return longTransactionTimeDumpThreshold.getOrDefault(dfltLongTransactionTimeDumpThreshold); |
| } |
| |
| /** |
| * Cluster wide update of {@link #transactionTimeDumpSamplesCoefficient}. |
| * |
| * @param transactionTimeDumpSamplesCoefficient New coefficient for samples of completed transactions that will be dumped in log. |
| * @return Future for {@link #transactionTimeDumpSamplesCoefficient} update operation. |
| * @throws IgniteCheckedException If failed during cluster wide update. |
| */ |
| public GridFutureAdapter<?> updateTransactionTimeDumpSamplesCoefficientAsync( |
| double transactionTimeDumpSamplesCoefficient |
| ) throws IgniteCheckedException { |
| return this.transactionTimeDumpSamplesCoefficient.propagateAsync(transactionTimeDumpSamplesCoefficient); |
| } |
| |
| /** |
| * Local update of {@link #transactionTimeDumpSamplesCoefficient}. |
| * |
| * @param transactionTimeDumpSamplesCoefficient New coefficient for samples of completed transactions that will be dumped in log. |
| */ |
| public void updateTransactionTimeDumpSamplesCoefficientLocal(double transactionTimeDumpSamplesCoefficient) { |
| this.transactionTimeDumpSamplesCoefficient.localUpdate(transactionTimeDumpSamplesCoefficient); |
| } |
| |
| /** |
| * @return The coefficient for samples of completed transactions that will be dumped in log. |
| * See {@link #transactionTimeDumpSamplesCoefficient}. |
| */ |
| public Double transactionTimeDumpSamplesCoefficient() { |
| return transactionTimeDumpSamplesCoefficient.getOrDefault(dfltTransactionTimeDumpSamplesCoefficient); |
| } |
| |
| /** |
| * Cluster wide update of {@link #longTransactionTimeDumpSamplesPerSecondLimit}. |
| * |
| * @param limit New limit of samples of completed transactions that will be dumped in log per second. |
| * @return Future for {@link #longTransactionTimeDumpSamplesPerSecondLimit} update operation. |
| * @throws IgniteCheckedException If failed during cluster wide update. |
| */ |
| public GridFutureAdapter<?> updateLongTransactionTimeDumpSamplesPerSecondLimitAsync(int limit) throws IgniteCheckedException { |
| return this.longTransactionTimeDumpSamplesPerSecondLimit.propagateAsync(limit); |
| } |
| |
| /** |
| * Local update of {@link #longTransactionTimeDumpSamplesPerSecondLimit}. |
| * |
| * @param limit New limit of samples of completed transactions that will be dumped in log per second. |
| */ |
| public void updateLongTransactionTimeDumpSamplesPerSecondLimitLocal(int limit) { |
| this.longTransactionTimeDumpSamplesPerSecondLimit.localUpdate(limit); |
| } |
| |
| /** |
| * @return Limit of samples of completed transactions that will be dumped in log per second. |
| * See {@link #longTransactionTimeDumpSamplesPerSecondLimit} for more information. |
| */ |
| public Integer longTransactionTimeDumpSamplesPerSecondLimit() { |
| return longTransactionTimeDumpSamplesPerSecondLimit.getOrDefault(dfltLongTransactionTimeDumpSamplesPerSecondLimit); |
| } |
| |
| /** |
| * Cluster wide update of {@link #collisionsDumpInterval}. |
| * |
| * @param collisionsDumpInterval New collisions dump interval. |
| * @return Future for {@link #collisionsDumpInterval} update operation. |
| * @throws IgniteCheckedException If failed during cluster wide update. |
| */ |
| public GridFutureAdapter<?> updateCollisionsDumpIntervalAsync(int collisionsDumpInterval) throws IgniteCheckedException { |
| return this.collisionsDumpInterval.propagateAsync(collisionsDumpInterval); |
| } |
| |
| /** |
| * Local update of {@link #collisionsDumpInterval}. |
| * |
| * @param collisionsDumpInterval New collisions dump interval. |
| */ |
| public void updateCollisionsDumpIntervalLocal(int collisionsDumpInterval) { |
| this.collisionsDumpInterval.localUpdate(collisionsDumpInterval); |
| } |
| |
| /** |
| * @return Collisions dump interval. See {@link #collisionsDumpInterval}. |
| */ |
| public Integer collisionsDumpInterval() { |
| return collisionsDumpInterval.getOrDefault(dfltCollisionsDumpInterval); |
| } |
| |
| /** |
| * Cluster wide update of {@link #txOwnerDumpRequestsAllowed}. |
| * |
| * @param allowed Allowance to dump requests from local node to near node, when long running transaction is found. |
| * @return Future for {@link #txOwnerDumpRequestsAllowed} update operation. |
| * @throws IgniteCheckedException If failed during cluster wide update. |
| */ |
| public GridFutureAdapter<?> updateTxOwnerDumpRequestsAllowedAsync(boolean allowed) throws IgniteCheckedException { |
| return this.txOwnerDumpRequestsAllowed.propagateAsync(allowed); |
| } |
| |
| /** |
| * Local update of {@link #txOwnerDumpRequestsAllowed}. |
| * |
| * @param allowed Allowance to dump requests from local node to near node, when long running transaction is found. |
| */ |
| public void updateTxOwnerDumpRequestsAllowedLocal(boolean allowed) { |
| this.txOwnerDumpRequestsAllowed.localUpdate(allowed); |
| } |
| |
| /** |
| * @return Allowance to dump requests from local node to near node, when long running transaction is found. |
| * See {@link #txOwnerDumpRequestsAllowed} for more information. |
| */ |
| public Boolean txOwnerDumpRequestsAllowed() { |
| return txOwnerDumpRequestsAllowed.getOrDefault(dfltTxOwnerDumpRequestsAllowed); |
| } |
| } |
