From 2cadd898f5ccfdfaf4d401ad5e3d6303606a2965 Mon Sep 17 00:00:00 2001 From: Mitsunori Komatsu Date: Sun, 13 Jul 2014 17:17:42 +0900 Subject: [PATCH] Fix assert() condition in MessageBufferOutput subclasses --- .../main/java/org/msgpack/core/buffer/ChannelBufferOutput.java | 2 +- .../java/org/msgpack/core/buffer/OutputStreamBufferOutput.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/msgpack-core/src/main/java/org/msgpack/core/buffer/ChannelBufferOutput.java b/msgpack-core/src/main/java/org/msgpack/core/buffer/ChannelBufferOutput.java index fcb511f29..20c45f6ac 100644 --- a/msgpack-core/src/main/java/org/msgpack/core/buffer/ChannelBufferOutput.java +++ b/msgpack-core/src/main/java/org/msgpack/core/buffer/ChannelBufferOutput.java @@ -19,7 +19,7 @@ public ChannelBufferOutput(WritableByteChannel channel) { @Override public void flush(MessageBuffer buf, int offset, int len) throws IOException { - assert(offset + len < buf.size()); + assert(offset + len <= buf.size()); ByteBuffer bb = buf.toByteBuffer(offset, len); channel.write(bb); } diff --git a/msgpack-core/src/main/java/org/msgpack/core/buffer/OutputStreamBufferOutput.java b/msgpack-core/src/main/java/org/msgpack/core/buffer/OutputStreamBufferOutput.java index 249ded724..9ad638257 100644 --- a/msgpack-core/src/main/java/org/msgpack/core/buffer/OutputStreamBufferOutput.java +++ b/msgpack-core/src/main/java/org/msgpack/core/buffer/OutputStreamBufferOutput.java @@ -18,7 +18,7 @@ public OutputStreamBufferOutput(OutputStream out) { @Override public void flush(MessageBuffer buf, int offset, int len) throws IOException { - assert(offset + len < buf.size()); + assert(offset + len <= buf.size()); // TODO reuse the allocated buffer byte[] in = new byte[len];