Updated Java-Lang version

This commit is contained in:
leventov
2015-01-28 14:26:35 +07:00
parent 20277fdbb9
commit b395770956
7 changed files with 8 additions and 8 deletions
@@ -65,6 +65,6 @@ public abstract class BasicCopyingMetaBytesInterop<E, W> implements MetaBytesInt
@Override
public void write(W writer, Bytes bytes, E e) {
bytes.write(buffer.buffer);
bytes.write(buffer.buffer, buffer.buffer.position(), size);
}
}
@@ -48,6 +48,6 @@ public enum BytesBytesInterop implements BytesInterop<Bytes> {
@Override
public void write(@NotNull Bytes bytes, @NotNull Bytes e) {
bytes.write(e);
bytes.write(e, e.position(), e.remaining());
}
}
@@ -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
@@ -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;
@@ -808,7 +808,7 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, ? supe
// write the key
entry.position(keyPosition);
entry.limit(keyLimit);
destination.write(entry);
destination.write(entry, entry.position(), entry.remaining());
boolean debugEnabled = LOG.isDebugEnabled();
String message = null;
@@ -833,7 +833,7 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, ? supe
// writes the value
entry.limit(entry.position() + valueSize);
destination.write(entry);
destination.write(entry, entry.position(), entry.remaining());
if (debugEnabled) {
LOG.debug(message + "value=" + entry.toString().trim() + ")");