GEODE-10008: Avoid possible EntryDestroyedException error (apache#7343)

rbowen · Feb 17, 2022 · 9cd402f · 9cd402f
1 parent 4d1a263
commit 9cd402f
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/...ava/org/apache/geode/management/internal/cli/functions/WanCopyRegionFunctionDelegate.java b/...ava/org/apache/geode/management/internal/cli/functions/WanCopyRegionFunctionDelegate.java
@@ -26,8 +26,6 @@
 import java.util.Iterator;
 import java.util.List;
 import java.util.Optional;
-import java.util.Set;
-import java.util.stream.Collectors;
 
 import org.apache.logging.log4j.Logger;
 
@@ -186,13 +184,11 @@ private Optional<CliFunctionResult> sendBatch(String memberName,
     return batch;
   }
 
-  private Set<?> getEntries(Region<?, ?> region, GatewaySender sender) {
+  private List<?> getEntries(Region<?, ?> region, GatewaySender sender) {
     if (region instanceof PartitionedRegion && sender.isParallel()) {
-      return ((PartitionedRegion) region).getDataStore().getAllLocalBucketRegions()
-          .stream()
-          .flatMap(br -> ((Set<?>) br.entrySet()).stream()).collect(Collectors.toSet());
+      return ((PartitionedRegion) region).getDataStore().getEntries();
     }
-    return region.entrySet();
+    return new ArrayList<>(region.entrySet());
   }
 
   /**