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

HCOLL-216 added a test for getLater

Browse Source
This commit is contained in:
Rob Austin
2014-11-24 14:53:57 +00:00
parent 5db55e566b
commit 1e87d6ba8a
6 changed files with 1351 additions and 1052 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
+1 -1
View File
@@ -307,7 +307,7 @@ abstract class AbstractChannelReplicator implements Closeable {
long pos0 = in.position();
// used to denote that this is not a stateless map event
in.writeByte(StatelessChronicleMap.EventId.STATEFUL_UPDATE.ordinal());
in.writeByte(StatelessChronicleMapUnsynchronized.EventId.STATEFUL_UPDATE.ordinal());
long sizeLocation = in.position();
src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java
+156 -1047
View File
File diff suppressed because it is too large Load Diff
src/main/java/net/openhft/chronicle/map/StatelessChronicleMapUnsynchronized.java
+1157
View File
File diff suppressed because it is too large Load Diff
src/main/java/net/openhft/chronicle/map/TcpReplicator.java
+4 -3
View File
@@ -42,7 +42,7 @@ import static java.nio.channels.SelectionKey.*;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static net.openhft.chronicle.map.AbstractChannelReplicator.SIZE_OF_SIZE;
import static net.openhft.chronicle.map.AbstractChannelReplicator.SIZE_OF_TRANSACTIONID;
import static net.openhft.chronicle.map.StatelessChronicleMap.EventId.HEARTBEAT;
import static net.openhft.chronicle.map.StatelessChronicleMapUnsynchronized.EventId.HEARTBEAT;
interface Work {
@@ -1259,7 +1259,8 @@ class StatelessServerConnector<K, V> {
("mapSupportsBytes"));
private static final Logger LOG = LoggerFactory.getLogger(StatelessServerConnector.class
.getName());
public static final StatelessChronicleMap.EventId[] VALUES = StatelessChronicleMap.EventId.values();
public static final StatelessChronicleMapUnsynchronized.EventId[] VALUES
= StatelessChronicleMapUnsynchronized.EventId.values();
public static final int SIZE_OF_IS_EXCEPTION = 1;
public static final int HEADER_SIZE = SIZE_OF_SIZE + SIZE_OF_IS_EXCEPTION + SIZE_OF_TRANSACTIONID;
@@ -1283,7 +1284,7 @@ class StatelessServerConnector<K, V> {
@NotNull final ByteBufferBytes reader) {
final StatelessChronicleMap.EventId event = VALUES[eventId];
final StatelessChronicleMapUnsynchronized.EventId event = VALUES[eventId];
// these methods don't return a result
switch (event) {
src/main/java/net/openhft/chronicle/map/VanillaChronicleMap.java
+1 -1
View File
@@ -303,7 +303,7 @@ class VanillaChronicleMap<K, KI, MKI extends MetaBytesInterop<K, KI>,
}
MapEventListener<K, V, ChronicleMap<K, V>> eventListener() {
return eventListener;
return eventListener == null ? MapEventListeners.NOP : eventListener;
}
void checkKey(Object key) {