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

Minor fixes in VanillaChronicleMap and ReplicatedChronicleMap

Browse Source
This commit is contained in:
leventov
2016-10-01 20:33:16 +03:00
parent ec919b94eb
commit f93001dc8e
2 changed files with 13 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
+6 -6
View File
@@ -560,10 +560,10 @@ public class ReplicatedChronicleMap<K, V, R> extends VanillaChronicleMap<K, V, R
}
private ChainingInterface q() {
ChainingInterface queryContext;
queryContext = cxt.get();
//noinspection unchecked
ChainingInterface queryContext = cxt.get();
if (queryContext == null) {
queryContext = new CompiledReplicatedMapQueryContext<>(ReplicatedChronicleMap.this);
queryContext = new CompiledReplicatedMapQueryContext<>(this);
addContext(queryContext);
cxt.set(queryContext);
}
@@ -595,10 +595,10 @@ public class ReplicatedChronicleMap<K, V, R> extends VanillaChronicleMap<K, V, R
}
private ChainingInterface i() {
ChainingInterface iterContext;
iterContext = cxt.get();
//noinspection unchecked
ChainingInterface iterContext = cxt.get();
if (iterContext == null) {
iterContext = new CompiledReplicatedMapIterationContext<>(ReplicatedChronicleMap.this);
iterContext = new CompiledReplicatedMapIterationContext<>(this);
addContext(iterContext);
cxt.set(iterContext);
}
src/main/java/net/openhft/chronicle/map/VanillaChronicleMap.java
+7 -6
View File
@@ -263,10 +263,10 @@ public class VanillaChronicleMap<K, V, R>
}
private ChainingInterface q() {
ChainingInterface queryContext;
queryContext = cxt.get();
//noinspection unchecked
ChainingInterface queryContext = cxt.get();
if (queryContext == null) {
queryContext = new CompiledMapQueryContext<>(VanillaChronicleMap.this);
queryContext = new CompiledMapQueryContext<>(this);
addContext(queryContext);
cxt.set(queryContext);
}
@@ -274,15 +274,16 @@ public class VanillaChronicleMap<K, V, R>
}
public QueryContextInterface<K, V, R> mapContext() {
//noinspection unchecked
return q().getContext(CompiledMapQueryContext.class,
ci -> new CompiledMapQueryContext<>(ci, this));
}
private ChainingInterface i() {
ChainingInterface iterContext;
iterContext = cxt.get();
//noinspection unchecked
ChainingInterface iterContext = cxt.get();
if (iterContext == null) {
iterContext = new CompiledMapIterationContext<>(VanillaChronicleMap.this);
iterContext = new CompiledMapIterationContext<>(this);
addContext(iterContext);
cxt.set(iterContext);
}