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

HBASE-16023 Fastpath for the FIFO rpcscheduler AMENDMENT

This commit is contained in:
stack 2016-06-20 08:28:39 +01:00
parent 4421fdf981
commit 01684c3417
1 changed files with 3 additions and 3 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/FifoWithFastPathBalancedQueueRpcExecutor.java
View File

@ -74,7 +74,7 @@ public class FifoWithFastPathBalancedQueueRpcExecutor extends BalancedQueueRpcEx
// if an empty queue of CallRunners so we are available for direct handoff when one comes in. // if an empty queue of CallRunners so we are available for direct handoff when one comes in.
final Deque<FastPathHandler> fastPathHandlerStack; final Deque<FastPathHandler> fastPathHandlerStack;
// Semaphore to coordinate loading of fastpathed loadedTask and our running it. // Semaphore to coordinate loading of fastpathed loadedTask and our running it.
private Semaphore semaphore = new Semaphore(1); private Semaphore semaphore = new Semaphore(0);
// The task we get when fast-pathing. // The task we get when fast-pathing.
private CallRunner loadedCallRunner; private CallRunner loadedCallRunner;
@ -82,7 +82,6 @@ public class FifoWithFastPathBalancedQueueRpcExecutor extends BalancedQueueRpcEx
final Deque<FastPathHandler> fastPathHandlerStack) { final Deque<FastPathHandler> fastPathHandlerStack) {
super(name, handlerFailureThreshhold, q); super(name, handlerFailureThreshhold, q);
this.fastPathHandlerStack = fastPathHandlerStack; this.fastPathHandlerStack = fastPathHandlerStack;
this.semaphore.drainPermits();
} }
protected CallRunner getCallRunner() throws InterruptedException { protected CallRunner getCallRunner() throws InterruptedException {
@ -95,6 +94,7 @@ public class FifoWithFastPathBalancedQueueRpcExecutor extends BalancedQueueRpcEx
this.fastPathHandlerStack.push(this); this.fastPathHandlerStack.push(this);
this.semaphore.acquire(); this.semaphore.acquire();
cr = this.loadedCallRunner; cr = this.loadedCallRunner;
this.loadedCallRunner = null;
} else { } else {
// No fastpath available. Block until a task comes available. // No fastpath available. Block until a task comes available.
cr = super.getCallRunner(); cr = super.getCallRunner();