http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6674e3ab/devapidocs/src-html/org/apache/hadoop/hbase/ipc/NettyRpcConnection.html
----------------------------------------------------------------------
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/NettyRpcConnection.html 
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/NettyRpcConnection.html
index 32c21a4..92a291e 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/NettyRpcConnection.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/NettyRpcConnection.html
@@ -259,107 +259,105 @@
 <span class="sourceLineNo">251</span>  }<a name="line.251"></a>
 <span class="sourceLineNo">252</span><a name="line.252"></a>
 <span class="sourceLineNo">253</span>  private void connect() {<a 
name="line.253"></a>
-<span class="sourceLineNo">254</span>    if (LOG.isDebugEnabled()) {<a 
name="line.254"></a>
-<span class="sourceLineNo">255</span>      LOG.debug("Connecting to " + 
remoteId.address);<a name="line.255"></a>
-<span class="sourceLineNo">256</span>    }<a name="line.256"></a>
-<span class="sourceLineNo">257</span><a name="line.257"></a>
-<span class="sourceLineNo">258</span>    this.channel = new 
Bootstrap().group(rpcClient.group).channel(rpcClient.channelClass)<a 
name="line.258"></a>
-<span class="sourceLineNo">259</span>        
.option(ChannelOption.TCP_NODELAY, rpcClient.isTcpNoDelay())<a 
name="line.259"></a>
-<span class="sourceLineNo">260</span>        
.option(ChannelOption.SO_KEEPALIVE, rpcClient.tcpKeepAlive)<a 
name="line.260"></a>
-<span class="sourceLineNo">261</span>        
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, rpcClient.connectTO)<a 
name="line.261"></a>
-<span class="sourceLineNo">262</span>        .handler(new 
BufferCallBeforeInitHandler()).localAddress(rpcClient.localAddr)<a 
name="line.262"></a>
-<span class="sourceLineNo">263</span>        
.remoteAddress(remoteId.address).connect().addListener(new 
ChannelFutureListener() {<a name="line.263"></a>
-<span class="sourceLineNo">264</span><a name="line.264"></a>
-<span class="sourceLineNo">265</span>          @Override<a name="line.265"></a>
-<span class="sourceLineNo">266</span>          public void 
operationComplete(ChannelFuture future) throws Exception {<a 
name="line.266"></a>
-<span class="sourceLineNo">267</span>            Channel ch = 
future.channel();<a name="line.267"></a>
-<span class="sourceLineNo">268</span>            if (!future.isSuccess()) {<a 
name="line.268"></a>
-<span class="sourceLineNo">269</span>              failInit(ch, 
toIOE(future.cause()));<a name="line.269"></a>
-<span class="sourceLineNo">270</span>              
rpcClient.failedServers.addToFailedServers(remoteId.address, future.cause());<a 
name="line.270"></a>
-<span class="sourceLineNo">271</span>              return;<a 
name="line.271"></a>
-<span class="sourceLineNo">272</span>            }<a name="line.272"></a>
-<span class="sourceLineNo">273</span>            
ch.writeAndFlush(connectionHeaderPreamble.retainedDuplicate());<a 
name="line.273"></a>
-<span class="sourceLineNo">274</span>            if (useSasl) {<a 
name="line.274"></a>
-<span class="sourceLineNo">275</span>              saslNegotiate(ch);<a 
name="line.275"></a>
-<span class="sourceLineNo">276</span>            } else {<a 
name="line.276"></a>
-<span class="sourceLineNo">277</span>              // send the connection 
header to server<a name="line.277"></a>
-<span class="sourceLineNo">278</span>              
ch.write(connectionHeaderWithLength.retainedDuplicate());<a name="line.278"></a>
-<span class="sourceLineNo">279</span>              established(ch);<a 
name="line.279"></a>
-<span class="sourceLineNo">280</span>            }<a name="line.280"></a>
-<span class="sourceLineNo">281</span>          }<a name="line.281"></a>
-<span class="sourceLineNo">282</span>        }).channel();<a 
name="line.282"></a>
-<span class="sourceLineNo">283</span>  }<a name="line.283"></a>
-<span class="sourceLineNo">284</span><a name="line.284"></a>
-<span class="sourceLineNo">285</span>  private void write(Channel ch, final 
Call call) {<a name="line.285"></a>
-<span class="sourceLineNo">286</span>    
ch.writeAndFlush(call).addListener(new ChannelFutureListener() {<a 
name="line.286"></a>
-<span class="sourceLineNo">287</span><a name="line.287"></a>
-<span class="sourceLineNo">288</span>      @Override<a name="line.288"></a>
-<span class="sourceLineNo">289</span>      public void 
operationComplete(ChannelFuture future) throws Exception {<a 
name="line.289"></a>
-<span class="sourceLineNo">290</span>        // Fail the call if we failed to 
write it out. This usually because the channel is<a name="line.290"></a>
-<span class="sourceLineNo">291</span>        // closed. This is needed because 
we may shutdown the channel inside event loop and<a name="line.291"></a>
-<span class="sourceLineNo">292</span>        // there may still be some 
pending calls in the event loop queue after us.<a name="line.292"></a>
-<span class="sourceLineNo">293</span>        if (!future.isSuccess()) {<a 
name="line.293"></a>
-<span class="sourceLineNo">294</span>          
call.setException(toIOE(future.cause()));<a name="line.294"></a>
-<span class="sourceLineNo">295</span>        }<a name="line.295"></a>
-<span class="sourceLineNo">296</span>      }<a name="line.296"></a>
-<span class="sourceLineNo">297</span>    });<a name="line.297"></a>
-<span class="sourceLineNo">298</span>  }<a name="line.298"></a>
-<span class="sourceLineNo">299</span><a name="line.299"></a>
-<span class="sourceLineNo">300</span>  @Override<a name="line.300"></a>
-<span class="sourceLineNo">301</span>  public synchronized void 
sendRequest(final Call call, HBaseRpcController hrc) throws IOException {<a 
name="line.301"></a>
-<span class="sourceLineNo">302</span>    if (reloginInProgress) {<a 
name="line.302"></a>
-<span class="sourceLineNo">303</span>      throw new IOException("Can not send 
request because relogin is in progress.");<a name="line.303"></a>
-<span class="sourceLineNo">304</span>    }<a name="line.304"></a>
-<span class="sourceLineNo">305</span>    hrc.notifyOnCancel(new 
RpcCallback&lt;Object&gt;() {<a name="line.305"></a>
-<span class="sourceLineNo">306</span><a name="line.306"></a>
-<span class="sourceLineNo">307</span>      @Override<a name="line.307"></a>
-<span class="sourceLineNo">308</span>      public void run(Object parameter) 
{<a name="line.308"></a>
-<span class="sourceLineNo">309</span>        setCancelled(call);<a 
name="line.309"></a>
-<span class="sourceLineNo">310</span>        synchronized (this) {<a 
name="line.310"></a>
-<span class="sourceLineNo">311</span>          if (channel != null) {<a 
name="line.311"></a>
-<span class="sourceLineNo">312</span>            
channel.pipeline().fireUserEventTriggered(new CallEvent(CANCELLED, call));<a 
name="line.312"></a>
-<span class="sourceLineNo">313</span>          }<a name="line.313"></a>
-<span class="sourceLineNo">314</span>        }<a name="line.314"></a>
-<span class="sourceLineNo">315</span>      }<a name="line.315"></a>
-<span class="sourceLineNo">316</span>    }, new CancellationCallback() {<a 
name="line.316"></a>
-<span class="sourceLineNo">317</span><a name="line.317"></a>
-<span class="sourceLineNo">318</span>      @Override<a name="line.318"></a>
-<span class="sourceLineNo">319</span>      public void run(boolean cancelled) 
throws IOException {<a name="line.319"></a>
-<span class="sourceLineNo">320</span>        if (cancelled) {<a 
name="line.320"></a>
-<span class="sourceLineNo">321</span>          setCancelled(call);<a 
name="line.321"></a>
-<span class="sourceLineNo">322</span>        } else {<a name="line.322"></a>
-<span class="sourceLineNo">323</span>          if (channel == null) {<a 
name="line.323"></a>
-<span class="sourceLineNo">324</span>            connect();<a 
name="line.324"></a>
-<span class="sourceLineNo">325</span>          }<a name="line.325"></a>
-<span class="sourceLineNo">326</span>          scheduleTimeoutTask(call);<a 
name="line.326"></a>
-<span class="sourceLineNo">327</span>          final Channel ch = channel;<a 
name="line.327"></a>
-<span class="sourceLineNo">328</span>          // We must move the whole 
writeAndFlush call inside event loop otherwise there will be a<a 
name="line.328"></a>
-<span class="sourceLineNo">329</span>          // race condition.<a 
name="line.329"></a>
-<span class="sourceLineNo">330</span>          // In netty's 
DefaultChannelPipeline, it will find the first outbound handler in the<a 
name="line.330"></a>
-<span class="sourceLineNo">331</span>          // current thread and then 
schedule a task to event loop which will start the process from<a 
name="line.331"></a>
-<span class="sourceLineNo">332</span>          // that outbound handler. It is 
possible that the first handler is<a name="line.332"></a>
-<span class="sourceLineNo">333</span>          // BufferCallBeforeInitHandler 
when we call writeAndFlush here, but the connection is set<a 
name="line.333"></a>
-<span class="sourceLineNo">334</span>          // up at the same time so in 
the event loop thread we remove the<a name="line.334"></a>
-<span class="sourceLineNo">335</span>          // BufferCallBeforeInitHandler, 
and then our writeAndFlush task comes, still calls the<a name="line.335"></a>
-<span class="sourceLineNo">336</span>          // write method of 
BufferCallBeforeInitHandler.<a name="line.336"></a>
-<span class="sourceLineNo">337</span>          // This may be considered as a 
bug of netty, but anyway there is a work around so let's<a name="line.337"></a>
-<span class="sourceLineNo">338</span>          // fix it by ourselves first.<a 
name="line.338"></a>
-<span class="sourceLineNo">339</span>          if 
(ch.eventLoop().inEventLoop()) {<a name="line.339"></a>
-<span class="sourceLineNo">340</span>            write(ch, call);<a 
name="line.340"></a>
-<span class="sourceLineNo">341</span>          } else {<a name="line.341"></a>
-<span class="sourceLineNo">342</span>            ch.eventLoop().execute(new 
Runnable() {<a name="line.342"></a>
-<span class="sourceLineNo">343</span><a name="line.343"></a>
-<span class="sourceLineNo">344</span>              @Override<a 
name="line.344"></a>
-<span class="sourceLineNo">345</span>              public void run() {<a 
name="line.345"></a>
-<span class="sourceLineNo">346</span>                write(ch, call);<a 
name="line.346"></a>
-<span class="sourceLineNo">347</span>              }<a name="line.347"></a>
-<span class="sourceLineNo">348</span>            });<a name="line.348"></a>
-<span class="sourceLineNo">349</span>          }<a name="line.349"></a>
-<span class="sourceLineNo">350</span>        }<a name="line.350"></a>
-<span class="sourceLineNo">351</span>      }<a name="line.351"></a>
-<span class="sourceLineNo">352</span>    });<a name="line.352"></a>
-<span class="sourceLineNo">353</span>  }<a name="line.353"></a>
-<span class="sourceLineNo">354</span>}<a name="line.354"></a>
+<span class="sourceLineNo">254</span>    LOG.debug("Connecting to {}", 
remoteId.address);<a name="line.254"></a>
+<span class="sourceLineNo">255</span><a name="line.255"></a>
+<span class="sourceLineNo">256</span>    this.channel = new 
Bootstrap().group(rpcClient.group).channel(rpcClient.channelClass)<a 
name="line.256"></a>
+<span class="sourceLineNo">257</span>        
.option(ChannelOption.TCP_NODELAY, rpcClient.isTcpNoDelay())<a 
name="line.257"></a>
+<span class="sourceLineNo">258</span>        
.option(ChannelOption.SO_KEEPALIVE, rpcClient.tcpKeepAlive)<a 
name="line.258"></a>
+<span class="sourceLineNo">259</span>        
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, rpcClient.connectTO)<a 
name="line.259"></a>
+<span class="sourceLineNo">260</span>        .handler(new 
BufferCallBeforeInitHandler()).localAddress(rpcClient.localAddr)<a 
name="line.260"></a>
+<span class="sourceLineNo">261</span>        
.remoteAddress(remoteId.address).connect().addListener(new 
ChannelFutureListener() {<a name="line.261"></a>
+<span class="sourceLineNo">262</span><a name="line.262"></a>
+<span class="sourceLineNo">263</span>          @Override<a name="line.263"></a>
+<span class="sourceLineNo">264</span>          public void 
operationComplete(ChannelFuture future) throws Exception {<a 
name="line.264"></a>
+<span class="sourceLineNo">265</span>            Channel ch = 
future.channel();<a name="line.265"></a>
+<span class="sourceLineNo">266</span>            if (!future.isSuccess()) {<a 
name="line.266"></a>
+<span class="sourceLineNo">267</span>              failInit(ch, 
toIOE(future.cause()));<a name="line.267"></a>
+<span class="sourceLineNo">268</span>              
rpcClient.failedServers.addToFailedServers(remoteId.address, future.cause());<a 
name="line.268"></a>
+<span class="sourceLineNo">269</span>              return;<a 
name="line.269"></a>
+<span class="sourceLineNo">270</span>            }<a name="line.270"></a>
+<span class="sourceLineNo">271</span>            
ch.writeAndFlush(connectionHeaderPreamble.retainedDuplicate());<a 
name="line.271"></a>
+<span class="sourceLineNo">272</span>            if (useSasl) {<a 
name="line.272"></a>
+<span class="sourceLineNo">273</span>              saslNegotiate(ch);<a 
name="line.273"></a>
+<span class="sourceLineNo">274</span>            } else {<a 
name="line.274"></a>
+<span class="sourceLineNo">275</span>              // send the connection 
header to server<a name="line.275"></a>
+<span class="sourceLineNo">276</span>              
ch.write(connectionHeaderWithLength.retainedDuplicate());<a name="line.276"></a>
+<span class="sourceLineNo">277</span>              established(ch);<a 
name="line.277"></a>
+<span class="sourceLineNo">278</span>            }<a name="line.278"></a>
+<span class="sourceLineNo">279</span>          }<a name="line.279"></a>
+<span class="sourceLineNo">280</span>        }).channel();<a 
name="line.280"></a>
+<span class="sourceLineNo">281</span>  }<a name="line.281"></a>
+<span class="sourceLineNo">282</span><a name="line.282"></a>
+<span class="sourceLineNo">283</span>  private void write(Channel ch, final 
Call call) {<a name="line.283"></a>
+<span class="sourceLineNo">284</span>    
ch.writeAndFlush(call).addListener(new ChannelFutureListener() {<a 
name="line.284"></a>
+<span class="sourceLineNo">285</span><a name="line.285"></a>
+<span class="sourceLineNo">286</span>      @Override<a name="line.286"></a>
+<span class="sourceLineNo">287</span>      public void 
operationComplete(ChannelFuture future) throws Exception {<a 
name="line.287"></a>
+<span class="sourceLineNo">288</span>        // Fail the call if we failed to 
write it out. This usually because the channel is<a name="line.288"></a>
+<span class="sourceLineNo">289</span>        // closed. This is needed because 
we may shutdown the channel inside event loop and<a name="line.289"></a>
+<span class="sourceLineNo">290</span>        // there may still be some 
pending calls in the event loop queue after us.<a name="line.290"></a>
+<span class="sourceLineNo">291</span>        if (!future.isSuccess()) {<a 
name="line.291"></a>
+<span class="sourceLineNo">292</span>          
call.setException(toIOE(future.cause()));<a name="line.292"></a>
+<span class="sourceLineNo">293</span>        }<a name="line.293"></a>
+<span class="sourceLineNo">294</span>      }<a name="line.294"></a>
+<span class="sourceLineNo">295</span>    });<a name="line.295"></a>
+<span class="sourceLineNo">296</span>  }<a name="line.296"></a>
+<span class="sourceLineNo">297</span><a name="line.297"></a>
+<span class="sourceLineNo">298</span>  @Override<a name="line.298"></a>
+<span class="sourceLineNo">299</span>  public synchronized void 
sendRequest(final Call call, HBaseRpcController hrc) throws IOException {<a 
name="line.299"></a>
+<span class="sourceLineNo">300</span>    if (reloginInProgress) {<a 
name="line.300"></a>
+<span class="sourceLineNo">301</span>      throw new IOException("Can not send 
request because relogin is in progress.");<a name="line.301"></a>
+<span class="sourceLineNo">302</span>    }<a name="line.302"></a>
+<span class="sourceLineNo">303</span>    hrc.notifyOnCancel(new 
RpcCallback&lt;Object&gt;() {<a name="line.303"></a>
+<span class="sourceLineNo">304</span><a name="line.304"></a>
+<span class="sourceLineNo">305</span>      @Override<a name="line.305"></a>
+<span class="sourceLineNo">306</span>      public void run(Object parameter) 
{<a name="line.306"></a>
+<span class="sourceLineNo">307</span>        setCancelled(call);<a 
name="line.307"></a>
+<span class="sourceLineNo">308</span>        synchronized (this) {<a 
name="line.308"></a>
+<span class="sourceLineNo">309</span>          if (channel != null) {<a 
name="line.309"></a>
+<span class="sourceLineNo">310</span>            
channel.pipeline().fireUserEventTriggered(new CallEvent(CANCELLED, call));<a 
name="line.310"></a>
+<span class="sourceLineNo">311</span>          }<a name="line.311"></a>
+<span class="sourceLineNo">312</span>        }<a name="line.312"></a>
+<span class="sourceLineNo">313</span>      }<a name="line.313"></a>
+<span class="sourceLineNo">314</span>    }, new CancellationCallback() {<a 
name="line.314"></a>
+<span class="sourceLineNo">315</span><a name="line.315"></a>
+<span class="sourceLineNo">316</span>      @Override<a name="line.316"></a>
+<span class="sourceLineNo">317</span>      public void run(boolean cancelled) 
throws IOException {<a name="line.317"></a>
+<span class="sourceLineNo">318</span>        if (cancelled) {<a 
name="line.318"></a>
+<span class="sourceLineNo">319</span>          setCancelled(call);<a 
name="line.319"></a>
+<span class="sourceLineNo">320</span>        } else {<a name="line.320"></a>
+<span class="sourceLineNo">321</span>          if (channel == null) {<a 
name="line.321"></a>
+<span class="sourceLineNo">322</span>            connect();<a 
name="line.322"></a>
+<span class="sourceLineNo">323</span>          }<a name="line.323"></a>
+<span class="sourceLineNo">324</span>          scheduleTimeoutTask(call);<a 
name="line.324"></a>
+<span class="sourceLineNo">325</span>          final Channel ch = channel;<a 
name="line.325"></a>
+<span class="sourceLineNo">326</span>          // We must move the whole 
writeAndFlush call inside event loop otherwise there will be a<a 
name="line.326"></a>
+<span class="sourceLineNo">327</span>          // race condition.<a 
name="line.327"></a>
+<span class="sourceLineNo">328</span>          // In netty's 
DefaultChannelPipeline, it will find the first outbound handler in the<a 
name="line.328"></a>
+<span class="sourceLineNo">329</span>          // current thread and then 
schedule a task to event loop which will start the process from<a 
name="line.329"></a>
+<span class="sourceLineNo">330</span>          // that outbound handler. It is 
possible that the first handler is<a name="line.330"></a>
+<span class="sourceLineNo">331</span>          // BufferCallBeforeInitHandler 
when we call writeAndFlush here, but the connection is set<a 
name="line.331"></a>
+<span class="sourceLineNo">332</span>          // up at the same time so in 
the event loop thread we remove the<a name="line.332"></a>
+<span class="sourceLineNo">333</span>          // BufferCallBeforeInitHandler, 
and then our writeAndFlush task comes, still calls the<a name="line.333"></a>
+<span class="sourceLineNo">334</span>          // write method of 
BufferCallBeforeInitHandler.<a name="line.334"></a>
+<span class="sourceLineNo">335</span>          // This may be considered as a 
bug of netty, but anyway there is a work around so let's<a name="line.335"></a>
+<span class="sourceLineNo">336</span>          // fix it by ourselves first.<a 
name="line.336"></a>
+<span class="sourceLineNo">337</span>          if 
(ch.eventLoop().inEventLoop()) {<a name="line.337"></a>
+<span class="sourceLineNo">338</span>            write(ch, call);<a 
name="line.338"></a>
+<span class="sourceLineNo">339</span>          } else {<a name="line.339"></a>
+<span class="sourceLineNo">340</span>            ch.eventLoop().execute(new 
Runnable() {<a name="line.340"></a>
+<span class="sourceLineNo">341</span><a name="line.341"></a>
+<span class="sourceLineNo">342</span>              @Override<a 
name="line.342"></a>
+<span class="sourceLineNo">343</span>              public void run() {<a 
name="line.343"></a>
+<span class="sourceLineNo">344</span>                write(ch, call);<a 
name="line.344"></a>
+<span class="sourceLineNo">345</span>              }<a name="line.345"></a>
+<span class="sourceLineNo">346</span>            });<a name="line.346"></a>
+<span class="sourceLineNo">347</span>          }<a name="line.347"></a>
+<span class="sourceLineNo">348</span>        }<a name="line.348"></a>
+<span class="sourceLineNo">349</span>      }<a name="line.349"></a>
+<span class="sourceLineNo">350</span>    });<a name="line.350"></a>
+<span class="sourceLineNo">351</span>  }<a name="line.351"></a>
+<span class="sourceLineNo">352</span>}<a name="line.352"></a>
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6674e3ab/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html
----------------------------------------------------------------------
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html
 
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html
index bfbae95..381bed6 100644
--- 
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html
+++ 
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.CallPriorityComparator.html
@@ -259,17 +259,17 @@
 <span class="sourceLineNo">251</span>    double handlerFailureThreshhold = 
