fixes the negative length

rsocket-broker · Nov 28, 2020 · 8125dde · 8125dde
1 parent 0ebd10e
commit 8125dde
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/rsocket-routing-frames/src/main/java/io/rsocket/routing/frames/FlyweightUtils.java b/rsocket-routing-frames/src/main/java/io/rsocket/routing/frames/FlyweightUtils.java
@@ -36,13 +36,15 @@ static void encodeByteString(ByteBuf byteBuf, String s) {
 
 	static String decodeByteString(ByteBuf byteBuf, int offset) {
 		int length = byteBuf.getByte(offset);
+		length &= UNSIGNED_BYTE_MAX_VALUE;
 		offset += Byte.BYTES;
 
 		return byteBuf.toString(offset, length, StandardCharsets.UTF_8);
 	}
 
 	static int decodeByteStringLength(ByteBuf byteBuf, int offset) {
 		int length = byteBuf.getByte(offset);
+		length &= UNSIGNED_BYTE_MAX_VALUE;
 		return Byte.BYTES + length;
 	}