HBASE-16670 Make RpcServer#processRequest logic more robust

This commit is contained in:
Yu Li 2016-09-22 15:43:53 +08:00
parent 19bbf44554
commit 2ff2c0ba6e
1 changed files with 6 additions and 0 deletions

View File

@ -1860,6 +1860,12 @@ public class RpcServer implements RpcServerInterface, ConfigurationObserver {
param = builder.build();
}
offset += paramSize;
} else {
// currently header must have request param, so we directly throw exception here
String msg = "Invalid request header: " + TextFormat.shortDebugString(header)
+ ", should have param set in it";
LOG.warn(msg);
throw new DoNotRetryIOException(msg);
}
if (header.hasCellBlockMeta()) {
buf.position(offset);