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 2017/09/24 15:13:28 UTC
[02/49] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/e6bd0774/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestQuotaGlobalsSettingsBypass.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestQuotaGlobalsSettingsBypass.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestQuotaGlobalsSettingsBypass.html
new file mode 100644
index 0000000..4532766
--- /dev/null
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestQuotaGlobalsSettingsBypass.html
@@ -0,0 +1,174 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
+<html lang="en">
+<head>
+<title>Source code</title>
+<link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style">
+</head>
+<body>
+<div class="sourceContainer">
+<pre><span class="sourceLineNo">001</span>/*<a name="line.1"></a>
+<span class="sourceLineNo">002</span> * Licensed to the Apache Software Foundation (ASF) under one or more<a name="line.2"></a>
+<span class="sourceLineNo">003</span> * contributor license agreements. See the NOTICE file distributed with<a name="line.3"></a>
+<span class="sourceLineNo">004</span> * this work for additional information regarding copyright ownership.<a name="line.4"></a>
+<span class="sourceLineNo">005</span> * The ASF licenses this file to you under the Apache License, Version 2.0<a name="line.5"></a>
+<span class="sourceLineNo">006</span> * (the "License"); you may not use this file except in compliance with<a name="line.6"></a>
+<span class="sourceLineNo">007</span> * the License. You may obtain a copy of the License at<a name="line.7"></a>
+<span class="sourceLineNo">008</span> *<a name="line.8"></a>
+<span class="sourceLineNo">009</span> * http://www.apache.org/licenses/LICENSE-2.0<a name="line.9"></a>
+<span class="sourceLineNo">010</span> *<a name="line.10"></a>
+<span class="sourceLineNo">011</span> * Unless required by applicable law or agreed to in writing, software<a name="line.11"></a>
+<span class="sourceLineNo">012</span> * distributed under the License is distributed on an "AS IS" BASIS,<a name="line.12"></a>
+<span class="sourceLineNo">013</span> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.<a name="line.13"></a>
+<span class="sourceLineNo">014</span> * See the License for the specific language governing permissions and<a name="line.14"></a>
+<span class="sourceLineNo">015</span> * limitations under the License.<a name="line.15"></a>
+<span class="sourceLineNo">016</span> */<a name="line.16"></a>
+<span class="sourceLineNo">017</span>package org.apache.hadoop.hbase.quotas;<a name="line.17"></a>
+<span class="sourceLineNo">018</span><a name="line.18"></a>
+<span class="sourceLineNo">019</span>import static org.junit.Assert.assertFalse;<a name="line.19"></a>
+<span class="sourceLineNo">020</span>import static org.junit.Assert.assertTrue;<a name="line.20"></a>
+<span class="sourceLineNo">021</span>import static org.junit.Assert.fail;<a name="line.21"></a>
+<span class="sourceLineNo">022</span><a name="line.22"></a>
+<span class="sourceLineNo">023</span>import java.io.IOException;<a name="line.23"></a>
+<span class="sourceLineNo">024</span><a name="line.24"></a>
+<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.TableName;<a name="line.25"></a>
+<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.quotas.QuotaSettingsFactory.QuotaGlobalsSettingsBypass;<a name="line.26"></a>
+<span class="sourceLineNo">027</span>import org.junit.Test;<a name="line.27"></a>
+<span class="sourceLineNo">028</span><a name="line.28"></a>
+<span class="sourceLineNo">029</span>public class TestQuotaGlobalsSettingsBypass {<a name="line.29"></a>
+<span class="sourceLineNo">030</span><a name="line.30"></a>
+<span class="sourceLineNo">031</span> @Test<a name="line.31"></a>
+<span class="sourceLineNo">032</span> public void testMerge() throws IOException {<a name="line.32"></a>
+<span class="sourceLineNo">033</span> QuotaGlobalsSettingsBypass orig = new QuotaGlobalsSettingsBypass("joe", null, null, true);<a name="line.33"></a>
+<span class="sourceLineNo">034</span> assertFalse(orig.merge(new QuotaGlobalsSettingsBypass(<a name="line.34"></a>
+<span class="sourceLineNo">035</span> "joe", null, null, false)).getBypass());<a name="line.35"></a>
+<span class="sourceLineNo">036</span> }<a name="line.36"></a>
+<span class="sourceLineNo">037</span><a name="line.37"></a>
+<span class="sourceLineNo">038</span> @Test<a name="line.38"></a>
+<span class="sourceLineNo">039</span> public void testInvalidMerges() throws IOException {<a name="line.39"></a>
+<span class="sourceLineNo">040</span> QuotaGlobalsSettingsBypass userBypass = new QuotaGlobalsSettingsBypass(<a name="line.40"></a>
+<span class="sourceLineNo">041</span> "joe", null, null, true);<a name="line.41"></a>
+<span class="sourceLineNo">042</span> QuotaGlobalsSettingsBypass tableBypass = new QuotaGlobalsSettingsBypass(<a name="line.42"></a>
+<span class="sourceLineNo">043</span> null, TableName.valueOf("table"), null, true);<a name="line.43"></a>
+<span class="sourceLineNo">044</span> QuotaGlobalsSettingsBypass namespaceBypass = new QuotaGlobalsSettingsBypass(<a name="line.44"></a>
+<span class="sourceLineNo">045</span> null, null, "ns", true);<a name="line.45"></a>
+<span class="sourceLineNo">046</span> QuotaGlobalsSettingsBypass userOnTableBypass = new QuotaGlobalsSettingsBypass(<a name="line.46"></a>
+<span class="sourceLineNo">047</span> "joe", TableName.valueOf("table"), null, true);<a name="line.47"></a>
+<span class="sourceLineNo">048</span> QuotaGlobalsSettingsBypass userOnNamespaceBypass = new QuotaGlobalsSettingsBypass(<a name="line.48"></a>
+<span class="sourceLineNo">049</span> "joe", null, "ns", true);<a name="line.49"></a>
+<span class="sourceLineNo">050</span><a name="line.50"></a>
+<span class="sourceLineNo">051</span> assertTrue(userBypass.merge(userBypass).getBypass());<a name="line.51"></a>
+<span class="sourceLineNo">052</span> expectFailure(userBypass, new QuotaGlobalsSettingsBypass("frank", null, null, false));<a name="line.52"></a>
+<span class="sourceLineNo">053</span> expectFailure(userBypass, tableBypass);<a name="line.53"></a>
+<span class="sourceLineNo">054</span> expectFailure(userBypass, namespaceBypass);<a name="line.54"></a>
+<span class="sourceLineNo">055</span> expectFailure(userBypass, userOnTableBypass);<a name="line.55"></a>
+<span class="sourceLineNo">056</span> expectFailure(userBypass, userOnNamespaceBypass);<a name="line.56"></a>
+<span class="sourceLineNo">057</span><a name="line.57"></a>
+<span class="sourceLineNo">058</span> assertTrue(tableBypass.merge(tableBypass).getBypass());<a name="line.58"></a>
+<span class="sourceLineNo">059</span> expectFailure(tableBypass, userBypass);<a name="line.59"></a>
+<span class="sourceLineNo">060</span> expectFailure(tableBypass, new QuotaGlobalsSettingsBypass(<a name="line.60"></a>
+<span class="sourceLineNo">061</span> null, TableName.valueOf("foo"), null, false));<a name="line.61"></a>
+<span class="sourceLineNo">062</span> expectFailure(tableBypass, namespaceBypass);<a name="line.62"></a>
+<span class="sourceLineNo">063</span> expectFailure(tableBypass, userOnTableBypass);<a name="line.63"></a>
+<span class="sourceLineNo">064</span> expectFailure(tableBypass, userOnNamespaceBypass);<a name="line.64"></a>
+<span class="sourceLineNo">065</span><a name="line.65"></a>
+<span class="sourceLineNo">066</span> assertTrue(namespaceBypass.merge(namespaceBypass).getBypass());<a name="line.66"></a>
+<span class="sourceLineNo">067</span> expectFailure(namespaceBypass, userBypass);<a name="line.67"></a>
+<span class="sourceLineNo">068</span> expectFailure(namespaceBypass, tableBypass);<a name="line.68"></a>
+<span class="sourceLineNo">069</span> expectFailure(namespaceBypass, new QuotaGlobalsSettingsBypass(null, null, "sn", false));<a name="line.69"></a>
+<span class="sourceLineNo">070</span> expectFailure(namespaceBypass, userOnTableBypass);<a name="line.70"></a>
+<span class="sourceLineNo">071</span> expectFailure(namespaceBypass, userOnNamespaceBypass);<a name="line.71"></a>
+<span class="sourceLineNo">072</span><a name="line.72"></a>
+<span class="sourceLineNo">073</span> assertTrue(userOnTableBypass.merge(userOnTableBypass).getBypass());<a name="line.73"></a>
+<span class="sourceLineNo">074</span> expectFailure(userOnTableBypass, userBypass);<a name="line.74"></a>
+<span class="sourceLineNo">075</span> expectFailure(userOnTableBypass, tableBypass);<a name="line.75"></a>
+<span class="sourceLineNo">076</span> expectFailure(userOnTableBypass, namespaceBypass);<a name="line.76"></a>
+<span class="sourceLineNo">077</span> // Incorrect user<a name="line.77"></a>
+<span class="sourceLineNo">078</span> expectFailure(userOnTableBypass, new QuotaGlobalsSettingsBypass(<a name="line.78"></a>
+<span class="sourceLineNo">079</span> "frank", TableName.valueOf("foo"), null, false));<a name="line.79"></a>
+<span class="sourceLineNo">080</span> // Incorrect tablename<a name="line.80"></a>
+<span class="sourceLineNo">081</span> expectFailure(userOnTableBypass, new QuotaGlobalsSettingsBypass(<a name="line.81"></a>
+<span class="sourceLineNo">082</span> "joe", TableName.valueOf("bar"), null, false));<a name="line.82"></a>
+<span class="sourceLineNo">083</span> expectFailure(userOnTableBypass, userOnNamespaceBypass);<a name="line.83"></a>
+<span class="sourceLineNo">084</span><a name="line.84"></a>
+<span class="sourceLineNo">085</span> assertTrue(userOnNamespaceBypass.merge(userOnNamespaceBypass).getBypass());<a name="line.85"></a>
+<span class="sourceLineNo">086</span> expectFailure(userOnNamespaceBypass, userBypass);<a name="line.86"></a>
+<span class="sourceLineNo">087</span> expectFailure(userOnNamespaceBypass, tableBypass);<a name="line.87"></a>
+<span class="sourceLineNo">088</span> expectFailure(userOnNamespaceBypass, namespaceBypass);<a name="line.88"></a>
+<span class="sourceLineNo">089</span> expectFailure(userOnNamespaceBypass, userOnTableBypass);<a name="line.89"></a>
+<span class="sourceLineNo">090</span> expectFailure(userOnNamespaceBypass, new QuotaGlobalsSettingsBypass(<a name="line.90"></a>
+<span class="sourceLineNo">091</span> "frank", null, "ns", false));<a name="line.91"></a>
+<span class="sourceLineNo">092</span> expectFailure(userOnNamespaceBypass, new QuotaGlobalsSettingsBypass(<a name="line.92"></a>
+<span class="sourceLineNo">093</span> "joe", null, "sn", false));<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">096</span> void expectFailure(QuotaSettings one, QuotaSettings two) throws IOException {<a name="line.96"></a>
+<span class="sourceLineNo">097</span> try {<a name="line.97"></a>
+<span class="sourceLineNo">098</span> one.merge(two);<a name="line.98"></a>
+<span class="sourceLineNo">099</span> fail("Expected to see an Exception merging " + two + " into " + one);<a name="line.99"></a>
+<span class="sourceLineNo">100</span> } catch (IllegalArgumentException e) {}<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>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+</pre>
+</div>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/e6bd0774/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestQuotaThrottle.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestQuotaThrottle.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestQuotaThrottle.html
index ef773f6..3c20d86 100644
--- a/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestQuotaThrottle.html
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestQuotaThrottle.html
@@ -522,94 +522,89 @@
<span class="sourceLineNo">514</span> }<a name="line.514"></a>
<span class="sourceLineNo">515</span> count += tables.length;<a name="line.515"></a>
<span class="sourceLineNo">516</span> }<a name="line.516"></a>
-<span class="sourceLineNo">517</span> } catch (RetriesExhaustedWithDetailsException e) {<a name="line.517"></a>
-<span class="sourceLineNo">518</span> for (Throwable t: e.getCauses()) {<a name="line.518"></a>
-<span class="sourceLineNo">519</span> if (!(t instanceof ThrottlingException)) {<a name="line.519"></a>
-<span class="sourceLineNo">520</span> throw e;<a name="line.520"></a>
-<span class="sourceLineNo">521</span> }<a name="line.521"></a>
-<span class="sourceLineNo">522</span> }<a name="line.522"></a>
-<span class="sourceLineNo">523</span> LOG.error("put failed after nRetries=" + count, e);<a name="line.523"></a>
-<span class="sourceLineNo">524</span> }<a name="line.524"></a>
-<span class="sourceLineNo">525</span> return count;<a name="line.525"></a>
-<span class="sourceLineNo">526</span> }<a name="line.526"></a>
-<span class="sourceLineNo">527</span><a name="line.527"></a>
-<span class="sourceLineNo">528</span> private long doGets(int maxOps, final Table... tables) throws Exception {<a name="line.528"></a>
-<span class="sourceLineNo">529</span> int count = 0;<a name="line.529"></a>
-<span class="sourceLineNo">530</span> try {<a name="line.530"></a>
-<span class="sourceLineNo">531</span> while (count < maxOps) {<a name="line.531"></a>
-<span class="sourceLineNo">532</span> Get get = new Get(Bytes.toBytes("row-" + count));<a name="line.532"></a>
-<span class="sourceLineNo">533</span> for (final Table table: tables) {<a name="line.533"></a>
-<span class="sourceLineNo">534</span> table.get(get);<a name="line.534"></a>
-<span class="sourceLineNo">535</span> }<a name="line.535"></a>
-<span class="sourceLineNo">536</span> count += tables.length;<a name="line.536"></a>
-<span class="sourceLineNo">537</span> }<a name="line.537"></a>
-<span class="sourceLineNo">538</span> } catch (ThrottlingException e) {<a name="line.538"></a>
-<span class="sourceLineNo">539</span> LOG.error("get failed after nRetries=" + count, e);<a name="line.539"></a>
-<span class="sourceLineNo">540</span> }<a name="line.540"></a>
-<span class="sourceLineNo">541</span> return count;<a name="line.541"></a>
-<span class="sourceLineNo">542</span> }<a name="line.542"></a>
-<span class="sourceLineNo">543</span><a name="line.543"></a>
-<span class="sourceLineNo">544</span> private void triggerUserCacheRefresh(boolean bypass, TableName... tables) throws Exception {<a name="line.544"></a>
-<span class="sourceLineNo">545</span> triggerCacheRefresh(bypass, true, false, false, tables);<a name="line.545"></a>
-<span class="sourceLineNo">546</span> }<a name="line.546"></a>
-<span class="sourceLineNo">547</span><a name="line.547"></a>
-<span class="sourceLineNo">548</span> private void triggerTableCacheRefresh(boolean bypass, TableName... tables) throws Exception {<a name="line.548"></a>
-<span class="sourceLineNo">549</span> triggerCacheRefresh(bypass, false, true, false, tables);<a name="line.549"></a>
-<span class="sourceLineNo">550</span> }<a name="line.550"></a>
-<span class="sourceLineNo">551</span><a name="line.551"></a>
-<span class="sourceLineNo">552</span> private void triggerNamespaceCacheRefresh(boolean bypass, TableName... tables) throws Exception {<a name="line.552"></a>
-<span class="sourceLineNo">553</span> triggerCacheRefresh(bypass, false, false, true, tables);<a name="line.553"></a>
-<span class="sourceLineNo">554</span> }<a name="line.554"></a>
-<span class="sourceLineNo">555</span><a name="line.555"></a>
-<span class="sourceLineNo">556</span> private void triggerCacheRefresh(boolean bypass, boolean userLimiter, boolean tableLimiter,<a name="line.556"></a>
-<span class="sourceLineNo">557</span> boolean nsLimiter, final TableName... tables) throws Exception {<a name="line.557"></a>
-<span class="sourceLineNo">558</span> envEdge.incValue(2 * REFRESH_TIME);<a name="line.558"></a>
-<span class="sourceLineNo">559</span> for (RegionServerThread rst: TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {<a name="line.559"></a>
-<span class="sourceLineNo">560</span> RegionServerRpcQuotaManager quotaManager = rst.getRegionServer().getRegionServerRpcQuotaManager();<a name="line.560"></a>
-<span class="sourceLineNo">561</span> QuotaCache quotaCache = quotaManager.getQuotaCache();<a name="line.561"></a>
-<span class="sourceLineNo">562</span><a name="line.562"></a>
-<span class="sourceLineNo">563</span> quotaCache.triggerCacheRefresh();<a name="line.563"></a>
-<span class="sourceLineNo">564</span> // sleep for cache update<a name="line.564"></a>
-<span class="sourceLineNo">565</span> Thread.sleep(250);<a name="line.565"></a>
-<span class="sourceLineNo">566</span><a name="line.566"></a>
-<span class="sourceLineNo">567</span> for (TableName table: tables) {<a name="line.567"></a>
-<span class="sourceLineNo">568</span> quotaCache.getTableLimiter(table);<a name="line.568"></a>
-<span class="sourceLineNo">569</span> }<a name="line.569"></a>
-<span class="sourceLineNo">570</span><a name="line.570"></a>
-<span class="sourceLineNo">571</span> boolean isUpdated = false;<a name="line.571"></a>
-<span class="sourceLineNo">572</span> while (!isUpdated) {<a name="line.572"></a>
-<span class="sourceLineNo">573</span> quotaCache.triggerCacheRefresh();<a name="line.573"></a>
-<span class="sourceLineNo">574</span> isUpdated = true;<a name="line.574"></a>
-<span class="sourceLineNo">575</span> for (TableName table: tables) {<a name="line.575"></a>
-<span class="sourceLineNo">576</span> boolean isBypass = true;<a name="line.576"></a>
-<span class="sourceLineNo">577</span> if (userLimiter) {<a name="line.577"></a>
-<span class="sourceLineNo">578</span> isBypass &= quotaCache.getUserLimiter(User.getCurrent().getUGI(), table).isBypass();<a name="line.578"></a>
-<span class="sourceLineNo">579</span> }<a name="line.579"></a>
-<span class="sourceLineNo">580</span> if (tableLimiter) {<a name="line.580"></a>
-<span class="sourceLineNo">581</span> isBypass &= quotaCache.getTableLimiter(table).isBypass();<a name="line.581"></a>
-<span class="sourceLineNo">582</span> }<a name="line.582"></a>
-<span class="sourceLineNo">583</span> if (nsLimiter) {<a name="line.583"></a>
-<span class="sourceLineNo">584</span> isBypass &= quotaCache.getNamespaceLimiter(table.getNamespaceAsString()).isBypass();<a name="line.584"></a>
+<span class="sourceLineNo">517</span> } catch (ThrottlingException e) {<a name="line.517"></a>
+<span class="sourceLineNo">518</span> LOG.error("put failed after nRetries=" + count, e);<a name="line.518"></a>
+<span class="sourceLineNo">519</span> }<a name="line.519"></a>
+<span class="sourceLineNo">520</span> return count;<a name="line.520"></a>
+<span class="sourceLineNo">521</span> }<a name="line.521"></a>
+<span class="sourceLineNo">522</span><a name="line.522"></a>
+<span class="sourceLineNo">523</span> private long doGets(int maxOps, final Table... tables) throws Exception {<a name="line.523"></a>
+<span class="sourceLineNo">524</span> int count = 0;<a name="line.524"></a>
+<span class="sourceLineNo">525</span> try {<a name="line.525"></a>
+<span class="sourceLineNo">526</span> while (count < maxOps) {<a name="line.526"></a>
+<span class="sourceLineNo">527</span> Get get = new Get(Bytes.toBytes("row-" + count));<a name="line.527"></a>
+<span class="sourceLineNo">528</span> for (final Table table: tables) {<a name="line.528"></a>
+<span class="sourceLineNo">529</span> table.get(get);<a name="line.529"></a>
+<span class="sourceLineNo">530</span> }<a name="line.530"></a>
+<span class="sourceLineNo">531</span> count += tables.length;<a name="line.531"></a>
+<span class="sourceLineNo">532</span> }<a name="line.532"></a>
+<span class="sourceLineNo">533</span> } catch (ThrottlingException e) {<a name="line.533"></a>
+<span class="sourceLineNo">534</span> LOG.error("get failed after nRetries=" + count, e);<a name="line.534"></a>
+<span class="sourceLineNo">535</span> }<a name="line.535"></a>
+<span class="sourceLineNo">536</span> return count;<a name="line.536"></a>
+<span class="sourceLineNo">537</span> }<a name="line.537"></a>
+<span class="sourceLineNo">538</span><a name="line.538"></a>
+<span class="sourceLineNo">539</span> private void triggerUserCacheRefresh(boolean bypass, TableName... tables) throws Exception {<a name="line.539"></a>
+<span class="sourceLineNo">540</span> triggerCacheRefresh(bypass, true, false, false, tables);<a name="line.540"></a>
+<span class="sourceLineNo">541</span> }<a name="line.541"></a>
+<span class="sourceLineNo">542</span><a name="line.542"></a>
+<span class="sourceLineNo">543</span> private void triggerTableCacheRefresh(boolean bypass, TableName... tables) throws Exception {<a name="line.543"></a>
+<span class="sourceLineNo">544</span> triggerCacheRefresh(bypass, false, true, false, tables);<a name="line.544"></a>
+<span class="sourceLineNo">545</span> }<a name="line.545"></a>
+<span class="sourceLineNo">546</span><a name="line.546"></a>
+<span class="sourceLineNo">547</span> private void triggerNamespaceCacheRefresh(boolean bypass, TableName... tables) throws Exception {<a name="line.547"></a>
+<span class="sourceLineNo">548</span> triggerCacheRefresh(bypass, false, false, true, tables);<a name="line.548"></a>
+<span class="sourceLineNo">549</span> }<a name="line.549"></a>
+<span class="sourceLineNo">550</span><a name="line.550"></a>
+<span class="sourceLineNo">551</span> private void triggerCacheRefresh(boolean bypass, boolean userLimiter, boolean tableLimiter,<a name="line.551"></a>
+<span class="sourceLineNo">552</span> boolean nsLimiter, final TableName... tables) throws Exception {<a name="line.552"></a>
+<span class="sourceLineNo">553</span> envEdge.incValue(2 * REFRESH_TIME);<a name="line.553"></a>
+<span class="sourceLineNo">554</span> for (RegionServerThread rst: TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {<a name="line.554"></a>
+<span class="sourceLineNo">555</span> RegionServerRpcQuotaManager quotaManager = rst.getRegionServer().getRegionServerRpcQuotaManager();<a name="line.555"></a>
+<span class="sourceLineNo">556</span> QuotaCache quotaCache = quotaManager.getQuotaCache();<a name="line.556"></a>
+<span class="sourceLineNo">557</span><a name="line.557"></a>
+<span class="sourceLineNo">558</span> quotaCache.triggerCacheRefresh();<a name="line.558"></a>
+<span class="sourceLineNo">559</span> // sleep for cache update<a name="line.559"></a>
+<span class="sourceLineNo">560</span> Thread.sleep(250);<a name="line.560"></a>
+<span class="sourceLineNo">561</span><a name="line.561"></a>
+<span class="sourceLineNo">562</span> for (TableName table: tables) {<a name="line.562"></a>
+<span class="sourceLineNo">563</span> quotaCache.getTableLimiter(table);<a name="line.563"></a>
+<span class="sourceLineNo">564</span> }<a name="line.564"></a>
+<span class="sourceLineNo">565</span><a name="line.565"></a>
+<span class="sourceLineNo">566</span> boolean isUpdated = false;<a name="line.566"></a>
+<span class="sourceLineNo">567</span> while (!isUpdated) {<a name="line.567"></a>
+<span class="sourceLineNo">568</span> quotaCache.triggerCacheRefresh();<a name="line.568"></a>
+<span class="sourceLineNo">569</span> isUpdated = true;<a name="line.569"></a>
+<span class="sourceLineNo">570</span> for (TableName table: tables) {<a name="line.570"></a>
+<span class="sourceLineNo">571</span> boolean isBypass = true;<a name="line.571"></a>
+<span class="sourceLineNo">572</span> if (userLimiter) {<a name="line.572"></a>
+<span class="sourceLineNo">573</span> isBypass &= quotaCache.getUserLimiter(User.getCurrent().getUGI(), table).isBypass();<a name="line.573"></a>
+<span class="sourceLineNo">574</span> }<a name="line.574"></a>
+<span class="sourceLineNo">575</span> if (tableLimiter) {<a name="line.575"></a>
+<span class="sourceLineNo">576</span> isBypass &= quotaCache.getTableLimiter(table).isBypass();<a name="line.576"></a>
+<span class="sourceLineNo">577</span> }<a name="line.577"></a>
+<span class="sourceLineNo">578</span> if (nsLimiter) {<a name="line.578"></a>
+<span class="sourceLineNo">579</span> isBypass &= quotaCache.getNamespaceLimiter(table.getNamespaceAsString()).isBypass();<a name="line.579"></a>
+<span class="sourceLineNo">580</span> }<a name="line.580"></a>
+<span class="sourceLineNo">581</span> if (isBypass != bypass) {<a name="line.581"></a>
+<span class="sourceLineNo">582</span> envEdge.incValue(100);<a name="line.582"></a>
+<span class="sourceLineNo">583</span> isUpdated = false;<a name="line.583"></a>
+<span class="sourceLineNo">584</span> break;<a name="line.584"></a>
<span class="sourceLineNo">585</span> }<a name="line.585"></a>
-<span class="sourceLineNo">586</span> if (isBypass != bypass) {<a name="line.586"></a>
-<span class="sourceLineNo">587</span> envEdge.incValue(100);<a name="line.587"></a>
-<span class="sourceLineNo">588</span> isUpdated = false;<a name="line.588"></a>
-<span class="sourceLineNo">589</span> break;<a name="line.589"></a>
-<span class="sourceLineNo">590</span> }<a name="line.590"></a>
-<span class="sourceLineNo">591</span> }<a name="line.591"></a>
-<span class="sourceLineNo">592</span> }<a name="line.592"></a>
-<span class="sourceLineNo">593</span><a name="line.593"></a>
-<span class="sourceLineNo">594</span> LOG.debug("QuotaCache");<a name="line.594"></a>
-<span class="sourceLineNo">595</span> LOG.debug(quotaCache.getNamespaceQuotaCache());<a name="line.595"></a>
-<span class="sourceLineNo">596</span> LOG.debug(quotaCache.getTableQuotaCache());<a name="line.596"></a>
-<span class="sourceLineNo">597</span> LOG.debug(quotaCache.getUserQuotaCache());<a name="line.597"></a>
-<span class="sourceLineNo">598</span> }<a name="line.598"></a>
-<span class="sourceLineNo">599</span> }<a name="line.599"></a>
-<span class="sourceLineNo">600</span><a name="line.600"></a>
-<span class="sourceLineNo">601</span> private void waitMinuteQuota() {<a name="line.601"></a>
-<span class="sourceLineNo">602</span> envEdge.incValue(70000);<a name="line.602"></a>
-<span class="sourceLineNo">603</span> }<a name="line.603"></a>
-<span class="sourceLineNo">604</span>}<a name="line.604"></a>
+<span class="sourceLineNo">586</span> }<a name="line.586"></a>
+<span class="sourceLineNo">587</span> }<a name="line.587"></a>
+<span class="sourceLineNo">588</span><a name="line.588"></a>
+<span class="sourceLineNo">589</span> LOG.debug("QuotaCache");<a name="line.589"></a>
+<span class="sourceLineNo">590</span> LOG.debug(quotaCache.getNamespaceQuotaCache());<a name="line.590"></a>
+<span class="sourceLineNo">591</span> LOG.debug(quotaCache.getTableQuotaCache());<a name="line.591"></a>
+<span class="sourceLineNo">592</span> LOG.debug(quotaCache.getUserQuotaCache());<a name="line.592"></a>
+<span class="sourceLineNo">593</span> }<a name="line.593"></a>
+<span class="sourceLineNo">594</span> }<a name="line.594"></a>
+<span class="sourceLineNo">595</span><a name="line.595"></a>
+<span class="sourceLineNo">596</span> private void waitMinuteQuota() {<a name="line.596"></a>
+<span class="sourceLineNo">597</span> envEdge.incValue(70000);<a name="line.597"></a>
+<span class="sourceLineNo">598</span> }<a name="line.598"></a>
+<span class="sourceLineNo">599</span>}<a name="line.599"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/e6bd0774/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestSpaceLimitSettings.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestSpaceLimitSettings.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestSpaceLimitSettings.html
index 4617b73..aa919c3 100644
--- a/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestSpaceLimitSettings.html
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestSpaceLimitSettings.html
@@ -27,104 +27,129 @@
<span class="sourceLineNo">019</span>import static org.junit.Assert.assertEquals;<a name="line.19"></a>
<span class="sourceLineNo">020</span>import static org.junit.Assert.assertFalse;<a name="line.20"></a>
<span class="sourceLineNo">021</span>import static org.junit.Assert.assertNotNull;<a name="line.21"></a>
-<span class="sourceLineNo">022</span><a name="line.22"></a>
-<span class="sourceLineNo">023</span>import org.apache.hadoop.hbase.TableName;<a name="line.23"></a>
-<span class="sourceLineNo">024</span>import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil;<a name="line.24"></a>
-<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetQuotaRequest;<a name="line.25"></a>
-<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceLimitRequest;<a name="line.26"></a>
-<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuota;<a name="line.27"></a>
-<span class="sourceLineNo">028</span>import org.apache.hadoop.hbase.testclassification.SmallTests;<a name="line.28"></a>
-<span class="sourceLineNo">029</span>import org.junit.Test;<a name="line.29"></a>
-<span class="sourceLineNo">030</span>import org.junit.experimental.categories.Category;<a name="line.30"></a>
-<span class="sourceLineNo">031</span><a name="line.31"></a>
-<span class="sourceLineNo">032</span>/**<a name="line.32"></a>
-<span class="sourceLineNo">033</span> * Test class for {@link SpaceLimitSettings}.<a name="line.33"></a>
-<span class="sourceLineNo">034</span> */<a name="line.34"></a>
-<span class="sourceLineNo">035</span>@Category({SmallTests.class})<a name="line.35"></a>
-<span class="sourceLineNo">036</span>public class TestSpaceLimitSettings {<a name="line.36"></a>
-<span class="sourceLineNo">037</span><a name="line.37"></a>
-<span class="sourceLineNo">038</span> @Test(expected = IllegalArgumentException.class)<a name="line.38"></a>
-<span class="sourceLineNo">039</span> public void testInvalidTableQuotaSizeLimit() {<a name="line.39"></a>
-<span class="sourceLineNo">040</span> new SpaceLimitSettings(TableName.valueOf("foo"), -1, SpaceViolationPolicy.NO_INSERTS);<a name="line.40"></a>
-<span class="sourceLineNo">041</span> }<a name="line.41"></a>
-<span class="sourceLineNo">042</span><a name="line.42"></a>
-<span class="sourceLineNo">043</span> @Test(expected = NullPointerException.class)<a name="line.43"></a>
-<span class="sourceLineNo">044</span> public void testNullTableName() {<a name="line.44"></a>
-<span class="sourceLineNo">045</span> TableName tn = null;<a name="line.45"></a>
-<span class="sourceLineNo">046</span> new SpaceLimitSettings(tn, 1, SpaceViolationPolicy.NO_INSERTS);<a name="line.46"></a>
-<span class="sourceLineNo">047</span> }<a name="line.47"></a>
-<span class="sourceLineNo">048</span><a name="line.48"></a>
-<span class="sourceLineNo">049</span> @Test(expected = NullPointerException.class)<a name="line.49"></a>
-<span class="sourceLineNo">050</span> public void testNullTableViolationPolicy() {<a name="line.50"></a>
-<span class="sourceLineNo">051</span> new SpaceLimitSettings(TableName.valueOf("foo"), 1, null);<a name="line.51"></a>
-<span class="sourceLineNo">052</span> }<a name="line.52"></a>
-<span class="sourceLineNo">053</span><a name="line.53"></a>
-<span class="sourceLineNo">054</span> @Test(expected = IllegalArgumentException.class)<a name="line.54"></a>
-<span class="sourceLineNo">055</span> public void testInvalidNamespaceQuotaSizeLimit() {<a name="line.55"></a>
-<span class="sourceLineNo">056</span> new SpaceLimitSettings("foo_ns", -1, SpaceViolationPolicy.NO_INSERTS);<a name="line.56"></a>
-<span class="sourceLineNo">057</span> }<a name="line.57"></a>
-<span class="sourceLineNo">058</span><a name="line.58"></a>
-<span class="sourceLineNo">059</span> @Test(expected = NullPointerException.class)<a name="line.59"></a>
-<span class="sourceLineNo">060</span> public void testNullNamespace() {<a name="line.60"></a>
-<span class="sourceLineNo">061</span> String ns = null;<a name="line.61"></a>
-<span class="sourceLineNo">062</span> new SpaceLimitSettings(ns, 1, SpaceViolationPolicy.NO_INSERTS);<a name="line.62"></a>
-<span class="sourceLineNo">063</span> }<a name="line.63"></a>
-<span class="sourceLineNo">064</span><a name="line.64"></a>
-<span class="sourceLineNo">065</span> @Test(expected = NullPointerException.class)<a name="line.65"></a>
-<span class="sourceLineNo">066</span> public void testNullNamespaceViolationPolicy() {<a name="line.66"></a>
-<span class="sourceLineNo">067</span> new SpaceLimitSettings("foo_ns", 1, null);<a name="line.67"></a>
-<span class="sourceLineNo">068</span> }<a name="line.68"></a>
-<span class="sourceLineNo">069</span><a name="line.69"></a>
-<span class="sourceLineNo">070</span> @Test<a name="line.70"></a>
-<span class="sourceLineNo">071</span> public void testTableQuota() {<a name="line.71"></a>
-<span class="sourceLineNo">072</span> final TableName tableName = TableName.valueOf("foo");<a name="line.72"></a>
-<span class="sourceLineNo">073</span> final long sizeLimit = 1024 * 1024;<a name="line.73"></a>
-<span class="sourceLineNo">074</span> final SpaceViolationPolicy policy = SpaceViolationPolicy.NO_WRITES;<a name="line.74"></a>
-<span class="sourceLineNo">075</span> SpaceLimitSettings settings = new SpaceLimitSettings(tableName, sizeLimit, policy);<a name="line.75"></a>
-<span class="sourceLineNo">076</span> SetQuotaRequest proto = QuotaSettings.buildSetQuotaRequestProto(settings);<a name="line.76"></a>
-<span class="sourceLineNo">077</span><a name="line.77"></a>
-<span class="sourceLineNo">078</span> assertFalse("User should be missing", proto.hasUserName());<a name="line.78"></a>
-<span class="sourceLineNo">079</span> assertFalse("Namespace should be missing", proto.hasNamespace());<a name="line.79"></a>
-<span class="sourceLineNo">080</span> assertEquals(ProtobufUtil.toProtoTableName(tableName), proto.getTableName());<a name="line.80"></a>
-<span class="sourceLineNo">081</span> SpaceLimitRequest spaceLimitReq = proto.getSpaceLimit();<a name="line.81"></a>
-<span class="sourceLineNo">082</span> assertNotNull("SpaceLimitRequest was null", spaceLimitReq);<a name="line.82"></a>
-<span class="sourceLineNo">083</span> SpaceQuota spaceQuota = spaceLimitReq.getQuota();<a name="line.83"></a>
-<span class="sourceLineNo">084</span> assertNotNull("SpaceQuota was null", spaceQuota);<a name="line.84"></a>
-<span class="sourceLineNo">085</span> assertEquals(sizeLimit, spaceQuota.getSoftLimit());<a name="line.85"></a>
-<span class="sourceLineNo">086</span> assertEquals(ProtobufUtil.toProtoViolationPolicy(policy), spaceQuota.getViolationPolicy());<a name="line.86"></a>
-<span class="sourceLineNo">087</span><a name="line.87"></a>
-<span class="sourceLineNo">088</span> assertEquals(QuotaType.SPACE, settings.getQuotaType());<a name="line.88"></a>
-<span class="sourceLineNo">089</span><a name="line.89"></a>
-<span class="sourceLineNo">090</span> SpaceLimitSettings copy = new SpaceLimitSettings(tableName, sizeLimit, policy);<a name="line.90"></a>
-<span class="sourceLineNo">091</span> assertEquals(settings, copy);<a name="line.91"></a>
-<span class="sourceLineNo">092</span> assertEquals(settings.hashCode(), copy.hashCode());<a name="line.92"></a>
-<span class="sourceLineNo">093</span> }<a name="line.93"></a>
-<span class="sourceLineNo">094</span><a name="line.94"></a>
-<span class="sourceLineNo">095</span> @Test<a name="line.95"></a>
-<span class="sourceLineNo">096</span> public void testNamespaceQuota() {<a name="line.96"></a>
-<span class="sourceLineNo">097</span> final String namespace = "foo_ns";<a name="line.97"></a>
-<span class="sourceLineNo">098</span> final long sizeLimit = 1024 * 1024;<a name="line.98"></a>
-<span class="sourceLineNo">099</span> final SpaceViolationPolicy policy = SpaceViolationPolicy.NO_WRITES;<a name="line.99"></a>
-<span class="sourceLineNo">100</span> SpaceLimitSettings settings = new SpaceLimitSettings(namespace, sizeLimit, policy);<a name="line.100"></a>
-<span class="sourceLineNo">101</span> SetQuotaRequest proto = QuotaSettings.buildSetQuotaRequestProto(settings);<a name="line.101"></a>
-<span class="sourceLineNo">102</span><a name="line.102"></a>
-<span class="sourceLineNo">103</span> assertFalse("User should be missing", proto.hasUserName());<a name="line.103"></a>
-<span class="sourceLineNo">104</span> assertFalse("TableName should be missing", proto.hasTableName());<a name="line.104"></a>
-<span class="sourceLineNo">105</span> assertEquals(namespace, proto.getNamespace());<a name="line.105"></a>
-<span class="sourceLineNo">106</span> SpaceLimitRequest spaceLimitReq = proto.getSpaceLimit();<a name="line.106"></a>
-<span class="sourceLineNo">107</span> assertNotNull("SpaceLimitRequest was null", spaceLimitReq);<a name="line.107"></a>
-<span class="sourceLineNo">108</span> SpaceQuota spaceQuota = spaceLimitReq.getQuota();<a name="line.108"></a>
-<span class="sourceLineNo">109</span> assertNotNull("SpaceQuota was null", spaceQuota);<a name="line.109"></a>
-<span class="sourceLineNo">110</span> assertEquals(sizeLimit, spaceQuota.getSoftLimit());<a name="line.110"></a>
-<span class="sourceLineNo">111</span> assertEquals(ProtobufUtil.toProtoViolationPolicy(policy), spaceQuota.getViolationPolicy());<a name="line.111"></a>
-<span class="sourceLineNo">112</span><a name="line.112"></a>
-<span class="sourceLineNo">113</span> assertEquals(QuotaType.SPACE, settings.getQuotaType());<a name="line.113"></a>
-<span class="sourceLineNo">114</span><a name="line.114"></a>
-<span class="sourceLineNo">115</span> SpaceLimitSettings copy = new SpaceLimitSettings(namespace, sizeLimit, policy);<a name="line.115"></a>
-<span class="sourceLineNo">116</span> assertEquals(settings, copy);<a name="line.116"></a>
-<span class="sourceLineNo">117</span> assertEquals(settings.hashCode(), copy.hashCode());<a name="line.117"></a>
-<span class="sourceLineNo">118</span> }<a name="line.118"></a>
-<span class="sourceLineNo">119</span>}<a name="line.119"></a>
+<span class="sourceLineNo">022</span>import static org.junit.Assert.fail;<a name="line.22"></a>
+<span class="sourceLineNo">023</span><a name="line.23"></a>
+<span class="sourceLineNo">024</span>import java.io.IOException;<a name="line.24"></a>
+<span class="sourceLineNo">025</span><a name="line.25"></a>
+<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.TableName;<a name="line.26"></a>
+<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil;<a name="line.27"></a>
+<span class="sourceLineNo">028</span>import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetQuotaRequest;<a name="line.28"></a>
+<span class="sourceLineNo">029</span>import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceLimitRequest;<a name="line.29"></a>
+<span class="sourceLineNo">030</span>import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuota;<a name="line.30"></a>
+<span class="sourceLineNo">031</span>import org.apache.hadoop.hbase.testclassification.SmallTests;<a name="line.31"></a>
+<span class="sourceLineNo">032</span>import org.junit.Test;<a name="line.32"></a>
+<span class="sourceLineNo">033</span>import org.junit.experimental.categories.Category;<a name="line.33"></a>
+<span class="sourceLineNo">034</span><a name="line.34"></a>
+<span class="sourceLineNo">035</span>/**<a name="line.35"></a>
+<span class="sourceLineNo">036</span> * Test class for {@link SpaceLimitSettings}.<a name="line.36"></a>
+<span class="sourceLineNo">037</span> */<a name="line.37"></a>
+<span class="sourceLineNo">038</span>@Category({SmallTests.class})<a name="line.38"></a>
+<span class="sourceLineNo">039</span>public class TestSpaceLimitSettings {<a name="line.39"></a>
+<span class="sourceLineNo">040</span><a name="line.40"></a>
+<span class="sourceLineNo">041</span> @Test(expected = IllegalArgumentException.class)<a name="line.41"></a>
+<span class="sourceLineNo">042</span> public void testInvalidTableQuotaSizeLimit() {<a name="line.42"></a>
+<span class="sourceLineNo">043</span> new SpaceLimitSettings(TableName.valueOf("foo"), -1, SpaceViolationPolicy.NO_INSERTS);<a name="line.43"></a>
+<span class="sourceLineNo">044</span> }<a name="line.44"></a>
+<span class="sourceLineNo">045</span><a name="line.45"></a>
+<span class="sourceLineNo">046</span> @Test(expected = NullPointerException.class)<a name="line.46"></a>
+<span class="sourceLineNo">047</span> public void testNullTableName() {<a name="line.47"></a>
+<span class="sourceLineNo">048</span> TableName tn = null;<a name="line.48"></a>
+<span class="sourceLineNo">049</span> new SpaceLimitSettings(tn, 1, SpaceViolationPolicy.NO_INSERTS);<a name="line.49"></a>
+<span class="sourceLineNo">050</span> }<a name="line.50"></a>
+<span class="sourceLineNo">051</span><a name="line.51"></a>
+<span class="sourceLineNo">052</span> @Test(expected = NullPointerException.class)<a name="line.52"></a>
+<span class="sourceLineNo">053</span> public void testNullTableViolationPolicy() {<a name="line.53"></a>
+<span class="sourceLineNo">054</span> new SpaceLimitSettings(TableName.valueOf("foo"), 1, null);<a name="line.54"></a>
+<span class="sourceLineNo">055</span> }<a name="line.55"></a>
+<span class="sourceLineNo">056</span><a name="line.56"></a>
+<span class="sourceLineNo">057</span> @Test(expected = IllegalArgumentException.class)<a name="line.57"></a>
+<span class="sourceLineNo">058</span> public void testInvalidNamespaceQuotaSizeLimit() {<a name="line.58"></a>
+<span class="sourceLineNo">059</span> new SpaceLimitSettings("foo_ns", -1, SpaceViolationPolicy.NO_INSERTS);<a name="line.59"></a>
+<span class="sourceLineNo">060</span> }<a name="line.60"></a>
+<span class="sourceLineNo">061</span><a name="line.61"></a>
+<span class="sourceLineNo">062</span> @Test(expected = NullPointerException.class)<a name="line.62"></a>
+<span class="sourceLineNo">063</span> public void testNullNamespace() {<a name="line.63"></a>
+<span class="sourceLineNo">064</span> String ns = null;<a name="line.64"></a>
+<span class="sourceLineNo">065</span> new SpaceLimitSettings(ns, 1, SpaceViolationPolicy.NO_INSERTS);<a name="line.65"></a>
+<span class="sourceLineNo">066</span> }<a name="line.66"></a>
+<span class="sourceLineNo">067</span><a name="line.67"></a>
+<span class="sourceLineNo">068</span> @Test(expected = NullPointerException.class)<a name="line.68"></a>
+<span class="sourceLineNo">069</span> public void testNullNamespaceViolationPolicy() {<a name="line.69"></a>
+<span class="sourceLineNo">070</span> new SpaceLimitSettings("foo_ns", 1, null);<a name="line.70"></a>
+<span class="sourceLineNo">071</span> }<a name="line.71"></a>
+<span class="sourceLineNo">072</span><a name="line.72"></a>
+<span class="sourceLineNo">073</span> @Test<a name="line.73"></a>
+<span class="sourceLineNo">074</span> public void testTableQuota() {<a name="line.74"></a>
+<span class="sourceLineNo">075</span> final TableName tableName = TableName.valueOf("foo");<a name="line.75"></a>
+<span class="sourceLineNo">076</span> final long sizeLimit = 1024 * 1024;<a name="line.76"></a>
+<span class="sourceLineNo">077</span> final SpaceViolationPolicy policy = SpaceViolationPolicy.NO_WRITES;<a name="line.77"></a>
+<span class="sourceLineNo">078</span> SpaceLimitSettings settings = new SpaceLimitSettings(tableName, sizeLimit, policy);<a name="line.78"></a>
+<span class="sourceLineNo">079</span> SetQuotaRequest proto = QuotaSettings.buildSetQuotaRequestProto(settings);<a name="line.79"></a>
+<span class="sourceLineNo">080</span><a name="line.80"></a>
+<span class="sourceLineNo">081</span> assertFalse("User should be missing", proto.hasUserName());<a name="line.81"></a>
+<span class="sourceLineNo">082</span> assertFalse("Namespace should be missing", proto.hasNamespace());<a name="line.82"></a>
+<span class="sourceLineNo">083</span> assertEquals(ProtobufUtil.toProtoTableName(tableName), proto.getTableName());<a name="line.83"></a>
+<span class="sourceLineNo">084</span> SpaceLimitRequest spaceLimitReq = proto.getSpaceLimit();<a name="line.84"></a>
+<span class="sourceLineNo">085</span> assertNotNull("SpaceLimitRequest was null", spaceLimitReq);<a name="line.85"></a>
+<span class="sourceLineNo">086</span> SpaceQuota spaceQuota = spaceLimitReq.getQuota();<a name="line.86"></a>
+<span class="sourceLineNo">087</span> assertNotNull("SpaceQuota was null", spaceQuota);<a name="line.87"></a>
+<span class="sourceLineNo">088</span> assertEquals(sizeLimit, spaceQuota.getSoftLimit());<a name="line.88"></a>
+<span class="sourceLineNo">089</span> assertEquals(ProtobufUtil.toProtoViolationPolicy(policy), spaceQuota.getViolationPolicy());<a name="line.89"></a>
+<span class="sourceLineNo">090</span><a name="line.90"></a>
+<span class="sourceLineNo">091</span> assertEquals(QuotaType.SPACE, settings.getQuotaType());<a name="line.91"></a>
+<span class="sourceLineNo">092</span><a name="line.92"></a>
+<span class="sourceLineNo">093</span> SpaceLimitSettings copy = new SpaceLimitSettings(tableName, sizeLimit, policy);<a name="line.93"></a>
+<span class="sourceLineNo">094</span> assertEquals(settings, copy);<a name="line.94"></a>
+<span class="sourceLineNo">095</span> assertEquals(settings.hashCode(), copy.hashCode());<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> @Test<a name="line.98"></a>
+<span class="sourceLineNo">099</span> public void testNamespaceQuota() {<a name="line.99"></a>
+<span class="sourceLineNo">100</span> final String namespace = "foo_ns";<a name="line.100"></a>
+<span class="sourceLineNo">101</span> final long sizeLimit = 1024 * 1024;<a name="line.101"></a>
+<span class="sourceLineNo">102</span> final SpaceViolationPolicy policy = SpaceViolationPolicy.NO_WRITES;<a name="line.102"></a>
+<span class="sourceLineNo">103</span> SpaceLimitSettings settings = new SpaceLimitSettings(namespace, sizeLimit, policy);<a name="line.103"></a>
+<span class="sourceLineNo">104</span> SetQuotaRequest proto = QuotaSettings.buildSetQuotaRequestProto(settings);<a name="line.104"></a>
+<span class="sourceLineNo">105</span><a name="line.105"></a>
+<span class="sourceLineNo">106</span> assertFalse("User should be missing", proto.hasUserName());<a name="line.106"></a>
+<span class="sourceLineNo">107</span> assertFalse("TableName should be missing", proto.hasTableName());<a name="line.107"></a>
+<span class="sourceLineNo">108</span> assertEquals(namespace, proto.getNamespace());<a name="line.108"></a>
+<span class="sourceLineNo">109</span> SpaceLimitRequest spaceLimitReq = proto.getSpaceLimit();<a name="line.109"></a>
+<span class="sourceLineNo">110</span> assertNotNull("SpaceLimitRequest was null", spaceLimitReq);<a name="line.110"></a>
+<span class="sourceLineNo">111</span> SpaceQuota spaceQuota = spaceLimitReq.getQuota();<a name="line.111"></a>
+<span class="sourceLineNo">112</span> assertNotNull("SpaceQuota was null", spaceQuota);<a name="line.112"></a>
+<span class="sourceLineNo">113</span> assertEquals(sizeLimit, spaceQuota.getSoftLimit());<a name="line.113"></a>
+<span class="sourceLineNo">114</span> assertEquals(ProtobufUtil.toProtoViolationPolicy(policy), spaceQuota.getViolationPolicy());<a name="line.114"></a>
+<span class="sourceLineNo">115</span><a name="line.115"></a>
+<span class="sourceLineNo">116</span> assertEquals(QuotaType.SPACE, settings.getQuotaType());<a name="line.116"></a>
+<span class="sourceLineNo">117</span><a name="line.117"></a>
+<span class="sourceLineNo">118</span> SpaceLimitSettings copy = new SpaceLimitSettings(namespace, sizeLimit, policy);<a name="line.118"></a>
+<span class="sourceLineNo">119</span> assertEquals(settings, copy);<a name="line.119"></a>
+<span class="sourceLineNo">120</span> assertEquals(settings.hashCode(), copy.hashCode());<a name="line.120"></a>
+<span class="sourceLineNo">121</span> }<a name="line.121"></a>
+<span class="sourceLineNo">122</span><a name="line.122"></a>
+<span class="sourceLineNo">123</span> @Test<a name="line.123"></a>
+<span class="sourceLineNo">124</span> public void testQuotaMerging() throws IOException {<a name="line.124"></a>
+<span class="sourceLineNo">125</span> TableName tn = TableName.valueOf("foo");<a name="line.125"></a>
+<span class="sourceLineNo">126</span> QuotaSettings originalSettings = QuotaSettingsFactory.limitTableSpace(<a name="line.126"></a>
+<span class="sourceLineNo">127</span> tn, 1024L * 1024L, SpaceViolationPolicy.DISABLE);<a name="line.127"></a>
+<span class="sourceLineNo">128</span> QuotaSettings largerSizeLimit = QuotaSettingsFactory.limitTableSpace(<a name="line.128"></a>
+<span class="sourceLineNo">129</span> tn, 5L * 1024L * 1024L, SpaceViolationPolicy.DISABLE);<a name="line.129"></a>
+<span class="sourceLineNo">130</span> QuotaSettings differentPolicy = QuotaSettingsFactory.limitTableSpace(<a name="line.130"></a>
+<span class="sourceLineNo">131</span> tn, 1024L * 1024L, SpaceViolationPolicy.NO_WRITES);<a name="line.131"></a>
+<span class="sourceLineNo">132</span> QuotaSettings incompatibleSettings = QuotaSettingsFactory.limitNamespaceSpace(<a name="line.132"></a>
+<span class="sourceLineNo">133</span> "ns1", 5L * 1024L * 1024L, SpaceViolationPolicy.NO_WRITES);<a name="line.133"></a>
+<span class="sourceLineNo">134</span><a name="line.134"></a>
+<span class="sourceLineNo">135</span> assertEquals(originalSettings.merge(largerSizeLimit), largerSizeLimit);<a name="line.135"></a>
+<span class="sourceLineNo">136</span> assertEquals(originalSettings.merge(differentPolicy), differentPolicy);<a name="line.136"></a>
+<span class="sourceLineNo">137</span> try {<a name="line.137"></a>
+<span class="sourceLineNo">138</span> originalSettings.merge(incompatibleSettings);<a name="line.138"></a>
+<span class="sourceLineNo">139</span> fail("Should not be able to merge a Table space quota with a namespace space quota.");<a name="line.139"></a>
+<span class="sourceLineNo">140</span> } catch (IllegalArgumentException e) {<a name="line.140"></a>
+<span class="sourceLineNo">141</span> //pass<a name="line.141"></a>
+<span class="sourceLineNo">142</span> }<a name="line.142"></a>
+<span class="sourceLineNo">143</span> }<a name="line.143"></a>
+<span class="sourceLineNo">144</span>}<a name="line.144"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/e6bd0774/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestThrottleSettings.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestThrottleSettings.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestThrottleSettings.html
new file mode 100644
index 0000000..b384f6f
--- /dev/null
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/quotas/TestThrottleSettings.html
@@ -0,0 +1,170 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
+<html lang="en">
+<head>
+<title>Source code</title>
+<link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style">
+</head>
+<body>
+<div class="sourceContainer">
+<pre><span class="sourceLineNo">001</span>/*<a name="line.1"></a>
+<span class="sourceLineNo">002</span> * Licensed to the Apache Software Foundation (ASF) under one or more<a name="line.2"></a>
+<span class="sourceLineNo">003</span> * contributor license agreements. See the NOTICE file distributed with<a name="line.3"></a>
+<span class="sourceLineNo">004</span> * this work for additional information regarding copyright ownership.<a name="line.4"></a>
+<span class="sourceLineNo">005</span> * The ASF licenses this file to you under the Apache License, Version 2.0<a name="line.5"></a>
+<span class="sourceLineNo">006</span> * (the "License"); you may not use this file except in compliance with<a name="line.6"></a>
+<span class="sourceLineNo">007</span> * the License. You may obtain a copy of the License at<a name="line.7"></a>
+<span class="sourceLineNo">008</span> *<a name="line.8"></a>
+<span class="sourceLineNo">009</span> * http://www.apache.org/licenses/LICENSE-2.0<a name="line.9"></a>
+<span class="sourceLineNo">010</span> *<a name="line.10"></a>
+<span class="sourceLineNo">011</span> * Unless required by applicable law or agreed to in writing, software<a name="line.11"></a>
+<span class="sourceLineNo">012</span> * distributed under the License is distributed on an "AS IS" BASIS,<a name="line.12"></a>
+<span class="sourceLineNo">013</span> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.<a name="line.13"></a>
+<span class="sourceLineNo">014</span> * See the License for the specific language governing permissions and<a name="line.14"></a>
+<span class="sourceLineNo">015</span> * limitations under the License.<a name="line.15"></a>
+<span class="sourceLineNo">016</span> */<a name="line.16"></a>
+<span class="sourceLineNo">017</span>package org.apache.hadoop.hbase.quotas;<a name="line.17"></a>
+<span class="sourceLineNo">018</span><a name="line.18"></a>
+<span class="sourceLineNo">019</span>import static org.junit.Assert.assertEquals;<a name="line.19"></a>
+<span class="sourceLineNo">020</span>import static org.junit.Assert.assertTrue;<a name="line.20"></a>
+<span class="sourceLineNo">021</span>import static org.junit.Assert.fail;<a name="line.21"></a>
+<span class="sourceLineNo">022</span><a name="line.22"></a>
+<span class="sourceLineNo">023</span>import java.io.IOException;<a name="line.23"></a>
+<span class="sourceLineNo">024</span>import java.util.concurrent.TimeUnit;<a name="line.24"></a>
+<span class="sourceLineNo">025</span><a name="line.25"></a>
+<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos;<a name="line.26"></a>
+<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos;<a name="line.27"></a>
+<span class="sourceLineNo">028</span>import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.ThrottleRequest;<a name="line.28"></a>
+<span class="sourceLineNo">029</span>import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.TimedQuota;<a name="line.29"></a>
+<span class="sourceLineNo">030</span>import org.apache.hadoop.hbase.testclassification.SmallTests;<a name="line.30"></a>
+<span class="sourceLineNo">031</span>import org.junit.Test;<a name="line.31"></a>
+<span class="sourceLineNo">032</span>import org.junit.experimental.categories.Category;<a name="line.32"></a>
+<span class="sourceLineNo">033</span><a name="line.33"></a>
+<span class="sourceLineNo">034</span>@Category({SmallTests.class})<a name="line.34"></a>
+<span class="sourceLineNo">035</span>public class TestThrottleSettings {<a name="line.35"></a>
+<span class="sourceLineNo">036</span><a name="line.36"></a>
+<span class="sourceLineNo">037</span> @Test<a name="line.37"></a>
+<span class="sourceLineNo">038</span> public void testMerge() throws IOException {<a name="line.38"></a>
+<span class="sourceLineNo">039</span> TimedQuota tq1 = TimedQuota.newBuilder().setSoftLimit(10)<a name="line.39"></a>
+<span class="sourceLineNo">040</span> .setScope(QuotaProtos.QuotaScope.MACHINE)<a name="line.40"></a>
+<span class="sourceLineNo">041</span> .setTimeUnit(HBaseProtos.TimeUnit.MINUTES).build();<a name="line.41"></a>
+<span class="sourceLineNo">042</span> ThrottleRequest tr1 = ThrottleRequest.newBuilder().setTimedQuota(tq1)<a name="line.42"></a>
+<span class="sourceLineNo">043</span> .setType(QuotaProtos.ThrottleType.REQUEST_NUMBER).build();<a name="line.43"></a>
+<span class="sourceLineNo">044</span> ThrottleSettings orig = new ThrottleSettings("joe", null, null, tr1);<a name="line.44"></a>
+<span class="sourceLineNo">045</span><a name="line.45"></a>
+<span class="sourceLineNo">046</span> TimedQuota tq2 = TimedQuota.newBuilder().setSoftLimit(10)<a name="line.46"></a>
+<span class="sourceLineNo">047</span> .setScope(QuotaProtos.QuotaScope.MACHINE)<a name="line.47"></a>
+<span class="sourceLineNo">048</span> .setTimeUnit(HBaseProtos.TimeUnit.SECONDS).build();<a name="line.48"></a>
+<span class="sourceLineNo">049</span> ThrottleRequest tr2 = ThrottleRequest.newBuilder().setTimedQuota(tq2)<a name="line.49"></a>
+<span class="sourceLineNo">050</span> .setType(QuotaProtos.ThrottleType.REQUEST_NUMBER).build();<a name="line.50"></a>
+<span class="sourceLineNo">051</span><a name="line.51"></a>
+<span class="sourceLineNo">052</span> ThrottleSettings merged = orig.merge(new ThrottleSettings("joe", null, null, tr2));<a name="line.52"></a>
+<span class="sourceLineNo">053</span><a name="line.53"></a>
+<span class="sourceLineNo">054</span> assertEquals(10, merged.getSoftLimit());<a name="line.54"></a>
+<span class="sourceLineNo">055</span> assertEquals(ThrottleType.REQUEST_NUMBER, merged.getThrottleType());<a name="line.55"></a>
+<span class="sourceLineNo">056</span> assertEquals(TimeUnit.SECONDS, merged.getTimeUnit());<a name="line.56"></a>
+<span class="sourceLineNo">057</span> }<a name="line.57"></a>
+<span class="sourceLineNo">058</span><a name="line.58"></a>
+<span class="sourceLineNo">059</span> @Test<a name="line.59"></a>
+<span class="sourceLineNo">060</span> public void testIncompatibleThrottleTypes() throws IOException {<a name="line.60"></a>
+<span class="sourceLineNo">061</span> TimedQuota requestsQuota = TimedQuota.newBuilder().setSoftLimit(10)<a name="line.61"></a>
+<span class="sourceLineNo">062</span> .setScope(QuotaProtos.QuotaScope.MACHINE)<a name="line.62"></a>
+<span class="sourceLineNo">063</span> .setTimeUnit(HBaseProtos.TimeUnit.MINUTES).build();<a name="line.63"></a>
+<span class="sourceLineNo">064</span> ThrottleRequest requestsQuotaReq = ThrottleRequest.newBuilder().setTimedQuota(requestsQuota)<a name="line.64"></a>
+<span class="sourceLineNo">065</span> .setType(QuotaProtos.ThrottleType.REQUEST_NUMBER).build();<a name="line.65"></a>
+<span class="sourceLineNo">066</span> ThrottleSettings orig = new ThrottleSettings("joe", null, null, requestsQuotaReq);<a name="line.66"></a>
+<span class="sourceLineNo">067</span><a name="line.67"></a>
+<span class="sourceLineNo">068</span> TimedQuota readsQuota = TimedQuota.newBuilder().setSoftLimit(10)<a name="line.68"></a>
+<span class="sourceLineNo">069</span> .setScope(QuotaProtos.QuotaScope.MACHINE)<a name="line.69"></a>
+<span class="sourceLineNo">070</span> .setTimeUnit(HBaseProtos.TimeUnit.SECONDS).build();<a name="line.70"></a>
+<span class="sourceLineNo">071</span> ThrottleRequest readsQuotaReq = ThrottleRequest.newBuilder().setTimedQuota(readsQuota)<a name="line.71"></a>
+<span class="sourceLineNo">072</span> .setType(QuotaProtos.ThrottleType.READ_NUMBER).build();<a name="line.72"></a>
+<span class="sourceLineNo">073</span><a name="line.73"></a>
+<span class="sourceLineNo">074</span> try {<a name="line.74"></a>
+<span class="sourceLineNo">075</span> orig.merge(new ThrottleSettings("joe", null, null, readsQuotaReq));<a name="line.75"></a>
+<span class="sourceLineNo">076</span> fail("A read throttle should not be capable of being merged with a request quota");<a name="line.76"></a>
+<span class="sourceLineNo">077</span> } catch (IllegalArgumentException e) {<a name="line.77"></a>
+<span class="sourceLineNo">078</span> // Pass<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><a name="line.81"></a>
+<span class="sourceLineNo">082</span> @Test<a name="line.82"></a>
+<span class="sourceLineNo">083</span> public void testNoThrottleReturnsOriginal() throws IOException {<a name="line.83"></a>
+<span class="sourceLineNo">084</span> TimedQuota tq1 = TimedQuota.newBuilder().setSoftLimit(10)<a name="line.84"></a>
+<span class="sourceLineNo">085</span> .setScope(QuotaProtos.QuotaScope.MACHINE)<a name="line.85"></a>
+<span class="sourceLineNo">086</span> .setTimeUnit(HBaseProtos.TimeUnit.MINUTES).build();<a name="line.86"></a>
+<span class="sourceLineNo">087</span> ThrottleRequest tr1 = ThrottleRequest.newBuilder().setTimedQuota(tq1)<a name="line.87"></a>
+<span class="sourceLineNo">088</span> .setType(QuotaProtos.ThrottleType.REQUEST_NUMBER).build();<a name="line.88"></a>
+<span class="sourceLineNo">089</span> ThrottleSettings orig = new ThrottleSettings("joe", null, null, tr1);<a name="line.89"></a>
+<span class="sourceLineNo">090</span><a name="line.90"></a>
+<span class="sourceLineNo">091</span> ThrottleRequest tr2 = ThrottleRequest.newBuilder()<a name="line.91"></a>
+<span class="sourceLineNo">092</span> .setType(QuotaProtos.ThrottleType.REQUEST_NUMBER).build();<a name="line.92"></a>
+<span class="sourceLineNo">093</span><a name="line.93"></a>
+<span class="sourceLineNo">094</span> assertTrue(<a name="line.94"></a>
+<span class="sourceLineNo">095</span> "The same object should be returned by merge, but it wasn't",<a name="line.95"></a>
+<span class="sourceLineNo">096</span> orig == orig.merge(new ThrottleSettings("joe", null, null, tr2)));<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>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+</pre>
+</div>
+</body>
+</html>