Fix ReturnValue.canDecode(…) byte counters.

Signed-off-by: Mark Paluch <mpaluch@vmware.com> [#199]
r2dbc · Jul 19, 2021 · e0a41ae · e0a41ae
1 parent f2e3618
commit e0a41ae
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/io/r2dbc/mssql/message/token/ReturnValue.java b/src/main/java/io/r2dbc/mssql/message/token/ReturnValue.java
@@ -126,11 +126,11 @@ public static boolean canDecode(ByteBuf buffer, boolean encryptionSupported) {
                 buffer.skipBytes(2);
                 int nameLength = Decode.asByte(buffer);
 
-                if (buffer.readableBytes() < nameLength + /* status */ 1) {
+                if (buffer.readableBytes() < (nameLength * 2) + /* status */ 1) {
                     return false;
                 }
 
-                buffer.skipBytes(nameLength + 1);
+                buffer.skipBytes((nameLength * 2) + 1);
 
                 if (!TypeInformation.canDecode(buffer, true)) {
                     return false;