Skip to content

Commit 9998ec8

Browse files
Kevin Gallardoolim7t
authored andcommitted
Implement new writeBytes variant in ByteBufPrimitiveCodec
1 parent fe1094a commit 9998ec8

File tree

3 files changed

+12
-2
lines changed

3 files changed

+12
-2
lines changed

core/src/main/java/com/datastax/oss/driver/internal/core/protocol/ByteBufPrimitiveCodec.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -178,6 +178,16 @@ public void writeBytes(ByteBuffer bytes, ByteBuf dest) {
178178
}
179179
}
180180

181+
@Override
182+
public void writeBytes(byte[] bytes, ByteBuf dest) {
183+
if (bytes == null) {
184+
writeInt(-1, dest);
185+
} else {
186+
writeInt(bytes.length, dest);
187+
dest.writeBytes(bytes);
188+
}
189+
}
190+
181191
@Override
182192
public void writeShortBytes(byte[] bytes, ByteBuf dest) {
183193
writeUnsignedShort(bytes.length, dest);

core/src/test/java/com/datastax/oss/driver/internal/core/protocol/ByteBufPrimitiveCodecTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -344,7 +344,7 @@ public void should_write_short_bytes() {
344344
@Test
345345
public void should_write_null_bytes() {
346346
ByteBuf dest = allocate(4);
347-
codec.writeBytes(null, dest);
347+
codec.writeBytes((ByteBuffer) null, dest);
348348
assertThat(dest).containsExactly("0xFFFFFFFF");
349349
}
350350

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@
5050
<guava.version>25.1-jre</guava.version>
5151
<hdrhistogram.version>2.1.10</hdrhistogram.version>
5252
<metrics.version>4.0.2</metrics.version>
53-
<native-protocol.version>1.4.3</native-protocol.version>
53+
<native-protocol.version>1.4.4-SNAPSHOT</native-protocol.version>
5454
<netty.version>4.1.27.Final</netty.version>
5555
<slf4j.version>1.7.25</slf4j.version>
5656
<!-- optional dependencies -->

0 commit comments

Comments
 (0)