[2/2] ignite git commit: IGNITE-7871 Implemented additional synchronization phase for correct partition counters update

2018-04-11 Thread agoncharuk 
IGNITE-7871 Implemented additional synchronization phase for correct partition 
counters update


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b4cc9f2d
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b4cc9f2d
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b4cc9f2d

Branch: refs/heads/ignite-2.5
Commit: b4cc9f2d45d78c360abe224165e707c23533469e
Parents: b4cb2f0
Author: Pavel Kovalenko 
Authored: Wed Apr 11 11:23:46 2018 +0300
Committer: Alexey Goncharuk 
Committed: Wed Apr 11 11:30:27 2018 +0300

--
 .../org/apache/ignite/internal/GridTopic.java   |   5 +-
 .../communication/GridIoMessageFactory.java |   6 +
 .../discovery/GridDiscoveryManager.java |  10 +
 .../MetaPageUpdatePartitionDataRecord.java  |   2 +-
 .../processors/cache/CacheMetricsImpl.java  |   2 +-
 .../processors/cache/GridCacheMvccManager.java  |  38 +
 .../GridCachePartitionExchangeManager.java  |  17 +
 .../cache/GridCacheSharedContext.java   |   9 +-
 .../processors/cache/GridCacheUtils.java|   2 +-
 .../cache/IgniteCacheOffheapManager.java|   8 +-
 .../cache/IgniteCacheOffheapManagerImpl.java|  10 +-
 .../dht/GridClientPartitionTopology.java|   5 +
 .../distributed/dht/GridDhtLocalPartition.java  |   9 +-
 .../dht/GridDhtPartitionTopology.java   |   6 +
 .../dht/GridDhtPartitionTopologyImpl.java   |  26 +-
 .../dht/GridDhtPartitionsStateValidator.java| 255 +++
 .../cache/distributed/dht/GridDhtTxLocal.java   |   5 +
 .../GridDhtPartitionsExchangeFuture.java|  96 ++-
 .../GridDhtPartitionsSingleMessage.java |  68 +-
 .../dht/preloader/InitNewCoordinatorFuture.java |   2 +-
 .../preloader/latch/ExchangeLatchManager.java   | 695 +++
 .../distributed/dht/preloader/latch/Latch.java  |  52 ++
 .../dht/preloader/latch/LatchAckMessage.java| 165 +
 .../cache/distributed/near/GridNearTxLocal.java |  10 +
 .../persistence/GridCacheOffheapManager.java|  10 +-
 .../cache/transactions/IgniteTxAdapter.java |   2 +-
 .../cache/transactions/IgniteTxManager.java |  36 +-
 ...cheDhtLocalPartitionAfterRemoveSelfTest.java |   2 +-
 .../processors/cache/IgniteCacheGroupsTest.java |   1 +
 ...ExchangeLatchManagerCoordinatorFailTest.java | 244 +++
 .../GridCachePartitionsStateValidationTest.java | 316 +
 ...idCachePartitionsStateValidatorSelfTest.java | 158 +
 .../TxOptimisticOnPartitionExchangeTest.java| 322 +
 .../ignite/testsuites/IgniteCacheTestSuite.java |   4 +
 .../testsuites/IgniteCacheTestSuite6.java   |   6 +
 35 files changed, 2568 insertions(+), 36 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/ignite/blob/b4cc9f2d/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java 
