anton-vinogradov commented on a change in pull request #8822:
URL: https://github.com/apache/ignite/pull/8822#discussion_r594298902
##########
File path:
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
##########
@@ -1634,41 +1631,12 @@ private void distributedExchange() throws
IgniteCheckedException {
boolean skipWaitOnLocalJoin = localJoinExchange()
&& cctx.exchange().latch().canSkipJoiningNodes(initialVersion());
- if (context().exchangeFreeSwitch() && isBaselineNodeFailed()) {
+ if (context().exchangeFreeSwitch() && isBaselineNodeFailed())
// Currently MVCC does not support operations on partially
switched cluster.
if (cctx.kernalContext().coordinators().mvccEnabled())
- waitPartitionRelease(EXCHANGE_FREE_LATCH_ID, true, false,
null);
- else {
- boolean partitionedRecoveryRequired =
rebalancedInfo.primaryNodes.contains(firstDiscoEvt.eventNode());
-
- IgnitePredicate<IgniteInternalTx> replicatedOnly = tx -> {
- Collection<IgniteTxEntry> entries = tx.writeEntries();
- for (IgniteTxEntry entry : entries)
- if (cctx.cacheContext(entry.cacheId()).isReplicated())
- return true;
-
- // Checks only affected nodes contain replicated-free txs
with failed primaries.
- assert partitionedRecoveryRequired;
-
- return false;
- };
-
- // Assuming that replicated transactions are absent,
non-affected nodes will wait only this short sync.
- waitPartitionRelease(EXCHANGE_FREE_LATCH_ID + "-replicated",
true, false, replicatedOnly);
-
- String partitionedLatchId = EXCHANGE_FREE_LATCH_ID +
"-partitioned";
-
- if (partitionedRecoveryRequired)
- // This node contain backup partitions for failed
partitioned caches primaries. Waiting for recovery.
- waitPartitionRelease(partitionedLatchId, true, false,
null);
- else {
- // This node contain no backup partitions for failed
partitioned caches primaries. Recovery is not needed.
- Latch releaseLatch =
cctx.exchange().latch().getOrCreate(partitionedLatchId, initialVersion());
-
- releaseLatch.countDown(); // Await-free confirmation.
- }
- }
- }
+ waitPartitionRelease(EXCHANGE_FREE_LATCH_ID, true, false);
+ else
+ waitPartitionRelease(null, false, false);
Review comment:
Relocated time bag message
https://github.com/apache/ignite/pull/8822/commits/c823f58e7660b90971c63fbbfa67e7120de26ab0
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
