Skip to content

Commit

Permalink
Update TestNonBlockingStore.java
Browse files Browse the repository at this point in the history
  • Loading branch information
mgamanho authored Sep 26, 2024
1 parent b763c58 commit 3ac8ea6
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -297,6 +297,7 @@ public void loadAll(Set<? extends BinaryEntry<K, V>> setBinEntries, StoreObserve
public void store(BinaryEntry<K, V> binEntry, StoreObserver<K, V> observer)
{
log(true, "TestNonBlockingStore store\n" + Base.getStackTrace());
log(true, "TestNonBlockingStore store binEntry hashcode(1): " + binEntry.hashCode());

Object oKey = binEntry.getKey();
Object oValue = binEntry.getValue();
Expand All @@ -314,10 +315,12 @@ public void store(BinaryEntry<K, V> binEntry, StoreObserver<K, V> observer)
}

log("**MG** store thread[" + Thread.currentThread().getName() + "] delay duration: " + getDurationStore());
log(true, "TestNonBlockingStore store binEntry hashcode(2): " + binEntry.hashCode());
delay(getDurationStore());
getStorageMap().put(oKey, oValue);
getProcessor().process(binEntry);
delay(200);
log(true, "TestNonBlockingStore store binEntry hashcode(3): " + binEntry.hashCode());
log("**MG** store thread[" + Thread.currentThread().getName() + "] calling onNext");
observer.onNext(binEntry);
});
Expand Down

0 comments on commit 3ac8ea6

Please sign in to comment.