Update ReadWriteBackingMap.java

mgamanho · Sep 25, 2024 · 3943d56 · 3943d56
1 parent d45e878
commit 3943d56
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/prj/coherence-core/src/main/java/com/tangosol/net/cache/ReadWriteBackingMap.java b/prj/coherence-core/src/main/java/com/tangosol/net/cache/ReadWriteBackingMap.java
@@ -7609,12 +7609,18 @@ public StoreOperationObserver(Set setEntries)
             */
             public void onNext(BinaryEntry binEntry)
                 {
+                log("**MG** onNext beginning");
+
                 Entry         entry      = (Entry) binEntry;
                 ConcurrentMap mapControl = getControlMap();
                 Object        binKey     = binEntry.getBinaryKey();
 
+                log("**MG** onNext here(1)");
+
                 f_counterProcessed.incrementAndGet();
 
+                log("**MG** onNext here(2)");
+
                 if (getContext().isKeyOwned(binKey) && mapControl.lock(binKey, 100L))
                     {
                     try