Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-6282 The introspection, etc. of objects in the RPC has to be handled for PB objects 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1409648 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2012-11-15 05:26:17 +00:00
parent e34f3890f3
commit f38ee24ed0
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/ProtobufRpcEngine.java
View File

@ -325,7 +325,7 @@ class ProtobufRpcEngine implements RpcEngine {
//which implementation of the protocol should be used to service the
//current request, etc. Ideally, we shouldn't land up in a situation
//where we need to support such a use case.
//For now the clientVersion field is simply ignored
//For now the clientVersion field is simply ignored
long clientVersion = rpcRequest.getClientProtocolVersion();
if (verbose) {
@ -333,10 +333,10 @@ class ProtobufRpcEngine implements RpcEngine {
", method=" + methodName);
}
status.setRPC(rpcRequest.getMethodName(),
status.setRPC(rpcRequest.getMethodName(),
new Object[]{rpcRequest.getRequest()}, receiveTime);
status.setRPCPacket(rpcRequest);
status.resume("Servicing call");
status.resume("Servicing call");
//get an instance of the method arg type
Message protoType = getMethodArgType(method);
Message param = protoType.newBuilderForType()
@ -366,10 +366,11 @@ class ProtobufRpcEngine implements RpcEngine {
int qTime = (int) (startTime-receiveTime);
if (TRACELOG.isDebugEnabled()) {
TRACELOG.debug("Call #" + CurCall.get().id +
"; Served: " + protocol.getSimpleName()+"#"+method.getName() +
" queueTime=" + qTime +
" processingTime=" + processingTime +
" contents=" + param.toString());
"; served=" + protocol.getSimpleName() + "#" + method.getName() +
", queueTime=" + qTime +
", processingTime=" + processingTime +
", request=" + param.toString() +
" response=" + result.toString());
}
rpcMetrics.rpcQueueTime.inc(qTime);
rpcMetrics.rpcProcessingTime.inc(processingTime);
@ -393,7 +394,7 @@ class ProtobufRpcEngine implements RpcEngine {
buffer.append(param.getClass().getName());
buffer.append(")");
buffer.append(", client version="+clientVersion);
logResponse(new Object[]{rpcRequest.getRequest()},
logResponse(new Object[]{rpcRequest.getRequest()},
methodName, buffer.toString(), (tooLarge ? "TooLarge" : "TooSlow"),
status.getClient(), startTime, processingTime, qTime,
responseSize);