mirror of
https://github.com/OpenHFT/Chronicle-Map.git
synced 2021-09-13 01:26:12 +00:00
HCOLL-200 removed trace code
This commit is contained in:
@@ -443,8 +443,6 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, KI>,
|
||||
final long valuePosition = entry.position();
|
||||
|
||||
keySizeMarshaller.writeSize(destination, keySize);
|
||||
System.out.println("keySize= " + keySize);
|
||||
|
||||
valueSizeMarshaller.writeSize(destination, valueSize);
|
||||
destination.writeStopBit(timeStamp);
|
||||
|
||||
@@ -495,19 +493,10 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, KI>,
|
||||
public void readExternalEntry(@NotNull Bytes source) {
|
||||
|
||||
final long keySize = keySizeMarshaller.readSize(source);
|
||||
System.out.println("read keySize= " + keySize);
|
||||
|
||||
// long valueSize = source.readStopBit();
|
||||
|
||||
final long valueSize = valueSizeMarshaller.readSize(source);
|
||||
System.out.println("read valueSize= " + valueSize);
|
||||
|
||||
|
||||
final long timeStamp = source.readStopBit();
|
||||
|
||||
|
||||
System.out.println("read timestamp= " + timeStamp);
|
||||
|
||||
final byte id = source.readByte();
|
||||
final boolean isDeleted = source.readBoolean();
|
||||
|
||||
|
||||
@@ -50,13 +50,13 @@ public class TCPSocketReplicationNativeTest {
|
||||
public void setup() throws IOException {
|
||||
InetSocketAddress endpoint = new InetSocketAddress("localhost", 8077);
|
||||
|
||||
TcpTransportAndNetworkConfig tcpConfig1 = TcpTransportAndNetworkConfig.forSendingNode(8076, endpoint)
|
||||
TcpTransportAndNetworkConfig tcpConfig1 = TcpTransportAndNetworkConfig.of(8076, endpoint)
|
||||
.heartBeatInterval(1L, TimeUnit.SECONDS);
|
||||
|
||||
map1 = OffHeapUpdatableChronicleMapBuilder.of(Integer.class, LongValue.class)
|
||||
.replication((byte) 1, tcpConfig1).create();
|
||||
|
||||
TcpTransportAndNetworkConfig tcpConfig2 = TcpTransportAndNetworkConfig.forReceivingOnlyNode(8077)
|
||||
TcpTransportAndNetworkConfig tcpConfig2 = TcpTransportAndNetworkConfig.of(8077)
|
||||
.heartBeatInterval(1L, TimeUnit.SECONDS);
|
||||
|
||||
map2 = OffHeapUpdatableChronicleMapBuilder.of(Integer.class, LongValue.class)
|
||||
@@ -89,7 +89,6 @@ public class TCPSocketReplicationNativeTest {
|
||||
}
|
||||
|
||||
|
||||
|
||||
// allow time for the recompilation to resolve
|
||||
waitTillEqual(5000);
|
||||
|
||||
@@ -99,7 +98,6 @@ public class TCPSocketReplicationNativeTest {
|
||||
}
|
||||
|
||||
|
||||
|
||||
@Test
|
||||
public void test2Puts() throws IOException, InterruptedException {
|
||||
|
||||
@@ -126,7 +124,6 @@ public class TCPSocketReplicationNativeTest {
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
* * waits until map1 and map2 show the same value
|
||||
*
|
||||
* @param timeOutMs timeout in milliseconds
|
||||
|
||||
Reference in New Issue
Block a user