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

stated to add meta data

Browse Source
This commit is contained in:
Rob Austin
2015-03-31 17:01:09 +01:00
parent 250c5fdd46
commit 75ecfb6c7e
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/ClientWiredStatelessTcpConnectionHub.java
+12 -5
View File
@@ -27,6 +27,8 @@ import net.openhft.chronicle.map.MapWireHandler.EventId;
import net.openhft.chronicle.network2.event.EventGroup;
import net.openhft.chronicle.wire.TextWire;
import net.openhft.chronicle.wire.Wire;
import net.openhft.chronicle.wire.WireIn;
import net.openhft.chronicle.wire.WireOut;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
import org.slf4j.Logger;
@@ -38,6 +40,7 @@ import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.locks.ReentrantLock;
import java.util.function.Consumer;
import static net.openhft.chronicle.map.MapWireHandler.EventId.applicationVersion;
import static net.openhft.chronicle.map.MapWireHandler.SIZE_OF_SIZE;
@@ -470,7 +473,6 @@ public class ClientWiredStatelessTcpConnectionHub {
buffer = inWireByteBuffer(position + requiredNumberOfBytes);
buffer.limit(position + requiredNumberOfBytes);
buffer.position(position);
}
long start = buffer.position();
@@ -644,10 +646,15 @@ public class ClientWiredStatelessTcpConnectionHub {
startTime(startTime);
long tid = nextUniqueTransaction(startTime);
wire.write(type).text("MAP");
wire.write(MapWireHandlerBuilder.Fields.tid).int64(tid);
wire.write(timeStamp).int64(startTime);
wire.write(channelId).int16(channelID);
wire.writeDocument(true, new Consumer<WireOut>() {
@Override
public void accept(WireOut wireOut) {
wireOut.write(type).text("MAP");
wireOut.write(MapWireHandlerBuilder.Fields.tid).int64(tid);
wireOut.write(timeStamp).int64(startTime);
wireOut.write(channelId).int16(channelID);
}
});
return tid;
}