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-167 in and out now share the same buffer

Browse Source
This commit is contained in:
Rob Austin
2014-10-23 13:54:08 +01:00
parent 0abc9bc003
commit f04cdd0d9f
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java
+3 -5
View File
@@ -27,7 +27,6 @@ import static net.openhft.chronicle.map.StatelessChronicleMap.EventId.*;
class StatelessChronicleMap<K, V> implements ChronicleMap<K, V>, Closeable {
private static final Logger LOG = LoggerFactory.getLogger(StatelessChronicleMap.class);
public static final byte STATELESS_CLIENT_IDENTIFIER = (byte) -127;
private final byte[] connectionByte = new byte[1];
@@ -35,12 +34,11 @@ class StatelessChronicleMap<K, V> implements ChronicleMap<K, V>, Closeable {
private final ByteBuffer outBuffer = allocateDirect(1024);
private final ByteBufferBytes out = new ByteBufferBytes(outBuffer.slice());
private ByteBufferBytes in = new ByteBufferBytes(allocateDirect(1024));
// if you want you could change this later so that "in" has its own buffer.
private ByteBufferBytes in = out;
private final KeyValueSerializer<K, V> keyValueSerializer;
// private final ByteBufferBytes connectionIn = new ByteBufferBytes(allocateDirect(1024));
private volatile SocketChannel clientChannel;
private CloseablesManager closeables;