Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

Extract MapAbsentEntryOperations.shouldInsert() for subclassing ease

Browse Source
This commit is contained in:
leventov
2015-05-18 13:51:03 +01:00
parent 4aa0af1acf
commit 078068d8ff
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/MapAbsentEntryOperations.java
+9 -6
View File
@@ -32,6 +32,14 @@ import static net.openhft.chronicle.hash.replication.DefaultEventualConsistencyS
* @param <V> type of the value in {@code ChronicleMap}
*/
public interface MapAbsentEntryOperations<K, V> {
static boolean shoudInsert(@NotNull MapAbsentEntry<?, ?> absentEntry) {
MapContext<?, ?> context = absentEntry.context();
return !(context instanceof ReplicationContext) ||
!(absentEntry instanceof ReplicatedEntry) ||
shouldApplyRemoteModification((ReplicatedEntry) absentEntry,
(ReplicationContext) context);
}
/**
* Inserts the new entry into the map, of {@link MapAbsentEntry#absentKey() the key} from
@@ -43,12 +51,7 @@ public interface MapAbsentEntryOperations<K, V> {
* operation are not met
*/
default boolean insert(@NotNull MapAbsentEntry<K, V> absentEntry, Value<V, ?> value) {
MapContext<K, V> context = absentEntry.context();
boolean shouldInsert = !(context instanceof ReplicationContext) ||
!(absentEntry instanceof ReplicatedEntry) ||
shouldApplyRemoteModification((ReplicatedEntry) absentEntry,
(ReplicationContext) context);
if (shouldInsert) {
if (shoudInsert(absentEntry)) {
absentEntry.doInsert(value);
return true;
} else {