From 7378755d327d46c157d3160889a0a83084a77af1 Mon Sep 17 00:00:00 2001 From: Maurice Gamanho Date: Thu, 26 Sep 2024 14:45:14 -0600 Subject: [PATCH] Update TestNonBlockingStore.java --- .../java/com/oracle/coherence/testing/TestNonBlockingStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/TestNonBlockingStore.java b/prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/TestNonBlockingStore.java index 7662b336bec9d..5219dd066df5d 100644 --- a/prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/TestNonBlockingStore.java +++ b/prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/TestNonBlockingStore.java @@ -316,10 +316,10 @@ public void store(BinaryEntry binEntry, StoreObserver observer) log("**MG** store thread[" + Thread.currentThread().getName() + "] delay duration: " + getDurationStore()); log("**MG** TestNonBlockingStore store binEntry hashcode(2): " + binEntry.getBinaryValue().hashCode()); + delay(200); delay(getDurationStore()); getStorageMap().put(oKey, oValue); getProcessor().process(binEntry); - delay(200); log("**MG** TestNonBlockingStore store binEntry hashcode(3): " + binEntry.getBinaryValue().hashCode()); log("**MG** store thread[" + Thread.currentThread().getName() + "] calling onNext"); observer.onNext(binEntry);