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

HBASE-11297 Remove some synchros in the rpcServer responder

This commit is contained in:
Nicolas Liochon 2014-06-25 11:01:42 +02:00
parent 3a097784b5
commit 07a771866f
3 changed files with 353 additions and 364 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java
View File

@ -75,9 +75,9 @@ public class CallRunner {
} }
this.status.setStatus("Setting up call"); this.status.setStatus("Setting up call");
this.status.setConnection(call.connection.getHostAddress(), call.connection.getRemotePort()); this.status.setConnection(call.connection.getHostAddress(), call.connection.getRemotePort());
if (RpcServer.LOG.isDebugEnabled()) { if (RpcServer.LOG.isTraceEnabled()) {
UserGroupInformation remoteUser = call.connection.user; UserGroupInformation remoteUser = call.connection.user;
RpcServer.LOG.debug(call.toShortString() + " executing as " + RpcServer.LOG.trace(call.toShortString() + " executing as " +
((remoteUser == null) ? "NULL principal" : remoteUser.getUserName())); ((remoteUser == null) ? "NULL principal" : remoteUser.getUserName()));
} }
Throwable errorThrowable = null; Throwable errorThrowable = null;

711
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
View File

File diff suppressed because it is too large Load Diff

2
hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestDelayedRpc.java
View File

@ -154,7 +154,7 @@ public class TestDelayedRpc {
conf.setInt("hbase.ipc.warn.delayedrpc.number", MAX_DELAYED_RPC); conf.setInt("hbase.ipc.warn.delayedrpc.number", MAX_DELAYED_RPC);
// Set up an appender to catch the "Too many delayed calls" that we expect. // Set up an appender to catch the "Too many delayed calls" that we expect.
ListAppender listAppender = new ListAppender(); ListAppender listAppender = new ListAppender();
Logger log = Logger.getLogger("org.apache.hadoop.ipc.RpcServer"); Logger log = Logger.getLogger(RpcServer.class);
log.addAppender(listAppender); log.addAppender(listAppender);
log.setLevel(Level.WARN); log.setLevel(Level.WARN);