b/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java
index 1227e8c..0b2d41a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java
@@ -124,7 +124,10 @@ public enum GridTopic {
 TOPIC_METRICS,
 
 /** */
-TOPIC_AUTH;
+TOPIC_AUTH,
+
+/** */
+TOPIC_EXCHANGE;
 
 /** Enum values. */
 private static final GridTopic[] VALS = values();

http://git-wip-us.apache.org/repos/asf/ignite/blob/b4cc9f2d/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
index 5616fd0..581c32e 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
@@ -53,6 +53,7 @@ import 
org.apache.ignite.internal.processors.cache.KeyCacheObjectImpl;
 import org.apache.ignite.internal.processors.cache.WalStateAckMessage;
 import 
org.apache.ignite.internal.processors.cache.binary.MetadataRequestMessage;
 import 
org.apache.ignite.internal.processors.cache.binary.MetadataResponseMessage;
+import 
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.LatchAckMessage;
 import 
org.apache.ignite.internal.processors.cache.distributed.GridCacheTtlUpdateRequest;
 import 
org.apache.ignite.internal.processors.cache.distributed.GridCacheTxRecoveryRequest;
 import 
org.apache.ignite.internal.processors

[2/2] ignite git commit: IGNITE-7871 Implemented additional synchronization phase for correct partition counters update

2018-04-11 Thread agoncharuk 
IGNITE-7871 Implemented additional synchronization phase for correct partition 
counters update


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/da77b981
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/da77b981
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/da77b981

Branch: refs/heads/master
Commit: da77b9818a70495b7afdf6899ebd9180dadd7f68
Parents: f4de6df
Author: Pavel Kovalenko 
Authored: Wed Apr 11 11:23:46 2018 +0300
Committer: Alexey Goncharuk 
Committed: Wed Apr 11 11:23:46 2018 +0300

--
 .../org/apache/ignite/internal/GridTopic.java   |   5 +-
 .../communication/GridIoMessageFactory.java |   6 +
 .../discovery/GridDiscoveryManager.java |  10 +
 .../MetaPageUpdatePartitionDataRecord.java  |   2 +-
 .../processors/cache/CacheMetricsImpl.java  |   2 +-
 .../processors/cache/GridCacheMvccManager.java  |  38 +
 .../GridCachePartitionExchangeManager.java  |  17 +
 .../cache/GridCacheSharedContext.java   |   9 +-
 .../processors/cache/GridCacheUtils.java|   2 +-
 .../cache/IgniteCacheOffheapManager.java|   8 +-
 .../cache/IgniteCacheOffheapManagerImpl.java|  10 +-
 .../dht/GridClientPartitionTopology.java|   5 +
 .../distributed/dht/GridDhtLocalPartition.java  |   9 +-
 .../dht/GridDhtPartitionTopology.java   |   6 +
 .../dht/GridDhtPartitionTopologyImpl.java   |  26 +-
 .../dht/GridDhtPartitionsStateValidator.java| 255 +++
 .../cache/distributed/dht/GridDhtTxLocal.java   |   5 +
 .../GridDhtPartitionsExchangeFuture.java|  96 ++-
 .../GridDhtPartitionsSingleMessage.java |  68 +-
 .../dht/preloader/InitNewCoordinatorFuture.java |   2 +-
 .../preloader/latch/ExchangeLatchManager.java   | 695 +++
 .../distributed/dht/preloader/latch/Latch.java  |  52 ++
 .../dht/preloader/latch/LatchAckMessage.java| 165 +
 .../cache/distributed/near/GridNearTxLocal.java |  10 +
 .../persistence/GridCacheOffheapManager.java|  10 +-
 .../cache/transactions/IgniteTxAdapter.java |   2 +-
 .../cache/transactions/IgniteTxManager.java |  36 +-
 ...cheDhtLocalPartitionAfterRemoveSelfTest.java |   2 +-
 .../processors/cache/IgniteCacheGroupsTest.java |   1 +
 ...ExchangeLatchManagerCoordinatorFailTest.java | 244 +++
 .../GridCachePartitionsStateValidationTest.java | 316 +
 ...idCachePartitionsStateValidatorSelfTest.java | 158 +
 .../TxOptimisticOnPartitionExchangeTest.java| 322 +
 .../ignite/testsuites/IgniteCacheTestSuite.java |   4 +
 .../testsuites/IgniteCacheTestSuite6.java   |   6 +
 35 files changed, 2568 insertions(+), 36 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/ignite/blob/da77b981/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java 
b/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java
index 1227e8c..0b2d41a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java
@@ -124,7 +124,10 @@ public enum GridTopic {
 TOPIC_METRICS,
 
 /** */
-TOPIC_AUTH;
+TOPIC_AUTH,
+
+/** */
+TOPIC_EXCHANGE;
 
 /** Enum values. */
 private static final GridTopic[] VALS = values();

http://git-wip-us.apache.org/repos/asf/ignite/blob/da77b981/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
index 5616fd0..581c32e 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
@@ -53,6 +53,7 @@ import 
org.apache.ignite.internal.processors.cache.KeyCacheObjectImpl;
 import org.apache.ignite.internal.processors.cache.WalStateAckMessage;
 import 
org.apache.ignite.internal.processors.cache.binary.MetadataRequestMessage;
 import 
org.apache.ignite.internal.processors.cache.binary.MetadataResponseMessage;
+import 
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.LatchAckMessage;
 import 
org.apache.ignite.internal.processors.cache.distributed.GridCacheTtlUpdateRequest;
 import 
org.apache.ignite.internal.processors.cache.distributed.GridCacheTxRecoveryRequest;
 import 
org.apache.ignite.internal.processors.cac