Fix for 9200

gridgain · Aug 9, 2018 · 9d898b9 · 9d898b9
1 parent cee22eb
commit 9d898b9
Show file tree

Hide file tree

Showing 2 changed files with 81 additions and 61 deletions.
diff --git a/...apache/ignite/internal/processors/cache/distributed/dht/atomic/DhtAtomicUpdateResult.java b/...apache/ignite/internal/processors/cache/distributed/dht/atomic/DhtAtomicUpdateResult.java
@@ -19,9 +19,11 @@
 
 import java.util.ArrayList;
 import java.util.Collection;
+import java.util.HashSet;
 import org.apache.ignite.internal.processors.cache.GridCacheReturn;
 import org.apache.ignite.internal.processors.cache.GridCacheUpdateAtomicResult;
 import org.apache.ignite.internal.processors.cache.IgniteCacheExpiryPolicy;
+import org.apache.ignite.internal.processors.cache.KeyCacheObject;
 import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheEntry;
 import org.apache.ignite.internal.processors.cache.version.GridCacheVersion;
 import org.apache.ignite.internal.util.typedef.F;
@@ -97,10 +99,14 @@ void addDeleted(GridDhtCacheEntry entry,
     /**
      * @return Deleted entries.
      */
-    Collection<IgniteBiTuple<GridDhtCacheEntry, GridCacheVersion>> deleted() {
+    public Collection<IgniteBiTuple<GridDhtCacheEntry, GridCacheVersion>> deleted() {
         return deleted;
     }
 
+    void deleted(Collection<IgniteBiTuple<GridDhtCacheEntry, GridCacheVersion>> deleted) {
+        this.deleted = deleted;
+    }
+
     /**
      * @return DHT future.
      */
@@ -128,4 +134,14 @@ GridCacheReturn returnValue() {
     void dhtFuture(@Nullable GridDhtAtomicAbstractUpdateFuture dhtFut) {
         this.dhtFut = dhtFut;
     }
+
+    HashSet<KeyCacheObject> processedKyes = new HashSet<>();
+
+    public void addProccessedKey(KeyCacheObject k) {
+        processedKyes.add(k);
+    }
+
+    public boolean isProccessedKey(KeyCacheObject k) {
+        return processedKyes.contains(k);
+    }
 }