This is an automated email from the ASF dual-hosted git repository.
NSAmelchev pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 87caedea097 IGNITE-28620 Remove
TxTimeoutOnPartitionMapExchangeChangeTask (#13086)
87caedea097 is described below
commit 87caedea0972033b744903697ddba7f679f04fe6
Author: Dmitry Werner <[email protected]>
AuthorDate: Wed Apr 29 12:51:27 2026 +0500
IGNITE-28620 Remove TxTimeoutOnPartitionMapExchangeChangeTask (#13086)
---
.../processors/cache/GridCacheProcessor.java | 5 --
.../TxTimeoutOnPartitionMapExchangeChangeTask.java | 61 ----------------------
.../cache/transactions/IgniteTxManager.java | 14 -----
3 files changed, 80 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
index 298c69cd767..223dac5edaa 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
@@ -447,11 +447,6 @@ public class GridCacheProcessor extends
GridProcessorAdapter {
processStatisticsModeChange(task0.message());
}
- else if (task instanceof TxTimeoutOnPartitionMapExchangeChangeTask) {
- TxTimeoutOnPartitionMapExchangeChangeTask task0 =
(TxTimeoutOnPartitionMapExchangeChangeTask)task;
-
-
sharedCtx.tm().processTxTimeoutOnPartitionMapExchangeChange(task0.message());
- }
else if (task instanceof StopCachesOnClientReconnectExchangeTask) {
StopCachesOnClientReconnectExchangeTask task0 =
(StopCachesOnClientReconnectExchangeTask)task;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeTask.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeTask.java
deleted file mode 100644
index 1c7c226c908..00000000000
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeTask.java
+++ /dev/null
@@ -1,61 +0,0 @@
-/*
- * 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.processors.cache;
-
-import org.apache.ignite.internal.processors.security.SecurityContext;
-import org.apache.ignite.internal.util.typedef.internal.S;
-
-/**
- * The task for changing transaction timeout on partition map exchange.
- */
-public class TxTimeoutOnPartitionMapExchangeChangeTask extends
AbstractCachePartitionExchangeWorkerTask {
- /** Discovery message. */
- private final TxTimeoutOnPartitionMapExchangeChangeMessage msg;
-
- /**
- * Constructor.
- *
- * @param secCtx Security context in which current task must be executed.
- * @param msg Discovery message.
- */
- public TxTimeoutOnPartitionMapExchangeChangeTask(SecurityContext secCtx,
TxTimeoutOnPartitionMapExchangeChangeMessage msg) {
- super(secCtx);
-
- assert msg != null;
- this.msg = msg;
- }
-
- /**
- * Gets discovery message.
- *
- * @return Discovery message.
- */
- public TxTimeoutOnPartitionMapExchangeChangeMessage message() {
- return msg;
- }
-
- /** {@inheritDoc} */
- @Override public boolean skipForExchangeMerge() {
- return false;
- }
-
- /** {@inheritDoc} */
- @Override public String toString() {
- return S.toString(TxTimeoutOnPartitionMapExchangeChangeTask.class,
this);
- }
-}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
index a65905b80ee..29c5283c0af 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
@@ -2768,20 +2768,6 @@ public class IgniteTxManager extends
GridCacheSharedManagerAdapter {
}
}
- /**
- * The task for changing transaction timeout on partition map exchange
processed by exchange worker.
- *
- * @param msg Message.
- */
- public void
processTxTimeoutOnPartitionMapExchangeChange(TxTimeoutOnPartitionMapExchangeChangeMessage
msg) {
- assert msg != null;
-
- long timeout =
cctx.kernalContext().config().getTransactionConfiguration().getTxTimeoutOnPartitionMapExchange();
-
- if (timeout != msg.getTimeout())
-
cctx.kernalContext().config().getTransactionConfiguration().setTxTimeoutOnPartitionMapExchange(msg.getTimeout());
- }
-
/**
* Method checks that current thread does not have active transactions.
* If transaction or topology lock is hold by current thread
