HBASE-27097 SimpleRpcServer is broken (#4521)

apurtell · Lijin Bin · apurtell · commit 2ef58ab52fd2 · 2022-06-11T10:42:18.000-07:00
Apply https://issues.apache.org/jira/secure/attachment/13044874/MultiByteBuff.patch from Lijin Bin on JIRA. Co-authored-by: Lijin Bin <binlijin@apache.org> Signed-off-by: Lijin Bin <binlijin@apache.org> Signed-off-by: Viraj Jasani <vjasani@apache.org>
diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/nio/MultiByteBuff.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/nio/MultiByteBuff.java
@@ -1148,6 +1148,9 @@ private int internalRead(ReadableByteChannel channel, long offset, ChannelReader
         offset += len;
       }
       if (buffer.hasRemaining()) {
+        // reset
+        curItem = buffer;
+        curItemIndex = (curItemIndex - 1);
         break;
       }
     }

Original file line number	Diff line number	Diff line change
`@@ -1148,6 +1148,9 @@ private int internalRead(ReadableByteChannel channel, long offset, ChannelReader`
`1148`	`1148`	`offset += len;`
`1149`	`1149`	`}`
`1150`	`1150`	`if (buffer.hasRemaining()) {`
	`1151`	`+ // reset`
	`1152`	`+ curItem = buffer;`
	`1153`	`+ curItemIndex = (curItemIndex - 1);`
`1151`	`1154`	`break;`
`1152`	`1155`	`}`
`1153`	`1156`	`}`