From b395770956195fd041b8a0119da0e8891cc297a8 Mon Sep 17 00:00:00 2001 From: leventov Date: Wed, 28 Jan 2015 14:25:30 +0700 Subject: [PATCH] Updated Java-Lang version --- pom.xml | 2 +- .../serialization/internal/BasicCopyingMetaBytesInterop.java | 2 +- .../hash/serialization/internal/BytesBytesInterop.java | 2 +- src/main/java/net/openhft/chronicle/map/ChannelProvider.java | 2 +- src/main/java/net/openhft/chronicle/map/NodeDiscovery.java | 2 +- .../net/openhft/chronicle/map/ReplicatedChronicleMap.java | 4 ++-- .../java/net/openhft/chronicle/map/StatelessClientTest.java | 2 +- 7 files changed, 8 insertions(+), 8 deletions(-) diff --git a/pom.xml b/pom.xml index 3224ba9ca..9bf7c5612 100644 --- a/pom.xml +++ b/pom.xml @@ -48,7 +48,7 @@ net.openhft lang - 6.5-SNAPSHOT + 6.6-SNAPSHOT diff --git a/src/main/java/net/openhft/chronicle/hash/serialization/internal/BasicCopyingMetaBytesInterop.java b/src/main/java/net/openhft/chronicle/hash/serialization/internal/BasicCopyingMetaBytesInterop.java index d1899f024..61c27335f 100644 --- a/src/main/java/net/openhft/chronicle/hash/serialization/internal/BasicCopyingMetaBytesInterop.java +++ b/src/main/java/net/openhft/chronicle/hash/serialization/internal/BasicCopyingMetaBytesInterop.java @@ -65,6 +65,6 @@ public abstract class BasicCopyingMetaBytesInterop implements MetaBytesInt @Override public void write(W writer, Bytes bytes, E e) { - bytes.write(buffer.buffer); + bytes.write(buffer.buffer, buffer.buffer.position(), size); } } diff --git a/src/main/java/net/openhft/chronicle/hash/serialization/internal/BytesBytesInterop.java b/src/main/java/net/openhft/chronicle/hash/serialization/internal/BytesBytesInterop.java index c1abb7c1b..4cdc2a49b 100644 --- a/src/main/java/net/openhft/chronicle/hash/serialization/internal/BytesBytesInterop.java +++ b/src/main/java/net/openhft/chronicle/hash/serialization/internal/BytesBytesInterop.java @@ -48,6 +48,6 @@ public enum BytesBytesInterop implements BytesInterop { @Override public void write(@NotNull Bytes bytes, @NotNull Bytes e) { - bytes.write(e); + bytes.write(e, e.position(), e.remaining()); } } diff --git a/src/main/java/net/openhft/chronicle/map/ChannelProvider.java b/src/main/java/net/openhft/chronicle/map/ChannelProvider.java index 8e08abe66..5f9ae55db 100644 --- a/src/main/java/net/openhft/chronicle/map/ChannelProvider.java +++ b/src/main/java/net/openhft/chronicle/map/ChannelProvider.java @@ -502,7 +502,7 @@ final class ChannelProvider implements Closeable { @Override public void writeExternalEntry(@NotNull Bytes entry, @NotNull Bytes destination, int na) { - destination.write(entry); + destination.write(entry, entry.position(), entry.remaining()); } @Override diff --git a/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java b/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java index 137bca57d..893f9a4be 100644 --- a/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java +++ b/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java @@ -755,7 +755,7 @@ class DiscoveryNodeBytesMarshallable implements BytesMarshallable { return false; BOOTSTRAP_BYTES.clear(); - out.write(BOOTSTRAP_BYTES); + out.write(BOOTSTRAP_BYTES, BOOTSTRAP_BYTES.position(), BOOTSTRAP_BYTES.remaining()); ourProposedIdentifier.writeMarshallable(out); return true; diff --git a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java index e41181abe..cd5642d1c 100644 --- a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java @@ -808,7 +808,7 @@ final class ReplicatedChronicleMap