http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/checkstyle.rss ---------------------------------------------------------------------- diff --git a/checkstyle.rss b/checkstyle.rss index 5419f68..3d679df 100644 --- a/checkstyle.rss +++ b/checkstyle.rss @@ -26,7 +26,7 @@ under the License. <copyright>©2007 - 2018 The Apache Software Foundation</copyright> <item> <title>File: 3631, - Errors: 16248, + Errors: 16202, Warnings: 0, Infos: 0 </title> @@ -489,7 +489,7 @@ under the License. 0 </td> <td> - 5 + 3 </td> </tr> <tr> @@ -1931,7 +1931,7 @@ under the License. 0 </td> <td> - 21 + 20 </td> </tr> <tr> @@ -2505,7 +2505,7 @@ under the License. 0 </td> <td> - 9 + 8 </td> </tr> <tr> @@ -3681,7 +3681,7 @@ under the License. 0 </td> <td> - 7 + 6 </td> </tr> <tr> @@ -6789,7 +6789,7 @@ under the License. 0 </td> <td> - 12 + 10 </td> </tr> <tr> @@ -7811,7 +7811,7 @@ under the License. 0 </td> <td> - 53 + 52 </td> </tr> <tr> @@ -8315,7 +8315,7 @@ under the License. 0 </td> <td> - 23 + 22 </td> </tr> <tr> @@ -8707,7 +8707,7 @@ under the License. 0 </td> <td> - 14 + 13 </td> </tr> <tr> @@ -8721,7 +8721,7 @@ under the License. 0 </td> <td> - 17 + 16 </td> </tr> <tr> @@ -9533,7 +9533,7 @@ under the License. 0 </td> <td> - 14 + 13 </td> </tr> <tr> @@ -12683,7 +12683,7 @@ under the License. 0 </td> <td> - 2 + 1 </td> </tr> <tr> @@ -12949,7 +12949,7 @@ under the License. 0 </td> <td> - 2 + 1 </td> </tr> <tr> @@ -13103,7 +13103,7 @@ under the License. 0 </td> <td> - 3 + 2 </td> </tr> <tr> @@ -17373,7 +17373,7 @@ under the License. 0 </td> <td> - 193 + 184 </td> </tr> <tr> @@ -17611,7 +17611,7 @@ under the License. 0 </td> <td> - 33 + 32 </td> </tr> <tr> @@ -17765,7 +17765,7 @@ under the License. 0 </td> <td> - 6 + 4 </td> </tr> <tr> @@ -20523,7 +20523,7 @@ under the License. 0 </td> <td> - 10 + 11 </td> </tr> <tr> @@ -23953,7 +23953,7 @@ under the License. 0 </td> <td> - 100 + 99 </td> </tr> <tr> @@ -24863,7 +24863,7 @@ under the License. 0 </td> <td> - 3 + 2 </td> </tr> <tr> @@ -32269,7 +32269,7 @@ under the License. 0 </td> <td> - 17 + 16 </td> </tr> <tr> @@ -34383,7 +34383,7 @@ under the License. 0 </td> <td> - 11 + 10 </td> </tr> <tr> @@ -36119,7 +36119,7 @@ under the License. 0 </td> <td> - 42 + 40 </td> </tr> <tr> @@ -38191,7 +38191,7 @@ under the License. 0 </td> <td> - 28 + 26 </td> </tr> <tr> @@ -38429,7 +38429,7 @@ under the License. 0 </td> <td> - 7 + 6 </td> </tr> <tr> @@ -38513,7 +38513,7 @@ under the License. 0 </td> <td> - 40 + 39 </td> </tr> <tr> @@ -39073,7 +39073,7 @@ under the License. 0 </td> <td> - 1 + 0 </td> </tr> <tr> @@ -39297,7 +39297,7 @@ under the License. 0 </td> <td> - 10 + 8 </td> </tr> <tr> @@ -40431,7 +40431,7 @@ under the License. 0 </td> <td> - 39 + 38 </td> </tr> <tr> @@ -40669,7 +40669,7 @@ under the License. 0 </td> <td> - 170 + 169 </td> </tr> <tr> @@ -41033,7 +41033,7 @@ under the License. 0 </td> <td> - 12 + 11 </td> </tr> <tr> @@ -41649,7 +41649,7 @@ under the License. 0 </td> <td> - 2 + 1 </td> </tr> <tr> @@ -46059,7 +46059,7 @@ under the License. 0 </td> <td> - 50 + 48 </td> </tr> <tr> @@ -46227,7 +46227,7 @@ under the License. 0 </td> <td> - 4 + 3 </td> </tr> <tr>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/devapidocs/constant-values.html ---------------------------------------------------------------------- diff --git a/devapidocs/constant-values.html b/devapidocs/constant-values.html index c596469..ad564e9 100644 --- a/devapidocs/constant-values.html +++ b/devapidocs/constant-values.html @@ -3768,21 +3768,21 @@ <!-- --> </a><code>public static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td><code><a href="org/apache/hadoop/hbase/Version.html#date">date</a></code></td> -<td class="colLast"><code>"Mon Jun 11 14:39:34 UTC 2018"</code></td> +<td class="colLast"><code>"Mon Jun 11 15:29:29 UTC 2018"</code></td> </tr> <tr class="rowColor"> <td class="colFirst"><a name="org.apache.hadoop.hbase.Version.revision"> <!-- --> </a><code>public static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td><code><a href="org/apache/hadoop/hbase/Version.html#revision">revision</a></code></td> -<td class="colLast"><code>"573b57d43798ba172597721097b9ea98ddac3303"</code></td> +<td class="colLast"><code>"eb13cdd7edd8a53fb7d5c724875fcce2db202b87"</code></td> </tr> <tr class="altColor"> <td class="colFirst"><a name="org.apache.hadoop.hbase.Version.srcChecksum"> <!-- --> </a><code>public static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td><code><a href="org/apache/hadoop/hbase/Version.html#srcChecksum">srcChecksum</a></code></td> -<td class="colLast"><code>"0970757eba2ee7e91bc018e6571f9df8"</code></td> +<td class="colLast"><code>"77d54cd000fb52f3a5260beb74050650"</code></td> </tr> <tr class="rowColor"> <td class="colFirst"><a name="org.apache.hadoop.hbase.Version.url"> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/devapidocs/src-html/org/apache/hadoop/hbase/Version.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html index 38abc41..b814fe1 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html @@ -16,11 +16,11 @@ <span class="sourceLineNo">008</span>@InterfaceAudience.Private<a name="line.8"></a> <span class="sourceLineNo">009</span>public class Version {<a name="line.9"></a> <span class="sourceLineNo">010</span> public static final String version = "3.0.0-SNAPSHOT";<a name="line.10"></a> -<span class="sourceLineNo">011</span> public static final String revision = "573b57d43798ba172597721097b9ea98ddac3303";<a name="line.11"></a> +<span class="sourceLineNo">011</span> public static final String revision = "eb13cdd7edd8a53fb7d5c724875fcce2db202b87";<a name="line.11"></a> <span class="sourceLineNo">012</span> public static final String user = "jenkins";<a name="line.12"></a> -<span class="sourceLineNo">013</span> public static final String date = "Mon Jun 11 14:39:34 UTC 2018";<a name="line.13"></a> +<span class="sourceLineNo">013</span> public static final String date = "Mon Jun 11 15:29:29 UTC 2018";<a name="line.13"></a> <span class="sourceLineNo">014</span> public static final String url = "git://jenkins-websites1.apache.org/home/jenkins/jenkins-slave/workspace/hbase_generate_website/hbase";<a name="line.14"></a> -<span class="sourceLineNo">015</span> public static final String srcChecksum = "0970757eba2ee7e91bc018e6571f9df8";<a name="line.15"></a> +<span class="sourceLineNo">015</span> public static final String srcChecksum = "77d54cd000fb52f3a5260beb74050650";<a name="line.15"></a> <span class="sourceLineNo">016</span>}<a name="line.16"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/devapidocs/src-html/org/apache/hadoop/hbase/security/visibility/ExpressionParser.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/security/visibility/ExpressionParser.html b/devapidocs/src-html/org/apache/hadoop/hbase/security/visibility/ExpressionParser.html index 588e3e6..48c1c42 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/security/visibility/ExpressionParser.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/security/visibility/ExpressionParser.html @@ -314,10 +314,11 @@ <span class="sourceLineNo">306</span> return Operator.OR;<a name="line.306"></a> <span class="sourceLineNo">307</span> case NOT:<a name="line.307"></a> <span class="sourceLineNo">308</span> return Operator.NOT;<a name="line.308"></a> -<span class="sourceLineNo">309</span> }<a name="line.309"></a> -<span class="sourceLineNo">310</span> return null;<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">309</span> default:<a name="line.309"></a> +<span class="sourceLineNo">310</span> return null;<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> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/devapidocs/src-html/org/apache/hadoop/hbase/util/JenkinsHash.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/util/JenkinsHash.html b/devapidocs/src-html/org/apache/hadoop/hbase/util/JenkinsHash.html index 5c379f1..88d5e63 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/util/JenkinsHash.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/util/JenkinsHash.html @@ -109,7 +109,7 @@ <span class="sourceLineNo">101</span> * <p>Use for hash table lookup, or anything where one collision in 2^^32 is<a name="line.101"></a> <span class="sourceLineNo">102</span> * acceptable. Do NOT use for cryptographic purposes.<a name="line.102"></a> <span class="sourceLineNo">103</span> */<a name="line.103"></a> -<span class="sourceLineNo">104</span> @SuppressWarnings("fallthrough")<a name="line.104"></a> +<span class="sourceLineNo">104</span> @SuppressWarnings({"fallthrough", "MissingDefault"})<a name="line.104"></a> <span class="sourceLineNo">105</span> @Override<a name="line.105"></a> <span class="sourceLineNo">106</span> public <T> int hash(HashKey<T> hashKey, int initval) {<a name="line.106"></a> <span class="sourceLineNo">107</span> int length = hashKey.length();<a name="line.107"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/devapidocs/src-html/org/apache/hadoop/hbase/util/MurmurHash3.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/util/MurmurHash3.html b/devapidocs/src-html/org/apache/hadoop/hbase/util/MurmurHash3.html index 6bf0017..ea5e8ce 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/util/MurmurHash3.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/util/MurmurHash3.html @@ -86,21 +86,23 @@ <span class="sourceLineNo">078</span> k1 = (k1 << 15) | (k1 >>> 17); // ROTL32(k1,15);<a name="line.78"></a> <span class="sourceLineNo">079</span> k1 *= c2;<a name="line.79"></a> <span class="sourceLineNo">080</span> h1 ^= k1;<a name="line.80"></a> -<span class="sourceLineNo">081</span> }<a name="line.81"></a> -<span class="sourceLineNo">082</span><a name="line.82"></a> -<span class="sourceLineNo">083</span> // finalization<a name="line.83"></a> -<span class="sourceLineNo">084</span> h1 ^= length;<a name="line.84"></a> -<span class="sourceLineNo">085</span><a name="line.85"></a> -<span class="sourceLineNo">086</span> // fmix(h1);<a name="line.86"></a> -<span class="sourceLineNo">087</span> h1 ^= h1 >>> 16;<a name="line.87"></a> -<span class="sourceLineNo">088</span> h1 *= 0x85ebca6b;<a name="line.88"></a> -<span class="sourceLineNo">089</span> h1 ^= h1 >>> 13;<a name="line.89"></a> -<span class="sourceLineNo">090</span> h1 *= 0xc2b2ae35;<a name="line.90"></a> -<span class="sourceLineNo">091</span> h1 ^= h1 >>> 16;<a name="line.91"></a> -<span class="sourceLineNo">092</span><a name="line.92"></a> -<span class="sourceLineNo">093</span> return h1;<a name="line.93"></a> -<span class="sourceLineNo">094</span> }<a name="line.94"></a> -<span class="sourceLineNo">095</span>}<a name="line.95"></a> +<span class="sourceLineNo">081</span> default:<a name="line.81"></a> +<span class="sourceLineNo">082</span> // fall out<a name="line.82"></a> +<span class="sourceLineNo">083</span> }<a name="line.83"></a> +<span class="sourceLineNo">084</span><a name="line.84"></a> +<span class="sourceLineNo">085</span> // finalization<a name="line.85"></a> +<span class="sourceLineNo">086</span> h1 ^= length;<a name="line.86"></a> +<span class="sourceLineNo">087</span><a name="line.87"></a> +<span class="sourceLineNo">088</span> // fmix(h1);<a name="line.88"></a> +<span class="sourceLineNo">089</span> h1 ^= h1 >>> 16;<a name="line.89"></a> +<span class="sourceLineNo">090</span> h1 *= 0x85ebca6b;<a name="line.90"></a> +<span class="sourceLineNo">091</span> h1 ^= h1 >>> 13;<a name="line.91"></a> +<span class="sourceLineNo">092</span> h1 *= 0xc2b2ae35;<a name="line.92"></a> +<span class="sourceLineNo">093</span> h1 ^= h1 >>> 16;<a name="line.93"></a> +<span class="sourceLineNo">094</span><a name="line.94"></a> +<span class="sourceLineNo">095</span> return h1;<a name="line.95"></a> +<span class="sourceLineNo">096</span> }<a name="line.96"></a> +<span class="sourceLineNo">097</span>}<a name="line.97"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/testdevapidocs/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html b/testdevapidocs/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html index f843bd7..d670044 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html +++ b/testdevapidocs/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html @@ -283,7 +283,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockListLast"> <li class="blockList"> <h4>testOrder</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html#line.89">testOrder</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html#line.90">testOrder</a>()</pre> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html b/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html index 3c0d631..794a512 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html +++ b/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html @@ -109,7 +109,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>private static interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html#line.816">TestAssignmentManager.MockRSExecutor</a></pre> +<pre>private static interface <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html#line.820">TestAssignmentManager.MockRSExecutor</a></pre> </li> </ul> </div> @@ -154,7 +154,7 @@ var activeTableTab = "activeTableTab"; <ul class="blockListLast"> <li class="blockList"> <h4>sendRequest</h4> -<pre>org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html#line.817">sendRequest</a>(org.apache.hadoop.hbase.ServerName server, +<pre>org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html#line.821">sendRequest</a>(org.apache.hadoop.hbase.ServerName server, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest req) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall.html b/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall.html index 6a4ee83..65369a6 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall.html +++ b/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall.html @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>private class <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html#line.837">TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall</a> +<pre>private class <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html#line.841">TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall</a> extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></pre> </li> </ul> @@ -188,7 +188,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockListLast"> <li class="blockList"> <h4>MockRemoteCall</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall.html#line.838">MockRemoteCall</a>(org.apache.hadoop.hbase.ServerName serverName, +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall.html#line.842">MockRemoteCall</a>(org.apache.hadoop.hbase.ServerName serverName, <a href="https://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true"; title="class or interface in java.util">Set</a><org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> operations)</pre> </li> </ul> @@ -206,7 +206,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockListLast"> <li class="blockList"> <h4>sendRequest</h4> -<pre>protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall.html#line.844">sendRequest</a>(org.apache.hadoop.hbase.ServerName serverName, +<pre>protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.MockRemoteCall.html#line.848">sendRequest</a>(org.apache.hadoop.hbase.ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html b/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html index ea52b48..6a10076 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html +++ b/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>private class <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html#line.821">TestAssignmentManager.MockRSProcedureDispatcher</a> +<pre>private class <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html#line.825">TestAssignmentManager.MockRSProcedureDispatcher</a> extends org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher</pre> </li> </ul> @@ -288,7 +288,7 @@ extends org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher</pre> <ul class="blockListLast"> <li class="blockList"> <h4>mockRsExec</h4> -<pre>private <a href="../../../../../../org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html" title="interface in org.apache.hadoop.hbase.master.assignment">TestAssignmentManager.MockRSExecutor</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html#line.822">mockRsExec</a></pre> +<pre>private <a href="../../../../../../org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html" title="interface in org.apache.hadoop.hbase.master.assignment">TestAssignmentManager.MockRSExecutor</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html#line.826">mockRsExec</a></pre> </li> </ul> </li> @@ -305,7 +305,7 @@ extends org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher</pre> <ul class="blockListLast"> <li class="blockList"> <h4>MockRSProcedureDispatcher</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html#line.824">MockRSProcedureDispatcher</a>(org.apache.hadoop.hbase.master.MasterServices master)</pre> +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html#line.828">MockRSProcedureDispatcher</a>(org.apache.hadoop.hbase.master.MasterServices master)</pre> </li> </ul> </li> @@ -322,7 +322,7 @@ extends org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher</pre> <ul class="blockList"> <li class="blockList"> <h4>setMockRsExecutor</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html#line.828">setMockRsExecutor</a>(<a href="../../../../../../org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html" title="interface in org.apache.hadoop.hbase.master.assignment">TestAssignmentManager.MockRSExecutor</a> mockRsExec)</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html#line.832">setMockRsExecutor</a>(<a href="../../../../../../org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSExecutor.html" title="interface in org.apache.hadoop.hbase.master.assignment">TestAssignmentManager.MockRSExecutor</a> mockRsExec)</pre> </li> </ul> <a name="remoteDispatch-org.apache.hadoop.hbase.ServerName-java.util.Set-"> @@ -331,7 +331,7 @@ extends org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher</pre> <ul class="blockListLast"> <li class="blockList"> <h4>remoteDispatch</h4> -<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html#line.833">remoteDispatch</a>(org.apache.hadoop.hbase.ServerName serverName, +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.MockRSProcedureDispatcher.html#line.837">remoteDispatch</a>(org.apache.hadoop.hbase.ServerName serverName, <a href="https://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true"; title="class or interface in java.util">Set</a><org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)</pre> <dl> <dt><span class="overrideSpecifyLabel">Overrides:</span></dt> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.RandRsExecutor.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.RandRsExecutor.html b/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.RandRsExecutor.html index 6579e95..4292f14 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.RandRsExecutor.html +++ b/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.RandRsExecutor.html @@ -276,7 +276,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/master/assignment/Tes <ul class="blockList"> <li class="blockList"> <h4>execOpenRegion</h4> -<pre>protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionResponse.RegionOpeningState <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.RandRsExecutor.html#line.773">execOpenRegion</a>(org.apache.hadoop.hbase.ServerName server, +<pre>protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionResponse.RegionOpeningState <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.RandRsExecutor.html#line.775">execOpenRegion</a>(org.apache.hadoop.hbase.ServerName server, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest.RegionOpenInfo openReq) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> @@ -293,7 +293,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/master/assignment/Tes <ul class="blockListLast"> <li class="blockList"> <h4>execCloseRegion</h4> -<pre>protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.RandRsExecutor.html#line.803">execCloseRegion</a>(org.apache.hadoop.hbase.ServerName server, +<pre>protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.RandRsExecutor.html#line.807">execCloseRegion</a>(org.apache.hadoop.hbase.ServerName server, byte[] regionName) throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html b/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html index 4b15e6d..44d7708 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html +++ b/testdevapidocs/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html @@ -1049,7 +1049,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html <ul class="blockListLast"> <li class="blockList"> <h4>collectAssignmentManagerMetrics</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html#line.851">collectAssignmentManagerMetrics</a>()</pre> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.html#line.855">collectAssignmentManagerMetrics</a>()</pre> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/testdevapidocs/src-html/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html index b8ebeb0..80d5a85 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/master/TestClusterStatusPublisher.html @@ -70,78 +70,79 @@ <span class="sourceLineNo">062</span> @Test<a name="line.62"></a> <span class="sourceLineNo">063</span> public void testMaxSend() {<a name="line.63"></a> <span class="sourceLineNo">064</span> ClusterStatusPublisher csp = new ClusterStatusPublisher() {<a name="line.64"></a> -<span class="sourceLineNo">065</span> @Override<a name="line.65"></a> -<span class="sourceLineNo">066</span> protected List<Pair<ServerName, Long>> getDeadServers(long since) {<a name="line.66"></a> -<span class="sourceLineNo">067</span> List<Pair<ServerName, Long>> res = new ArrayList<>();<a name="line.67"></a> -<span class="sourceLineNo">068</span> switch ((int) EnvironmentEdgeManager.currentTime()) {<a name="line.68"></a> -<span class="sourceLineNo">069</span> case 2:<a name="line.69"></a> -<span class="sourceLineNo">070</span> res.add(new Pair<>(ServerName.valueOf("hn", 10, 10), 1L));<a name="line.70"></a> -<span class="sourceLineNo">071</span> break;<a name="line.71"></a> -<span class="sourceLineNo">072</span> case 1000:<a name="line.72"></a> -<span class="sourceLineNo">073</span> break;<a name="line.73"></a> -<span class="sourceLineNo">074</span> }<a name="line.74"></a> -<span class="sourceLineNo">075</span><a name="line.75"></a> -<span class="sourceLineNo">076</span> return res;<a name="line.76"></a> -<span class="sourceLineNo">077</span> }<a name="line.77"></a> -<span class="sourceLineNo">078</span> };<a name="line.78"></a> -<span class="sourceLineNo">079</span><a name="line.79"></a> -<span class="sourceLineNo">080</span> mee.setValue(2);<a name="line.80"></a> -<span class="sourceLineNo">081</span> for (int i = 0; i < ClusterStatusPublisher.NB_SEND; i++) {<a name="line.81"></a> -<span class="sourceLineNo">082</span> Assert.assertEquals("i=" + i, 1, csp.generateDeadServersListToSend().size());<a name="line.82"></a> -<span class="sourceLineNo">083</span> }<a name="line.83"></a> -<span class="sourceLineNo">084</span> mee.setValue(1000);<a name="line.84"></a> -<span class="sourceLineNo">085</span> Assert.assertTrue(csp.generateDeadServersListToSend().isEmpty());<a name="line.85"></a> -<span class="sourceLineNo">086</span> }<a name="line.86"></a> -<span class="sourceLineNo">087</span><a name="line.87"></a> -<span class="sourceLineNo">088</span> @Test<a name="line.88"></a> -<span class="sourceLineNo">089</span> public void testOrder() {<a name="line.89"></a> -<span class="sourceLineNo">090</span> ClusterStatusPublisher csp = new ClusterStatusPublisher() {<a name="line.90"></a> -<span class="sourceLineNo">091</span> @Override<a name="line.91"></a> -<span class="sourceLineNo">092</span> protected List<Pair<ServerName, Long>> getDeadServers(long since) {<a name="line.92"></a> -<span class="sourceLineNo">093</span> List<Pair<ServerName, Long>> res = new ArrayList<>();<a name="line.93"></a> -<span class="sourceLineNo">094</span> for (int i = 0; i < 25; i++) {<a name="line.94"></a> -<span class="sourceLineNo">095</span> res.add(new Pair<>(ServerName.valueOf("hn" + i, 10, 10), 20L));<a name="line.95"></a> -<span class="sourceLineNo">096</span> }<a name="line.96"></a> -<span class="sourceLineNo">097</span><a name="line.97"></a> -<span class="sourceLineNo">098</span> return res;<a name="line.98"></a> -<span class="sourceLineNo">099</span> }<a name="line.99"></a> -<span class="sourceLineNo">100</span> };<a name="line.100"></a> -<span class="sourceLineNo">101</span><a name="line.101"></a> +<span class="sourceLineNo">065</span> @SuppressWarnings("MissingDefault")<a name="line.65"></a> +<span class="sourceLineNo">066</span> @Override<a name="line.66"></a> +<span class="sourceLineNo">067</span> protected List<Pair<ServerName, Long>> getDeadServers(long since) {<a name="line.67"></a> +<span class="sourceLineNo">068</span> List<Pair<ServerName, Long>> res = new ArrayList<>();<a name="line.68"></a> +<span class="sourceLineNo">069</span> switch ((int) EnvironmentEdgeManager.currentTime()) {<a name="line.69"></a> +<span class="sourceLineNo">070</span> case 2:<a name="line.70"></a> +<span class="sourceLineNo">071</span> res.add(new Pair<>(ServerName.valueOf("hn", 10, 10), 1L));<a name="line.71"></a> +<span class="sourceLineNo">072</span> break;<a name="line.72"></a> +<span class="sourceLineNo">073</span> case 1000:<a name="line.73"></a> +<span class="sourceLineNo">074</span> break;<a name="line.74"></a> +<span class="sourceLineNo">075</span> }<a name="line.75"></a> +<span class="sourceLineNo">076</span><a name="line.76"></a> +<span class="sourceLineNo">077</span> return res;<a name="line.77"></a> +<span class="sourceLineNo">078</span> }<a name="line.78"></a> +<span class="sourceLineNo">079</span> };<a name="line.79"></a> +<span class="sourceLineNo">080</span><a name="line.80"></a> +<span class="sourceLineNo">081</span> mee.setValue(2);<a name="line.81"></a> +<span class="sourceLineNo">082</span> for (int i = 0; i < ClusterStatusPublisher.NB_SEND; i++) {<a name="line.82"></a> +<span class="sourceLineNo">083</span> Assert.assertEquals("i=" + i, 1, csp.generateDeadServersListToSend().size());<a name="line.83"></a> +<span class="sourceLineNo">084</span> }<a name="line.84"></a> +<span class="sourceLineNo">085</span> mee.setValue(1000);<a name="line.85"></a> +<span class="sourceLineNo">086</span> Assert.assertTrue(csp.generateDeadServersListToSend().isEmpty());<a name="line.86"></a> +<span class="sourceLineNo">087</span> }<a name="line.87"></a> +<span class="sourceLineNo">088</span><a name="line.88"></a> +<span class="sourceLineNo">089</span> @Test<a name="line.89"></a> +<span class="sourceLineNo">090</span> public void testOrder() {<a name="line.90"></a> +<span class="sourceLineNo">091</span> ClusterStatusPublisher csp = new ClusterStatusPublisher() {<a name="line.91"></a> +<span class="sourceLineNo">092</span> @Override<a name="line.92"></a> +<span class="sourceLineNo">093</span> protected List<Pair<ServerName, Long>> getDeadServers(long since) {<a name="line.93"></a> +<span class="sourceLineNo">094</span> List<Pair<ServerName, Long>> res = new ArrayList<>();<a name="line.94"></a> +<span class="sourceLineNo">095</span> for (int i = 0; i < 25; i++) {<a name="line.95"></a> +<span class="sourceLineNo">096</span> res.add(new Pair<>(ServerName.valueOf("hn" + i, 10, 10), 20L));<a name="line.96"></a> +<span class="sourceLineNo">097</span> }<a name="line.97"></a> +<span class="sourceLineNo">098</span><a name="line.98"></a> +<span class="sourceLineNo">099</span> return res;<a name="line.99"></a> +<span class="sourceLineNo">100</span> }<a name="line.100"></a> +<span class="sourceLineNo">101</span> };<a name="line.101"></a> <span class="sourceLineNo">102</span><a name="line.102"></a> -<span class="sourceLineNo">103</span> mee.setValue(3);<a name="line.103"></a> -<span class="sourceLineNo">104</span> List<ServerName> allSNS = csp.generateDeadServersListToSend();<a name="line.104"></a> -<span class="sourceLineNo">105</span><a name="line.105"></a> -<span class="sourceLineNo">106</span> Assert.assertEquals(10, ClusterStatusPublisher.MAX_SERVER_PER_MESSAGE);<a name="line.106"></a> -<span class="sourceLineNo">107</span> Assert.assertEquals(10, allSNS.size());<a name="line.107"></a> -<span class="sourceLineNo">108</span><a name="line.108"></a> -<span class="sourceLineNo">109</span> List<ServerName> nextMes = csp.generateDeadServersListToSend();<a name="line.109"></a> -<span class="sourceLineNo">110</span> Assert.assertEquals(10, nextMes.size());<a name="line.110"></a> -<span class="sourceLineNo">111</span> for (ServerName sn : nextMes) {<a name="line.111"></a> -<span class="sourceLineNo">112</span> if (!allSNS.contains(sn)) {<a name="line.112"></a> -<span class="sourceLineNo">113</span> allSNS.add(sn);<a name="line.113"></a> -<span class="sourceLineNo">114</span> }<a name="line.114"></a> -<span class="sourceLineNo">115</span> }<a name="line.115"></a> -<span class="sourceLineNo">116</span> Assert.assertEquals(20, allSNS.size());<a name="line.116"></a> -<span class="sourceLineNo">117</span><a name="line.117"></a> -<span class="sourceLineNo">118</span> nextMes = csp.generateDeadServersListToSend();<a name="line.118"></a> -<span class="sourceLineNo">119</span> Assert.assertEquals(10, nextMes.size());<a name="line.119"></a> -<span class="sourceLineNo">120</span> for (ServerName sn : nextMes) {<a name="line.120"></a> -<span class="sourceLineNo">121</span> if (!allSNS.contains(sn)) {<a name="line.121"></a> -<span class="sourceLineNo">122</span> allSNS.add(sn);<a name="line.122"></a> -<span class="sourceLineNo">123</span> }<a name="line.123"></a> -<span class="sourceLineNo">124</span> }<a name="line.124"></a> -<span class="sourceLineNo">125</span> Assert.assertEquals(25, allSNS.size());<a name="line.125"></a> -<span class="sourceLineNo">126</span><a name="line.126"></a> -<span class="sourceLineNo">127</span> nextMes = csp.generateDeadServersListToSend();<a name="line.127"></a> -<span class="sourceLineNo">128</span> Assert.assertEquals(10, nextMes.size());<a name="line.128"></a> -<span class="sourceLineNo">129</span> for (ServerName sn : nextMes) {<a name="line.129"></a> -<span class="sourceLineNo">130</span> if (!allSNS.contains(sn)) {<a name="line.130"></a> -<span class="sourceLineNo">131</span> allSNS.add(sn);<a name="line.131"></a> -<span class="sourceLineNo">132</span> }<a name="line.132"></a> -<span class="sourceLineNo">133</span> }<a name="line.133"></a> -<span class="sourceLineNo">134</span> Assert.assertEquals(25, allSNS.size());<a name="line.134"></a> -<span class="sourceLineNo">135</span> }<a name="line.135"></a> -<span class="sourceLineNo">136</span>}<a name="line.136"></a> +<span class="sourceLineNo">103</span><a name="line.103"></a> +<span class="sourceLineNo">104</span> mee.setValue(3);<a name="line.104"></a> +<span class="sourceLineNo">105</span> List<ServerName> allSNS = csp.generateDeadServersListToSend();<a name="line.105"></a> +<span class="sourceLineNo">106</span><a name="line.106"></a> +<span class="sourceLineNo">107</span> Assert.assertEquals(10, ClusterStatusPublisher.MAX_SERVER_PER_MESSAGE);<a name="line.107"></a> +<span class="sourceLineNo">108</span> Assert.assertEquals(10, allSNS.size());<a name="line.108"></a> +<span class="sourceLineNo">109</span><a name="line.109"></a> +<span class="sourceLineNo">110</span> List<ServerName> nextMes = csp.generateDeadServersListToSend();<a name="line.110"></a> +<span class="sourceLineNo">111</span> Assert.assertEquals(10, nextMes.size());<a name="line.111"></a> +<span class="sourceLineNo">112</span> for (ServerName sn : nextMes) {<a name="line.112"></a> +<span class="sourceLineNo">113</span> if (!allSNS.contains(sn)) {<a name="line.113"></a> +<span class="sourceLineNo">114</span> allSNS.add(sn);<a name="line.114"></a> +<span class="sourceLineNo">115</span> }<a name="line.115"></a> +<span class="sourceLineNo">116</span> }<a name="line.116"></a> +<span class="sourceLineNo">117</span> Assert.assertEquals(20, allSNS.size());<a name="line.117"></a> +<span class="sourceLineNo">118</span><a name="line.118"></a> +<span class="sourceLineNo">119</span> nextMes = csp.generateDeadServersListToSend();<a name="line.119"></a> +<span class="sourceLineNo">120</span> Assert.assertEquals(10, nextMes.size());<a name="line.120"></a> +<span class="sourceLineNo">121</span> for (ServerName sn : nextMes) {<a name="line.121"></a> +<span class="sourceLineNo">122</span> if (!allSNS.contains(sn)) {<a name="line.122"></a> +<span class="sourceLineNo">123</span> allSNS.add(sn);<a name="line.123"></a> +<span class="sourceLineNo">124</span> }<a name="line.124"></a> +<span class="sourceLineNo">125</span> }<a name="line.125"></a> +<span class="sourceLineNo">126</span> Assert.assertEquals(25, allSNS.size());<a name="line.126"></a> +<span class="sourceLineNo">127</span><a name="line.127"></a> +<span class="sourceLineNo">128</span> nextMes = csp.generateDeadServersListToSend();<a name="line.128"></a> +<span class="sourceLineNo">129</span> Assert.assertEquals(10, nextMes.size());<a name="line.129"></a> +<span class="sourceLineNo">130</span> for (ServerName sn : nextMes) {<a name="line.130"></a> +<span class="sourceLineNo">131</span> if (!allSNS.contains(sn)) {<a name="line.131"></a> +<span class="sourceLineNo">132</span> allSNS.add(sn);<a name="line.132"></a> +<span class="sourceLineNo">133</span> }<a name="line.133"></a> +<span class="sourceLineNo">134</span> }<a name="line.134"></a> +<span class="sourceLineNo">135</span> Assert.assertEquals(25, allSNS.size());<a name="line.135"></a> +<span class="sourceLineNo">136</span> }<a name="line.136"></a> +<span class="sourceLineNo">137</span>}<a name="line.137"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/testdevapidocs/src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.FaultyRsExecutor.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.FaultyRsExecutor.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.FaultyRsExecutor.html index 42507a2..8b6dda3 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.FaultyRsExecutor.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.FaultyRsExecutor.html @@ -773,96 +773,100 @@ <span class="sourceLineNo">765</span> case 0: throw new ServerNotRunningYetException("wait on server startup");<a name="line.765"></a> <span class="sourceLineNo">766</span> case 1: throw new SocketTimeoutException("simulate socket timeout");<a name="line.766"></a> <span class="sourceLineNo">767</span> case 2: throw new RemoteException("java.io.IOException", "unexpected exception");<a name="line.767"></a> -<span class="sourceLineNo">768</span> }<a name="line.768"></a> -<span class="sourceLineNo">769</span> return super.sendRequest(server, req);<a name="line.769"></a> -<span class="sourceLineNo">770</span> }<a name="line.770"></a> -<span class="sourceLineNo">771</span><a name="line.771"></a> -<span class="sourceLineNo">772</span> @Override<a name="line.772"></a> -<span class="sourceLineNo">773</span> protected RegionOpeningState execOpenRegion(final ServerName server, RegionOpenInfo openReq)<a name="line.773"></a> -<span class="sourceLineNo">774</span> throws IOException {<a name="line.774"></a> -<span class="sourceLineNo">775</span> switch (rand.nextInt(6)) {<a name="line.775"></a> -<span class="sourceLineNo">776</span> case 0:<a name="line.776"></a> -<span class="sourceLineNo">777</span> LOG.info("Return OPENED response");<a name="line.777"></a> -<span class="sourceLineNo">778</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.OPENED);<a name="line.778"></a> -<span class="sourceLineNo">779</span> return OpenRegionResponse.RegionOpeningState.OPENED;<a name="line.779"></a> -<span class="sourceLineNo">780</span> case 1:<a name="line.780"></a> -<span class="sourceLineNo">781</span> LOG.info("Return transition report that OPENED/ALREADY_OPENED response");<a name="line.781"></a> -<span class="sourceLineNo">782</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.OPENED);<a name="line.782"></a> -<span class="sourceLineNo">783</span> return OpenRegionResponse.RegionOpeningState.ALREADY_OPENED;<a name="line.783"></a> -<span class="sourceLineNo">784</span> case 2:<a name="line.784"></a> -<span class="sourceLineNo">785</span> LOG.info("Return transition report that FAILED_OPEN/FAILED_OPENING response");<a name="line.785"></a> -<span class="sourceLineNo">786</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.FAILED_OPEN);<a name="line.786"></a> -<span class="sourceLineNo">787</span> return OpenRegionResponse.RegionOpeningState.FAILED_OPENING;<a name="line.787"></a> -<span class="sourceLineNo">788</span> }<a name="line.788"></a> -<span class="sourceLineNo">789</span> // The procedure on master will just hang forever because nothing comes back<a name="line.789"></a> -<span class="sourceLineNo">790</span> // from the RS in this case.<a name="line.790"></a> -<span class="sourceLineNo">791</span> LOG.info("Return null as response; means proc stuck so we send in a crash report after a few seconds...");<a name="line.791"></a> -<span class="sourceLineNo">792</span> executor.schedule(new Runnable() {<a name="line.792"></a> -<span class="sourceLineNo">793</span> @Override<a name="line.793"></a> -<span class="sourceLineNo">794</span> public void run() {<a name="line.794"></a> -<span class="sourceLineNo">795</span> LOG.info("Delayed CRASHING of " + server);<a name="line.795"></a> -<span class="sourceLineNo">796</span> doCrash(server);<a name="line.796"></a> -<span class="sourceLineNo">797</span> }<a name="line.797"></a> -<span class="sourceLineNo">798</span> }, 5, TimeUnit.SECONDS);<a name="line.798"></a> -<span class="sourceLineNo">799</span> return null;<a name="line.799"></a> -<span class="sourceLineNo">800</span> }<a name="line.800"></a> -<span class="sourceLineNo">801</span><a name="line.801"></a> -<span class="sourceLineNo">802</span> @Override<a name="line.802"></a> -<span class="sourceLineNo">803</span> protected CloseRegionResponse execCloseRegion(ServerName server, byte[] regionName)<a name="line.803"></a> -<span class="sourceLineNo">804</span> throws IOException {<a name="line.804"></a> -<span class="sourceLineNo">805</span> CloseRegionResponse.Builder resp = CloseRegionResponse.newBuilder();<a name="line.805"></a> -<span class="sourceLineNo">806</span> boolean closed = rand.nextBoolean();<a name="line.806"></a> -<span class="sourceLineNo">807</span> if (closed) {<a name="line.807"></a> -<span class="sourceLineNo">808</span> RegionInfo hri = am.getRegionInfo(regionName);<a name="line.808"></a> -<span class="sourceLineNo">809</span> sendTransitionReport(server, ProtobufUtil.toRegionInfo(hri), TransitionCode.CLOSED);<a name="line.809"></a> -<span class="sourceLineNo">810</span> }<a name="line.810"></a> -<span class="sourceLineNo">811</span> resp.setClosed(closed);<a name="line.811"></a> -<span class="sourceLineNo">812</span> return resp.build();<a name="line.812"></a> -<span class="sourceLineNo">813</span> }<a name="line.813"></a> -<span class="sourceLineNo">814</span> }<a name="line.814"></a> -<span class="sourceLineNo">815</span><a name="line.815"></a> -<span class="sourceLineNo">816</span> private interface MockRSExecutor {<a name="line.816"></a> -<span class="sourceLineNo">817</span> ExecuteProceduresResponse sendRequest(ServerName server, ExecuteProceduresRequest req)<a name="line.817"></a> -<span class="sourceLineNo">818</span> throws IOException;<a name="line.818"></a> -<span class="sourceLineNo">819</span> }<a name="line.819"></a> -<span class="sourceLineNo">820</span><a name="line.820"></a> -<span class="sourceLineNo">821</span> private class MockRSProcedureDispatcher extends RSProcedureDispatcher {<a name="line.821"></a> -<span class="sourceLineNo">822</span> private MockRSExecutor mockRsExec;<a name="line.822"></a> -<span class="sourceLineNo">823</span><a name="line.823"></a> -<span class="sourceLineNo">824</span> public MockRSProcedureDispatcher(final MasterServices master) {<a name="line.824"></a> -<span class="sourceLineNo">825</span> super(master);<a name="line.825"></a> -<span class="sourceLineNo">826</span> }<a name="line.826"></a> +<span class="sourceLineNo">768</span> default:<a name="line.768"></a> +<span class="sourceLineNo">769</span> // fall out<a name="line.769"></a> +<span class="sourceLineNo">770</span> }<a name="line.770"></a> +<span class="sourceLineNo">771</span> return super.sendRequest(server, req);<a name="line.771"></a> +<span class="sourceLineNo">772</span> }<a name="line.772"></a> +<span class="sourceLineNo">773</span><a name="line.773"></a> +<span class="sourceLineNo">774</span> @Override<a name="line.774"></a> +<span class="sourceLineNo">775</span> protected RegionOpeningState execOpenRegion(final ServerName server, RegionOpenInfo openReq)<a name="line.775"></a> +<span class="sourceLineNo">776</span> throws IOException {<a name="line.776"></a> +<span class="sourceLineNo">777</span> switch (rand.nextInt(6)) {<a name="line.777"></a> +<span class="sourceLineNo">778</span> case 0:<a name="line.778"></a> +<span class="sourceLineNo">779</span> LOG.info("Return OPENED response");<a name="line.779"></a> +<span class="sourceLineNo">780</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.OPENED);<a name="line.780"></a> +<span class="sourceLineNo">781</span> return OpenRegionResponse.RegionOpeningState.OPENED;<a name="line.781"></a> +<span class="sourceLineNo">782</span> case 1:<a name="line.782"></a> +<span class="sourceLineNo">783</span> LOG.info("Return transition report that OPENED/ALREADY_OPENED response");<a name="line.783"></a> +<span class="sourceLineNo">784</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.OPENED);<a name="line.784"></a> +<span class="sourceLineNo">785</span> return OpenRegionResponse.RegionOpeningState.ALREADY_OPENED;<a name="line.785"></a> +<span class="sourceLineNo">786</span> case 2:<a name="line.786"></a> +<span class="sourceLineNo">787</span> LOG.info("Return transition report that FAILED_OPEN/FAILED_OPENING response");<a name="line.787"></a> +<span class="sourceLineNo">788</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.FAILED_OPEN);<a name="line.788"></a> +<span class="sourceLineNo">789</span> return OpenRegionResponse.RegionOpeningState.FAILED_OPENING;<a name="line.789"></a> +<span class="sourceLineNo">790</span> default:<a name="line.790"></a> +<span class="sourceLineNo">791</span> // fall out<a name="line.791"></a> +<span class="sourceLineNo">792</span> }<a name="line.792"></a> +<span class="sourceLineNo">793</span> // The procedure on master will just hang forever because nothing comes back<a name="line.793"></a> +<span class="sourceLineNo">794</span> // from the RS in this case.<a name="line.794"></a> +<span class="sourceLineNo">795</span> LOG.info("Return null as response; means proc stuck so we send in a crash report after a few seconds...");<a name="line.795"></a> +<span class="sourceLineNo">796</span> executor.schedule(new Runnable() {<a name="line.796"></a> +<span class="sourceLineNo">797</span> @Override<a name="line.797"></a> +<span class="sourceLineNo">798</span> public void run() {<a name="line.798"></a> +<span class="sourceLineNo">799</span> LOG.info("Delayed CRASHING of " + server);<a name="line.799"></a> +<span class="sourceLineNo">800</span> doCrash(server);<a name="line.800"></a> +<span class="sourceLineNo">801</span> }<a name="line.801"></a> +<span class="sourceLineNo">802</span> }, 5, TimeUnit.SECONDS);<a name="line.802"></a> +<span class="sourceLineNo">803</span> return null;<a name="line.803"></a> +<span class="sourceLineNo">804</span> }<a name="line.804"></a> +<span class="sourceLineNo">805</span><a name="line.805"></a> +<span class="sourceLineNo">806</span> @Override<a name="line.806"></a> +<span class="sourceLineNo">807</span> protected CloseRegionResponse execCloseRegion(ServerName server, byte[] regionName)<a name="line.807"></a> +<span class="sourceLineNo">808</span> throws IOException {<a name="line.808"></a> +<span class="sourceLineNo">809</span> CloseRegionResponse.Builder resp = CloseRegionResponse.newBuilder();<a name="line.809"></a> +<span class="sourceLineNo">810</span> boolean closed = rand.nextBoolean();<a name="line.810"></a> +<span class="sourceLineNo">811</span> if (closed) {<a name="line.811"></a> +<span class="sourceLineNo">812</span> RegionInfo hri = am.getRegionInfo(regionName);<a name="line.812"></a> +<span class="sourceLineNo">813</span> sendTransitionReport(server, ProtobufUtil.toRegionInfo(hri), TransitionCode.CLOSED);<a name="line.813"></a> +<span class="sourceLineNo">814</span> }<a name="line.814"></a> +<span class="sourceLineNo">815</span> resp.setClosed(closed);<a name="line.815"></a> +<span class="sourceLineNo">816</span> return resp.build();<a name="line.816"></a> +<span class="sourceLineNo">817</span> }<a name="line.817"></a> +<span class="sourceLineNo">818</span> }<a name="line.818"></a> +<span class="sourceLineNo">819</span><a name="line.819"></a> +<span class="sourceLineNo">820</span> private interface MockRSExecutor {<a name="line.820"></a> +<span class="sourceLineNo">821</span> ExecuteProceduresResponse sendRequest(ServerName server, ExecuteProceduresRequest req)<a name="line.821"></a> +<span class="sourceLineNo">822</span> throws IOException;<a name="line.822"></a> +<span class="sourceLineNo">823</span> }<a name="line.823"></a> +<span class="sourceLineNo">824</span><a name="line.824"></a> +<span class="sourceLineNo">825</span> private class MockRSProcedureDispatcher extends RSProcedureDispatcher {<a name="line.825"></a> +<span class="sourceLineNo">826</span> private MockRSExecutor mockRsExec;<a name="line.826"></a> <span class="sourceLineNo">827</span><a name="line.827"></a> -<span class="sourceLineNo">828</span> public void setMockRsExecutor(final MockRSExecutor mockRsExec) {<a name="line.828"></a> -<span class="sourceLineNo">829</span> this.mockRsExec = mockRsExec;<a name="line.829"></a> +<span class="sourceLineNo">828</span> public MockRSProcedureDispatcher(final MasterServices master) {<a name="line.828"></a> +<span class="sourceLineNo">829</span> super(master);<a name="line.829"></a> <span class="sourceLineNo">830</span> }<a name="line.830"></a> <span class="sourceLineNo">831</span><a name="line.831"></a> -<span class="sourceLineNo">832</span> @Override<a name="line.832"></a> -<span class="sourceLineNo">833</span> protected void remoteDispatch(ServerName serverName, Set<RemoteProcedure> remoteProcedures) {<a name="line.833"></a> -<span class="sourceLineNo">834</span> submitTask(new MockRemoteCall(serverName, remoteProcedures));<a name="line.834"></a> -<span class="sourceLineNo">835</span> }<a name="line.835"></a> -<span class="sourceLineNo">836</span><a name="line.836"></a> -<span class="sourceLineNo">837</span> private class MockRemoteCall extends ExecuteProceduresRemoteCall {<a name="line.837"></a> -<span class="sourceLineNo">838</span> public MockRemoteCall(final ServerName serverName,<a name="line.838"></a> -<span class="sourceLineNo">839</span> final Set<RemoteProcedure> operations) {<a name="line.839"></a> -<span class="sourceLineNo">840</span> super(serverName, operations);<a name="line.840"></a> -<span class="sourceLineNo">841</span> }<a name="line.841"></a> -<span class="sourceLineNo">842</span><a name="line.842"></a> -<span class="sourceLineNo">843</span> @Override<a name="line.843"></a> -<span class="sourceLineNo">844</span> protected ExecuteProceduresResponse sendRequest(final ServerName serverName,<a name="line.844"></a> -<span class="sourceLineNo">845</span> final ExecuteProceduresRequest request) throws IOException {<a name="line.845"></a> -<span class="sourceLineNo">846</span> return mockRsExec.sendRequest(serverName, request);<a name="line.846"></a> -<span class="sourceLineNo">847</span> }<a name="line.847"></a> -<span class="sourceLineNo">848</span> }<a name="line.848"></a> -<span class="sourceLineNo">849</span> }<a name="line.849"></a> -<span class="sourceLineNo">850</span><a name="line.850"></a> -<span class="sourceLineNo">851</span> private void collectAssignmentManagerMetrics() {<a name="line.851"></a> -<span class="sourceLineNo">852</span> assignSubmittedCount = assignProcMetrics.getSubmittedCounter().getCount();<a name="line.852"></a> -<span class="sourceLineNo">853</span> assignFailedCount = assignProcMetrics.getFailedCounter().getCount();<a name="line.853"></a> -<span class="sourceLineNo">854</span> unassignSubmittedCount = unassignProcMetrics.getSubmittedCounter().getCount();<a name="line.854"></a> -<span class="sourceLineNo">855</span> unassignFailedCount = unassignProcMetrics.getFailedCounter().getCount();<a name="line.855"></a> -<span class="sourceLineNo">856</span> }<a name="line.856"></a> -<span class="sourceLineNo">857</span>}<a name="line.857"></a> +<span class="sourceLineNo">832</span> public void setMockRsExecutor(final MockRSExecutor mockRsExec) {<a name="line.832"></a> +<span class="sourceLineNo">833</span> this.mockRsExec = mockRsExec;<a name="line.833"></a> +<span class="sourceLineNo">834</span> }<a name="line.834"></a> +<span class="sourceLineNo">835</span><a name="line.835"></a> +<span class="sourceLineNo">836</span> @Override<a name="line.836"></a> +<span class="sourceLineNo">837</span> protected void remoteDispatch(ServerName serverName, Set<RemoteProcedure> remoteProcedures) {<a name="line.837"></a> +<span class="sourceLineNo">838</span> submitTask(new MockRemoteCall(serverName, remoteProcedures));<a name="line.838"></a> +<span class="sourceLineNo">839</span> }<a name="line.839"></a> +<span class="sourceLineNo">840</span><a name="line.840"></a> +<span class="sourceLineNo">841</span> private class MockRemoteCall extends ExecuteProceduresRemoteCall {<a name="line.841"></a> +<span class="sourceLineNo">842</span> public MockRemoteCall(final ServerName serverName,<a name="line.842"></a> +<span class="sourceLineNo">843</span> final Set<RemoteProcedure> operations) {<a name="line.843"></a> +<span class="sourceLineNo">844</span> super(serverName, operations);<a name="line.844"></a> +<span class="sourceLineNo">845</span> }<a name="line.845"></a> +<span class="sourceLineNo">846</span><a name="line.846"></a> +<span class="sourceLineNo">847</span> @Override<a name="line.847"></a> +<span class="sourceLineNo">848</span> protected ExecuteProceduresResponse sendRequest(final ServerName serverName,<a name="line.848"></a> +<span class="sourceLineNo">849</span> final ExecuteProceduresRequest request) throws IOException {<a name="line.849"></a> +<span class="sourceLineNo">850</span> return mockRsExec.sendRequest(serverName, request);<a name="line.850"></a> +<span class="sourceLineNo">851</span> }<a name="line.851"></a> +<span class="sourceLineNo">852</span> }<a name="line.852"></a> +<span class="sourceLineNo">853</span> }<a name="line.853"></a> +<span class="sourceLineNo">854</span><a name="line.854"></a> +<span class="sourceLineNo">855</span> private void collectAssignmentManagerMetrics() {<a name="line.855"></a> +<span class="sourceLineNo">856</span> assignSubmittedCount = assignProcMetrics.getSubmittedCounter().getCount();<a name="line.856"></a> +<span class="sourceLineNo">857</span> assignFailedCount = assignProcMetrics.getFailedCounter().getCount();<a name="line.857"></a> +<span class="sourceLineNo">858</span> unassignSubmittedCount = unassignProcMetrics.getSubmittedCounter().getCount();<a name="line.858"></a> +<span class="sourceLineNo">859</span> unassignFailedCount = unassignProcMetrics.getFailedCounter().getCount();<a name="line.859"></a> +<span class="sourceLineNo">860</span> }<a name="line.860"></a> +<span class="sourceLineNo">861</span>}<a name="line.861"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/464fda73/testdevapidocs/src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.GoodRsExecutor.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.GoodRsExecutor.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.GoodRsExecutor.html index 42507a2..8b6dda3 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.GoodRsExecutor.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/master/assignment/TestAssignmentManager.GoodRsExecutor.html @@ -773,96 +773,100 @@ <span class="sourceLineNo">765</span> case 0: throw new ServerNotRunningYetException("wait on server startup");<a name="line.765"></a> <span class="sourceLineNo">766</span> case 1: throw new SocketTimeoutException("simulate socket timeout");<a name="line.766"></a> <span class="sourceLineNo">767</span> case 2: throw new RemoteException("java.io.IOException", "unexpected exception");<a name="line.767"></a> -<span class="sourceLineNo">768</span> }<a name="line.768"></a> -<span class="sourceLineNo">769</span> return super.sendRequest(server, req);<a name="line.769"></a> -<span class="sourceLineNo">770</span> }<a name="line.770"></a> -<span class="sourceLineNo">771</span><a name="line.771"></a> -<span class="sourceLineNo">772</span> @Override<a name="line.772"></a> -<span class="sourceLineNo">773</span> protected RegionOpeningState execOpenRegion(final ServerName server, RegionOpenInfo openReq)<a name="line.773"></a> -<span class="sourceLineNo">774</span> throws IOException {<a name="line.774"></a> -<span class="sourceLineNo">775</span> switch (rand.nextInt(6)) {<a name="line.775"></a> -<span class="sourceLineNo">776</span> case 0:<a name="line.776"></a> -<span class="sourceLineNo">777</span> LOG.info("Return OPENED response");<a name="line.777"></a> -<span class="sourceLineNo">778</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.OPENED);<a name="line.778"></a> -<span class="sourceLineNo">779</span> return OpenRegionResponse.RegionOpeningState.OPENED;<a name="line.779"></a> -<span class="sourceLineNo">780</span> case 1:<a name="line.780"></a> -<span class="sourceLineNo">781</span> LOG.info("Return transition report that OPENED/ALREADY_OPENED response");<a name="line.781"></a> -<span class="sourceLineNo">782</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.OPENED);<a name="line.782"></a> -<span class="sourceLineNo">783</span> return OpenRegionResponse.RegionOpeningState.ALREADY_OPENED;<a name="line.783"></a> -<span class="sourceLineNo">784</span> case 2:<a name="line.784"></a> -<span class="sourceLineNo">785</span> LOG.info("Return transition report that FAILED_OPEN/FAILED_OPENING response");<a name="line.785"></a> -<span class="sourceLineNo">786</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.FAILED_OPEN);<a name="line.786"></a> -<span class="sourceLineNo">787</span> return OpenRegionResponse.RegionOpeningState.FAILED_OPENING;<a name="line.787"></a> -<span class="sourceLineNo">788</span> }<a name="line.788"></a> -<span class="sourceLineNo">789</span> // The procedure on master will just hang forever because nothing comes back<a name="line.789"></a> -<span class="sourceLineNo">790</span> // from the RS in this case.<a name="line.790"></a> -<span class="sourceLineNo">791</span> LOG.info("Return null as response; means proc stuck so we send in a crash report after a few seconds...");<a name="line.791"></a> -<span class="sourceLineNo">792</span> executor.schedule(new Runnable() {<a name="line.792"></a> -<span class="sourceLineNo">793</span> @Override<a name="line.793"></a> -<span class="sourceLineNo">794</span> public void run() {<a name="line.794"></a> -<span class="sourceLineNo">795</span> LOG.info("Delayed CRASHING of " + server);<a name="line.795"></a> -<span class="sourceLineNo">796</span> doCrash(server);<a name="line.796"></a> -<span class="sourceLineNo">797</span> }<a name="line.797"></a> -<span class="sourceLineNo">798</span> }, 5, TimeUnit.SECONDS);<a name="line.798"></a> -<span class="sourceLineNo">799</span> return null;<a name="line.799"></a> -<span class="sourceLineNo">800</span> }<a name="line.800"></a> -<span class="sourceLineNo">801</span><a name="line.801"></a> -<span class="sourceLineNo">802</span> @Override<a name="line.802"></a> -<span class="sourceLineNo">803</span> protected CloseRegionResponse execCloseRegion(ServerName server, byte[] regionName)<a name="line.803"></a> -<span class="sourceLineNo">804</span> throws IOException {<a name="line.804"></a> -<span class="sourceLineNo">805</span> CloseRegionResponse.Builder resp = CloseRegionResponse.newBuilder();<a name="line.805"></a> -<span class="sourceLineNo">806</span> boolean closed = rand.nextBoolean();<a name="line.806"></a> -<span class="sourceLineNo">807</span> if (closed) {<a name="line.807"></a> -<span class="sourceLineNo">808</span> RegionInfo hri = am.getRegionInfo(regionName);<a name="line.808"></a> -<span class="sourceLineNo">809</span> sendTransitionReport(server, ProtobufUtil.toRegionInfo(hri), TransitionCode.CLOSED);<a name="line.809"></a> -<span class="sourceLineNo">810</span> }<a name="line.810"></a> -<span class="sourceLineNo">811</span> resp.setClosed(closed);<a name="line.811"></a> -<span class="sourceLineNo">812</span> return resp.build();<a name="line.812"></a> -<span class="sourceLineNo">813</span> }<a name="line.813"></a> -<span class="sourceLineNo">814</span> }<a name="line.814"></a> -<span class="sourceLineNo">815</span><a name="line.815"></a> -<span class="sourceLineNo">816</span> private interface MockRSExecutor {<a name="line.816"></a> -<span class="sourceLineNo">817</span> ExecuteProceduresResponse sendRequest(ServerName server, ExecuteProceduresRequest req)<a name="line.817"></a> -<span class="sourceLineNo">818</span> throws IOException;<a name="line.818"></a> -<span class="sourceLineNo">819</span> }<a name="line.819"></a> -<span class="sourceLineNo">820</span><a name="line.820"></a> -<span class="sourceLineNo">821</span> private class MockRSProcedureDispatcher extends RSProcedureDispatcher {<a name="line.821"></a> -<span class="sourceLineNo">822</span> private MockRSExecutor mockRsExec;<a name="line.822"></a> -<span class="sourceLineNo">823</span><a name="line.823"></a> -<span class="sourceLineNo">824</span> public MockRSProcedureDispatcher(final MasterServices master) {<a name="line.824"></a> -<span class="sourceLineNo">825</span> super(master);<a name="line.825"></a> -<span class="sourceLineNo">826</span> }<a name="line.826"></a> +<span class="sourceLineNo">768</span> default:<a name="line.768"></a> +<span class="sourceLineNo">769</span> // fall out<a name="line.769"></a> +<span class="sourceLineNo">770</span> }<a name="line.770"></a> +<span class="sourceLineNo">771</span> return super.sendRequest(server, req);<a name="line.771"></a> +<span class="sourceLineNo">772</span> }<a name="line.772"></a> +<span class="sourceLineNo">773</span><a name="line.773"></a> +<span class="sourceLineNo">774</span> @Override<a name="line.774"></a> +<span class="sourceLineNo">775</span> protected RegionOpeningState execOpenRegion(final ServerName server, RegionOpenInfo openReq)<a name="line.775"></a> +<span class="sourceLineNo">776</span> throws IOException {<a name="line.776"></a> +<span class="sourceLineNo">777</span> switch (rand.nextInt(6)) {<a name="line.777"></a> +<span class="sourceLineNo">778</span> case 0:<a name="line.778"></a> +<span class="sourceLineNo">779</span> LOG.info("Return OPENED response");<a name="line.779"></a> +<span class="sourceLineNo">780</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.OPENED);<a name="line.780"></a> +<span class="sourceLineNo">781</span> return OpenRegionResponse.RegionOpeningState.OPENED;<a name="line.781"></a> +<span class="sourceLineNo">782</span> case 1:<a name="line.782"></a> +<span class="sourceLineNo">783</span> LOG.info("Return transition report that OPENED/ALREADY_OPENED response");<a name="line.783"></a> +<span class="sourceLineNo">784</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.OPENED);<a name="line.784"></a> +<span class="sourceLineNo">785</span> return OpenRegionResponse.RegionOpeningState.ALREADY_OPENED;<a name="line.785"></a> +<span class="sourceLineNo">786</span> case 2:<a name="line.786"></a> +<span class="sourceLineNo">787</span> LOG.info("Return transition report that FAILED_OPEN/FAILED_OPENING response");<a name="line.787"></a> +<span class="sourceLineNo">788</span> sendTransitionReport(server, openReq.getRegion(), TransitionCode.FAILED_OPEN);<a name="line.788"></a> +<span class="sourceLineNo">789</span> return OpenRegionResponse.RegionOpeningState.FAILED_OPENING;<a name="line.789"></a> +<span class="sourceLineNo">790</span> default:<a name="line.790"></a> +<span class="sourceLineNo">791</span> // fall out<a name="line.791"></a> +<span class="sourceLineNo">792</span> }<a name="line.792"></a> +<span class="sourceLineNo">793</span> // The procedure on master will just hang forever because nothing comes back<a name="line.793"></a> +<span class="sourceLineNo">794</span> // from the RS in this case.<a name="line.794"></a> +<span class="sourceLineNo">795</span> LOG.info("Return null as response; means proc stuck so we send in a crash report after a few seconds...");<a name="line.795"></a> +<span class="sourceLineNo">796</span> executor.schedule(new Runnable() {<a name="line.796"></a> +<span class="sourceLineNo">797</span> @Override<a name="line.797"></a> +<span class="sourceLineNo">798</span> public void run() {<a name="line.798"></a> +<span class="sourceLineNo">799</span> LOG.info("Delayed CRASHING of " + server);<a name="line.799"></a> +<span class="sourceLineNo">800</span> doCrash(server);<a name="line.800"></a> +<span class="sourceLineNo">801</span> }<a name="line.801"></a> +<span class="sourceLineNo">802</span> }, 5, TimeUnit.SECONDS);<a name="line.802"></a> +<span class="sourceLineNo">803</span> return null;<a name="line.803"></a> +<span class="sourceLineNo">804</span> }<a name="line.804"></a> +<span class="sourceLineNo">805</span><a name="line.805"></a> +<span class="sourceLineNo">806</span> @Override<a name="line.806"></a> +<span class="sourceLineNo">807</span> protected CloseRegionResponse execCloseRegion(ServerName server, byte[] regionName)<a name="line.807"></a> +<span class="sourceLineNo">808</span> throws IOException {<a name="line.808"></a> +<span class="sourceLineNo">809</span> CloseRegionResponse.Builder resp = CloseRegionResponse.newBuilder();<a name="line.809"></a> +<span class="sourceLineNo">810</span> boolean closed = rand.nextBoolean();<a name="line.810"></a> +<span class="sourceLineNo">811</span> if (closed) {<a name="line.811"></a> +<span class="sourceLineNo">812</span> RegionInfo hri = am.getRegionInfo(regionName);<a name="line.812"></a> +<span class="sourceLineNo">813</span> sendTransitionReport(server, ProtobufUtil.toRegionInfo(hri), TransitionCode.CLOSED);<a name="line.813"></a> +<span class="sourceLineNo">814</span> }<a name="line.814"></a> +<span class="sourceLineNo">815</span> resp.setClosed(closed);<a name="line.815"></a> +<span class="sourceLineNo">816</span> return resp.build();<a name="line.816"></a> +<span class="sourceLineNo">817</span> }<a name="line.817"></a> +<span class="sourceLineNo">818</span> }<a name="line.818"></a> +<span class="sourceLineNo">819</span><a name="line.819"></a> +<span class="sourceLineNo">820</span> private interface MockRSExecutor {<a name="line.820"></a> +<span class="sourceLineNo">821</span> ExecuteProceduresResponse sendRequest(ServerName server, ExecuteProceduresRequest req)<a name="line.821"></a> +<span class="sourceLineNo">822</span> throws IOException;<a name="line.822"></a> +<span class="sourceLineNo">823</span> }<a name="line.823"></a> +<span class="sourceLineNo">824</span><a name="line.824"></a> +<span class="sourceLineNo">825</span> private class MockRSProcedureDispatcher extends RSProcedureDispatcher {<a name="line.825"></a> +<span class="sourceLineNo">826</span> private MockRSExecutor mockRsExec;<a name="line.826"></a> <span class="sourceLineNo">827</span><a name="line.827"></a> -<span class="sourceLineNo">828</span> public void setMockRsExecutor(final MockRSExecutor mockRsExec) {<a name="line.828"></a> -<span class="sourceLineNo">829</span> this.mockRsExec = mockRsExec;<a name="line.829"></a> +<span class="sourceLineNo">828</span> public MockRSProcedureDispatcher(final MasterServices master) {<a name="line.828"></a> +<span class="sourceLineNo">829</span> super(master);<a name="line.829"></a> <span class="sourceLineNo">830</span> }<a name="line.830"></a> <span class="sourceLineNo">831</span><a name="line.831"></a> -<span class="sourceLineNo">832</span> @Override<a name="line.832"></a> -<span class="sourceLineNo">833</span> protected void remoteDispatch(ServerName serverName, Set<RemoteProcedure> remoteProcedures) {<a name="line.833"></a> -<span class="sourceLineNo">834</span> submitTask(new MockRemoteCall(serverName, remoteProcedures));<a name="line.834"></a> -<span class="sourceLineNo">835</span> }<a name="line.835"></a> -<span class="sourceLineNo">836</span><a name="line.836"></a> -<span class="sourceLineNo">837</span> private class MockRemoteCall extends ExecuteProceduresRemoteCall {<a name="line.837"></a> -<span class="sourceLineNo">838</span> public MockRemoteCall(final ServerName serverName,<a name="line.838"></a> -<span class="sourceLineNo">839</span> final Set<RemoteProcedure> operations) {<a name="line.839"></a> -<span class="sourceLineNo">840</span> super(serverName, operations);<a name="line.840"></a> -<span class="sourceLineNo">841</span> }<a name="line.841"></a> -<span class="sourceLineNo">842</span><a name="line.842"></a> -<span class="sourceLineNo">843</span> @Override<a name="line.843"></a> -<span class="sourceLineNo">844</span> protected ExecuteProceduresResponse sendRequest(final ServerName serverName,<a name="line.844"></a> -<span class="sourceLineNo">845</span> final ExecuteProceduresRequest request) throws IOException {<a name="line.845"></a> -<span class="sourceLineNo">846</span> return mockRsExec.sendRequest(serverName, request);<a name="line.846"></a> -<span class="sourceLineNo">847</span> }<a name="line.847"></a> -<span class="sourceLineNo">848</span> }<a name="line.848"></a> -<span class="sourceLineNo">849</span> }<a name="line.849"></a> -<span class="sourceLineNo">850</span><a name="line.850"></a> -<span class="sourceLineNo">851</span> private void collectAssignmentManagerMetrics() {<a name="line.851"></a> -<span class="sourceLineNo">852</span> assignSubmittedCount = assignProcMetrics.getSubmittedCounter().getCount();<a name="line.852"></a> -<span class="sourceLineNo">853</span> assignFailedCount = assignProcMetrics.getFailedCounter().getCount();<a name="line.853"></a> -<span class="sourceLineNo">854</span> unassignSubmittedCount = unassignProcMetrics.getSubmittedCounter().getCount();<a name="line.854"></a> -<span class="sourceLineNo">855</span> unassignFailedCount = unassignProcMetrics.getFailedCounter().getCount();<a name="line.855"></a> -<span class="sourceLineNo">856</span> }<a name="line.856"></a> -<span class="sourceLineNo">857</span>}<a name="line.857"></a> +<span class="sourceLineNo">832</span> public void setMockRsExecutor(final MockRSExecutor mockRsExec) {<a name="line.832"></a> +<span class="sourceLineNo">833</span> this.mockRsExec = mockRsExec;<a name="line.833"></a> +<span class="sourceLineNo">834</span> }<a name="line.834"></a> +<span class="sourceLineNo">835</span><a name="line.835"></a> +<span class="sourceLineNo">836</span> @Override<a name="line.836"></a> +<span class="sourceLineNo">837</span> protected void remoteDispatch(ServerName serverName, Set<RemoteProcedure> remoteProcedures) {<a name="line.837"></a> +<span class="sourceLineNo">838</span> submitTask(new MockRemoteCall(serverName, remoteProcedures));<a name="line.838"></a> +<span class="sourceLineNo">839</span> }<a name="line.839"></a> +<span class="sourceLineNo">840</span><a name="line.840"></a> +<span class="sourceLineNo">841</span> private class MockRemoteCall extends ExecuteProceduresRemoteCall {<a name="line.841"></a> +<span class="sourceLineNo">842</span> public MockRemoteCall(final ServerName serverName,<a name="line.842"></a> +<span class="sourceLineNo">843</span> final Set<RemoteProcedure> operations) {<a name="line.843"></a> +<span class="sourceLineNo">844</span> super(serverName, operations);<a name="line.844"></a> +<span class="sourceLineNo">845</span> }<a name="line.845"></a> +<span class="sourceLineNo">846</span><a name="line.846"></a> +<span class="sourceLineNo">847</span> @Override<a name="line.847"></a> +<span class="sourceLineNo">848</span> protected ExecuteProceduresResponse sendRequest(final ServerName serverName,<a name="line.848"></a> +<span class="sourceLineNo">849</span> final ExecuteProceduresRequest request) throws IOException {<a name="line.849"></a> +<span class="sourceLineNo">850</span> return mockRsExec.sendRequest(serverName, request);<a name="line.850"></a> +<span class="sourceLineNo">851</span> }<a name="line.851"></a> +<span class="sourceLineNo">852</span> }<a name="line.852"></a> +<span class="sourceLineNo">853</span> }<a name="line.853"></a> +<span class="sourceLineNo">854</span><a name="line.854"></a> +<span class="sourceLineNo">855</span> private void collectAssignmentManagerMetrics() {<a name="line.855"></a> +<span class="sourceLineNo">856</span> assignSubmittedCount = assignProcMetrics.getSubmittedCounter().getCount();<a name="line.856"></a> +<span class="sourceLineNo">857</span> assignFailedCount = assignProcMetrics.getFailedCounter().getCount();<a name="line.857"></a> +<span class="sourceLineNo">858</span> unassignSubmittedCount = unassignProcMetrics.getSubmittedCounter().getCount();<a name="line.858"></a> +<span class="sourceLineNo">859</span> unassignFailedCount = unassignProcMetrics.getFailedCounter().getCount();<a name="line.859"></a> +<span class="sourceLineNo">860</span> }<a name="line.860"></a> +<span class="sourceLineNo">861</span>}<a name="line.861"></a>