conf == null ? 1.0 : conf.getDouble(<a name="line.251"></a>
 <span class="sourceLineNo">252</span>      
HConstants.REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT,<a name="line.252"></a>
 <span class="sourceLineNo">253</span>      
HConstants.DEFAULT_REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT);<a 
name="line.253"></a>
-<span class="sourceLineNo">254</span>    LOG.debug("Started " + 
handlers.size() + " " + threadPrefix +<a name="line.254"></a>
-<span class="sourceLineNo">255</span>        " handlers, qsize=" + qsize + " 
on port=" + port);<a name="line.255"></a>
-<span class="sourceLineNo">256</span>    for (int i = 0; i &lt; numHandlers; 
i++) {<a name="line.256"></a>
-<span class="sourceLineNo">257</span>      final int index = qindex + (i % 
qsize);<a name="line.257"></a>
-<span class="sourceLineNo">258</span>      String name = "RpcServer." + 
threadPrefix + ".handler=" + handlers.size() + ",queue=" + index<a 
name="line.258"></a>
-<span class="sourceLineNo">259</span>          + ",port=" + port;<a 
name="line.259"></a>
-<span class="sourceLineNo">260</span>      Handler handler = getHandler(name, 
handlerFailureThreshhold, callQueues.get(index),<a name="line.260"></a>
-<span class="sourceLineNo">261</span>        activeHandlerCount);<a 
name="line.261"></a>
-<span class="sourceLineNo">262</span>      handler.start();<a 
name="line.262"></a>
-<span class="sourceLineNo">263</span>      handlers.add(handler);<a 
name="line.263"></a>
-<span class="sourceLineNo">264</span>    }<a name="line.264"></a>
+<span class="sourceLineNo">254</span>    for (int i = 0; i &lt; numHandlers; 
i++) {<a name="line.254"></a>
+<span class="sourceLineNo">255</span>      final int index = qindex + (i % 
qsize);<a name="line.255"></a>
+<span class="sourceLineNo">256</span>      String name = "RpcServer." + 
threadPrefix + ".handler=" + handlers.size() + ",queue=" + index<a 
name="line.256"></a>
+<span class="sourceLineNo">257</span>          + ",port=" + port;<a 
name="line.257"></a>
+<span class="sourceLineNo">258</span>      Handler handler = getHandler(name, 
handlerFailureThreshhold, callQueues.get(index),<a name="line.258"></a>
+<span class="sourceLineNo">259</span>        activeHandlerCount);<a 
name="line.259"></a>
+<span class="sourceLineNo">260</span>      handler.start();<a 
name="line.260"></a>
+<span class="sourceLineNo">261</span>      handlers.add(handler);<a 
name="line.261"></a>
+<span class="sourceLineNo">262</span>    }<a name="line.262"></a>
+<span class="sourceLineNo">263</span>    LOG.debug("Started " + 
handlers.size() + " " + threadPrefix +<a name="line.263"></a>
+<span class="sourceLineNo">264</span>        " handlers, queues=" + qsize + ", 
port=" + port);<a name="line.264"></a>
 <span class="sourceLineNo">265</span>  }<a name="line.265"></a>
 <span class="sourceLineNo">266</span><a name="line.266"></a>
 <span class="sourceLineNo">267</span>  /**<a name="line.267"></a>

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6674e3ab/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html
----------------------------------------------------------------------
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html 
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html
index bfbae95..381bed6 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.Handler.html
@@ -259,17 +259,17 @@
 <span class="sourceLineNo">251</span>    double handlerFailureThreshhold = 
conf == null ? 1.0 : conf.getDouble(<a name="line.251"></a>
 <span class="sourceLineNo">252</span>      
HConstants.REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT,<a name="line.252"></a>
 <span class="sourceLineNo">253</span>      
HConstants.DEFAULT_REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT);<a 
name="line.253"></a>
-<span class="sourceLineNo">254</span>    LOG.debug("Started " + 
handlers.size() + " " + threadPrefix +<a name="line.254"></a>
-<span class="sourceLineNo">255</span>        " handlers, qsize=" + qsize + " 
on port=" + port);<a name="line.255"></a>
-<span class="sourceLineNo">256</span>    for (int i = 0; i &lt; numHandlers; 
i++) {<a name="line.256"></a>
-<span class="sourceLineNo">257</span>      final int index = qindex + (i % 
qsize);<a name="line.257"></a>
-<span class="sourceLineNo">258</span>      String name = "RpcServer." + 
threadPrefix + ".handler=" + handlers.size() + ",queue=" + index<a 
name="line.258"></a>
-<span class="sourceLineNo">259</span>          + ",port=" + port;<a 
name="line.259"></a>
-<span class="sourceLineNo">260</span>      Handler handler = getHandler(name, 
handlerFailureThreshhold, callQueues.get(index),<a name="line.260"></a>
-<span class="sourceLineNo">261</span>        activeHandlerCount);<a 
name="line.261"></a>
-<span class="sourceLineNo">262</span>      handler.start();<a 
name="line.262"></a>
-<span class="sourceLineNo">263</span>      handlers.add(handler);<a 
name="line.263"></a>
-<span class="sourceLineNo">264</span>    }<a name="line.264"></a>
+<span class="sourceLineNo">254</span>    for (int i = 0; i &lt; numHandlers; 
i++) {<a name="line.254"></a>
+<span class="sourceLineNo">255</span>      final int index = qindex + (i % 
qsize);<a name="line.255"></a>
+<span class="sourceLineNo">256</span>      String name = "RpcServer." + 
threadPrefix + ".handler=" + handlers.size() + ",queue=" + index<a 
name="line.256"></a>
+<span class="sourceLineNo">257</span>          + ",port=" + port;<a 
name="line.257"></a>
+<span class="sourceLineNo">258</span>      Handler handler = getHandler(name, 
handlerFailureThreshhold, callQueues.get(index),<a name="line.258"></a>
+<span class="sourceLineNo">259</span>        activeHandlerCount);<a 
name="line.259"></a>
+<span class="sourceLineNo">260</span>      handler.start();<a 
name="line.260"></a>
+<span class="sourceLineNo">261</span>      handlers.add(handler);<a 
name="line.261"></a>
+<span class="sourceLineNo">262</span>    }<a name="line.262"></a>
+<span class="sourceLineNo">263</span>    LOG.debug("Started " + 
handlers.size() + " " + threadPrefix +<a name="line.263"></a>
+<span class="sourceLineNo">264</span>        " handlers, queues=" + qsize + ", 
port=" + port);<a name="line.264"></a>
 <span class="sourceLineNo">265</span>  }<a name="line.265"></a>
 <span class="sourceLineNo">266</span><a name="line.266"></a>
 <span class="sourceLineNo">267</span>  /**<a name="line.267"></a>

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6674e3ab/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html
----------------------------------------------------------------------
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html
 
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html
index bfbae95..381bed6 100644
--- 
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html
+++ 
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.QueueBalancer.html
@@ -259,17 +259,17 @@
 <span class="sourceLineNo">251</span>    double handlerFailureThreshhold = 
conf == null ? 1.0 : conf.getDouble(<a name="line.251"></a>
 <span class="sourceLineNo">252</span>      
HConstants.REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT,<a name="line.252"></a>
 <span class="sourceLineNo">253</span>      
HConstants.DEFAULT_REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT);<a 
name="line.253"></a>
-<span class="sourceLineNo">254</span>    LOG.debug("Started " + 
handlers.size() + " " + threadPrefix +<a name="line.254"></a>
-<span class="sourceLineNo">255</span>        " handlers, qsize=" + qsize + " 
on port=" + port);<a name="line.255"></a>
-<span class="sourceLineNo">256</span>    for (int i = 0; i &lt; numHandlers; 
i++) {<a name="line.256"></a>
-<span class="sourceLineNo">257</span>      final int index = qindex + (i % 
qsize);<a name="line.257"></a>
-<span class="sourceLineNo">258</span>      String name = "RpcServer." + 
threadPrefix + ".handler=" + handlers.size() + ",queue=" + index<a 
name="line.258"></a>
-<span class="sourceLineNo">259</span>          + ",port=" + port;<a 
name="line.259"></a>
-<span class="sourceLineNo">260</span>      Handler handler = getHandler(name, 
handlerFailureThreshhold, callQueues.get(index),<a name="line.260"></a>
-<span class="sourceLineNo">261</span>        activeHandlerCount);<a 
name="line.261"></a>
-<span class="sourceLineNo">262</span>      handler.start();<a 
name="line.262"></a>
-<span class="sourceLineNo">263</span>      handlers.add(handler);<a 
name="line.263"></a>
-<span class="sourceLineNo">264</span>    }<a name="line.264"></a>
+<span class="sourceLineNo">254</span>    for (int i = 0; i &lt; numHandlers; 
i++) {<a name="line.254"></a>
+<span class="sourceLineNo">255</span>      final int index = qindex + (i % 
qsize);<a name="line.255"></a>
+<span class="sourceLineNo">256</span>      String name = "RpcServer." + 
threadPrefix + ".handler=" + handlers.size() + ",queue=" + index<a 
name="line.256"></a>
+<span class="sourceLineNo">257</span>          + ",port=" + port;<a 
name="line.257"></a>
+<span class="sourceLineNo">258</span>      Handler handler = getHandler(name, 
handlerFailureThreshhold, callQueues.get(index),<a name="line.258"></a>
+<span class="sourceLineNo">259</span>        activeHandlerCount);<a 
name="line.259"></a>
+<span class="sourceLineNo">260</span>      handler.start();<a 
name="line.260"></a>
+<span class="sourceLineNo">261</span>      handlers.add(handler);<a 
name="line.261"></a>
+<span class="sourceLineNo">262</span>    }<a name="line.262"></a>
+<span class="sourceLineNo">263</span>    LOG.debug("Started " + 
handlers.size() + " " + threadPrefix +<a name="line.263"></a>
+<span class="sourceLineNo">264</span>        " handlers, queues=" + qsize + ", 
port=" + port);<a name="line.264"></a>
 <span class="sourceLineNo">265</span>  }<a name="line.265"></a>
 <span class="sourceLineNo">266</span><a name="line.266"></a>
 <span class="sourceLineNo">267</span>  /**<a name="line.267"></a>

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6674e3ab/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html
----------------------------------------------------------------------
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html
 
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html
index bfbae95..381bed6 100644
--- 
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html
+++ 
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.RandomQueueBalancer.html
@@ -259,17 +259,17 @@
 <span class="sourceLineNo">251</span>    double handlerFailureThreshhold = 
conf == null ? 1.0 : conf.getDouble(<a name="line.251"></a>
 <span class="sourceLineNo">252</span>      
HConstants.REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT,<a name="line.252"></a>
 <span class="sourceLineNo">253</span>      
HConstants.DEFAULT_REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT);<a 
name="line.253"></a>
-<span class="sourceLineNo">254</span>    LOG.debug("Started " + 
handlers.size() + " " + threadPrefix +<a name="line.254"></a>
-<span class="sourceLineNo">255</span>        " handlers, qsize=" + qsize + " 
on port=" + port);<a name="line.255"></a>
-<span class="sourceLineNo">256</span>    for (int i = 0; i &lt; numHandlers; 
i++) {<a name="line.256"></a>
-<span class="sourceLineNo">257</span>      final int index = qindex + (i % 
qsize);<a name="line.257"></a>
-<span class="sourceLineNo">258</span>      String name = "RpcServer." + 
threadPrefix + ".handler=" + handlers.size() + ",queue=" + index<a 
name="line.258"></a>
-<span class="sourceLineNo">259</span>          + ",port=" + port;<a 
name="line.259"></a>
-<span class="sourceLineNo">260</span>      Handler handler = getHandler(name, 
handlerFailureThreshhold, callQueues.get(index),<a name="line.260"></a>
-<span class="sourceLineNo">261</span>        activeHandlerCount);<a 
name="line.261"></a>
-<span class="sourceLineNo">262</span>      handler.start();<a 
name="line.262"></a>
-<span class="sourceLineNo">263</span>      handlers.add(handler);<a 
name="line.263"></a>
-<span class="sourceLineNo">264</span>    }<a name="line.264"></a>
+<span class="sourceLineNo">254</span>    for (int i = 0; i &lt; numHandlers; 
i++) {<a name="line.254"></a>
+<span class="sourceLineNo">255</span>      final int index = qindex + (i % 
qsize);<a name="line.255"></a>
+<span class="sourceLineNo">256</span>      String name = "RpcServer." + 
threadPrefix + ".handler=" + handlers.size() + ",queue=" + index<a 
name="line.256"></a>
+<span class="sourceLineNo">257</span>          + ",port=" + port;<a 
name="line.257"></a>
+<span class="sourceLineNo">258</span>      Handler handler = getHandler(name, 
handlerFailureThreshhold, callQueues.get(index),<a name="line.258"></a>
+<span class="sourceLineNo">259</span>        activeHandlerCount);<a 
name="line.259"></a>
+<span class="sourceLineNo">260</span>      handler.start();<a 
name="line.260"></a>
+<span class="sourceLineNo">261</span>      handlers.add(handler);<a 
name="line.261"></a>
+<span class="sourceLineNo">262</span>    }<a name="line.262"></a>
+<span class="sourceLineNo">263</span>    LOG.debug("Started " + 
handlers.size() + " " + threadPrefix +<a name="line.263"></a>
+<span class="sourceLineNo">264</span>        " handlers, queues=" + qsize + ", 
port=" + port);<a name="line.264"></a>
 <span class="sourceLineNo">265</span>  }<a name="line.265"></a>
 <span class="sourceLineNo">266</span><a name="line.266"></a>
 <span class="sourceLineNo">267</span>  /**<a name="line.267"></a>

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6674e3ab/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html 
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html
index bfbae95..381bed6 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcExecutor.html
@@ -259,17 +259,17 @@
 <span class="sourceLineNo">251</span>    double handlerFailureThreshhold = 
conf == null ? 1.0 : conf.getDouble(<a name="line.251"></a>
 <span class="sourceLineNo">252</span>      
HConstants.REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT,<a name="line.252"></a>
 <span class="sourceLineNo">253</span>      
HConstants.DEFAULT_REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT);<a 
name="line.253"></a>
-<span class="sourceLineNo">254</span>    LOG.debug("Started " + 
handlers.size() + " " + threadPrefix +<a name="line.254"></a>
-<span class="sourceLineNo">255</span>        " handlers, qsize=" + qsize + " 
on port=" + port);<a name="line.255"></a>
-<span class="sourceLineNo">256</span>    for (int i = 0; i &lt; numHandlers; 
i++) {<a name="line.256"></a>
-<span class="sourceLineNo">257</span>      final int index = qindex + (i % 
qsize);<a name="line.257"></a>
-<span class="sourceLineNo">258</span>      String name = "RpcServer." + 
threadPrefix + ".handler=" + handlers.size() + ",queue=" + index<a 
name="line.258"></a>
-<span class="sourceLineNo">259</span>          + ",port=" + port;<a 
name="line.259"></a>
-<span class="sourceLineNo">260</span>      Handler handler = getHandler(name, 
handlerFailureThreshhold, callQueues.get(index),<a name="line.260"></a>
-<span class="sourceLineNo">261</span>        activeHandlerCount);<a 
name="line.261"></a>
-<span class="sourceLineNo">262</span>      handler.start();<a 
name="line.262"></a>
-<span class="sourceLineNo">263</span>      handlers.add(handler);<a 
name="line.263"></a>
-<span class="sourceLineNo">264</span>    }<a name="line.264"></a>
+<span class="sourceLineNo">254</span>    for (int i = 0; i &lt; numHandlers; 
i++) {<a name="line.254"></a>
+<span class="sourceLineNo">255</span>      final int index = qindex + (i % 
qsize);<a name="line.255"></a>
+<span class="sourceLineNo">256</span>      String name = "RpcServer." + 
threadPrefix + ".handler=" + handlers.size() + ",queue=" + index<a 
name="line.256"></a>
+<span class="sourceLineNo">257</span>          + ",port=" + port;<a 
name="line.257"></a>
+<span class="sourceLineNo">258</span>      Handler handler = getHandler(name, 
handlerFailureThreshhold, callQueues.get(index),<a name="line.258"></a>
+<span class="sourceLineNo">259</span>        activeHandlerCount);<a 
name="line.259"></a>
+<span class="sourceLineNo">260</span>      handler.start();<a 
name="line.260"></a>
+<span class="sourceLineNo">261</span>      handlers.add(handler);<a 
name="line.261"></a>
+<span class="sourceLineNo">262</span>    }<a name="line.262"></a>
+<span class="sourceLineNo">263</span>    LOG.debug("Started " + 
handlers.size() + " " + threadPrefix +<a name="line.263"></a>
+<span class="sourceLineNo">264</span>        " handlers, queues=" + qsize + ", 
port=" + port);<a name="line.264"></a>
 <span class="sourceLineNo">265</span>  }<a name="line.265"></a>
 <span class="sourceLineNo">266</span><a name="line.266"></a>
 <span class="sourceLineNo">267</span>  /**<a name="line.267"></a>

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6674e3ab/devapidocs/src-html/org/apache/hadoop/hbase/master/ActiveMasterManager.html
----------------------------------------------------------------------
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/ActiveMasterManager.html 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/ActiveMasterManager.html
index 82b2cb3..4dcf522 100644
--- 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/ActiveMasterManager.html
+++ 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/ActiveMasterManager.html
@@ -133,7 +133,7 @@
 <span class="sourceLineNo">125</span>      
synchronized(clusterHasActiveMaster) {<a name="line.125"></a>
 <span class="sourceLineNo">126</span>        if 
(ZKUtil.watchAndCheckExists(watcher, watcher.znodePaths.masterAddressZNode)) 
{<a name="line.126"></a>
 <span class="sourceLineNo">127</span>          // A master node exists, there 
is an active master<a name="line.127"></a>
-<span class="sourceLineNo">128</span>          LOG.debug("A master is now 
available");<a name="line.128"></a>
+<span class="sourceLineNo">128</span>          LOG.trace("A master is now 
available");<a name="line.128"></a>
 <span class="sourceLineNo">129</span>          
clusterHasActiveMaster.set(true);<a name="line.129"></a>
 <span class="sourceLineNo">130</span>        } else {<a name="line.130"></a>
 <span class="sourceLineNo">131</span>          // Node is no longer there, 
cluster does not have an active master<a name="line.131"></a>
@@ -186,7 +186,7 @@
 <span class="sourceLineNo">178</span>          // We are the master, return<a 
name="line.178"></a>
 <span class="sourceLineNo">179</span>          
startupStatus.setStatus("Successfully registered as active master.");<a 
name="line.179"></a>
 <span class="sourceLineNo">180</span>          
this.clusterHasActiveMaster.set(true);<a name="line.180"></a>
-<span class="sourceLineNo">181</span>          LOG.info("Registered Active 
Master=" + this.sn);<a name="line.181"></a>
+<span class="sourceLineNo">181</span>          LOG.info("Registered as active 
master=" + this.sn);<a name="line.181"></a>
 <span class="sourceLineNo">182</span>          return true;<a 
name="line.182"></a>
 <span class="sourceLineNo">183</span>        }<a name="line.183"></a>
 <span class="sourceLineNo">184</span><a name="line.184"></a>

Reply via email to