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

HBASE-11718 Remove some logs in RpcClient.java

This commit is contained in:
Nicolas Liochon 2014-08-12 09:52:24 +02:00
parent d8a262996b
commit 2c3340c00a
1 changed files with 0 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClient.java
View File

@ -1129,10 +1129,6 @@ public class RpcClient {
// Now that we notified, we can rethrow the exception if any. Otherwise we're good. // Now that we notified, we can rethrow the exception if any. Otherwise we're good.
if (writeException != null) throw writeException; if (writeException != null) throw writeException;
if (LOG.isDebugEnabled()) {
LOG.debug(getName() + ": wrote request header " + TextFormat.shortDebugString(header));
}
} }
/* Receive a response. /* Receive a response.
@ -1150,10 +1146,6 @@ public class RpcClient {
// Read the header // Read the header
ResponseHeader responseHeader = ResponseHeader.parseDelimitedFrom(in); ResponseHeader responseHeader = ResponseHeader.parseDelimitedFrom(in);
int id = responseHeader.getCallId(); int id = responseHeader.getCallId();
if (LOG.isDebugEnabled()) {
LOG.debug(getName() + ": got response header " +
TextFormat.shortDebugString(responseHeader) + ", totalSize: " + totalSize + " bytes");
}
call = calls.remove(id); // call.done have to be set before leaving this method call = calls.remove(id); // call.done have to be set before leaving this method
expectedCall = (call != null && !call.done); expectedCall = (call != null && !call.done);
if (!expectedCall) { if (!expectedCall) {
@ -1164,10 +1156,6 @@ public class RpcClient {
// this connection. // this connection.
int readSoFar = IPCUtil.getTotalSizeWhenWrittenDelimited(responseHeader); int readSoFar = IPCUtil.getTotalSizeWhenWrittenDelimited(responseHeader);
int whatIsLeftToRead = totalSize - readSoFar; int whatIsLeftToRead = totalSize - readSoFar;
if (LOG.isDebugEnabled()) {
LOG.debug("Unknown callId: " + id + ", skipping over this response of " +
whatIsLeftToRead + " bytes");
}
IOUtils.skipFully(in, whatIsLeftToRead); IOUtils.skipFully(in, whatIsLeftToRead);
} }
if (responseHeader.hasException()) { if (responseHeader.hasException()) {