You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by gi...@apache.org on 2018/11/16 14:52:50 UTC
[2/5] hbase-site git commit: Published site at
43a10df70fcf36999ce28e1ba0ac06e0d62ccaf1.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1c87639a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.TableDescriptorGetter.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.TableDescriptorGetter.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.TableDescriptorGetter.html
index 0377974..c4c914c 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.TableDescriptorGetter.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.TableDescriptorGetter.html
@@ -3896,78 +3896,80 @@
<span class="sourceLineNo">3888</span> }<a name="line.3888"></a>
<span class="sourceLineNo">3889</span><a name="line.3889"></a>
<span class="sourceLineNo">3890</span> public void remoteProcedureCompleted(long procId) {<a name="line.3890"></a>
-<span class="sourceLineNo">3891</span> RemoteProcedure<MasterProcedureEnv, ?> procedure = getRemoteProcedure(procId);<a name="line.3891"></a>
-<span class="sourceLineNo">3892</span> if (procedure != null) {<a name="line.3892"></a>
-<span class="sourceLineNo">3893</span> procedure.remoteOperationCompleted(procedureExecutor.getEnvironment());<a name="line.3893"></a>
-<span class="sourceLineNo">3894</span> }<a name="line.3894"></a>
-<span class="sourceLineNo">3895</span> }<a name="line.3895"></a>
-<span class="sourceLineNo">3896</span><a name="line.3896"></a>
-<span class="sourceLineNo">3897</span> public void remoteProcedureFailed(long procId, RemoteProcedureException error) {<a name="line.3897"></a>
-<span class="sourceLineNo">3898</span> RemoteProcedure<MasterProcedureEnv, ?> procedure = getRemoteProcedure(procId);<a name="line.3898"></a>
-<span class="sourceLineNo">3899</span> if (procedure != null) {<a name="line.3899"></a>
-<span class="sourceLineNo">3900</span> procedure.remoteOperationFailed(procedureExecutor.getEnvironment(), error);<a name="line.3900"></a>
-<span class="sourceLineNo">3901</span> }<a name="line.3901"></a>
-<span class="sourceLineNo">3902</span> }<a name="line.3902"></a>
-<span class="sourceLineNo">3903</span><a name="line.3903"></a>
-<span class="sourceLineNo">3904</span> @Override<a name="line.3904"></a>
-<span class="sourceLineNo">3905</span> public ReplicationPeerManager getReplicationPeerManager() {<a name="line.3905"></a>
-<span class="sourceLineNo">3906</span> return replicationPeerManager;<a name="line.3906"></a>
-<span class="sourceLineNo">3907</span> }<a name="line.3907"></a>
-<span class="sourceLineNo">3908</span><a name="line.3908"></a>
-<span class="sourceLineNo">3909</span> public HashMap<String, List<Pair<ServerName, ReplicationLoadSource>>><a name="line.3909"></a>
-<span class="sourceLineNo">3910</span> getReplicationLoad(ServerName[] serverNames) {<a name="line.3910"></a>
-<span class="sourceLineNo">3911</span> List<ReplicationPeerDescription> peerList = this.getReplicationPeerManager().listPeers(null);<a name="line.3911"></a>
-<span class="sourceLineNo">3912</span> if (peerList == null) {<a name="line.3912"></a>
-<span class="sourceLineNo">3913</span> return null;<a name="line.3913"></a>
-<span class="sourceLineNo">3914</span> }<a name="line.3914"></a>
-<span class="sourceLineNo">3915</span> HashMap<String, List<Pair<ServerName, ReplicationLoadSource>>> replicationLoadSourceMap =<a name="line.3915"></a>
-<span class="sourceLineNo">3916</span> new HashMap<>(peerList.size());<a name="line.3916"></a>
-<span class="sourceLineNo">3917</span> peerList.stream()<a name="line.3917"></a>
-<span class="sourceLineNo">3918</span> .forEach(peer -> replicationLoadSourceMap.put(peer.getPeerId(), new ArrayList<>()));<a name="line.3918"></a>
-<span class="sourceLineNo">3919</span> for (ServerName serverName : serverNames) {<a name="line.3919"></a>
-<span class="sourceLineNo">3920</span> List<ReplicationLoadSource> replicationLoadSources =<a name="line.3920"></a>
-<span class="sourceLineNo">3921</span> getServerManager().getLoad(serverName).getReplicationLoadSourceList();<a name="line.3921"></a>
-<span class="sourceLineNo">3922</span> for (ReplicationLoadSource replicationLoadSource : replicationLoadSources) {<a name="line.3922"></a>
-<span class="sourceLineNo">3923</span> replicationLoadSourceMap.get(replicationLoadSource.getPeerID())<a name="line.3923"></a>
-<span class="sourceLineNo">3924</span> .add(new Pair<>(serverName, replicationLoadSource));<a name="line.3924"></a>
-<span class="sourceLineNo">3925</span> }<a name="line.3925"></a>
-<span class="sourceLineNo">3926</span> }<a name="line.3926"></a>
-<span class="sourceLineNo">3927</span> for (List<Pair<ServerName, ReplicationLoadSource>> loads : replicationLoadSourceMap.values()) {<a name="line.3927"></a>
-<span class="sourceLineNo">3928</span> if (loads.size() > 0) {<a name="line.3928"></a>
-<span class="sourceLineNo">3929</span> loads.sort(Comparator.comparingLong(load -> (-1) * load.getSecond().getReplicationLag()));<a name="line.3929"></a>
-<span class="sourceLineNo">3930</span> }<a name="line.3930"></a>
-<span class="sourceLineNo">3931</span> }<a name="line.3931"></a>
-<span class="sourceLineNo">3932</span> return replicationLoadSourceMap;<a name="line.3932"></a>
-<span class="sourceLineNo">3933</span> }<a name="line.3933"></a>
-<span class="sourceLineNo">3934</span><a name="line.3934"></a>
-<span class="sourceLineNo">3935</span> /**<a name="line.3935"></a>
-<span class="sourceLineNo">3936</span> * This method modifies the master's configuration in order to inject replication-related features<a name="line.3936"></a>
-<span class="sourceLineNo">3937</span> */<a name="line.3937"></a>
-<span class="sourceLineNo">3938</span> @VisibleForTesting<a name="line.3938"></a>
-<span class="sourceLineNo">3939</span> public static void decorateMasterConfiguration(Configuration conf) {<a name="line.3939"></a>
-<span class="sourceLineNo">3940</span> String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);<a name="line.3940"></a>
-<span class="sourceLineNo">3941</span> String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();<a name="line.3941"></a>
-<span class="sourceLineNo">3942</span> if (!plugins.contains(cleanerClass)) {<a name="line.3942"></a>
-<span class="sourceLineNo">3943</span> conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);<a name="line.3943"></a>
-<span class="sourceLineNo">3944</span> }<a name="line.3944"></a>
-<span class="sourceLineNo">3945</span> if (ReplicationUtils.isReplicationForBulkLoadDataEnabled(conf)) {<a name="line.3945"></a>
-<span class="sourceLineNo">3946</span> plugins = conf.get(HFileCleaner.MASTER_HFILE_CLEANER_PLUGINS);<a name="line.3946"></a>
-<span class="sourceLineNo">3947</span> cleanerClass = ReplicationHFileCleaner.class.getCanonicalName();<a name="line.3947"></a>
-<span class="sourceLineNo">3948</span> if (!plugins.contains(cleanerClass)) {<a name="line.3948"></a>
-<span class="sourceLineNo">3949</span> conf.set(HFileCleaner.MASTER_HFILE_CLEANER_PLUGINS, plugins + "," + cleanerClass);<a name="line.3949"></a>
-<span class="sourceLineNo">3950</span> }<a name="line.3950"></a>
-<span class="sourceLineNo">3951</span> }<a name="line.3951"></a>
-<span class="sourceLineNo">3952</span> }<a name="line.3952"></a>
-<span class="sourceLineNo">3953</span><a name="line.3953"></a>
-<span class="sourceLineNo">3954</span> public SnapshotQuotaObserverChore getSnapshotQuotaObserverChore() {<a name="line.3954"></a>
-<span class="sourceLineNo">3955</span> return this.snapshotQuotaChore;<a name="line.3955"></a>
-<span class="sourceLineNo">3956</span> }<a name="line.3956"></a>
-<span class="sourceLineNo">3957</span><a name="line.3957"></a>
-<span class="sourceLineNo">3958</span> @Override<a name="line.3958"></a>
-<span class="sourceLineNo">3959</span> public SyncReplicationReplayWALManager getSyncReplicationReplayWALManager() {<a name="line.3959"></a>
-<span class="sourceLineNo">3960</span> return this.syncReplicationReplayWALManager;<a name="line.3960"></a>
-<span class="sourceLineNo">3961</span> }<a name="line.3961"></a>
-<span class="sourceLineNo">3962</span>}<a name="line.3962"></a>
+<span class="sourceLineNo">3891</span> LOG.debug("Remote procedure done, pid={}", procId);<a name="line.3891"></a>
+<span class="sourceLineNo">3892</span> RemoteProcedure<MasterProcedureEnv, ?> procedure = getRemoteProcedure(procId);<a name="line.3892"></a>
+<span class="sourceLineNo">3893</span> if (procedure != null) {<a name="line.3893"></a>
+<span class="sourceLineNo">3894</span> procedure.remoteOperationCompleted(procedureExecutor.getEnvironment());<a name="line.3894"></a>
+<span class="sourceLineNo">3895</span> }<a name="line.3895"></a>
+<span class="sourceLineNo">3896</span> }<a name="line.3896"></a>
+<span class="sourceLineNo">3897</span><a name="line.3897"></a>
+<span class="sourceLineNo">3898</span> public void remoteProcedureFailed(long procId, RemoteProcedureException error) {<a name="line.3898"></a>
+<span class="sourceLineNo">3899</span> LOG.debug("Remote procedure failed, pid={}", procId, error);<a name="line.3899"></a>
+<span class="sourceLineNo">3900</span> RemoteProcedure<MasterProcedureEnv, ?> procedure = getRemoteProcedure(procId);<a name="line.3900"></a>
+<span class="sourceLineNo">3901</span> if (procedure != null) {<a name="line.3901"></a>
+<span class="sourceLineNo">3902</span> procedure.remoteOperationFailed(procedureExecutor.getEnvironment(), error);<a name="line.3902"></a>
+<span class="sourceLineNo">3903</span> }<a name="line.3903"></a>
+<span class="sourceLineNo">3904</span> }<a name="line.3904"></a>
+<span class="sourceLineNo">3905</span><a name="line.3905"></a>
+<span class="sourceLineNo">3906</span> @Override<a name="line.3906"></a>
+<span class="sourceLineNo">3907</span> public ReplicationPeerManager getReplicationPeerManager() {<a name="line.3907"></a>
+<span class="sourceLineNo">3908</span> return replicationPeerManager;<a name="line.3908"></a>
+<span class="sourceLineNo">3909</span> }<a name="line.3909"></a>
+<span class="sourceLineNo">3910</span><a name="line.3910"></a>
+<span class="sourceLineNo">3911</span> public HashMap<String, List<Pair<ServerName, ReplicationLoadSource>>><a name="line.3911"></a>
+<span class="sourceLineNo">3912</span> getReplicationLoad(ServerName[] serverNames) {<a name="line.3912"></a>
+<span class="sourceLineNo">3913</span> List<ReplicationPeerDescription> peerList = this.getReplicationPeerManager().listPeers(null);<a name="line.3913"></a>
+<span class="sourceLineNo">3914</span> if (peerList == null) {<a name="line.3914"></a>
+<span class="sourceLineNo">3915</span> return null;<a name="line.3915"></a>
+<span class="sourceLineNo">3916</span> }<a name="line.3916"></a>
+<span class="sourceLineNo">3917</span> HashMap<String, List<Pair<ServerName, ReplicationLoadSource>>> replicationLoadSourceMap =<a name="line.3917"></a>
+<span class="sourceLineNo">3918</span> new HashMap<>(peerList.size());<a name="line.3918"></a>
+<span class="sourceLineNo">3919</span> peerList.stream()<a name="line.3919"></a>
+<span class="sourceLineNo">3920</span> .forEach(peer -> replicationLoadSourceMap.put(peer.getPeerId(), new ArrayList<>()));<a name="line.3920"></a>
+<span class="sourceLineNo">3921</span> for (ServerName serverName : serverNames) {<a name="line.3921"></a>
+<span class="sourceLineNo">3922</span> List<ReplicationLoadSource> replicationLoadSources =<a name="line.3922"></a>
+<span class="sourceLineNo">3923</span> getServerManager().getLoad(serverName).getReplicationLoadSourceList();<a name="line.3923"></a>
+<span class="sourceLineNo">3924</span> for (ReplicationLoadSource replicationLoadSource : replicationLoadSources) {<a name="line.3924"></a>
+<span class="sourceLineNo">3925</span> replicationLoadSourceMap.get(replicationLoadSource.getPeerID())<a name="line.3925"></a>
+<span class="sourceLineNo">3926</span> .add(new Pair<>(serverName, replicationLoadSource));<a name="line.3926"></a>
+<span class="sourceLineNo">3927</span> }<a name="line.3927"></a>
+<span class="sourceLineNo">3928</span> }<a name="line.3928"></a>
+<span class="sourceLineNo">3929</span> for (List<Pair<ServerName, ReplicationLoadSource>> loads : replicationLoadSourceMap.values()) {<a name="line.3929"></a>
+<span class="sourceLineNo">3930</span> if (loads.size() > 0) {<a name="line.3930"></a>
+<span class="sourceLineNo">3931</span> loads.sort(Comparator.comparingLong(load -> (-1) * load.getSecond().getReplicationLag()));<a name="line.3931"></a>
+<span class="sourceLineNo">3932</span> }<a name="line.3932"></a>
+<span class="sourceLineNo">3933</span> }<a name="line.3933"></a>
+<span class="sourceLineNo">3934</span> return replicationLoadSourceMap;<a name="line.3934"></a>
+<span class="sourceLineNo">3935</span> }<a name="line.3935"></a>
+<span class="sourceLineNo">3936</span><a name="line.3936"></a>
+<span class="sourceLineNo">3937</span> /**<a name="line.3937"></a>
+<span class="sourceLineNo">3938</span> * This method modifies the master's configuration in order to inject replication-related features<a name="line.3938"></a>
+<span class="sourceLineNo">3939</span> */<a name="line.3939"></a>
+<span class="sourceLineNo">3940</span> @VisibleForTesting<a name="line.3940"></a>
+<span class="sourceLineNo">3941</span> public static void decorateMasterConfiguration(Configuration conf) {<a name="line.3941"></a>
+<span class="sourceLineNo">3942</span> String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);<a name="line.3942"></a>
+<span class="sourceLineNo">3943</span> String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();<a name="line.3943"></a>
+<span class="sourceLineNo">3944</span> if (!plugins.contains(cleanerClass)) {<a name="line.3944"></a>
+<span class="sourceLineNo">3945</span> conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);<a name="line.3945"></a>
+<span class="sourceLineNo">3946</span> }<a name="line.3946"></a>
+<span class="sourceLineNo">3947</span> if (ReplicationUtils.isReplicationForBulkLoadDataEnabled(conf)) {<a name="line.3947"></a>
+<span class="sourceLineNo">3948</span> plugins = conf.get(HFileCleaner.MASTER_HFILE_CLEANER_PLUGINS);<a name="line.3948"></a>
+<span class="sourceLineNo">3949</span> cleanerClass = ReplicationHFileCleaner.class.getCanonicalName();<a name="line.3949"></a>
+<span class="sourceLineNo">3950</span> if (!plugins.contains(cleanerClass)) {<a name="line.3950"></a>
+<span class="sourceLineNo">3951</span> conf.set(HFileCleaner.MASTER_HFILE_CLEANER_PLUGINS, plugins + "," + cleanerClass);<a name="line.3951"></a>
+<span class="sourceLineNo">3952</span> }<a name="line.3952"></a>
+<span class="sourceLineNo">3953</span> }<a name="line.3953"></a>
+<span class="sourceLineNo">3954</span> }<a name="line.3954"></a>
+<span class="sourceLineNo">3955</span><a name="line.3955"></a>
+<span class="sourceLineNo">3956</span> public SnapshotQuotaObserverChore getSnapshotQuotaObserverChore() {<a name="line.3956"></a>
+<span class="sourceLineNo">3957</span> return this.snapshotQuotaChore;<a name="line.3957"></a>
+<span class="sourceLineNo">3958</span> }<a name="line.3958"></a>
+<span class="sourceLineNo">3959</span><a name="line.3959"></a>
+<span class="sourceLineNo">3960</span> @Override<a name="line.3960"></a>
+<span class="sourceLineNo">3961</span> public SyncReplicationReplayWALManager getSyncReplicationReplayWALManager() {<a name="line.3961"></a>
+<span class="sourceLineNo">3962</span> return this.syncReplicationReplayWALManager;<a name="line.3962"></a>
+<span class="sourceLineNo">3963</span> }<a name="line.3963"></a>
+<span class="sourceLineNo">3964</span>}<a name="line.3964"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1c87639a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html
index 0377974..c4c914c 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html
@@ -3896,78 +3896,80 @@
<span class="sourceLineNo">3888</span> }<a name="line.3888"></a>
<span class="sourceLineNo">3889</span><a name="line.3889"></a>
<span class="sourceLineNo">3890</span> public void remoteProcedureCompleted(long procId) {<a name="line.3890"></a>
-<span class="sourceLineNo">3891</span> RemoteProcedure<MasterProcedureEnv, ?> procedure = getRemoteProcedure(procId);<a name="line.3891"></a>
-<span class="sourceLineNo">3892</span> if (procedure != null) {<a name="line.3892"></a>
-<span class="sourceLineNo">3893</span> procedure.remoteOperationCompleted(procedureExecutor.getEnvironment());<a name="line.3893"></a>
-<span class="sourceLineNo">3894</span> }<a name="line.3894"></a>
-<span class="sourceLineNo">3895</span> }<a name="line.3895"></a>
-<span class="sourceLineNo">3896</span><a name="line.3896"></a>
-<span class="sourceLineNo">3897</span> public void remoteProcedureFailed(long procId, RemoteProcedureException error) {<a name="line.3897"></a>
-<span class="sourceLineNo">3898</span> RemoteProcedure<MasterProcedureEnv, ?> procedure = getRemoteProcedure(procId);<a name="line.3898"></a>
-<span class="sourceLineNo">3899</span> if (procedure != null) {<a name="line.3899"></a>
-<span class="sourceLineNo">3900</span> procedure.remoteOperationFailed(procedureExecutor.getEnvironment(), error);<a name="line.3900"></a>
-<span class="sourceLineNo">3901</span> }<a name="line.3901"></a>
-<span class="sourceLineNo">3902</span> }<a name="line.3902"></a>
-<span class="sourceLineNo">3903</span><a name="line.3903"></a>
-<span class="sourceLineNo">3904</span> @Override<a name="line.3904"></a>
-<span class="sourceLineNo">3905</span> public ReplicationPeerManager getReplicationPeerManager() {<a name="line.3905"></a>
-<span class="sourceLineNo">3906</span> return replicationPeerManager;<a name="line.3906"></a>
-<span class="sourceLineNo">3907</span> }<a name="line.3907"></a>
-<span class="sourceLineNo">3908</span><a name="line.3908"></a>
-<span class="sourceLineNo">3909</span> public HashMap<String, List<Pair<ServerName, ReplicationLoadSource>>><a name="line.3909"></a>
-<span class="sourceLineNo">3910</span> getReplicationLoad(ServerName[] serverNames) {<a name="line.3910"></a>
-<span class="sourceLineNo">3911</span> List<ReplicationPeerDescription> peerList = this.getReplicationPeerManager().listPeers(null);<a name="line.3911"></a>
-<span class="sourceLineNo">3912</span> if (peerList == null) {<a name="line.3912"></a>
-<span class="sourceLineNo">3913</span> return null;<a name="line.3913"></a>
-<span class="sourceLineNo">3914</span> }<a name="line.3914"></a>
-<span class="sourceLineNo">3915</span> HashMap<String, List<Pair<ServerName, ReplicationLoadSource>>> replicationLoadSourceMap =<a name="line.3915"></a>
-<span class="sourceLineNo">3916</span> new HashMap<>(peerList.size());<a name="line.3916"></a>
-<span class="sourceLineNo">3917</span> peerList.stream()<a name="line.3917"></a>
-<span class="sourceLineNo">3918</span> .forEach(peer -> replicationLoadSourceMap.put(peer.getPeerId(), new ArrayList<>()));<a name="line.3918"></a>
-<span class="sourceLineNo">3919</span> for (ServerName serverName : serverNames) {<a name="line.3919"></a>
-<span class="sourceLineNo">3920</span> List<ReplicationLoadSource> replicationLoadSources =<a name="line.3920"></a>
-<span class="sourceLineNo">3921</span> getServerManager().getLoad(serverName).getReplicationLoadSourceList();<a name="line.3921"></a>
-<span class="sourceLineNo">3922</span> for (ReplicationLoadSource replicationLoadSource : replicationLoadSources) {<a name="line.3922"></a>
-<span class="sourceLineNo">3923</span> replicationLoadSourceMap.get(replicationLoadSource.getPeerID())<a name="line.3923"></a>
-<span class="sourceLineNo">3924</span> .add(new Pair<>(serverName, replicationLoadSource));<a name="line.3924"></a>
-<span class="sourceLineNo">3925</span> }<a name="line.3925"></a>
-<span class="sourceLineNo">3926</span> }<a name="line.3926"></a>
-<span class="sourceLineNo">3927</span> for (List<Pair<ServerName, ReplicationLoadSource>> loads : replicationLoadSourceMap.values()) {<a name="line.3927"></a>
-<span class="sourceLineNo">3928</span> if (loads.size() > 0) {<a name="line.3928"></a>
-<span class="sourceLineNo">3929</span> loads.sort(Comparator.comparingLong(load -> (-1) * load.getSecond().getReplicationLag()));<a name="line.3929"></a>
-<span class="sourceLineNo">3930</span> }<a name="line.3930"></a>
-<span class="sourceLineNo">3931</span> }<a name="line.3931"></a>
-<span class="sourceLineNo">3932</span> return replicationLoadSourceMap;<a name="line.3932"></a>
-<span class="sourceLineNo">3933</span> }<a name="line.3933"></a>
-<span class="sourceLineNo">3934</span><a name="line.3934"></a>
-<span class="sourceLineNo">3935</span> /**<a name="line.3935"></a>
-<span class="sourceLineNo">3936</span> * This method modifies the master's configuration in order to inject replication-related features<a name="line.3936"></a>
-<span class="sourceLineNo">3937</span> */<a name="line.3937"></a>
-<span class="sourceLineNo">3938</span> @VisibleForTesting<a name="line.3938"></a>
-<span class="sourceLineNo">3939</span> public static void decorateMasterConfiguration(Configuration conf) {<a name="line.3939"></a>
-<span class="sourceLineNo">3940</span> String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);<a name="line.3940"></a>
-<span class="sourceLineNo">3941</span> String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();<a name="line.3941"></a>
-<span class="sourceLineNo">3942</span> if (!plugins.contains(cleanerClass)) {<a name="line.3942"></a>
-<span class="sourceLineNo">3943</span> conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);<a name="line.3943"></a>
-<span class="sourceLineNo">3944</span> }<a name="line.3944"></a>
-<span class="sourceLineNo">3945</span> if (ReplicationUtils.isReplicationForBulkLoadDataEnabled(conf)) {<a name="line.3945"></a>
-<span class="sourceLineNo">3946</span> plugins = conf.get(HFileCleaner.MASTER_HFILE_CLEANER_PLUGINS);<a name="line.3946"></a>
-<span class="sourceLineNo">3947</span> cleanerClass = ReplicationHFileCleaner.class.getCanonicalName();<a name="line.3947"></a>
-<span class="sourceLineNo">3948</span> if (!plugins.contains(cleanerClass)) {<a name="line.3948"></a>
-<span class="sourceLineNo">3949</span> conf.set(HFileCleaner.MASTER_HFILE_CLEANER_PLUGINS, plugins + "," + cleanerClass);<a name="line.3949"></a>
-<span class="sourceLineNo">3950</span> }<a name="line.3950"></a>
-<span class="sourceLineNo">3951</span> }<a name="line.3951"></a>
-<span class="sourceLineNo">3952</span> }<a name="line.3952"></a>
-<span class="sourceLineNo">3953</span><a name="line.3953"></a>
-<span class="sourceLineNo">3954</span> public SnapshotQuotaObserverChore getSnapshotQuotaObserverChore() {<a name="line.3954"></a>
-<span class="sourceLineNo">3955</span> return this.snapshotQuotaChore;<a name="line.3955"></a>
-<span class="sourceLineNo">3956</span> }<a name="line.3956"></a>
-<span class="sourceLineNo">3957</span><a name="line.3957"></a>
-<span class="sourceLineNo">3958</span> @Override<a name="line.3958"></a>
-<span class="sourceLineNo">3959</span> public SyncReplicationReplayWALManager getSyncReplicationReplayWALManager() {<a name="line.3959"></a>
-<span class="sourceLineNo">3960</span> return this.syncReplicationReplayWALManager;<a name="line.3960"></a>
-<span class="sourceLineNo">3961</span> }<a name="line.3961"></a>
-<span class="sourceLineNo">3962</span>}<a name="line.3962"></a>
+<span class="sourceLineNo">3891</span> LOG.debug("Remote procedure done, pid={}", procId);<a name="line.3891"></a>
+<span class="sourceLineNo">3892</span> RemoteProcedure<MasterProcedureEnv, ?> procedure = getRemoteProcedure(procId);<a name="line.3892"></a>
+<span class="sourceLineNo">3893</span> if (procedure != null) {<a name="line.3893"></a>
+<span class="sourceLineNo">3894</span> procedure.remoteOperationCompleted(procedureExecutor.getEnvironment());<a name="line.3894"></a>
+<span class="sourceLineNo">3895</span> }<a name="line.3895"></a>
+<span class="sourceLineNo">3896</span> }<a name="line.3896"></a>
+<span class="sourceLineNo">3897</span><a name="line.3897"></a>
+<span class="sourceLineNo">3898</span> public void remoteProcedureFailed(long procId, RemoteProcedureException error) {<a name="line.3898"></a>
+<span class="sourceLineNo">3899</span> LOG.debug("Remote procedure failed, pid={}", procId, error);<a name="line.3899"></a>
+<span class="sourceLineNo">3900</span> RemoteProcedure<MasterProcedureEnv, ?> procedure = getRemoteProcedure(procId);<a name="line.3900"></a>
+<span class="sourceLineNo">3901</span> if (procedure != null) {<a name="line.3901"></a>
+<span class="sourceLineNo">3902</span> procedure.remoteOperationFailed(procedureExecutor.getEnvironment(), error);<a name="line.3902"></a>
+<span class="sourceLineNo">3903</span> }<a name="line.3903"></a>
+<span class="sourceLineNo">3904</span> }<a name="line.3904"></a>
+<span class="sourceLineNo">3905</span><a name="line.3905"></a>
+<span class="sourceLineNo">3906</span> @Override<a name="line.3906"></a>
+<span class="sourceLineNo">3907</span> public ReplicationPeerManager getReplicationPeerManager() {<a name="line.3907"></a>
+<span class="sourceLineNo">3908</span> return replicationPeerManager;<a name="line.3908"></a>
+<span class="sourceLineNo">3909</span> }<a name="line.3909"></a>
+<span class="sourceLineNo">3910</span><a name="line.3910"></a>
+<span class="sourceLineNo">3911</span> public HashMap<String, List<Pair<ServerName, ReplicationLoadSource>>><a name="line.3911"></a>
+<span class="sourceLineNo">3912</span> getReplicationLoad(ServerName[] serverNames) {<a name="line.3912"></a>
+<span class="sourceLineNo">3913</span> List<ReplicationPeerDescription> peerList = this.getReplicationPeerManager().listPeers(null);<a name="line.3913"></a>
+<span class="sourceLineNo">3914</span> if (peerList == null) {<a name="line.3914"></a>
+<span class="sourceLineNo">3915</span> return null;<a name="line.3915"></a>
+<span class="sourceLineNo">3916</span> }<a name="line.3916"></a>
+<span class="sourceLineNo">3917</span> HashMap<String, List<Pair<ServerName, ReplicationLoadSource>>> replicationLoadSourceMap =<a name="line.3917"></a>
+<span class="sourceLineNo">3918</span> new HashMap<>(peerList.size());<a name="line.3918"></a>
+<span class="sourceLineNo">3919</span> peerList.stream()<a name="line.3919"></a>
+<span class="sourceLineNo">3920</span> .forEach(peer -> replicationLoadSourceMap.put(peer.getPeerId(), new ArrayList<>()));<a name="line.3920"></a>
+<span class="sourceLineNo">3921</span> for (ServerName serverName : serverNames) {<a name="line.3921"></a>
+<span class="sourceLineNo">3922</span> List<ReplicationLoadSource> replicationLoadSources =<a name="line.3922"></a>
+<span class="sourceLineNo">3923</span> getServerManager().getLoad(serverName).getReplicationLoadSourceList();<a name="line.3923"></a>
+<span class="sourceLineNo">3924</span> for (ReplicationLoadSource replicationLoadSource : replicationLoadSources) {<a name="line.3924"></a>
+<span class="sourceLineNo">3925</span> replicationLoadSourceMap.get(replicationLoadSource.getPeerID())<a name="line.3925"></a>
+<span class="sourceLineNo">3926</span> .add(new Pair<>(serverName, replicationLoadSource));<a name="line.3926"></a>
+<span class="sourceLineNo">3927</span> }<a name="line.3927"></a>
+<span class="sourceLineNo">3928</span> }<a name="line.3928"></a>
+<span class="sourceLineNo">3929</span> for (List<Pair<ServerName, ReplicationLoadSource>> loads : replicationLoadSourceMap.values()) {<a name="line.3929"></a>
+<span class="sourceLineNo">3930</span> if (loads.size() > 0) {<a name="line.3930"></a>
+<span class="sourceLineNo">3931</span> loads.sort(Comparator.comparingLong(load -> (-1) * load.getSecond().getReplicationLag()));<a name="line.3931"></a>
+<span class="sourceLineNo">3932</span> }<a name="line.3932"></a>
+<span class="sourceLineNo">3933</span> }<a name="line.3933"></a>
+<span class="sourceLineNo">3934</span> return replicationLoadSourceMap;<a name="line.3934"></a>
+<span class="sourceLineNo">3935</span> }<a name="line.3935"></a>
+<span class="sourceLineNo">3936</span><a name="line.3936"></a>
+<span class="sourceLineNo">3937</span> /**<a name="line.3937"></a>
+<span class="sourceLineNo">3938</span> * This method modifies the master's configuration in order to inject replication-related features<a name="line.3938"></a>
+<span class="sourceLineNo">3939</span> */<a name="line.3939"></a>
+<span class="sourceLineNo">3940</span> @VisibleForTesting<a name="line.3940"></a>
+<span class="sourceLineNo">3941</span> public static void decorateMasterConfiguration(Configuration conf) {<a name="line.3941"></a>
+<span class="sourceLineNo">3942</span> String plugins = conf.get(HBASE_MASTER_LOGCLEANER_PLUGINS);<a name="line.3942"></a>
+<span class="sourceLineNo">3943</span> String cleanerClass = ReplicationLogCleaner.class.getCanonicalName();<a name="line.3943"></a>
+<span class="sourceLineNo">3944</span> if (!plugins.contains(cleanerClass)) {<a name="line.3944"></a>
+<span class="sourceLineNo">3945</span> conf.set(HBASE_MASTER_LOGCLEANER_PLUGINS, plugins + "," + cleanerClass);<a name="line.3945"></a>
+<span class="sourceLineNo">3946</span> }<a name="line.3946"></a>
+<span class="sourceLineNo">3947</span> if (ReplicationUtils.isReplicationForBulkLoadDataEnabled(conf)) {<a name="line.3947"></a>
+<span class="sourceLineNo">3948</span> plugins = conf.get(HFileCleaner.MASTER_HFILE_CLEANER_PLUGINS);<a name="line.3948"></a>
+<span class="sourceLineNo">3949</span> cleanerClass = ReplicationHFileCleaner.class.getCanonicalName();<a name="line.3949"></a>
+<span class="sourceLineNo">3950</span> if (!plugins.contains(cleanerClass)) {<a name="line.3950"></a>
+<span class="sourceLineNo">3951</span> conf.set(HFileCleaner.MASTER_HFILE_CLEANER_PLUGINS, plugins + "," + cleanerClass);<a name="line.3951"></a>
+<span class="sourceLineNo">3952</span> }<a name="line.3952"></a>
+<span class="sourceLineNo">3953</span> }<a name="line.3953"></a>
+<span class="sourceLineNo">3954</span> }<a name="line.3954"></a>
+<span class="sourceLineNo">3955</span><a name="line.3955"></a>
+<span class="sourceLineNo">3956</span> public SnapshotQuotaObserverChore getSnapshotQuotaObserverChore() {<a name="line.3956"></a>
+<span class="sourceLineNo">3957</span> return this.snapshotQuotaChore;<a name="line.3957"></a>
+<span class="sourceLineNo">3958</span> }<a name="line.3958"></a>
+<span class="sourceLineNo">3959</span><a name="line.3959"></a>
+<span class="sourceLineNo">3960</span> @Override<a name="line.3960"></a>
+<span class="sourceLineNo">3961</span> public SyncReplicationReplayWALManager getSyncReplicationReplayWALManager() {<a name="line.3961"></a>
+<span class="sourceLineNo">3962</span> return this.syncReplicationReplayWALManager;<a name="line.3962"></a>
+<span class="sourceLineNo">3963</span> }<a name="line.3963"></a>
+<span class="sourceLineNo">3964</span>}<a name="line.3964"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1c87639a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html
index b257d07..86f2fb9 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html
@@ -3742,44 +3742,47 @@
<span class="sourceLineNo">3734</span> callable = Class.forName(request.getProcClass()).asSubclass(RSProcedureCallable.class)<a name="line.3734"></a>
<span class="sourceLineNo">3735</span> .getDeclaredConstructor().newInstance();<a name="line.3735"></a>
<span class="sourceLineNo">3736</span> } catch (Exception e) {<a name="line.3736"></a>
-<span class="sourceLineNo">3737</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3737"></a>
-<span class="sourceLineNo">3738</span> return;<a name="line.3738"></a>
-<span class="sourceLineNo">3739</span> }<a name="line.3739"></a>
-<span class="sourceLineNo">3740</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3740"></a>
-<span class="sourceLineNo">3741</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3741"></a>
-<span class="sourceLineNo">3742</span> }<a name="line.3742"></a>
-<span class="sourceLineNo">3743</span><a name="line.3743"></a>
-<span class="sourceLineNo">3744</span> @Override<a name="line.3744"></a>
-<span class="sourceLineNo">3745</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3745"></a>
-<span class="sourceLineNo">3746</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3746"></a>
-<span class="sourceLineNo">3747</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3747"></a>
-<span class="sourceLineNo">3748</span> try {<a name="line.3748"></a>
-<span class="sourceLineNo">3749</span> checkOpen();<a name="line.3749"></a>
-<span class="sourceLineNo">3750</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3750"></a>
-<span class="sourceLineNo">3751</span> if (request.getOpenRegionCount() > 0) {<a name="line.3751"></a>
-<span class="sourceLineNo">3752</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3752"></a>
-<span class="sourceLineNo">3753</span> // system)<a name="line.3753"></a>
-<span class="sourceLineNo">3754</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3754"></a>
-<span class="sourceLineNo">3755</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3755"></a>
-<span class="sourceLineNo">3756</span> }<a name="line.3756"></a>
-<span class="sourceLineNo">3757</span> if (request.getCloseRegionCount() > 0) {<a name="line.3757"></a>
-<span class="sourceLineNo">3758</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3758"></a>
+<span class="sourceLineNo">3737</span> LOG.warn("Failed to instantiating remote procedure {}, pid={}", request.getProcClass(),<a name="line.3737"></a>
+<span class="sourceLineNo">3738</span> request.getProcId(), e);<a name="line.3738"></a>
+<span class="sourceLineNo">3739</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3739"></a>
+<span class="sourceLineNo">3740</span> return;<a name="line.3740"></a>
+<span class="sourceLineNo">3741</span> }<a name="line.3741"></a>
+<span class="sourceLineNo">3742</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3742"></a>
+<span class="sourceLineNo">3743</span> LOG.debug("Executing remote procedure {}, pid={}", callable.getClass(), request.getProcId());<a name="line.3743"></a>
+<span class="sourceLineNo">3744</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3744"></a>
+<span class="sourceLineNo">3745</span> }<a name="line.3745"></a>
+<span class="sourceLineNo">3746</span><a name="line.3746"></a>
+<span class="sourceLineNo">3747</span> @Override<a name="line.3747"></a>
+<span class="sourceLineNo">3748</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3748"></a>
+<span class="sourceLineNo">3749</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3749"></a>
+<span class="sourceLineNo">3750</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3750"></a>
+<span class="sourceLineNo">3751</span> try {<a name="line.3751"></a>
+<span class="sourceLineNo">3752</span> checkOpen();<a name="line.3752"></a>
+<span class="sourceLineNo">3753</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3753"></a>
+<span class="sourceLineNo">3754</span> if (request.getOpenRegionCount() > 0) {<a name="line.3754"></a>
+<span class="sourceLineNo">3755</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3755"></a>
+<span class="sourceLineNo">3756</span> // system)<a name="line.3756"></a>
+<span class="sourceLineNo">3757</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3757"></a>
+<span class="sourceLineNo">3758</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3758"></a>
<span class="sourceLineNo">3759</span> }<a name="line.3759"></a>
-<span class="sourceLineNo">3760</span> if (request.getProcCount() > 0) {<a name="line.3760"></a>
-<span class="sourceLineNo">3761</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3761"></a>
+<span class="sourceLineNo">3760</span> if (request.getCloseRegionCount() > 0) {<a name="line.3760"></a>
+<span class="sourceLineNo">3761</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3761"></a>
<span class="sourceLineNo">3762</span> }<a name="line.3762"></a>
-<span class="sourceLineNo">3763</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3763"></a>
-<span class="sourceLineNo">3764</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3764"></a>
-<span class="sourceLineNo">3765</span> } catch (IOException e) {<a name="line.3765"></a>
-<span class="sourceLineNo">3766</span> throw new ServiceException(e);<a name="line.3766"></a>
-<span class="sourceLineNo">3767</span> }<a name="line.3767"></a>
-<span class="sourceLineNo">3768</span> }<a name="line.3768"></a>
-<span class="sourceLineNo">3769</span><a name="line.3769"></a>
-<span class="sourceLineNo">3770</span> @VisibleForTesting<a name="line.3770"></a>
-<span class="sourceLineNo">3771</span> public RpcScheduler getRpcScheduler() {<a name="line.3771"></a>
-<span class="sourceLineNo">3772</span> return rpcServer.getScheduler();<a name="line.3772"></a>
-<span class="sourceLineNo">3773</span> }<a name="line.3773"></a>
-<span class="sourceLineNo">3774</span>}<a name="line.3774"></a>
+<span class="sourceLineNo">3763</span> if (request.getProcCount() > 0) {<a name="line.3763"></a>
+<span class="sourceLineNo">3764</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3764"></a>
+<span class="sourceLineNo">3765</span> }<a name="line.3765"></a>
+<span class="sourceLineNo">3766</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3766"></a>
+<span class="sourceLineNo">3767</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3767"></a>
+<span class="sourceLineNo">3768</span> } catch (IOException e) {<a name="line.3768"></a>
+<span class="sourceLineNo">3769</span> throw new ServiceException(e);<a name="line.3769"></a>
+<span class="sourceLineNo">3770</span> }<a name="line.3770"></a>
+<span class="sourceLineNo">3771</span> }<a name="line.3771"></a>
+<span class="sourceLineNo">3772</span><a name="line.3772"></a>
+<span class="sourceLineNo">3773</span> @VisibleForTesting<a name="line.3773"></a>
+<span class="sourceLineNo">3774</span> public RpcScheduler getRpcScheduler() {<a name="line.3774"></a>
+<span class="sourceLineNo">3775</span> return rpcServer.getScheduler();<a name="line.3775"></a>
+<span class="sourceLineNo">3776</span> }<a name="line.3776"></a>
+<span class="sourceLineNo">3777</span>}<a name="line.3777"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1c87639a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html
index b257d07..86f2fb9 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html
@@ -3742,44 +3742,47 @@
<span class="sourceLineNo">3734</span> callable = Class.forName(request.getProcClass()).asSubclass(RSProcedureCallable.class)<a name="line.3734"></a>
<span class="sourceLineNo">3735</span> .getDeclaredConstructor().newInstance();<a name="line.3735"></a>
<span class="sourceLineNo">3736</span> } catch (Exception e) {<a name="line.3736"></a>
-<span class="sourceLineNo">3737</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3737"></a>
-<span class="sourceLineNo">3738</span> return;<a name="line.3738"></a>
-<span class="sourceLineNo">3739</span> }<a name="line.3739"></a>
-<span class="sourceLineNo">3740</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3740"></a>
-<span class="sourceLineNo">3741</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3741"></a>
-<span class="sourceLineNo">3742</span> }<a name="line.3742"></a>
-<span class="sourceLineNo">3743</span><a name="line.3743"></a>
-<span class="sourceLineNo">3744</span> @Override<a name="line.3744"></a>
-<span class="sourceLineNo">3745</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3745"></a>
-<span class="sourceLineNo">3746</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3746"></a>
-<span class="sourceLineNo">3747</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3747"></a>
-<span class="sourceLineNo">3748</span> try {<a name="line.3748"></a>
-<span class="sourceLineNo">3749</span> checkOpen();<a name="line.3749"></a>
-<span class="sourceLineNo">3750</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3750"></a>
-<span class="sourceLineNo">3751</span> if (request.getOpenRegionCount() > 0) {<a name="line.3751"></a>
-<span class="sourceLineNo">3752</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3752"></a>
-<span class="sourceLineNo">3753</span> // system)<a name="line.3753"></a>
-<span class="sourceLineNo">3754</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3754"></a>
-<span class="sourceLineNo">3755</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3755"></a>
-<span class="sourceLineNo">3756</span> }<a name="line.3756"></a>
-<span class="sourceLineNo">3757</span> if (request.getCloseRegionCount() > 0) {<a name="line.3757"></a>
-<span class="sourceLineNo">3758</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3758"></a>
+<span class="sourceLineNo">3737</span> LOG.warn("Failed to instantiating remote procedure {}, pid={}", request.getProcClass(),<a name="line.3737"></a>
+<span class="sourceLineNo">3738</span> request.getProcId(), e);<a name="line.3738"></a>
+<span class="sourceLineNo">3739</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3739"></a>
+<span class="sourceLineNo">3740</span> return;<a name="line.3740"></a>
+<span class="sourceLineNo">3741</span> }<a name="line.3741"></a>
+<span class="sourceLineNo">3742</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3742"></a>
+<span class="sourceLineNo">3743</span> LOG.debug("Executing remote procedure {}, pid={}", callable.getClass(), request.getProcId());<a name="line.3743"></a>
+<span class="sourceLineNo">3744</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3744"></a>
+<span class="sourceLineNo">3745</span> }<a name="line.3745"></a>
+<span class="sourceLineNo">3746</span><a name="line.3746"></a>
+<span class="sourceLineNo">3747</span> @Override<a name="line.3747"></a>
+<span class="sourceLineNo">3748</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3748"></a>
+<span class="sourceLineNo">3749</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3749"></a>
+<span class="sourceLineNo">3750</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3750"></a>
+<span class="sourceLineNo">3751</span> try {<a name="line.3751"></a>
+<span class="sourceLineNo">3752</span> checkOpen();<a name="line.3752"></a>
+<span class="sourceLineNo">3753</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3753"></a>
+<span class="sourceLineNo">3754</span> if (request.getOpenRegionCount() > 0) {<a name="line.3754"></a>
+<span class="sourceLineNo">3755</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3755"></a>
+<span class="sourceLineNo">3756</span> // system)<a name="line.3756"></a>
+<span class="sourceLineNo">3757</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3757"></a>
+<span class="sourceLineNo">3758</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3758"></a>
<span class="sourceLineNo">3759</span> }<a name="line.3759"></a>
-<span class="sourceLineNo">3760</span> if (request.getProcCount() > 0) {<a name="line.3760"></a>
-<span class="sourceLineNo">3761</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3761"></a>
+<span class="sourceLineNo">3760</span> if (request.getCloseRegionCount() > 0) {<a name="line.3760"></a>
+<span class="sourceLineNo">3761</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3761"></a>
<span class="sourceLineNo">3762</span> }<a name="line.3762"></a>
-<span class="sourceLineNo">3763</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3763"></a>
-<span class="sourceLineNo">3764</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3764"></a>
-<span class="sourceLineNo">3765</span> } catch (IOException e) {<a name="line.3765"></a>
-<span class="sourceLineNo">3766</span> throw new ServiceException(e);<a name="line.3766"></a>
-<span class="sourceLineNo">3767</span> }<a name="line.3767"></a>
-<span class="sourceLineNo">3768</span> }<a name="line.3768"></a>
-<span class="sourceLineNo">3769</span><a name="line.3769"></a>
-<span class="sourceLineNo">3770</span> @VisibleForTesting<a name="line.3770"></a>
-<span class="sourceLineNo">3771</span> public RpcScheduler getRpcScheduler() {<a name="line.3771"></a>
-<span class="sourceLineNo">3772</span> return rpcServer.getScheduler();<a name="line.3772"></a>
-<span class="sourceLineNo">3773</span> }<a name="line.3773"></a>
-<span class="sourceLineNo">3774</span>}<a name="line.3774"></a>
+<span class="sourceLineNo">3763</span> if (request.getProcCount() > 0) {<a name="line.3763"></a>
+<span class="sourceLineNo">3764</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3764"></a>
+<span class="sourceLineNo">3765</span> }<a name="line.3765"></a>
+<span class="sourceLineNo">3766</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3766"></a>
+<span class="sourceLineNo">3767</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3767"></a>
+<span class="sourceLineNo">3768</span> } catch (IOException e) {<a name="line.3768"></a>
+<span class="sourceLineNo">3769</span> throw new ServiceException(e);<a name="line.3769"></a>
+<span class="sourceLineNo">3770</span> }<a name="line.3770"></a>
+<span class="sourceLineNo">3771</span> }<a name="line.3771"></a>
+<span class="sourceLineNo">3772</span><a name="line.3772"></a>
+<span class="sourceLineNo">3773</span> @VisibleForTesting<a name="line.3773"></a>
+<span class="sourceLineNo">3774</span> public RpcScheduler getRpcScheduler() {<a name="line.3774"></a>
+<span class="sourceLineNo">3775</span> return rpcServer.getScheduler();<a name="line.3775"></a>
+<span class="sourceLineNo">3776</span> }<a name="line.3776"></a>
+<span class="sourceLineNo">3777</span>}<a name="line.3777"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1c87639a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html
index b257d07..86f2fb9 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html
@@ -3742,44 +3742,47 @@
<span class="sourceLineNo">3734</span> callable = Class.forName(request.getProcClass()).asSubclass(RSProcedureCallable.class)<a name="line.3734"></a>
<span class="sourceLineNo">3735</span> .getDeclaredConstructor().newInstance();<a name="line.3735"></a>
<span class="sourceLineNo">3736</span> } catch (Exception e) {<a name="line.3736"></a>
-<span class="sourceLineNo">3737</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3737"></a>
-<span class="sourceLineNo">3738</span> return;<a name="line.3738"></a>
-<span class="sourceLineNo">3739</span> }<a name="line.3739"></a>
-<span class="sourceLineNo">3740</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3740"></a>
-<span class="sourceLineNo">3741</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3741"></a>
-<span class="sourceLineNo">3742</span> }<a name="line.3742"></a>
-<span class="sourceLineNo">3743</span><a name="line.3743"></a>
-<span class="sourceLineNo">3744</span> @Override<a name="line.3744"></a>
-<span class="sourceLineNo">3745</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3745"></a>
-<span class="sourceLineNo">3746</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3746"></a>
-<span class="sourceLineNo">3747</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3747"></a>
-<span class="sourceLineNo">3748</span> try {<a name="line.3748"></a>
-<span class="sourceLineNo">3749</span> checkOpen();<a name="line.3749"></a>
-<span class="sourceLineNo">3750</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3750"></a>
-<span class="sourceLineNo">3751</span> if (request.getOpenRegionCount() > 0) {<a name="line.3751"></a>
-<span class="sourceLineNo">3752</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3752"></a>
-<span class="sourceLineNo">3753</span> // system)<a name="line.3753"></a>
-<span class="sourceLineNo">3754</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3754"></a>
-<span class="sourceLineNo">3755</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3755"></a>
-<span class="sourceLineNo">3756</span> }<a name="line.3756"></a>
-<span class="sourceLineNo">3757</span> if (request.getCloseRegionCount() > 0) {<a name="line.3757"></a>
-<span class="sourceLineNo">3758</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3758"></a>
+<span class="sourceLineNo">3737</span> LOG.warn("Failed to instantiating remote procedure {}, pid={}", request.getProcClass(),<a name="line.3737"></a>
+<span class="sourceLineNo">3738</span> request.getProcId(), e);<a name="line.3738"></a>
+<span class="sourceLineNo">3739</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3739"></a>
+<span class="sourceLineNo">3740</span> return;<a name="line.3740"></a>
+<span class="sourceLineNo">3741</span> }<a name="line.3741"></a>
+<span class="sourceLineNo">3742</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3742"></a>
+<span class="sourceLineNo">3743</span> LOG.debug("Executing remote procedure {}, pid={}", callable.getClass(), request.getProcId());<a name="line.3743"></a>
+<span class="sourceLineNo">3744</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3744"></a>
+<span class="sourceLineNo">3745</span> }<a name="line.3745"></a>
+<span class="sourceLineNo">3746</span><a name="line.3746"></a>
+<span class="sourceLineNo">3747</span> @Override<a name="line.3747"></a>
+<span class="sourceLineNo">3748</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3748"></a>
+<span class="sourceLineNo">3749</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3749"></a>
+<span class="sourceLineNo">3750</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3750"></a>
+<span class="sourceLineNo">3751</span> try {<a name="line.3751"></a>
+<span class="sourceLineNo">3752</span> checkOpen();<a name="line.3752"></a>
+<span class="sourceLineNo">3753</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3753"></a>
+<span class="sourceLineNo">3754</span> if (request.getOpenRegionCount() > 0) {<a name="line.3754"></a>
+<span class="sourceLineNo">3755</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3755"></a>
+<span class="sourceLineNo">3756</span> // system)<a name="line.3756"></a>
+<span class="sourceLineNo">3757</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3757"></a>
+<span class="sourceLineNo">3758</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3758"></a>
<span class="sourceLineNo">3759</span> }<a name="line.3759"></a>
-<span class="sourceLineNo">3760</span> if (request.getProcCount() > 0) {<a name="line.3760"></a>
-<span class="sourceLineNo">3761</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3761"></a>
+<span class="sourceLineNo">3760</span> if (request.getCloseRegionCount() > 0) {<a name="line.3760"></a>
+<span class="sourceLineNo">3761</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3761"></a>
<span class="sourceLineNo">3762</span> }<a name="line.3762"></a>
-<span class="sourceLineNo">3763</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3763"></a>
-<span class="sourceLineNo">3764</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3764"></a>
-<span class="sourceLineNo">3765</span> } catch (IOException e) {<a name="line.3765"></a>
-<span class="sourceLineNo">3766</span> throw new ServiceException(e);<a name="line.3766"></a>
-<span class="sourceLineNo">3767</span> }<a name="line.3767"></a>
-<span class="sourceLineNo">3768</span> }<a name="line.3768"></a>
-<span class="sourceLineNo">3769</span><a name="line.3769"></a>
-<span class="sourceLineNo">3770</span> @VisibleForTesting<a name="line.3770"></a>
-<span class="sourceLineNo">3771</span> public RpcScheduler getRpcScheduler() {<a name="line.3771"></a>
-<span class="sourceLineNo">3772</span> return rpcServer.getScheduler();<a name="line.3772"></a>
-<span class="sourceLineNo">3773</span> }<a name="line.3773"></a>
-<span class="sourceLineNo">3774</span>}<a name="line.3774"></a>
+<span class="sourceLineNo">3763</span> if (request.getProcCount() > 0) {<a name="line.3763"></a>
+<span class="sourceLineNo">3764</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3764"></a>
+<span class="sourceLineNo">3765</span> }<a name="line.3765"></a>
+<span class="sourceLineNo">3766</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3766"></a>
+<span class="sourceLineNo">3767</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3767"></a>
+<span class="sourceLineNo">3768</span> } catch (IOException e) {<a name="line.3768"></a>
+<span class="sourceLineNo">3769</span> throw new ServiceException(e);<a name="line.3769"></a>
+<span class="sourceLineNo">3770</span> }<a name="line.3770"></a>
+<span class="sourceLineNo">3771</span> }<a name="line.3771"></a>
+<span class="sourceLineNo">3772</span><a name="line.3772"></a>
+<span class="sourceLineNo">3773</span> @VisibleForTesting<a name="line.3773"></a>
+<span class="sourceLineNo">3774</span> public RpcScheduler getRpcScheduler() {<a name="line.3774"></a>
+<span class="sourceLineNo">3775</span> return rpcServer.getScheduler();<a name="line.3775"></a>
+<span class="sourceLineNo">3776</span> }<a name="line.3776"></a>
+<span class="sourceLineNo">3777</span>}<a name="line.3777"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1c87639a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html
index b257d07..86f2fb9 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html
@@ -3742,44 +3742,47 @@
<span class="sourceLineNo">3734</span> callable = Class.forName(request.getProcClass()).asSubclass(RSProcedureCallable.class)<a name="line.3734"></a>
<span class="sourceLineNo">3735</span> .getDeclaredConstructor().newInstance();<a name="line.3735"></a>
<span class="sourceLineNo">3736</span> } catch (Exception e) {<a name="line.3736"></a>
-<span class="sourceLineNo">3737</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3737"></a>
-<span class="sourceLineNo">3738</span> return;<a name="line.3738"></a>
-<span class="sourceLineNo">3739</span> }<a name="line.3739"></a>
-<span class="sourceLineNo">3740</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3740"></a>
-<span class="sourceLineNo">3741</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3741"></a>
-<span class="sourceLineNo">3742</span> }<a name="line.3742"></a>
-<span class="sourceLineNo">3743</span><a name="line.3743"></a>
-<span class="sourceLineNo">3744</span> @Override<a name="line.3744"></a>
-<span class="sourceLineNo">3745</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3745"></a>
-<span class="sourceLineNo">3746</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3746"></a>
-<span class="sourceLineNo">3747</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3747"></a>
-<span class="sourceLineNo">3748</span> try {<a name="line.3748"></a>
-<span class="sourceLineNo">3749</span> checkOpen();<a name="line.3749"></a>
-<span class="sourceLineNo">3750</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3750"></a>
-<span class="sourceLineNo">3751</span> if (request.getOpenRegionCount() > 0) {<a name="line.3751"></a>
-<span class="sourceLineNo">3752</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3752"></a>
-<span class="sourceLineNo">3753</span> // system)<a name="line.3753"></a>
-<span class="sourceLineNo">3754</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3754"></a>
-<span class="sourceLineNo">3755</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3755"></a>
-<span class="sourceLineNo">3756</span> }<a name="line.3756"></a>
-<span class="sourceLineNo">3757</span> if (request.getCloseRegionCount() > 0) {<a name="line.3757"></a>
-<span class="sourceLineNo">3758</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3758"></a>
+<span class="sourceLineNo">3737</span> LOG.warn("Failed to instantiating remote procedure {}, pid={}", request.getProcClass(),<a name="line.3737"></a>
+<span class="sourceLineNo">3738</span> request.getProcId(), e);<a name="line.3738"></a>
+<span class="sourceLineNo">3739</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3739"></a>
+<span class="sourceLineNo">3740</span> return;<a name="line.3740"></a>
+<span class="sourceLineNo">3741</span> }<a name="line.3741"></a>
+<span class="sourceLineNo">3742</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3742"></a>
+<span class="sourceLineNo">3743</span> LOG.debug("Executing remote procedure {}, pid={}", callable.getClass(), request.getProcId());<a name="line.3743"></a>
+<span class="sourceLineNo">3744</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3744"></a>
+<span class="sourceLineNo">3745</span> }<a name="line.3745"></a>
+<span class="sourceLineNo">3746</span><a name="line.3746"></a>
+<span class="sourceLineNo">3747</span> @Override<a name="line.3747"></a>
+<span class="sourceLineNo">3748</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3748"></a>
+<span class="sourceLineNo">3749</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3749"></a>
+<span class="sourceLineNo">3750</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3750"></a>
+<span class="sourceLineNo">3751</span> try {<a name="line.3751"></a>
+<span class="sourceLineNo">3752</span> checkOpen();<a name="line.3752"></a>
+<span class="sourceLineNo">3753</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3753"></a>
+<span class="sourceLineNo">3754</span> if (request.getOpenRegionCount() > 0) {<a name="line.3754"></a>
+<span class="sourceLineNo">3755</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3755"></a>
+<span class="sourceLineNo">3756</span> // system)<a name="line.3756"></a>
+<span class="sourceLineNo">3757</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3757"></a>
+<span class="sourceLineNo">3758</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3758"></a>
<span class="sourceLineNo">3759</span> }<a name="line.3759"></a>
-<span class="sourceLineNo">3760</span> if (request.getProcCount() > 0) {<a name="line.3760"></a>
-<span class="sourceLineNo">3761</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3761"></a>
+<span class="sourceLineNo">3760</span> if (request.getCloseRegionCount() > 0) {<a name="line.3760"></a>
+<span class="sourceLineNo">3761</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3761"></a>
<span class="sourceLineNo">3762</span> }<a name="line.3762"></a>
-<span class="sourceLineNo">3763</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3763"></a>
-<span class="sourceLineNo">3764</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3764"></a>
-<span class="sourceLineNo">3765</span> } catch (IOException e) {<a name="line.3765"></a>
-<span class="sourceLineNo">3766</span> throw new ServiceException(e);<a name="line.3766"></a>
-<span class="sourceLineNo">3767</span> }<a name="line.3767"></a>
-<span class="sourceLineNo">3768</span> }<a name="line.3768"></a>
-<span class="sourceLineNo">3769</span><a name="line.3769"></a>
-<span class="sourceLineNo">3770</span> @VisibleForTesting<a name="line.3770"></a>
-<span class="sourceLineNo">3771</span> public RpcScheduler getRpcScheduler() {<a name="line.3771"></a>
-<span class="sourceLineNo">3772</span> return rpcServer.getScheduler();<a name="line.3772"></a>
-<span class="sourceLineNo">3773</span> }<a name="line.3773"></a>
-<span class="sourceLineNo">3774</span>}<a name="line.3774"></a>
+<span class="sourceLineNo">3763</span> if (request.getProcCount() > 0) {<a name="line.3763"></a>
+<span class="sourceLineNo">3764</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3764"></a>
+<span class="sourceLineNo">3765</span> }<a name="line.3765"></a>
+<span class="sourceLineNo">3766</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3766"></a>
+<span class="sourceLineNo">3767</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3767"></a>
+<span class="sourceLineNo">3768</span> } catch (IOException e) {<a name="line.3768"></a>
+<span class="sourceLineNo">3769</span> throw new ServiceException(e);<a name="line.3769"></a>
+<span class="sourceLineNo">3770</span> }<a name="line.3770"></a>
+<span class="sourceLineNo">3771</span> }<a name="line.3771"></a>
+<span class="sourceLineNo">3772</span><a name="line.3772"></a>
+<span class="sourceLineNo">3773</span> @VisibleForTesting<a name="line.3773"></a>
+<span class="sourceLineNo">3774</span> public RpcScheduler getRpcScheduler() {<a name="line.3774"></a>
+<span class="sourceLineNo">3775</span> return rpcServer.getScheduler();<a name="line.3775"></a>
+<span class="sourceLineNo">3776</span> }<a name="line.3776"></a>
+<span class="sourceLineNo">3777</span>}<a name="line.3777"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1c87639a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html
index b257d07..86f2fb9 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html
@@ -3742,44 +3742,47 @@
<span class="sourceLineNo">3734</span> callable = Class.forName(request.getProcClass()).asSubclass(RSProcedureCallable.class)<a name="line.3734"></a>
<span class="sourceLineNo">3735</span> .getDeclaredConstructor().newInstance();<a name="line.3735"></a>
<span class="sourceLineNo">3736</span> } catch (Exception e) {<a name="line.3736"></a>
-<span class="sourceLineNo">3737</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3737"></a>
-<span class="sourceLineNo">3738</span> return;<a name="line.3738"></a>
-<span class="sourceLineNo">3739</span> }<a name="line.3739"></a>
-<span class="sourceLineNo">3740</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3740"></a>
-<span class="sourceLineNo">3741</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3741"></a>
-<span class="sourceLineNo">3742</span> }<a name="line.3742"></a>
-<span class="sourceLineNo">3743</span><a name="line.3743"></a>
-<span class="sourceLineNo">3744</span> @Override<a name="line.3744"></a>
-<span class="sourceLineNo">3745</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3745"></a>
-<span class="sourceLineNo">3746</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3746"></a>
-<span class="sourceLineNo">3747</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3747"></a>
-<span class="sourceLineNo">3748</span> try {<a name="line.3748"></a>
-<span class="sourceLineNo">3749</span> checkOpen();<a name="line.3749"></a>
-<span class="sourceLineNo">3750</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3750"></a>
-<span class="sourceLineNo">3751</span> if (request.getOpenRegionCount() > 0) {<a name="line.3751"></a>
-<span class="sourceLineNo">3752</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3752"></a>
-<span class="sourceLineNo">3753</span> // system)<a name="line.3753"></a>
-<span class="sourceLineNo">3754</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3754"></a>
-<span class="sourceLineNo">3755</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3755"></a>
-<span class="sourceLineNo">3756</span> }<a name="line.3756"></a>
-<span class="sourceLineNo">3757</span> if (request.getCloseRegionCount() > 0) {<a name="line.3757"></a>
-<span class="sourceLineNo">3758</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3758"></a>
+<span class="sourceLineNo">3737</span> LOG.warn("Failed to instantiating remote procedure {}, pid={}", request.getProcClass(),<a name="line.3737"></a>
+<span class="sourceLineNo">3738</span> request.getProcId(), e);<a name="line.3738"></a>
+<span class="sourceLineNo">3739</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3739"></a>
+<span class="sourceLineNo">3740</span> return;<a name="line.3740"></a>
+<span class="sourceLineNo">3741</span> }<a name="line.3741"></a>
+<span class="sourceLineNo">3742</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3742"></a>
+<span class="sourceLineNo">3743</span> LOG.debug("Executing remote procedure {}, pid={}", callable.getClass(), request.getProcId());<a name="line.3743"></a>
+<span class="sourceLineNo">3744</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3744"></a>
+<span class="sourceLineNo">3745</span> }<a name="line.3745"></a>
+<span class="sourceLineNo">3746</span><a name="line.3746"></a>
+<span class="sourceLineNo">3747</span> @Override<a name="line.3747"></a>
+<span class="sourceLineNo">3748</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3748"></a>
+<span class="sourceLineNo">3749</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3749"></a>
+<span class="sourceLineNo">3750</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3750"></a>
+<span class="sourceLineNo">3751</span> try {<a name="line.3751"></a>
+<span class="sourceLineNo">3752</span> checkOpen();<a name="line.3752"></a>
+<span class="sourceLineNo">3753</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3753"></a>
+<span class="sourceLineNo">3754</span> if (request.getOpenRegionCount() > 0) {<a name="line.3754"></a>
+<span class="sourceLineNo">3755</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3755"></a>
+<span class="sourceLineNo">3756</span> // system)<a name="line.3756"></a>
+<span class="sourceLineNo">3757</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3757"></a>
+<span class="sourceLineNo">3758</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3758"></a>
<span class="sourceLineNo">3759</span> }<a name="line.3759"></a>
-<span class="sourceLineNo">3760</span> if (request.getProcCount() > 0) {<a name="line.3760"></a>
-<span class="sourceLineNo">3761</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3761"></a>
+<span class="sourceLineNo">3760</span> if (request.getCloseRegionCount() > 0) {<a name="line.3760"></a>
+<span class="sourceLineNo">3761</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3761"></a>
<span class="sourceLineNo">3762</span> }<a name="line.3762"></a>
-<span class="sourceLineNo">3763</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3763"></a>
-<span class="sourceLineNo">3764</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3764"></a>
-<span class="sourceLineNo">3765</span> } catch (IOException e) {<a name="line.3765"></a>
-<span class="sourceLineNo">3766</span> throw new ServiceException(e);<a name="line.3766"></a>
-<span class="sourceLineNo">3767</span> }<a name="line.3767"></a>
-<span class="sourceLineNo">3768</span> }<a name="line.3768"></a>
-<span class="sourceLineNo">3769</span><a name="line.3769"></a>
-<span class="sourceLineNo">3770</span> @VisibleForTesting<a name="line.3770"></a>
-<span class="sourceLineNo">3771</span> public RpcScheduler getRpcScheduler() {<a name="line.3771"></a>
-<span class="sourceLineNo">3772</span> return rpcServer.getScheduler();<a name="line.3772"></a>
-<span class="sourceLineNo">3773</span> }<a name="line.3773"></a>
-<span class="sourceLineNo">3774</span>}<a name="line.3774"></a>
+<span class="sourceLineNo">3763</span> if (request.getProcCount() > 0) {<a name="line.3763"></a>
+<span class="sourceLineNo">3764</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3764"></a>
+<span class="sourceLineNo">3765</span> }<a name="line.3765"></a>
+<span class="sourceLineNo">3766</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3766"></a>
+<span class="sourceLineNo">3767</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3767"></a>
+<span class="sourceLineNo">3768</span> } catch (IOException e) {<a name="line.3768"></a>
+<span class="sourceLineNo">3769</span> throw new ServiceException(e);<a name="line.3769"></a>
+<span class="sourceLineNo">3770</span> }<a name="line.3770"></a>
+<span class="sourceLineNo">3771</span> }<a name="line.3771"></a>
+<span class="sourceLineNo">3772</span><a name="line.3772"></a>
+<span class="sourceLineNo">3773</span> @VisibleForTesting<a name="line.3773"></a>
+<span class="sourceLineNo">3774</span> public RpcScheduler getRpcScheduler() {<a name="line.3774"></a>
+<span class="sourceLineNo">3775</span> return rpcServer.getScheduler();<a name="line.3775"></a>
+<span class="sourceLineNo">3776</span> }<a name="line.3776"></a>
+<span class="sourceLineNo">3777</span>}<a name="line.3777"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1c87639a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html
index b257d07..86f2fb9 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html
@@ -3742,44 +3742,47 @@
<span class="sourceLineNo">3734</span> callable = Class.forName(request.getProcClass()).asSubclass(RSProcedureCallable.class)<a name="line.3734"></a>
<span class="sourceLineNo">3735</span> .getDeclaredConstructor().newInstance();<a name="line.3735"></a>
<span class="sourceLineNo">3736</span> } catch (Exception e) {<a name="line.3736"></a>
-<span class="sourceLineNo">3737</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3737"></a>
-<span class="sourceLineNo">3738</span> return;<a name="line.3738"></a>
-<span class="sourceLineNo">3739</span> }<a name="line.3739"></a>
-<span class="sourceLineNo">3740</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3740"></a>
-<span class="sourceLineNo">3741</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3741"></a>
-<span class="sourceLineNo">3742</span> }<a name="line.3742"></a>
-<span class="sourceLineNo">3743</span><a name="line.3743"></a>
-<span class="sourceLineNo">3744</span> @Override<a name="line.3744"></a>
-<span class="sourceLineNo">3745</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3745"></a>
-<span class="sourceLineNo">3746</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3746"></a>
-<span class="sourceLineNo">3747</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3747"></a>
-<span class="sourceLineNo">3748</span> try {<a name="line.3748"></a>
-<span class="sourceLineNo">3749</span> checkOpen();<a name="line.3749"></a>
-<span class="sourceLineNo">3750</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3750"></a>
-<span class="sourceLineNo">3751</span> if (request.getOpenRegionCount() > 0) {<a name="line.3751"></a>
-<span class="sourceLineNo">3752</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3752"></a>
-<span class="sourceLineNo">3753</span> // system)<a name="line.3753"></a>
-<span class="sourceLineNo">3754</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3754"></a>
-<span class="sourceLineNo">3755</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3755"></a>
-<span class="sourceLineNo">3756</span> }<a name="line.3756"></a>
-<span class="sourceLineNo">3757</span> if (request.getCloseRegionCount() > 0) {<a name="line.3757"></a>
-<span class="sourceLineNo">3758</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3758"></a>
+<span class="sourceLineNo">3737</span> LOG.warn("Failed to instantiating remote procedure {}, pid={}", request.getProcClass(),<a name="line.3737"></a>
+<span class="sourceLineNo">3738</span> request.getProcId(), e);<a name="line.3738"></a>
+<span class="sourceLineNo">3739</span> regionServer.remoteProcedureComplete(request.getProcId(), e);<a name="line.3739"></a>
+<span class="sourceLineNo">3740</span> return;<a name="line.3740"></a>
+<span class="sourceLineNo">3741</span> }<a name="line.3741"></a>
+<span class="sourceLineNo">3742</span> callable.init(request.getProcData().toByteArray(), regionServer);<a name="line.3742"></a>
+<span class="sourceLineNo">3743</span> LOG.debug("Executing remote procedure {}, pid={}", callable.getClass(), request.getProcId());<a name="line.3743"></a>
+<span class="sourceLineNo">3744</span> regionServer.executeProcedure(request.getProcId(), callable);<a name="line.3744"></a>
+<span class="sourceLineNo">3745</span> }<a name="line.3745"></a>
+<span class="sourceLineNo">3746</span><a name="line.3746"></a>
+<span class="sourceLineNo">3747</span> @Override<a name="line.3747"></a>
+<span class="sourceLineNo">3748</span> @QosPriority(priority = HConstants.ADMIN_QOS)<a name="line.3748"></a>
+<span class="sourceLineNo">3749</span> public ExecuteProceduresResponse executeProcedures(RpcController controller,<a name="line.3749"></a>
+<span class="sourceLineNo">3750</span> ExecuteProceduresRequest request) throws ServiceException {<a name="line.3750"></a>
+<span class="sourceLineNo">3751</span> try {<a name="line.3751"></a>
+<span class="sourceLineNo">3752</span> checkOpen();<a name="line.3752"></a>
+<span class="sourceLineNo">3753</span> regionServer.getRegionServerCoprocessorHost().preExecuteProcedures();<a name="line.3753"></a>
+<span class="sourceLineNo">3754</span> if (request.getOpenRegionCount() > 0) {<a name="line.3754"></a>
+<span class="sourceLineNo">3755</span> // Avoid reading from the TableDescritor every time(usually it will read from the file<a name="line.3755"></a>
+<span class="sourceLineNo">3756</span> // system)<a name="line.3756"></a>
+<span class="sourceLineNo">3757</span> Map<TableName, TableDescriptor> tdCache = new HashMap<>();<a name="line.3757"></a>
+<span class="sourceLineNo">3758</span> request.getOpenRegionList().forEach(req -> executeOpenRegionProcedures(req, tdCache));<a name="line.3758"></a>
<span class="sourceLineNo">3759</span> }<a name="line.3759"></a>
-<span class="sourceLineNo">3760</span> if (request.getProcCount() > 0) {<a name="line.3760"></a>
-<span class="sourceLineNo">3761</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3761"></a>
+<span class="sourceLineNo">3760</span> if (request.getCloseRegionCount() > 0) {<a name="line.3760"></a>
+<span class="sourceLineNo">3761</span> request.getCloseRegionList().forEach(this::executeCloseRegionProcedures);<a name="line.3761"></a>
<span class="sourceLineNo">3762</span> }<a name="line.3762"></a>
-<span class="sourceLineNo">3763</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3763"></a>
-<span class="sourceLineNo">3764</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3764"></a>
-<span class="sourceLineNo">3765</span> } catch (IOException e) {<a name="line.3765"></a>
-<span class="sourceLineNo">3766</span> throw new ServiceException(e);<a name="line.3766"></a>
-<span class="sourceLineNo">3767</span> }<a name="line.3767"></a>
-<span class="sourceLineNo">3768</span> }<a name="line.3768"></a>
-<span class="sourceLineNo">3769</span><a name="line.3769"></a>
-<span class="sourceLineNo">3770</span> @VisibleForTesting<a name="line.3770"></a>
-<span class="sourceLineNo">3771</span> public RpcScheduler getRpcScheduler() {<a name="line.3771"></a>
-<span class="sourceLineNo">3772</span> return rpcServer.getScheduler();<a name="line.3772"></a>
-<span class="sourceLineNo">3773</span> }<a name="line.3773"></a>
-<span class="sourceLineNo">3774</span>}<a name="line.3774"></a>
+<span class="sourceLineNo">3763</span> if (request.getProcCount() > 0) {<a name="line.3763"></a>
+<span class="sourceLineNo">3764</span> request.getProcList().forEach(this::executeProcedures);<a name="line.3764"></a>
+<span class="sourceLineNo">3765</span> }<a name="line.3765"></a>
+<span class="sourceLineNo">3766</span> regionServer.getRegionServerCoprocessorHost().postExecuteProcedures();<a name="line.3766"></a>
+<span class="sourceLineNo">3767</span> return ExecuteProceduresResponse.getDefaultInstance();<a name="line.3767"></a>
+<span class="sourceLineNo">3768</span> } catch (IOException e) {<a name="line.3768"></a>
+<span class="sourceLineNo">3769</span> throw new ServiceException(e);<a name="line.3769"></a>
+<span class="sourceLineNo">3770</span> }<a name="line.3770"></a>
+<span class="sourceLineNo">3771</span> }<a name="line.3771"></a>
+<span class="sourceLineNo">3772</span><a name="line.3772"></a>
+<span class="sourceLineNo">3773</span> @VisibleForTesting<a name="line.3773"></a>
+<span class="sourceLineNo">3774</span> public RpcScheduler getRpcScheduler() {<a name="line.3774"></a>
+<span class="sourceLineNo">3775</span> return rpcServer.getScheduler();<a name="line.3775"></a>
+<span class="sourceLineNo">3776</span> }<a name="line.3776"></a>
+<span class="sourceLineNo">3777</span>}<a name="line.3777"></a>