HBASE-16670 Make RpcServer#processRequest logic more robust
This commit is contained in:
parent
ecc1c294f5
commit
76da21fc59
@ -1904,6 +1904,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);
|
||||
|
Loading…
x
Reference in New Issue
Block a user