GG-19515: GG: destroying of the cache and re-creating with the same n…

…ame make DR paused in case of persistence.
gridgain · Jun 27, 2019 · e093716 · e093716
1 parent 6ccbbfe
commit e093716
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 4 deletions.
diff --git a/.../internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java b/.../internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
@@ -2226,7 +2226,7 @@ private String exchangeTimingsLogMessage(String header, List<String> timings) {
 
                     if (drCacheCtx.isDrEnabled()) {
                         try {
-                            drCacheCtx.dr().onExchange(res, exchId.isLeft(), activateCluster());
+                            drCacheCtx.dr().onExchange(res, exchId.isLeft());
                         }
                         catch (IgniteCheckedException e) {
                             U.error(log, "Failed to notify DR: " + e, e);

diff --git a/...core/src/main/java/org/apache/ignite/internal/processors/cache/dr/GridCacheDrManager.java b/...core/src/main/java/org/apache/ignite/internal/processors/cache/dr/GridCacheDrManager.java
@@ -59,10 +59,9 @@ public void replicate(KeyCacheObject key,
      *
      * @param topVer Topology version.
      * @param left {@code True} if exchange has been caused by node leave.
-     * @param activate {@code True} if exchange has been caused by cluster activation.
      * @throws IgniteCheckedException If failed.
      */
-    public void onExchange(AffinityTopologyVersion topVer, boolean left, boolean activate) throws IgniteCheckedException;
+    public void onExchange(AffinityTopologyVersion topVer, boolean left) throws IgniteCheckedException;
 
     /**
      * @return {@code True} is DR is enabled.

diff --git a/...re/src/main/java/org/apache/ignite/internal/processors/cache/dr/GridOsCacheDrManager.java b/...re/src/main/java/org/apache/ignite/internal/processors/cache/dr/GridOsCacheDrManager.java
@@ -77,7 +77,7 @@ public class GridOsCacheDrManager implements GridCacheDrManager {
     }
 
     /** {@inheritDoc} */
-    @Override public void onExchange(AffinityTopologyVersion topVer, boolean left, boolean activate) throws IgniteCheckedException {
+    @Override public void onExchange(AffinityTopologyVersion topVer, boolean left) throws IgniteCheckedException {
         // No-op.
     }