| <!DOCTYPE HTML> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (17) --> |
| <title>Source code</title> |
| <meta name="viewport" content="width=device-width, initial-scale=1"> |
| <meta name="description" content="source: package: org.apache.hadoop.hbase.master, class: MasterCoprocessorHost, class: MasterEnvironment"> |
| <meta name="generator" content="javadoc/SourceToHTMLConverter"> |
| <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> |
| </head> |
| <body class="source-page"> |
| <main role="main"> |
| <div class="source-container"> |
| <pre><span class="source-line-no">001</span><span id="line-1">/*</span> |
| <span class="source-line-no">002</span><span id="line-2"> * Licensed to the Apache Software Foundation (ASF) under one</span> |
| <span class="source-line-no">003</span><span id="line-3"> * or more contributor license agreements. See the NOTICE file</span> |
| <span class="source-line-no">004</span><span id="line-4"> * distributed with this work for additional information</span> |
| <span class="source-line-no">005</span><span id="line-5"> * regarding copyright ownership. The ASF licenses this file</span> |
| <span class="source-line-no">006</span><span id="line-6"> * to you under the Apache License, Version 2.0 (the</span> |
| <span class="source-line-no">007</span><span id="line-7"> * "License"); you may not use this file except in compliance</span> |
| <span class="source-line-no">008</span><span id="line-8"> * with the License. You may obtain a copy of the License at</span> |
| <span class="source-line-no">009</span><span id="line-9"> *</span> |
| <span class="source-line-no">010</span><span id="line-10"> * http://www.apache.org/licenses/LICENSE-2.0</span> |
| <span class="source-line-no">011</span><span id="line-11"> *</span> |
| <span class="source-line-no">012</span><span id="line-12"> * Unless required by applicable law or agreed to in writing, software</span> |
| <span class="source-line-no">013</span><span id="line-13"> * distributed under the License is distributed on an "AS IS" BASIS,</span> |
| <span class="source-line-no">014</span><span id="line-14"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span> |
| <span class="source-line-no">015</span><span id="line-15"> * See the License for the specific language governing permissions and</span> |
| <span class="source-line-no">016</span><span id="line-16"> * limitations under the License.</span> |
| <span class="source-line-no">017</span><span id="line-17"> */</span> |
| <span class="source-line-no">018</span><span id="line-18">package org.apache.hadoop.hbase.master;</span> |
| <span class="source-line-no">019</span><span id="line-19"></span> |
| <span class="source-line-no">020</span><span id="line-20">import java.io.IOException;</span> |
| <span class="source-line-no">021</span><span id="line-21">import java.lang.reflect.InvocationTargetException;</span> |
| <span class="source-line-no">022</span><span id="line-22">import java.util.List;</span> |
| <span class="source-line-no">023</span><span id="line-23">import java.util.Map;</span> |
| <span class="source-line-no">024</span><span id="line-24">import java.util.Set;</span> |
| <span class="source-line-no">025</span><span id="line-25">import org.apache.hadoop.conf.Configuration;</span> |
| <span class="source-line-no">026</span><span id="line-26">import org.apache.hadoop.hbase.ClusterMetrics;</span> |
| <span class="source-line-no">027</span><span id="line-27">import org.apache.hadoop.hbase.MetaMutationAnnotation;</span> |
| <span class="source-line-no">028</span><span id="line-28">import org.apache.hadoop.hbase.NamespaceDescriptor;</span> |
| <span class="source-line-no">029</span><span id="line-29">import org.apache.hadoop.hbase.ServerName;</span> |
| <span class="source-line-no">030</span><span id="line-30">import org.apache.hadoop.hbase.TableName;</span> |
| <span class="source-line-no">031</span><span id="line-31">import org.apache.hadoop.hbase.client.BalanceRequest;</span> |
| <span class="source-line-no">032</span><span id="line-32">import org.apache.hadoop.hbase.client.BalanceResponse;</span> |
| <span class="source-line-no">033</span><span id="line-33">import org.apache.hadoop.hbase.client.Connection;</span> |
| <span class="source-line-no">034</span><span id="line-34">import org.apache.hadoop.hbase.client.MasterSwitchType;</span> |
| <span class="source-line-no">035</span><span id="line-35">import org.apache.hadoop.hbase.client.Mutation;</span> |
| <span class="source-line-no">036</span><span id="line-36">import org.apache.hadoop.hbase.client.RegionInfo;</span> |
| <span class="source-line-no">037</span><span id="line-37">import org.apache.hadoop.hbase.client.SharedConnection;</span> |
| <span class="source-line-no">038</span><span id="line-38">import org.apache.hadoop.hbase.client.SnapshotDescription;</span> |
| <span class="source-line-no">039</span><span id="line-39">import org.apache.hadoop.hbase.client.TableDescriptor;</span> |
| <span class="source-line-no">040</span><span id="line-40">import org.apache.hadoop.hbase.coprocessor.BaseEnvironment;</span> |
| <span class="source-line-no">041</span><span id="line-41">import org.apache.hadoop.hbase.coprocessor.CoprocessorHost;</span> |
| <span class="source-line-no">042</span><span id="line-42">import org.apache.hadoop.hbase.coprocessor.CoreCoprocessor;</span> |
| <span class="source-line-no">043</span><span id="line-43">import org.apache.hadoop.hbase.coprocessor.HasMasterServices;</span> |
| <span class="source-line-no">044</span><span id="line-44">import org.apache.hadoop.hbase.coprocessor.MasterCoprocessor;</span> |
| <span class="source-line-no">045</span><span id="line-45">import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment;</span> |
| <span class="source-line-no">046</span><span id="line-46">import org.apache.hadoop.hbase.coprocessor.MasterObserver;</span> |
| <span class="source-line-no">047</span><span id="line-47">import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor;</span> |
| <span class="source-line-no">048</span><span id="line-48">import org.apache.hadoop.hbase.master.locking.LockProcedure;</span> |
| <span class="source-line-no">049</span><span id="line-49">import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv;</span> |
| <span class="source-line-no">050</span><span id="line-50">import org.apache.hadoop.hbase.metrics.MetricRegistry;</span> |
| <span class="source-line-no">051</span><span id="line-51">import org.apache.hadoop.hbase.net.Address;</span> |
| <span class="source-line-no">052</span><span id="line-52">import org.apache.hadoop.hbase.procedure2.LockType;</span> |
| <span class="source-line-no">053</span><span id="line-53">import org.apache.hadoop.hbase.procedure2.LockedResource;</span> |
| <span class="source-line-no">054</span><span id="line-54">import org.apache.hadoop.hbase.procedure2.Procedure;</span> |
| <span class="source-line-no">055</span><span id="line-55">import org.apache.hadoop.hbase.procedure2.ProcedureExecutor;</span> |
| <span class="source-line-no">056</span><span id="line-56">import org.apache.hadoop.hbase.quotas.GlobalQuotaSettings;</span> |
| <span class="source-line-no">057</span><span id="line-57">import org.apache.hadoop.hbase.replication.ReplicationPeerConfig;</span> |
| <span class="source-line-no">058</span><span id="line-58">import org.apache.hadoop.hbase.replication.SyncReplicationState;</span> |
| <span class="source-line-no">059</span><span id="line-59">import org.apache.hadoop.hbase.security.User;</span> |
| <span class="source-line-no">060</span><span id="line-60">import org.apache.hadoop.hbase.security.access.Permission;</span> |
| <span class="source-line-no">061</span><span id="line-61">import org.apache.hadoop.hbase.security.access.UserPermission;</span> |
| <span class="source-line-no">062</span><span id="line-62">import org.apache.yetus.audience.InterfaceAudience;</span> |
| <span class="source-line-no">063</span><span id="line-63">import org.slf4j.Logger;</span> |
| <span class="source-line-no">064</span><span id="line-64">import org.slf4j.LoggerFactory;</span> |
| <span class="source-line-no">065</span><span id="line-65"></span> |
| <span class="source-line-no">066</span><span id="line-66">import org.apache.hbase.thirdparty.com.google.protobuf.Service;</span> |
| <span class="source-line-no">067</span><span id="line-67"></span> |
| <span class="source-line-no">068</span><span id="line-68">/**</span> |
| <span class="source-line-no">069</span><span id="line-69"> * Provides the coprocessor framework and environment for master oriented operations.</span> |
| <span class="source-line-no">070</span><span id="line-70"> * {@link HMaster} interacts with the loaded coprocessors through this class.</span> |
| <span class="source-line-no">071</span><span id="line-71"> */</span> |
| <span class="source-line-no">072</span><span id="line-72">@InterfaceAudience.Private</span> |
| <span class="source-line-no">073</span><span id="line-73">public class MasterCoprocessorHost</span> |
| <span class="source-line-no">074</span><span id="line-74"> extends CoprocessorHost<MasterCoprocessor, MasterCoprocessorEnvironment> {</span> |
| <span class="source-line-no">075</span><span id="line-75"></span> |
| <span class="source-line-no">076</span><span id="line-76"> private static final Logger LOG = LoggerFactory.getLogger(MasterCoprocessorHost.class);</span> |
| <span class="source-line-no">077</span><span id="line-77"></span> |
| <span class="source-line-no">078</span><span id="line-78"> /**</span> |
| <span class="source-line-no">079</span><span id="line-79"> * Coprocessor environment extension providing access to master related services.</span> |
| <span class="source-line-no">080</span><span id="line-80"> */</span> |
| <span class="source-line-no">081</span><span id="line-81"> private static class MasterEnvironment extends BaseEnvironment<MasterCoprocessor></span> |
| <span class="source-line-no">082</span><span id="line-82"> implements MasterCoprocessorEnvironment {</span> |
| <span class="source-line-no">083</span><span id="line-83"> private final MetricRegistry metricRegistry;</span> |
| <span class="source-line-no">084</span><span id="line-84"> private final MasterServices services;</span> |
| <span class="source-line-no">085</span><span id="line-85"></span> |
| <span class="source-line-no">086</span><span id="line-86"> public MasterEnvironment(final MasterCoprocessor impl, final int priority, final int seq,</span> |
| <span class="source-line-no">087</span><span id="line-87"> final Configuration conf, final MasterServices services) {</span> |
| <span class="source-line-no">088</span><span id="line-88"> super(impl, priority, seq, conf);</span> |
| <span class="source-line-no">089</span><span id="line-89"> this.services = services;</span> |
| <span class="source-line-no">090</span><span id="line-90"> this.metricRegistry =</span> |
| <span class="source-line-no">091</span><span id="line-91"> MetricsCoprocessor.createRegistryForMasterCoprocessor(impl.getClass().getName());</span> |
| <span class="source-line-no">092</span><span id="line-92"> }</span> |
| <span class="source-line-no">093</span><span id="line-93"></span> |
| <span class="source-line-no">094</span><span id="line-94"> @Override</span> |
| <span class="source-line-no">095</span><span id="line-95"> public ServerName getServerName() {</span> |
| <span class="source-line-no">096</span><span id="line-96"> return this.services.getServerName();</span> |
| <span class="source-line-no">097</span><span id="line-97"> }</span> |
| <span class="source-line-no">098</span><span id="line-98"></span> |
| <span class="source-line-no">099</span><span id="line-99"> @Override</span> |
| <span class="source-line-no">100</span><span id="line-100"> public Connection getConnection() {</span> |
| <span class="source-line-no">101</span><span id="line-101"> return new SharedConnection(this.services.getConnection());</span> |
| <span class="source-line-no">102</span><span id="line-102"> }</span> |
| <span class="source-line-no">103</span><span id="line-103"></span> |
| <span class="source-line-no">104</span><span id="line-104"> @Override</span> |
| <span class="source-line-no">105</span><span id="line-105"> public Connection createConnection(Configuration conf) throws IOException {</span> |
| <span class="source-line-no">106</span><span id="line-106"> return this.services.createConnection(conf);</span> |
| <span class="source-line-no">107</span><span id="line-107"> }</span> |
| <span class="source-line-no">108</span><span id="line-108"></span> |
| <span class="source-line-no">109</span><span id="line-109"> @Override</span> |
| <span class="source-line-no">110</span><span id="line-110"> public MetricRegistry getMetricRegistryForMaster() {</span> |
| <span class="source-line-no">111</span><span id="line-111"> return metricRegistry;</span> |
| <span class="source-line-no">112</span><span id="line-112"> }</span> |
| <span class="source-line-no">113</span><span id="line-113"></span> |
| <span class="source-line-no">114</span><span id="line-114"> @Override</span> |
| <span class="source-line-no">115</span><span id="line-115"> public void shutdown() {</span> |
| <span class="source-line-no">116</span><span id="line-116"> super.shutdown();</span> |
| <span class="source-line-no">117</span><span id="line-117"> MetricsCoprocessor.removeRegistry(this.metricRegistry);</span> |
| <span class="source-line-no">118</span><span id="line-118"> }</span> |
| <span class="source-line-no">119</span><span id="line-119"> }</span> |
| <span class="source-line-no">120</span><span id="line-120"></span> |
| <span class="source-line-no">121</span><span id="line-121"> /**</span> |
| <span class="source-line-no">122</span><span id="line-122"> * Special version of MasterEnvironment that exposes MasterServices for Core Coprocessors only.</span> |
| <span class="source-line-no">123</span><span id="line-123"> * Temporary hack until Core Coprocessors are integrated into Core.</span> |
| <span class="source-line-no">124</span><span id="line-124"> */</span> |
| <span class="source-line-no">125</span><span id="line-125"> private static class MasterEnvironmentForCoreCoprocessors extends MasterEnvironment</span> |
| <span class="source-line-no">126</span><span id="line-126"> implements HasMasterServices {</span> |
| <span class="source-line-no">127</span><span id="line-127"> private final MasterServices masterServices;</span> |
| <span class="source-line-no">128</span><span id="line-128"></span> |
| <span class="source-line-no">129</span><span id="line-129"> public MasterEnvironmentForCoreCoprocessors(final MasterCoprocessor impl, final int priority,</span> |
| <span class="source-line-no">130</span><span id="line-130"> final int seq, final Configuration conf, final MasterServices services) {</span> |
| <span class="source-line-no">131</span><span id="line-131"> super(impl, priority, seq, conf, services);</span> |
| <span class="source-line-no">132</span><span id="line-132"> this.masterServices = services;</span> |
| <span class="source-line-no">133</span><span id="line-133"> }</span> |
| <span class="source-line-no">134</span><span id="line-134"></span> |
| <span class="source-line-no">135</span><span id="line-135"> /**</span> |
| <span class="source-line-no">136</span><span id="line-136"> * @return An instance of MasterServices, an object NOT for general user-space Coprocessor</span> |
| <span class="source-line-no">137</span><span id="line-137"> * consumption.</span> |
| <span class="source-line-no">138</span><span id="line-138"> */</span> |
| <span class="source-line-no">139</span><span id="line-139"> @Override</span> |
| <span class="source-line-no">140</span><span id="line-140"> public MasterServices getMasterServices() {</span> |
| <span class="source-line-no">141</span><span id="line-141"> return this.masterServices;</span> |
| <span class="source-line-no">142</span><span id="line-142"> }</span> |
| <span class="source-line-no">143</span><span id="line-143"> }</span> |
| <span class="source-line-no">144</span><span id="line-144"></span> |
| <span class="source-line-no">145</span><span id="line-145"> private MasterServices masterServices;</span> |
| <span class="source-line-no">146</span><span id="line-146"></span> |
| <span class="source-line-no">147</span><span id="line-147"> public MasterCoprocessorHost(final MasterServices services, final Configuration conf) {</span> |
| <span class="source-line-no">148</span><span id="line-148"> super(services);</span> |
| <span class="source-line-no">149</span><span id="line-149"> this.conf = conf;</span> |
| <span class="source-line-no">150</span><span id="line-150"> this.masterServices = services;</span> |
| <span class="source-line-no">151</span><span id="line-151"> // Log the state of coprocessor loading here; should appear only once or</span> |
| <span class="source-line-no">152</span><span id="line-152"> // twice in the daemon log, depending on HBase version, because there is</span> |
| <span class="source-line-no">153</span><span id="line-153"> // only one MasterCoprocessorHost instance in the master process</span> |
| <span class="source-line-no">154</span><span id="line-154"> boolean coprocessorsEnabled =</span> |
| <span class="source-line-no">155</span><span id="line-155"> conf.getBoolean(COPROCESSORS_ENABLED_CONF_KEY, DEFAULT_COPROCESSORS_ENABLED);</span> |
| <span class="source-line-no">156</span><span id="line-156"> LOG.trace("System coprocessor loading is {}", (coprocessorsEnabled ? "enabled" : "disabled"));</span> |
| <span class="source-line-no">157</span><span id="line-157"> loadSystemCoprocessors(conf, MASTER_COPROCESSOR_CONF_KEY);</span> |
| <span class="source-line-no">158</span><span id="line-158"> }</span> |
| <span class="source-line-no">159</span><span id="line-159"></span> |
| <span class="source-line-no">160</span><span id="line-160"> @Override</span> |
| <span class="source-line-no">161</span><span id="line-161"> public MasterEnvironment createEnvironment(final MasterCoprocessor instance, final int priority,</span> |
| <span class="source-line-no">162</span><span id="line-162"> final int seq, final Configuration conf) {</span> |
| <span class="source-line-no">163</span><span id="line-163"> // If coprocessor exposes any services, register them.</span> |
| <span class="source-line-no">164</span><span id="line-164"> for (Service service : instance.getServices()) {</span> |
| <span class="source-line-no">165</span><span id="line-165"> masterServices.registerService(service);</span> |
| <span class="source-line-no">166</span><span id="line-166"> }</span> |
| <span class="source-line-no">167</span><span id="line-167"> // If a CoreCoprocessor, return a 'richer' environment, one laden with MasterServices.</span> |
| <span class="source-line-no">168</span><span id="line-168"> return instance.getClass().isAnnotationPresent(CoreCoprocessor.class)</span> |
| <span class="source-line-no">169</span><span id="line-169"> ? new MasterEnvironmentForCoreCoprocessors(instance, priority, seq, conf, masterServices)</span> |
| <span class="source-line-no">170</span><span id="line-170"> : new MasterEnvironment(instance, priority, seq, conf, masterServices);</span> |
| <span class="source-line-no">171</span><span id="line-171"> }</span> |
| <span class="source-line-no">172</span><span id="line-172"></span> |
| <span class="source-line-no">173</span><span id="line-173"> @Override</span> |
| <span class="source-line-no">174</span><span id="line-174"> public MasterCoprocessor checkAndGetInstance(Class<?> implClass)</span> |
| <span class="source-line-no">175</span><span id="line-175"> throws InstantiationException, IllegalAccessException {</span> |
| <span class="source-line-no">176</span><span id="line-176"> try {</span> |
| <span class="source-line-no">177</span><span id="line-177"> if (MasterCoprocessor.class.isAssignableFrom(implClass)) {</span> |
| <span class="source-line-no">178</span><span id="line-178"> return implClass.asSubclass(MasterCoprocessor.class).getDeclaredConstructor().newInstance();</span> |
| <span class="source-line-no">179</span><span id="line-179"> } else {</span> |
| <span class="source-line-no">180</span><span id="line-180"> LOG.error("{} is not of type MasterCoprocessor. Check the configuration of {}",</span> |
| <span class="source-line-no">181</span><span id="line-181"> implClass.getName(), CoprocessorHost.MASTER_COPROCESSOR_CONF_KEY);</span> |
| <span class="source-line-no">182</span><span id="line-182"> return null;</span> |
| <span class="source-line-no">183</span><span id="line-183"> }</span> |
| <span class="source-line-no">184</span><span id="line-184"> } catch (NoSuchMethodException | InvocationTargetException e) {</span> |
| <span class="source-line-no">185</span><span id="line-185"> throw (InstantiationException) new InstantiationException(implClass.getName()).initCause(e);</span> |
| <span class="source-line-no">186</span><span id="line-186"> }</span> |
| <span class="source-line-no">187</span><span id="line-187"> }</span> |
| <span class="source-line-no">188</span><span id="line-188"></span> |
| <span class="source-line-no">189</span><span id="line-189"> private ObserverGetter<MasterCoprocessor, MasterObserver> masterObserverGetter =</span> |
| <span class="source-line-no">190</span><span id="line-190"> MasterCoprocessor::getMasterObserver;</span> |
| <span class="source-line-no">191</span><span id="line-191"></span> |
| <span class="source-line-no">192</span><span id="line-192"> abstract class MasterObserverOperation extends ObserverOperationWithoutResult<MasterObserver> {</span> |
| <span class="source-line-no">193</span><span id="line-193"> public MasterObserverOperation() {</span> |
| <span class="source-line-no">194</span><span id="line-194"> super(masterObserverGetter);</span> |
| <span class="source-line-no">195</span><span id="line-195"> }</span> |
| <span class="source-line-no">196</span><span id="line-196"></span> |
| <span class="source-line-no">197</span><span id="line-197"> public MasterObserverOperation(boolean bypassable) {</span> |
| <span class="source-line-no">198</span><span id="line-198"> this(null, bypassable);</span> |
| <span class="source-line-no">199</span><span id="line-199"> }</span> |
| <span class="source-line-no">200</span><span id="line-200"></span> |
| <span class="source-line-no">201</span><span id="line-201"> public MasterObserverOperation(User user) {</span> |
| <span class="source-line-no">202</span><span id="line-202"> super(masterObserverGetter, user);</span> |
| <span class="source-line-no">203</span><span id="line-203"> }</span> |
| <span class="source-line-no">204</span><span id="line-204"></span> |
| <span class="source-line-no">205</span><span id="line-205"> public MasterObserverOperation(User user, boolean bypassable) {</span> |
| <span class="source-line-no">206</span><span id="line-206"> super(masterObserverGetter, user, bypassable);</span> |
| <span class="source-line-no">207</span><span id="line-207"> }</span> |
| <span class="source-line-no">208</span><span id="line-208"> }</span> |
| <span class="source-line-no">209</span><span id="line-209"></span> |
| <span class="source-line-no">210</span><span id="line-210"> //////////////////////////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">211</span><span id="line-211"> // MasterObserver operations</span> |
| <span class="source-line-no">212</span><span id="line-212"> //////////////////////////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">213</span><span id="line-213"></span> |
| <span class="source-line-no">214</span><span id="line-214"> public void preCreateNamespace(final NamespaceDescriptor ns) throws IOException {</span> |
| <span class="source-line-no">215</span><span id="line-215"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">216</span><span id="line-216"> @Override</span> |
| <span class="source-line-no">217</span><span id="line-217"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">218</span><span id="line-218"> observer.preCreateNamespace(this, ns);</span> |
| <span class="source-line-no">219</span><span id="line-219"> }</span> |
| <span class="source-line-no">220</span><span id="line-220"> });</span> |
| <span class="source-line-no">221</span><span id="line-221"> }</span> |
| <span class="source-line-no">222</span><span id="line-222"></span> |
| <span class="source-line-no">223</span><span id="line-223"> public void postCreateNamespace(final NamespaceDescriptor ns) throws IOException {</span> |
| <span class="source-line-no">224</span><span id="line-224"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">225</span><span id="line-225"> @Override</span> |
| <span class="source-line-no">226</span><span id="line-226"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">227</span><span id="line-227"> observer.postCreateNamespace(this, ns);</span> |
| <span class="source-line-no">228</span><span id="line-228"> }</span> |
| <span class="source-line-no">229</span><span id="line-229"> });</span> |
| <span class="source-line-no">230</span><span id="line-230"> }</span> |
| <span class="source-line-no">231</span><span id="line-231"></span> |
| <span class="source-line-no">232</span><span id="line-232"> public void preDeleteNamespace(final String namespaceName) throws IOException {</span> |
| <span class="source-line-no">233</span><span id="line-233"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">234</span><span id="line-234"> @Override</span> |
| <span class="source-line-no">235</span><span id="line-235"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">236</span><span id="line-236"> observer.preDeleteNamespace(this, namespaceName);</span> |
| <span class="source-line-no">237</span><span id="line-237"> }</span> |
| <span class="source-line-no">238</span><span id="line-238"> });</span> |
| <span class="source-line-no">239</span><span id="line-239"> }</span> |
| <span class="source-line-no">240</span><span id="line-240"></span> |
| <span class="source-line-no">241</span><span id="line-241"> public void postDeleteNamespace(final String namespaceName) throws IOException {</span> |
| <span class="source-line-no">242</span><span id="line-242"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">243</span><span id="line-243"> @Override</span> |
| <span class="source-line-no">244</span><span id="line-244"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">245</span><span id="line-245"> observer.postDeleteNamespace(this, namespaceName);</span> |
| <span class="source-line-no">246</span><span id="line-246"> }</span> |
| <span class="source-line-no">247</span><span id="line-247"> });</span> |
| <span class="source-line-no">248</span><span id="line-248"> }</span> |
| <span class="source-line-no">249</span><span id="line-249"></span> |
| <span class="source-line-no">250</span><span id="line-250"> public void preModifyNamespace(final NamespaceDescriptor currentNsDescriptor,</span> |
| <span class="source-line-no">251</span><span id="line-251"> final NamespaceDescriptor newNsDescriptor) throws IOException {</span> |
| <span class="source-line-no">252</span><span id="line-252"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">253</span><span id="line-253"> @Override</span> |
| <span class="source-line-no">254</span><span id="line-254"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">255</span><span id="line-255"> observer.preModifyNamespace(this, currentNsDescriptor, newNsDescriptor);</span> |
| <span class="source-line-no">256</span><span id="line-256"> }</span> |
| <span class="source-line-no">257</span><span id="line-257"> });</span> |
| <span class="source-line-no">258</span><span id="line-258"> }</span> |
| <span class="source-line-no">259</span><span id="line-259"></span> |
| <span class="source-line-no">260</span><span id="line-260"> public void postModifyNamespace(final NamespaceDescriptor oldNsDescriptor,</span> |
| <span class="source-line-no">261</span><span id="line-261"> final NamespaceDescriptor currentNsDescriptor) throws IOException {</span> |
| <span class="source-line-no">262</span><span id="line-262"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">263</span><span id="line-263"> @Override</span> |
| <span class="source-line-no">264</span><span id="line-264"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">265</span><span id="line-265"> observer.postModifyNamespace(this, oldNsDescriptor, currentNsDescriptor);</span> |
| <span class="source-line-no">266</span><span id="line-266"> }</span> |
| <span class="source-line-no">267</span><span id="line-267"> });</span> |
| <span class="source-line-no">268</span><span id="line-268"> }</span> |
| <span class="source-line-no">269</span><span id="line-269"></span> |
| <span class="source-line-no">270</span><span id="line-270"> public void preGetNamespaceDescriptor(final String namespaceName) throws IOException {</span> |
| <span class="source-line-no">271</span><span id="line-271"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">272</span><span id="line-272"> @Override</span> |
| <span class="source-line-no">273</span><span id="line-273"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">274</span><span id="line-274"> observer.preGetNamespaceDescriptor(this, namespaceName);</span> |
| <span class="source-line-no">275</span><span id="line-275"> }</span> |
| <span class="source-line-no">276</span><span id="line-276"> });</span> |
| <span class="source-line-no">277</span><span id="line-277"> }</span> |
| <span class="source-line-no">278</span><span id="line-278"></span> |
| <span class="source-line-no">279</span><span id="line-279"> public void postGetNamespaceDescriptor(final NamespaceDescriptor ns) throws IOException {</span> |
| <span class="source-line-no">280</span><span id="line-280"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">281</span><span id="line-281"> @Override</span> |
| <span class="source-line-no">282</span><span id="line-282"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">283</span><span id="line-283"> observer.postGetNamespaceDescriptor(this, ns);</span> |
| <span class="source-line-no">284</span><span id="line-284"> }</span> |
| <span class="source-line-no">285</span><span id="line-285"> });</span> |
| <span class="source-line-no">286</span><span id="line-286"> }</span> |
| <span class="source-line-no">287</span><span id="line-287"></span> |
| <span class="source-line-no">288</span><span id="line-288"> public void preListNamespaces(final List<String> namespaces) throws IOException {</span> |
| <span class="source-line-no">289</span><span id="line-289"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">290</span><span id="line-290"> @Override</span> |
| <span class="source-line-no">291</span><span id="line-291"> public void call(MasterObserver oserver) throws IOException {</span> |
| <span class="source-line-no">292</span><span id="line-292"> oserver.preListNamespaces(this, namespaces);</span> |
| <span class="source-line-no">293</span><span id="line-293"> }</span> |
| <span class="source-line-no">294</span><span id="line-294"> });</span> |
| <span class="source-line-no">295</span><span id="line-295"> }</span> |
| <span class="source-line-no">296</span><span id="line-296"></span> |
| <span class="source-line-no">297</span><span id="line-297"> public void postListNamespaces(final List<String> namespaces) throws IOException {</span> |
| <span class="source-line-no">298</span><span id="line-298"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">299</span><span id="line-299"> @Override</span> |
| <span class="source-line-no">300</span><span id="line-300"> public void call(MasterObserver oserver) throws IOException {</span> |
| <span class="source-line-no">301</span><span id="line-301"> oserver.postListNamespaces(this, namespaces);</span> |
| <span class="source-line-no">302</span><span id="line-302"> }</span> |
| <span class="source-line-no">303</span><span id="line-303"> });</span> |
| <span class="source-line-no">304</span><span id="line-304"> }</span> |
| <span class="source-line-no">305</span><span id="line-305"></span> |
| <span class="source-line-no">306</span><span id="line-306"> public void preListNamespaceDescriptors(final List<NamespaceDescriptor> descriptors)</span> |
| <span class="source-line-no">307</span><span id="line-307"> throws IOException {</span> |
| <span class="source-line-no">308</span><span id="line-308"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">309</span><span id="line-309"> @Override</span> |
| <span class="source-line-no">310</span><span id="line-310"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">311</span><span id="line-311"> observer.preListNamespaceDescriptors(this, descriptors);</span> |
| <span class="source-line-no">312</span><span id="line-312"> }</span> |
| <span class="source-line-no">313</span><span id="line-313"> });</span> |
| <span class="source-line-no">314</span><span id="line-314"> }</span> |
| <span class="source-line-no">315</span><span id="line-315"></span> |
| <span class="source-line-no">316</span><span id="line-316"> public void postListNamespaceDescriptors(final List<NamespaceDescriptor> descriptors)</span> |
| <span class="source-line-no">317</span><span id="line-317"> throws IOException {</span> |
| <span class="source-line-no">318</span><span id="line-318"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">319</span><span id="line-319"> @Override</span> |
| <span class="source-line-no">320</span><span id="line-320"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">321</span><span id="line-321"> observer.postListNamespaceDescriptors(this, descriptors);</span> |
| <span class="source-line-no">322</span><span id="line-322"> }</span> |
| <span class="source-line-no">323</span><span id="line-323"> });</span> |
| <span class="source-line-no">324</span><span id="line-324"> }</span> |
| <span class="source-line-no">325</span><span id="line-325"></span> |
| <span class="source-line-no">326</span><span id="line-326"> /* Implementation of hooks for invoking MasterObservers */</span> |
| <span class="source-line-no">327</span><span id="line-327"></span> |
| <span class="source-line-no">328</span><span id="line-328"> public TableDescriptor preCreateTableRegionsInfos(TableDescriptor desc) throws IOException {</span> |
| <span class="source-line-no">329</span><span id="line-329"> if (coprocEnvironments.isEmpty()) {</span> |
| <span class="source-line-no">330</span><span id="line-330"> return desc;</span> |
| <span class="source-line-no">331</span><span id="line-331"> }</span> |
| <span class="source-line-no">332</span><span id="line-332"> return execOperationWithResult(</span> |
| <span class="source-line-no">333</span><span id="line-333"> new ObserverOperationWithResult<MasterObserver, TableDescriptor>(masterObserverGetter, desc) {</span> |
| <span class="source-line-no">334</span><span id="line-334"></span> |
| <span class="source-line-no">335</span><span id="line-335"> @Override</span> |
| <span class="source-line-no">336</span><span id="line-336"> protected TableDescriptor call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">337</span><span id="line-337"> return observer.preCreateTableRegionsInfos(this, getResult());</span> |
| <span class="source-line-no">338</span><span id="line-338"> }</span> |
| <span class="source-line-no">339</span><span id="line-339"> });</span> |
| <span class="source-line-no">340</span><span id="line-340"> }</span> |
| <span class="source-line-no">341</span><span id="line-341"></span> |
| <span class="source-line-no">342</span><span id="line-342"> public void preCreateTable(final TableDescriptor htd, final RegionInfo[] regions)</span> |
| <span class="source-line-no">343</span><span id="line-343"> throws IOException {</span> |
| <span class="source-line-no">344</span><span id="line-344"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">345</span><span id="line-345"> @Override</span> |
| <span class="source-line-no">346</span><span id="line-346"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">347</span><span id="line-347"> observer.preCreateTable(this, htd, regions);</span> |
| <span class="source-line-no">348</span><span id="line-348"> }</span> |
| <span class="source-line-no">349</span><span id="line-349"> });</span> |
| <span class="source-line-no">350</span><span id="line-350"> }</span> |
| <span class="source-line-no">351</span><span id="line-351"></span> |
| <span class="source-line-no">352</span><span id="line-352"> public void postCreateTable(final TableDescriptor htd, final RegionInfo[] regions)</span> |
| <span class="source-line-no">353</span><span id="line-353"> throws IOException {</span> |
| <span class="source-line-no">354</span><span id="line-354"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">355</span><span id="line-355"> @Override</span> |
| <span class="source-line-no">356</span><span id="line-356"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">357</span><span id="line-357"> observer.postCreateTable(this, htd, regions);</span> |
| <span class="source-line-no">358</span><span id="line-358"> }</span> |
| <span class="source-line-no">359</span><span id="line-359"> });</span> |
| <span class="source-line-no">360</span><span id="line-360"> }</span> |
| <span class="source-line-no">361</span><span id="line-361"></span> |
| <span class="source-line-no">362</span><span id="line-362"> public void preCreateTableAction(final TableDescriptor htd, final RegionInfo[] regions,</span> |
| <span class="source-line-no">363</span><span id="line-363"> final User user) throws IOException {</span> |
| <span class="source-line-no">364</span><span id="line-364"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">365</span><span id="line-365"> @Override</span> |
| <span class="source-line-no">366</span><span id="line-366"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">367</span><span id="line-367"> observer.preCreateTableAction(this, htd, regions);</span> |
| <span class="source-line-no">368</span><span id="line-368"> }</span> |
| <span class="source-line-no">369</span><span id="line-369"> });</span> |
| <span class="source-line-no">370</span><span id="line-370"> }</span> |
| <span class="source-line-no">371</span><span id="line-371"></span> |
| <span class="source-line-no">372</span><span id="line-372"> public void postCompletedCreateTableAction(final TableDescriptor htd, final RegionInfo[] regions,</span> |
| <span class="source-line-no">373</span><span id="line-373"> final User user) throws IOException {</span> |
| <span class="source-line-no">374</span><span id="line-374"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">375</span><span id="line-375"> @Override</span> |
| <span class="source-line-no">376</span><span id="line-376"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">377</span><span id="line-377"> observer.postCompletedCreateTableAction(this, htd, regions);</span> |
| <span class="source-line-no">378</span><span id="line-378"> }</span> |
| <span class="source-line-no">379</span><span id="line-379"> });</span> |
| <span class="source-line-no">380</span><span id="line-380"> }</span> |
| <span class="source-line-no">381</span><span id="line-381"></span> |
| <span class="source-line-no">382</span><span id="line-382"> public void preDeleteTable(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">383</span><span id="line-383"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">384</span><span id="line-384"> @Override</span> |
| <span class="source-line-no">385</span><span id="line-385"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">386</span><span id="line-386"> observer.preDeleteTable(this, tableName);</span> |
| <span class="source-line-no">387</span><span id="line-387"> }</span> |
| <span class="source-line-no">388</span><span id="line-388"> });</span> |
| <span class="source-line-no">389</span><span id="line-389"> }</span> |
| <span class="source-line-no">390</span><span id="line-390"></span> |
| <span class="source-line-no">391</span><span id="line-391"> public void postDeleteTable(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">392</span><span id="line-392"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">393</span><span id="line-393"> @Override</span> |
| <span class="source-line-no">394</span><span id="line-394"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">395</span><span id="line-395"> observer.postDeleteTable(this, tableName);</span> |
| <span class="source-line-no">396</span><span id="line-396"> }</span> |
| <span class="source-line-no">397</span><span id="line-397"> });</span> |
| <span class="source-line-no">398</span><span id="line-398"> }</span> |
| <span class="source-line-no">399</span><span id="line-399"></span> |
| <span class="source-line-no">400</span><span id="line-400"> public void preDeleteTableAction(final TableName tableName, final User user) throws IOException {</span> |
| <span class="source-line-no">401</span><span id="line-401"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">402</span><span id="line-402"> @Override</span> |
| <span class="source-line-no">403</span><span id="line-403"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">404</span><span id="line-404"> observer.preDeleteTableAction(this, tableName);</span> |
| <span class="source-line-no">405</span><span id="line-405"> }</span> |
| <span class="source-line-no">406</span><span id="line-406"> });</span> |
| <span class="source-line-no">407</span><span id="line-407"> }</span> |
| <span class="source-line-no">408</span><span id="line-408"></span> |
| <span class="source-line-no">409</span><span id="line-409"> public void postCompletedDeleteTableAction(final TableName tableName, final User user)</span> |
| <span class="source-line-no">410</span><span id="line-410"> throws IOException {</span> |
| <span class="source-line-no">411</span><span id="line-411"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">412</span><span id="line-412"> @Override</span> |
| <span class="source-line-no">413</span><span id="line-413"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">414</span><span id="line-414"> observer.postCompletedDeleteTableAction(this, tableName);</span> |
| <span class="source-line-no">415</span><span id="line-415"> }</span> |
| <span class="source-line-no">416</span><span id="line-416"> });</span> |
| <span class="source-line-no">417</span><span id="line-417"> }</span> |
| <span class="source-line-no">418</span><span id="line-418"></span> |
| <span class="source-line-no">419</span><span id="line-419"> public void preTruncateTable(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">420</span><span id="line-420"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">421</span><span id="line-421"> @Override</span> |
| <span class="source-line-no">422</span><span id="line-422"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">423</span><span id="line-423"> observer.preTruncateTable(this, tableName);</span> |
| <span class="source-line-no">424</span><span id="line-424"> }</span> |
| <span class="source-line-no">425</span><span id="line-425"> });</span> |
| <span class="source-line-no">426</span><span id="line-426"> }</span> |
| <span class="source-line-no">427</span><span id="line-427"></span> |
| <span class="source-line-no">428</span><span id="line-428"> public void postTruncateTable(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">429</span><span id="line-429"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">430</span><span id="line-430"> @Override</span> |
| <span class="source-line-no">431</span><span id="line-431"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">432</span><span id="line-432"> observer.postTruncateTable(this, tableName);</span> |
| <span class="source-line-no">433</span><span id="line-433"> }</span> |
| <span class="source-line-no">434</span><span id="line-434"> });</span> |
| <span class="source-line-no">435</span><span id="line-435"> }</span> |
| <span class="source-line-no">436</span><span id="line-436"></span> |
| <span class="source-line-no">437</span><span id="line-437"> public void preTruncateTableAction(final TableName tableName, final User user)</span> |
| <span class="source-line-no">438</span><span id="line-438"> throws IOException {</span> |
| <span class="source-line-no">439</span><span id="line-439"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">440</span><span id="line-440"> @Override</span> |
| <span class="source-line-no">441</span><span id="line-441"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">442</span><span id="line-442"> observer.preTruncateTableAction(this, tableName);</span> |
| <span class="source-line-no">443</span><span id="line-443"> }</span> |
| <span class="source-line-no">444</span><span id="line-444"> });</span> |
| <span class="source-line-no">445</span><span id="line-445"> }</span> |
| <span class="source-line-no">446</span><span id="line-446"></span> |
| <span class="source-line-no">447</span><span id="line-447"> public void postCompletedTruncateTableAction(final TableName tableName, final User user)</span> |
| <span class="source-line-no">448</span><span id="line-448"> throws IOException {</span> |
| <span class="source-line-no">449</span><span id="line-449"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">450</span><span id="line-450"> @Override</span> |
| <span class="source-line-no">451</span><span id="line-451"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">452</span><span id="line-452"> observer.postCompletedTruncateTableAction(this, tableName);</span> |
| <span class="source-line-no">453</span><span id="line-453"> }</span> |
| <span class="source-line-no">454</span><span id="line-454"> });</span> |
| <span class="source-line-no">455</span><span id="line-455"> }</span> |
| <span class="source-line-no">456</span><span id="line-456"></span> |
| <span class="source-line-no">457</span><span id="line-457"> public TableDescriptor preModifyTable(final TableName tableName,</span> |
| <span class="source-line-no">458</span><span id="line-458"> final TableDescriptor currentDescriptor, final TableDescriptor newDescriptor)</span> |
| <span class="source-line-no">459</span><span id="line-459"> throws IOException {</span> |
| <span class="source-line-no">460</span><span id="line-460"> if (coprocEnvironments.isEmpty()) {</span> |
| <span class="source-line-no">461</span><span id="line-461"> return newDescriptor;</span> |
| <span class="source-line-no">462</span><span id="line-462"> }</span> |
| <span class="source-line-no">463</span><span id="line-463"> return execOperationWithResult(new ObserverOperationWithResult<MasterObserver, TableDescriptor>(</span> |
| <span class="source-line-no">464</span><span id="line-464"> masterObserverGetter, newDescriptor) {</span> |
| <span class="source-line-no">465</span><span id="line-465"> @Override</span> |
| <span class="source-line-no">466</span><span id="line-466"> protected TableDescriptor call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">467</span><span id="line-467"> return observer.preModifyTable(this, tableName, currentDescriptor, getResult());</span> |
| <span class="source-line-no">468</span><span id="line-468"> }</span> |
| <span class="source-line-no">469</span><span id="line-469"> });</span> |
| <span class="source-line-no">470</span><span id="line-470"> }</span> |
| <span class="source-line-no">471</span><span id="line-471"></span> |
| <span class="source-line-no">472</span><span id="line-472"> public void postModifyTable(final TableName tableName, final TableDescriptor oldDescriptor,</span> |
| <span class="source-line-no">473</span><span id="line-473"> final TableDescriptor currentDescriptor) throws IOException {</span> |
| <span class="source-line-no">474</span><span id="line-474"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">475</span><span id="line-475"> @Override</span> |
| <span class="source-line-no">476</span><span id="line-476"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">477</span><span id="line-477"> observer.postModifyTable(this, tableName, oldDescriptor, currentDescriptor);</span> |
| <span class="source-line-no">478</span><span id="line-478"> }</span> |
| <span class="source-line-no">479</span><span id="line-479"> });</span> |
| <span class="source-line-no">480</span><span id="line-480"> }</span> |
| <span class="source-line-no">481</span><span id="line-481"></span> |
| <span class="source-line-no">482</span><span id="line-482"> public String preModifyTableStoreFileTracker(final TableName tableName, final String dstSFT)</span> |
| <span class="source-line-no">483</span><span id="line-483"> throws IOException {</span> |
| <span class="source-line-no">484</span><span id="line-484"> if (coprocEnvironments.isEmpty()) {</span> |
| <span class="source-line-no">485</span><span id="line-485"> return dstSFT;</span> |
| <span class="source-line-no">486</span><span id="line-486"> }</span> |
| <span class="source-line-no">487</span><span id="line-487"> return execOperationWithResult(</span> |
| <span class="source-line-no">488</span><span id="line-488"> new ObserverOperationWithResult<MasterObserver, String>(masterObserverGetter, dstSFT) {</span> |
| <span class="source-line-no">489</span><span id="line-489"> @Override</span> |
| <span class="source-line-no">490</span><span id="line-490"> protected String call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">491</span><span id="line-491"> return observer.preModifyTableStoreFileTracker(this, tableName, getResult());</span> |
| <span class="source-line-no">492</span><span id="line-492"> }</span> |
| <span class="source-line-no">493</span><span id="line-493"> });</span> |
| <span class="source-line-no">494</span><span id="line-494"> }</span> |
| <span class="source-line-no">495</span><span id="line-495"></span> |
| <span class="source-line-no">496</span><span id="line-496"> public void postModifyTableStoreFileTracker(final TableName tableName, final String dstSFT)</span> |
| <span class="source-line-no">497</span><span id="line-497"> throws IOException {</span> |
| <span class="source-line-no">498</span><span id="line-498"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">499</span><span id="line-499"> @Override</span> |
| <span class="source-line-no">500</span><span id="line-500"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">501</span><span id="line-501"> observer.postModifyTableStoreFileTracker(this, tableName, dstSFT);</span> |
| <span class="source-line-no">502</span><span id="line-502"> }</span> |
| <span class="source-line-no">503</span><span id="line-503"> });</span> |
| <span class="source-line-no">504</span><span id="line-504"> }</span> |
| <span class="source-line-no">505</span><span id="line-505"></span> |
| <span class="source-line-no">506</span><span id="line-506"> public String preModifyColumnFamilyStoreFileTracker(final TableName tableName,</span> |
| <span class="source-line-no">507</span><span id="line-507"> final byte[] family, final String dstSFT) throws IOException {</span> |
| <span class="source-line-no">508</span><span id="line-508"> if (coprocEnvironments.isEmpty()) {</span> |
| <span class="source-line-no">509</span><span id="line-509"> return dstSFT;</span> |
| <span class="source-line-no">510</span><span id="line-510"> }</span> |
| <span class="source-line-no">511</span><span id="line-511"> return execOperationWithResult(</span> |
| <span class="source-line-no">512</span><span id="line-512"> new ObserverOperationWithResult<MasterObserver, String>(masterObserverGetter, dstSFT) {</span> |
| <span class="source-line-no">513</span><span id="line-513"> @Override</span> |
| <span class="source-line-no">514</span><span id="line-514"> protected String call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">515</span><span id="line-515"> return observer.preModifyColumnFamilyStoreFileTracker(this, tableName, family,</span> |
| <span class="source-line-no">516</span><span id="line-516"> getResult());</span> |
| <span class="source-line-no">517</span><span id="line-517"> }</span> |
| <span class="source-line-no">518</span><span id="line-518"> });</span> |
| <span class="source-line-no">519</span><span id="line-519"> }</span> |
| <span class="source-line-no">520</span><span id="line-520"></span> |
| <span class="source-line-no">521</span><span id="line-521"> public void postModifyColumnFamilyStoreFileTracker(final TableName tableName, final byte[] family,</span> |
| <span class="source-line-no">522</span><span id="line-522"> final String dstSFT) throws IOException {</span> |
| <span class="source-line-no">523</span><span id="line-523"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">524</span><span id="line-524"> @Override</span> |
| <span class="source-line-no">525</span><span id="line-525"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">526</span><span id="line-526"> observer.postModifyColumnFamilyStoreFileTracker(this, tableName, family, dstSFT);</span> |
| <span class="source-line-no">527</span><span id="line-527"> }</span> |
| <span class="source-line-no">528</span><span id="line-528"> });</span> |
| <span class="source-line-no">529</span><span id="line-529"> }</span> |
| <span class="source-line-no">530</span><span id="line-530"></span> |
| <span class="source-line-no">531</span><span id="line-531"> public void preModifyTableAction(final TableName tableName,</span> |
| <span class="source-line-no">532</span><span id="line-532"> final TableDescriptor currentDescriptor, final TableDescriptor newDescriptor, final User user)</span> |
| <span class="source-line-no">533</span><span id="line-533"> throws IOException {</span> |
| <span class="source-line-no">534</span><span id="line-534"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">535</span><span id="line-535"> @Override</span> |
| <span class="source-line-no">536</span><span id="line-536"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">537</span><span id="line-537"> observer.preModifyTableAction(this, tableName, currentDescriptor, newDescriptor);</span> |
| <span class="source-line-no">538</span><span id="line-538"> }</span> |
| <span class="source-line-no">539</span><span id="line-539"> });</span> |
| <span class="source-line-no">540</span><span id="line-540"> }</span> |
| <span class="source-line-no">541</span><span id="line-541"></span> |
| <span class="source-line-no">542</span><span id="line-542"> public void postCompletedModifyTableAction(final TableName tableName,</span> |
| <span class="source-line-no">543</span><span id="line-543"> final TableDescriptor oldDescriptor, final TableDescriptor currentDescriptor, final User user)</span> |
| <span class="source-line-no">544</span><span id="line-544"> throws IOException {</span> |
| <span class="source-line-no">545</span><span id="line-545"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">546</span><span id="line-546"> @Override</span> |
| <span class="source-line-no">547</span><span id="line-547"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">548</span><span id="line-548"> observer.postCompletedModifyTableAction(this, tableName, oldDescriptor, currentDescriptor);</span> |
| <span class="source-line-no">549</span><span id="line-549"> }</span> |
| <span class="source-line-no">550</span><span id="line-550"> });</span> |
| <span class="source-line-no">551</span><span id="line-551"> }</span> |
| <span class="source-line-no">552</span><span id="line-552"></span> |
| <span class="source-line-no">553</span><span id="line-553"> public void preEnableTable(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">554</span><span id="line-554"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">555</span><span id="line-555"> @Override</span> |
| <span class="source-line-no">556</span><span id="line-556"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">557</span><span id="line-557"> observer.preEnableTable(this, tableName);</span> |
| <span class="source-line-no">558</span><span id="line-558"> }</span> |
| <span class="source-line-no">559</span><span id="line-559"> });</span> |
| <span class="source-line-no">560</span><span id="line-560"> }</span> |
| <span class="source-line-no">561</span><span id="line-561"></span> |
| <span class="source-line-no">562</span><span id="line-562"> public void postEnableTable(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">563</span><span id="line-563"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">564</span><span id="line-564"> @Override</span> |
| <span class="source-line-no">565</span><span id="line-565"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">566</span><span id="line-566"> observer.postEnableTable(this, tableName);</span> |
| <span class="source-line-no">567</span><span id="line-567"> }</span> |
| <span class="source-line-no">568</span><span id="line-568"> });</span> |
| <span class="source-line-no">569</span><span id="line-569"> }</span> |
| <span class="source-line-no">570</span><span id="line-570"></span> |
| <span class="source-line-no">571</span><span id="line-571"> public void preEnableTableAction(final TableName tableName, final User user) throws IOException {</span> |
| <span class="source-line-no">572</span><span id="line-572"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">573</span><span id="line-573"> @Override</span> |
| <span class="source-line-no">574</span><span id="line-574"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">575</span><span id="line-575"> observer.preEnableTableAction(this, tableName);</span> |
| <span class="source-line-no">576</span><span id="line-576"> }</span> |
| <span class="source-line-no">577</span><span id="line-577"> });</span> |
| <span class="source-line-no">578</span><span id="line-578"> }</span> |
| <span class="source-line-no">579</span><span id="line-579"></span> |
| <span class="source-line-no">580</span><span id="line-580"> public void postCompletedEnableTableAction(final TableName tableName, final User user)</span> |
| <span class="source-line-no">581</span><span id="line-581"> throws IOException {</span> |
| <span class="source-line-no">582</span><span id="line-582"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">583</span><span id="line-583"> @Override</span> |
| <span class="source-line-no">584</span><span id="line-584"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">585</span><span id="line-585"> observer.postCompletedEnableTableAction(this, tableName);</span> |
| <span class="source-line-no">586</span><span id="line-586"> }</span> |
| <span class="source-line-no">587</span><span id="line-587"> });</span> |
| <span class="source-line-no">588</span><span id="line-588"> }</span> |
| <span class="source-line-no">589</span><span id="line-589"></span> |
| <span class="source-line-no">590</span><span id="line-590"> public void preDisableTable(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">591</span><span id="line-591"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">592</span><span id="line-592"> @Override</span> |
| <span class="source-line-no">593</span><span id="line-593"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">594</span><span id="line-594"> observer.preDisableTable(this, tableName);</span> |
| <span class="source-line-no">595</span><span id="line-595"> }</span> |
| <span class="source-line-no">596</span><span id="line-596"> });</span> |
| <span class="source-line-no">597</span><span id="line-597"> }</span> |
| <span class="source-line-no">598</span><span id="line-598"></span> |
| <span class="source-line-no">599</span><span id="line-599"> public void postDisableTable(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">600</span><span id="line-600"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">601</span><span id="line-601"> @Override</span> |
| <span class="source-line-no">602</span><span id="line-602"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">603</span><span id="line-603"> observer.postDisableTable(this, tableName);</span> |
| <span class="source-line-no">604</span><span id="line-604"> }</span> |
| <span class="source-line-no">605</span><span id="line-605"> });</span> |
| <span class="source-line-no">606</span><span id="line-606"> }</span> |
| <span class="source-line-no">607</span><span id="line-607"></span> |
| <span class="source-line-no">608</span><span id="line-608"> public void preDisableTableAction(final TableName tableName, final User user) throws IOException {</span> |
| <span class="source-line-no">609</span><span id="line-609"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">610</span><span id="line-610"> @Override</span> |
| <span class="source-line-no">611</span><span id="line-611"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">612</span><span id="line-612"> observer.preDisableTableAction(this, tableName);</span> |
| <span class="source-line-no">613</span><span id="line-613"> }</span> |
| <span class="source-line-no">614</span><span id="line-614"> });</span> |
| <span class="source-line-no">615</span><span id="line-615"> }</span> |
| <span class="source-line-no">616</span><span id="line-616"></span> |
| <span class="source-line-no">617</span><span id="line-617"> public void postCompletedDisableTableAction(final TableName tableName, final User user)</span> |
| <span class="source-line-no">618</span><span id="line-618"> throws IOException {</span> |
| <span class="source-line-no">619</span><span id="line-619"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">620</span><span id="line-620"> @Override</span> |
| <span class="source-line-no">621</span><span id="line-621"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">622</span><span id="line-622"> observer.postCompletedDisableTableAction(this, tableName);</span> |
| <span class="source-line-no">623</span><span id="line-623"> }</span> |
| <span class="source-line-no">624</span><span id="line-624"> });</span> |
| <span class="source-line-no">625</span><span id="line-625"> }</span> |
| <span class="source-line-no">626</span><span id="line-626"></span> |
| <span class="source-line-no">627</span><span id="line-627"> public void preAbortProcedure(final ProcedureExecutor<MasterProcedureEnv> procEnv,</span> |
| <span class="source-line-no">628</span><span id="line-628"> final long procId) throws IOException {</span> |
| <span class="source-line-no">629</span><span id="line-629"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">630</span><span id="line-630"> @Override</span> |
| <span class="source-line-no">631</span><span id="line-631"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">632</span><span id="line-632"> observer.preAbortProcedure(this, procId);</span> |
| <span class="source-line-no">633</span><span id="line-633"> }</span> |
| <span class="source-line-no">634</span><span id="line-634"> });</span> |
| <span class="source-line-no">635</span><span id="line-635"> }</span> |
| <span class="source-line-no">636</span><span id="line-636"></span> |
| <span class="source-line-no">637</span><span id="line-637"> public void postAbortProcedure() throws IOException {</span> |
| <span class="source-line-no">638</span><span id="line-638"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">639</span><span id="line-639"> @Override</span> |
| <span class="source-line-no">640</span><span id="line-640"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">641</span><span id="line-641"> observer.postAbortProcedure(this);</span> |
| <span class="source-line-no">642</span><span id="line-642"> }</span> |
| <span class="source-line-no">643</span><span id="line-643"> });</span> |
| <span class="source-line-no">644</span><span id="line-644"> }</span> |
| <span class="source-line-no">645</span><span id="line-645"></span> |
| <span class="source-line-no">646</span><span id="line-646"> public void preGetProcedures() throws IOException {</span> |
| <span class="source-line-no">647</span><span id="line-647"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">648</span><span id="line-648"> @Override</span> |
| <span class="source-line-no">649</span><span id="line-649"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">650</span><span id="line-650"> observer.preGetProcedures(this);</span> |
| <span class="source-line-no">651</span><span id="line-651"> }</span> |
| <span class="source-line-no">652</span><span id="line-652"> });</span> |
| <span class="source-line-no">653</span><span id="line-653"> }</span> |
| <span class="source-line-no">654</span><span id="line-654"></span> |
| <span class="source-line-no">655</span><span id="line-655"> public void postGetProcedures(final List<Procedure<?>> procInfoList) throws IOException {</span> |
| <span class="source-line-no">656</span><span id="line-656"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">657</span><span id="line-657"> @Override</span> |
| <span class="source-line-no">658</span><span id="line-658"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">659</span><span id="line-659"> observer.postGetProcedures(this);</span> |
| <span class="source-line-no">660</span><span id="line-660"> }</span> |
| <span class="source-line-no">661</span><span id="line-661"> });</span> |
| <span class="source-line-no">662</span><span id="line-662"> }</span> |
| <span class="source-line-no">663</span><span id="line-663"></span> |
| <span class="source-line-no">664</span><span id="line-664"> public void preGetLocks() throws IOException {</span> |
| <span class="source-line-no">665</span><span id="line-665"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">666</span><span id="line-666"> @Override</span> |
| <span class="source-line-no">667</span><span id="line-667"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">668</span><span id="line-668"> observer.preGetLocks(this);</span> |
| <span class="source-line-no">669</span><span id="line-669"> }</span> |
| <span class="source-line-no">670</span><span id="line-670"> });</span> |
| <span class="source-line-no">671</span><span id="line-671"> }</span> |
| <span class="source-line-no">672</span><span id="line-672"></span> |
| <span class="source-line-no">673</span><span id="line-673"> public void postGetLocks(final List<LockedResource> lockedResources) throws IOException {</span> |
| <span class="source-line-no">674</span><span id="line-674"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">675</span><span id="line-675"> @Override</span> |
| <span class="source-line-no">676</span><span id="line-676"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">677</span><span id="line-677"> observer.postGetLocks(this);</span> |
| <span class="source-line-no">678</span><span id="line-678"> }</span> |
| <span class="source-line-no">679</span><span id="line-679"> });</span> |
| <span class="source-line-no">680</span><span id="line-680"> }</span> |
| <span class="source-line-no">681</span><span id="line-681"></span> |
| <span class="source-line-no">682</span><span id="line-682"> public void preMove(final RegionInfo region, final ServerName srcServer,</span> |
| <span class="source-line-no">683</span><span id="line-683"> final ServerName destServer) throws IOException {</span> |
| <span class="source-line-no">684</span><span id="line-684"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">685</span><span id="line-685"> @Override</span> |
| <span class="source-line-no">686</span><span id="line-686"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">687</span><span id="line-687"> observer.preMove(this, region, srcServer, destServer);</span> |
| <span class="source-line-no">688</span><span id="line-688"> }</span> |
| <span class="source-line-no">689</span><span id="line-689"> });</span> |
| <span class="source-line-no">690</span><span id="line-690"> }</span> |
| <span class="source-line-no">691</span><span id="line-691"></span> |
| <span class="source-line-no">692</span><span id="line-692"> public void postMove(final RegionInfo region, final ServerName srcServer,</span> |
| <span class="source-line-no">693</span><span id="line-693"> final ServerName destServer) throws IOException {</span> |
| <span class="source-line-no">694</span><span id="line-694"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">695</span><span id="line-695"> @Override</span> |
| <span class="source-line-no">696</span><span id="line-696"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">697</span><span id="line-697"> observer.postMove(this, region, srcServer, destServer);</span> |
| <span class="source-line-no">698</span><span id="line-698"> }</span> |
| <span class="source-line-no">699</span><span id="line-699"> });</span> |
| <span class="source-line-no">700</span><span id="line-700"> }</span> |
| <span class="source-line-no">701</span><span id="line-701"></span> |
| <span class="source-line-no">702</span><span id="line-702"> public void preAssign(final RegionInfo regionInfo) throws IOException {</span> |
| <span class="source-line-no">703</span><span id="line-703"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">704</span><span id="line-704"> @Override</span> |
| <span class="source-line-no">705</span><span id="line-705"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">706</span><span id="line-706"> observer.preAssign(this, regionInfo);</span> |
| <span class="source-line-no">707</span><span id="line-707"> }</span> |
| <span class="source-line-no">708</span><span id="line-708"> });</span> |
| <span class="source-line-no">709</span><span id="line-709"> }</span> |
| <span class="source-line-no">710</span><span id="line-710"></span> |
| <span class="source-line-no">711</span><span id="line-711"> public void postAssign(final RegionInfo regionInfo) throws IOException {</span> |
| <span class="source-line-no">712</span><span id="line-712"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">713</span><span id="line-713"> @Override</span> |
| <span class="source-line-no">714</span><span id="line-714"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">715</span><span id="line-715"> observer.postAssign(this, regionInfo);</span> |
| <span class="source-line-no">716</span><span id="line-716"> }</span> |
| <span class="source-line-no">717</span><span id="line-717"> });</span> |
| <span class="source-line-no">718</span><span id="line-718"> }</span> |
| <span class="source-line-no">719</span><span id="line-719"></span> |
| <span class="source-line-no">720</span><span id="line-720"> public void preUnassign(final RegionInfo regionInfo) throws IOException {</span> |
| <span class="source-line-no">721</span><span id="line-721"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">722</span><span id="line-722"> @Override</span> |
| <span class="source-line-no">723</span><span id="line-723"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">724</span><span id="line-724"> observer.preUnassign(this, regionInfo);</span> |
| <span class="source-line-no">725</span><span id="line-725"> }</span> |
| <span class="source-line-no">726</span><span id="line-726"> });</span> |
| <span class="source-line-no">727</span><span id="line-727"> }</span> |
| <span class="source-line-no">728</span><span id="line-728"></span> |
| <span class="source-line-no">729</span><span id="line-729"> public void postUnassign(final RegionInfo regionInfo) throws IOException {</span> |
| <span class="source-line-no">730</span><span id="line-730"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">731</span><span id="line-731"> @Override</span> |
| <span class="source-line-no">732</span><span id="line-732"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">733</span><span id="line-733"> observer.postUnassign(this, regionInfo);</span> |
| <span class="source-line-no">734</span><span id="line-734"> }</span> |
| <span class="source-line-no">735</span><span id="line-735"> });</span> |
| <span class="source-line-no">736</span><span id="line-736"> }</span> |
| <span class="source-line-no">737</span><span id="line-737"></span> |
| <span class="source-line-no">738</span><span id="line-738"> public void preRegionOffline(final RegionInfo regionInfo) throws IOException {</span> |
| <span class="source-line-no">739</span><span id="line-739"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">740</span><span id="line-740"> @Override</span> |
| <span class="source-line-no">741</span><span id="line-741"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">742</span><span id="line-742"> observer.preRegionOffline(this, regionInfo);</span> |
| <span class="source-line-no">743</span><span id="line-743"> }</span> |
| <span class="source-line-no">744</span><span id="line-744"> });</span> |
| <span class="source-line-no">745</span><span id="line-745"> }</span> |
| <span class="source-line-no">746</span><span id="line-746"></span> |
| <span class="source-line-no">747</span><span id="line-747"> public void postRegionOffline(final RegionInfo regionInfo) throws IOException {</span> |
| <span class="source-line-no">748</span><span id="line-748"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">749</span><span id="line-749"> @Override</span> |
| <span class="source-line-no">750</span><span id="line-750"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">751</span><span id="line-751"> observer.postRegionOffline(this, regionInfo);</span> |
| <span class="source-line-no">752</span><span id="line-752"> }</span> |
| <span class="source-line-no">753</span><span id="line-753"> });</span> |
| <span class="source-line-no">754</span><span id="line-754"> }</span> |
| <span class="source-line-no">755</span><span id="line-755"></span> |
| <span class="source-line-no">756</span><span id="line-756"> public void preMergeRegions(final RegionInfo[] regionsToMerge) throws IOException {</span> |
| <span class="source-line-no">757</span><span id="line-757"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">758</span><span id="line-758"> @Override</span> |
| <span class="source-line-no">759</span><span id="line-759"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">760</span><span id="line-760"> observer.preMergeRegions(this, regionsToMerge);</span> |
| <span class="source-line-no">761</span><span id="line-761"> }</span> |
| <span class="source-line-no">762</span><span id="line-762"> });</span> |
| <span class="source-line-no">763</span><span id="line-763"> }</span> |
| <span class="source-line-no">764</span><span id="line-764"></span> |
| <span class="source-line-no">765</span><span id="line-765"> public void postMergeRegions(final RegionInfo[] regionsToMerge) throws IOException {</span> |
| <span class="source-line-no">766</span><span id="line-766"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">767</span><span id="line-767"> @Override</span> |
| <span class="source-line-no">768</span><span id="line-768"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">769</span><span id="line-769"> observer.postMergeRegions(this, regionsToMerge);</span> |
| <span class="source-line-no">770</span><span id="line-770"> }</span> |
| <span class="source-line-no">771</span><span id="line-771"> });</span> |
| <span class="source-line-no">772</span><span id="line-772"> }</span> |
| <span class="source-line-no">773</span><span id="line-773"></span> |
| <span class="source-line-no">774</span><span id="line-774"> public boolean preBalance(final BalanceRequest request) throws IOException {</span> |
| <span class="source-line-no">775</span><span id="line-775"> return execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">776</span><span id="line-776"> @Override</span> |
| <span class="source-line-no">777</span><span id="line-777"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">778</span><span id="line-778"> observer.preBalance(this, request);</span> |
| <span class="source-line-no">779</span><span id="line-779"> }</span> |
| <span class="source-line-no">780</span><span id="line-780"> });</span> |
| <span class="source-line-no">781</span><span id="line-781"> }</span> |
| <span class="source-line-no">782</span><span id="line-782"></span> |
| <span class="source-line-no">783</span><span id="line-783"> public void postBalance(final BalanceRequest request, final List<RegionPlan> plans)</span> |
| <span class="source-line-no">784</span><span id="line-784"> throws IOException {</span> |
| <span class="source-line-no">785</span><span id="line-785"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">786</span><span id="line-786"> @Override</span> |
| <span class="source-line-no">787</span><span id="line-787"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">788</span><span id="line-788"> observer.postBalance(this, request, plans);</span> |
| <span class="source-line-no">789</span><span id="line-789"> }</span> |
| <span class="source-line-no">790</span><span id="line-790"> });</span> |
| <span class="source-line-no">791</span><span id="line-791"> }</span> |
| <span class="source-line-no">792</span><span id="line-792"></span> |
| <span class="source-line-no">793</span><span id="line-793"> public void preSetSplitOrMergeEnabled(final boolean newValue, final MasterSwitchType switchType)</span> |
| <span class="source-line-no">794</span><span id="line-794"> throws IOException {</span> |
| <span class="source-line-no">795</span><span id="line-795"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">796</span><span id="line-796"> @Override</span> |
| <span class="source-line-no">797</span><span id="line-797"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">798</span><span id="line-798"> observer.preSetSplitOrMergeEnabled(this, newValue, switchType);</span> |
| <span class="source-line-no">799</span><span id="line-799"> }</span> |
| <span class="source-line-no">800</span><span id="line-800"> });</span> |
| <span class="source-line-no">801</span><span id="line-801"> }</span> |
| <span class="source-line-no">802</span><span id="line-802"></span> |
| <span class="source-line-no">803</span><span id="line-803"> public void postSetSplitOrMergeEnabled(final boolean newValue, final MasterSwitchType switchType)</span> |
| <span class="source-line-no">804</span><span id="line-804"> throws IOException {</span> |
| <span class="source-line-no">805</span><span id="line-805"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">806</span><span id="line-806"> @Override</span> |
| <span class="source-line-no">807</span><span id="line-807"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">808</span><span id="line-808"> observer.postSetSplitOrMergeEnabled(this, newValue, switchType);</span> |
| <span class="source-line-no">809</span><span id="line-809"> }</span> |
| <span class="source-line-no">810</span><span id="line-810"> });</span> |
| <span class="source-line-no">811</span><span id="line-811"> }</span> |
| <span class="source-line-no">812</span><span id="line-812"></span> |
| <span class="source-line-no">813</span><span id="line-813"> /**</span> |
| <span class="source-line-no">814</span><span id="line-814"> * Invoked just before calling the split region procedure</span> |
| <span class="source-line-no">815</span><span id="line-815"> * @param tableName the table where the region belongs to</span> |
| <span class="source-line-no">816</span><span id="line-816"> * @param splitRow the split point</span> |
| <span class="source-line-no">817</span><span id="line-817"> */</span> |
| <span class="source-line-no">818</span><span id="line-818"> public void preSplitRegion(final TableName tableName, final byte[] splitRow) throws IOException {</span> |
| <span class="source-line-no">819</span><span id="line-819"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">820</span><span id="line-820"> @Override</span> |
| <span class="source-line-no">821</span><span id="line-821"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">822</span><span id="line-822"> observer.preSplitRegion(this, tableName, splitRow);</span> |
| <span class="source-line-no">823</span><span id="line-823"> }</span> |
| <span class="source-line-no">824</span><span id="line-824"> });</span> |
| <span class="source-line-no">825</span><span id="line-825"> }</span> |
| <span class="source-line-no">826</span><span id="line-826"></span> |
| <span class="source-line-no">827</span><span id="line-827"> /**</span> |
| <span class="source-line-no">828</span><span id="line-828"> * Invoked just before a split</span> |
| <span class="source-line-no">829</span><span id="line-829"> * @param tableName the table where the region belongs to</span> |
| <span class="source-line-no">830</span><span id="line-830"> * @param splitRow the split point</span> |
| <span class="source-line-no">831</span><span id="line-831"> * @param user the user</span> |
| <span class="source-line-no">832</span><span id="line-832"> */</span> |
| <span class="source-line-no">833</span><span id="line-833"> public void preSplitRegionAction(final TableName tableName, final byte[] splitRow,</span> |
| <span class="source-line-no">834</span><span id="line-834"> final User user) throws IOException {</span> |
| <span class="source-line-no">835</span><span id="line-835"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">836</span><span id="line-836"> @Override</span> |
| <span class="source-line-no">837</span><span id="line-837"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">838</span><span id="line-838"> observer.preSplitRegionAction(this, tableName, splitRow);</span> |
| <span class="source-line-no">839</span><span id="line-839"> }</span> |
| <span class="source-line-no">840</span><span id="line-840"> });</span> |
| <span class="source-line-no">841</span><span id="line-841"> }</span> |
| <span class="source-line-no">842</span><span id="line-842"></span> |
| <span class="source-line-no">843</span><span id="line-843"> /**</span> |
| <span class="source-line-no">844</span><span id="line-844"> * Invoked just after a split</span> |
| <span class="source-line-no">845</span><span id="line-845"> * @param regionInfoA the new left-hand daughter region</span> |
| <span class="source-line-no">846</span><span id="line-846"> * @param regionInfoB the new right-hand daughter region</span> |
| <span class="source-line-no">847</span><span id="line-847"> * @param user the user</span> |
| <span class="source-line-no">848</span><span id="line-848"> */</span> |
| <span class="source-line-no">849</span><span id="line-849"> public void postCompletedSplitRegionAction(final RegionInfo regionInfoA,</span> |
| <span class="source-line-no">850</span><span id="line-850"> final RegionInfo regionInfoB, final User user) throws IOException {</span> |
| <span class="source-line-no">851</span><span id="line-851"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">852</span><span id="line-852"> @Override</span> |
| <span class="source-line-no">853</span><span id="line-853"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">854</span><span id="line-854"> observer.postCompletedSplitRegionAction(this, regionInfoA, regionInfoB);</span> |
| <span class="source-line-no">855</span><span id="line-855"> }</span> |
| <span class="source-line-no">856</span><span id="line-856"> });</span> |
| <span class="source-line-no">857</span><span id="line-857"> }</span> |
| <span class="source-line-no">858</span><span id="line-858"></span> |
| <span class="source-line-no">859</span><span id="line-859"> /**</span> |
| <span class="source-line-no">860</span><span id="line-860"> * Invoked just before calling the truncate region procedure</span> |
| <span class="source-line-no">861</span><span id="line-861"> * @param regionInfo region being truncated</span> |
| <span class="source-line-no">862</span><span id="line-862"> */</span> |
| <span class="source-line-no">863</span><span id="line-863"> public void preTruncateRegion(RegionInfo regionInfo) throws IOException {</span> |
| <span class="source-line-no">864</span><span id="line-864"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">865</span><span id="line-865"> @Override</span> |
| <span class="source-line-no">866</span><span id="line-866"> public void call(MasterObserver observer) {</span> |
| <span class="source-line-no">867</span><span id="line-867"> observer.preTruncateRegion(this, regionInfo);</span> |
| <span class="source-line-no">868</span><span id="line-868"> }</span> |
| <span class="source-line-no">869</span><span id="line-869"> });</span> |
| <span class="source-line-no">870</span><span id="line-870"> }</span> |
| <span class="source-line-no">871</span><span id="line-871"></span> |
| <span class="source-line-no">872</span><span id="line-872"> /**</span> |
| <span class="source-line-no">873</span><span id="line-873"> * Invoked after calling the truncate region procedure</span> |
| <span class="source-line-no">874</span><span id="line-874"> * @param regionInfo region being truncated</span> |
| <span class="source-line-no">875</span><span id="line-875"> */</span> |
| <span class="source-line-no">876</span><span id="line-876"> public void postTruncateRegion(RegionInfo regionInfo) throws IOException {</span> |
| <span class="source-line-no">877</span><span id="line-877"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">878</span><span id="line-878"> @Override</span> |
| <span class="source-line-no">879</span><span id="line-879"> public void call(MasterObserver observer) {</span> |
| <span class="source-line-no">880</span><span id="line-880"> observer.postTruncateRegion(this, regionInfo);</span> |
| <span class="source-line-no">881</span><span id="line-881"> }</span> |
| <span class="source-line-no">882</span><span id="line-882"> });</span> |
| <span class="source-line-no">883</span><span id="line-883"> }</span> |
| <span class="source-line-no">884</span><span id="line-884"></span> |
| <span class="source-line-no">885</span><span id="line-885"> /**</span> |
| <span class="source-line-no">886</span><span id="line-886"> * Invoked just before calling the truncate region procedure</span> |
| <span class="source-line-no">887</span><span id="line-887"> * @param region Region to be truncated</span> |
| <span class="source-line-no">888</span><span id="line-888"> * @param user The user</span> |
| <span class="source-line-no">889</span><span id="line-889"> */</span> |
| <span class="source-line-no">890</span><span id="line-890"> public void preTruncateRegionAction(final RegionInfo region, User user) throws IOException {</span> |
| <span class="source-line-no">891</span><span id="line-891"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">892</span><span id="line-892"> @Override</span> |
| <span class="source-line-no">893</span><span id="line-893"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">894</span><span id="line-894"> observer.preTruncateRegionAction(this, region);</span> |
| <span class="source-line-no">895</span><span id="line-895"> }</span> |
| <span class="source-line-no">896</span><span id="line-896"> });</span> |
| <span class="source-line-no">897</span><span id="line-897"> }</span> |
| <span class="source-line-no">898</span><span id="line-898"></span> |
| <span class="source-line-no">899</span><span id="line-899"> /**</span> |
| <span class="source-line-no">900</span><span id="line-900"> * Invoked after calling the truncate region procedure</span> |
| <span class="source-line-no">901</span><span id="line-901"> * @param region Region which was truncated</span> |
| <span class="source-line-no">902</span><span id="line-902"> * @param user The user</span> |
| <span class="source-line-no">903</span><span id="line-903"> */</span> |
| <span class="source-line-no">904</span><span id="line-904"> public void postTruncateRegionAction(final RegionInfo region, User user) throws IOException {</span> |
| <span class="source-line-no">905</span><span id="line-905"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">906</span><span id="line-906"> @Override</span> |
| <span class="source-line-no">907</span><span id="line-907"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">908</span><span id="line-908"> observer.postTruncateRegionAction(this, region);</span> |
| <span class="source-line-no">909</span><span id="line-909"> }</span> |
| <span class="source-line-no">910</span><span id="line-910"> });</span> |
| <span class="source-line-no">911</span><span id="line-911"> }</span> |
| <span class="source-line-no">912</span><span id="line-912"></span> |
| <span class="source-line-no">913</span><span id="line-913"> /**</span> |
| <span class="source-line-no">914</span><span id="line-914"> * This will be called before update META step as part of split table region procedure.</span> |
| <span class="source-line-no">915</span><span id="line-915"> * @param user the user</span> |
| <span class="source-line-no">916</span><span id="line-916"> */</span> |
| <span class="source-line-no">917</span><span id="line-917"> public void preSplitBeforeMETAAction(final byte[] splitKey, final List<Mutation> metaEntries,</span> |
| <span class="source-line-no">918</span><span id="line-918"> final User user) throws IOException {</span> |
| <span class="source-line-no">919</span><span id="line-919"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">920</span><span id="line-920"> @Override</span> |
| <span class="source-line-no">921</span><span id="line-921"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">922</span><span id="line-922"> observer.preSplitRegionBeforeMETAAction(this, splitKey, metaEntries);</span> |
| <span class="source-line-no">923</span><span id="line-923"> }</span> |
| <span class="source-line-no">924</span><span id="line-924"> });</span> |
| <span class="source-line-no">925</span><span id="line-925"> }</span> |
| <span class="source-line-no">926</span><span id="line-926"></span> |
| <span class="source-line-no">927</span><span id="line-927"> /**</span> |
| <span class="source-line-no">928</span><span id="line-928"> * This will be called after update META step as part of split table region procedure.</span> |
| <span class="source-line-no">929</span><span id="line-929"> * @param user the user</span> |
| <span class="source-line-no">930</span><span id="line-930"> */</span> |
| <span class="source-line-no">931</span><span id="line-931"> public void preSplitAfterMETAAction(final User user) throws IOException {</span> |
| <span class="source-line-no">932</span><span id="line-932"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">933</span><span id="line-933"> @Override</span> |
| <span class="source-line-no">934</span><span id="line-934"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">935</span><span id="line-935"> observer.preSplitRegionAfterMETAAction(this);</span> |
| <span class="source-line-no">936</span><span id="line-936"> }</span> |
| <span class="source-line-no">937</span><span id="line-937"> });</span> |
| <span class="source-line-no">938</span><span id="line-938"> }</span> |
| <span class="source-line-no">939</span><span id="line-939"></span> |
| <span class="source-line-no">940</span><span id="line-940"> /**</span> |
| <span class="source-line-no">941</span><span id="line-941"> * Invoked just after the rollback of a failed split</span> |
| <span class="source-line-no">942</span><span id="line-942"> * @param user the user</span> |
| <span class="source-line-no">943</span><span id="line-943"> */</span> |
| <span class="source-line-no">944</span><span id="line-944"> public void postRollBackSplitRegionAction(final User user) throws IOException {</span> |
| <span class="source-line-no">945</span><span id="line-945"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">946</span><span id="line-946"> @Override</span> |
| <span class="source-line-no">947</span><span id="line-947"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">948</span><span id="line-948"> observer.postRollBackSplitRegionAction(this);</span> |
| <span class="source-line-no">949</span><span id="line-949"> }</span> |
| <span class="source-line-no">950</span><span id="line-950"> });</span> |
| <span class="source-line-no">951</span><span id="line-951"> }</span> |
| <span class="source-line-no">952</span><span id="line-952"></span> |
| <span class="source-line-no">953</span><span id="line-953"> /**</span> |
| <span class="source-line-no">954</span><span id="line-954"> * Invoked just before a merge</span> |
| <span class="source-line-no">955</span><span id="line-955"> * @param regionsToMerge the regions to merge</span> |
| <span class="source-line-no">956</span><span id="line-956"> * @param user the user</span> |
| <span class="source-line-no">957</span><span id="line-957"> */</span> |
| <span class="source-line-no">958</span><span id="line-958"> public void preMergeRegionsAction(final RegionInfo[] regionsToMerge, final User user)</span> |
| <span class="source-line-no">959</span><span id="line-959"> throws IOException {</span> |
| <span class="source-line-no">960</span><span id="line-960"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">961</span><span id="line-961"> @Override</span> |
| <span class="source-line-no">962</span><span id="line-962"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">963</span><span id="line-963"> observer.preMergeRegionsAction(this, regionsToMerge);</span> |
| <span class="source-line-no">964</span><span id="line-964"> }</span> |
| <span class="source-line-no">965</span><span id="line-965"> });</span> |
| <span class="source-line-no">966</span><span id="line-966"> }</span> |
| <span class="source-line-no">967</span><span id="line-967"></span> |
| <span class="source-line-no">968</span><span id="line-968"> /**</span> |
| <span class="source-line-no">969</span><span id="line-969"> * Invoked after completing merge regions operation</span> |
| <span class="source-line-no">970</span><span id="line-970"> * @param regionsToMerge the regions to merge</span> |
| <span class="source-line-no">971</span><span id="line-971"> * @param mergedRegion the new merged region</span> |
| <span class="source-line-no">972</span><span id="line-972"> * @param user the user</span> |
| <span class="source-line-no">973</span><span id="line-973"> */</span> |
| <span class="source-line-no">974</span><span id="line-974"> public void postCompletedMergeRegionsAction(final RegionInfo[] regionsToMerge,</span> |
| <span class="source-line-no">975</span><span id="line-975"> final RegionInfo mergedRegion, final User user) throws IOException {</span> |
| <span class="source-line-no">976</span><span id="line-976"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">977</span><span id="line-977"> @Override</span> |
| <span class="source-line-no">978</span><span id="line-978"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">979</span><span id="line-979"> observer.postCompletedMergeRegionsAction(this, regionsToMerge, mergedRegion);</span> |
| <span class="source-line-no">980</span><span id="line-980"> }</span> |
| <span class="source-line-no">981</span><span id="line-981"> });</span> |
| <span class="source-line-no">982</span><span id="line-982"> }</span> |
| <span class="source-line-no">983</span><span id="line-983"></span> |
| <span class="source-line-no">984</span><span id="line-984"> /**</span> |
| <span class="source-line-no">985</span><span id="line-985"> * Invoked before merge regions operation writes the new region to hbase:meta</span> |
| <span class="source-line-no">986</span><span id="line-986"> * @param regionsToMerge the regions to merge</span> |
| <span class="source-line-no">987</span><span id="line-987"> * @param metaEntries the meta entry</span> |
| <span class="source-line-no">988</span><span id="line-988"> * @param user the user</span> |
| <span class="source-line-no">989</span><span id="line-989"> */</span> |
| <span class="source-line-no">990</span><span id="line-990"> public void preMergeRegionsCommit(final RegionInfo[] regionsToMerge,</span> |
| <span class="source-line-no">991</span><span id="line-991"> final @MetaMutationAnnotation List<Mutation> metaEntries, final User user) throws IOException {</span> |
| <span class="source-line-no">992</span><span id="line-992"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">993</span><span id="line-993"> @Override</span> |
| <span class="source-line-no">994</span><span id="line-994"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">995</span><span id="line-995"> observer.preMergeRegionsCommitAction(this, regionsToMerge, metaEntries);</span> |
| <span class="source-line-no">996</span><span id="line-996"> }</span> |
| <span class="source-line-no">997</span><span id="line-997"> });</span> |
| <span class="source-line-no">998</span><span id="line-998"> }</span> |
| <span class="source-line-no">999</span><span id="line-999"></span> |
| <span class="source-line-no">1000</span><span id="line-1000"> /**</span> |
| <span class="source-line-no">1001</span><span id="line-1001"> * Invoked after merge regions operation writes the new region to hbase:meta</span> |
| <span class="source-line-no">1002</span><span id="line-1002"> * @param regionsToMerge the regions to merge</span> |
| <span class="source-line-no">1003</span><span id="line-1003"> * @param mergedRegion the new merged region</span> |
| <span class="source-line-no">1004</span><span id="line-1004"> * @param user the user</span> |
| <span class="source-line-no">1005</span><span id="line-1005"> */</span> |
| <span class="source-line-no">1006</span><span id="line-1006"> public void postMergeRegionsCommit(final RegionInfo[] regionsToMerge,</span> |
| <span class="source-line-no">1007</span><span id="line-1007"> final RegionInfo mergedRegion, final User user) throws IOException {</span> |
| <span class="source-line-no">1008</span><span id="line-1008"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">1009</span><span id="line-1009"> @Override</span> |
| <span class="source-line-no">1010</span><span id="line-1010"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1011</span><span id="line-1011"> observer.postMergeRegionsCommitAction(this, regionsToMerge, mergedRegion);</span> |
| <span class="source-line-no">1012</span><span id="line-1012"> }</span> |
| <span class="source-line-no">1013</span><span id="line-1013"> });</span> |
| <span class="source-line-no">1014</span><span id="line-1014"> }</span> |
| <span class="source-line-no">1015</span><span id="line-1015"></span> |
| <span class="source-line-no">1016</span><span id="line-1016"> /**</span> |
| <span class="source-line-no">1017</span><span id="line-1017"> * Invoked after rollback merge regions operation</span> |
| <span class="source-line-no">1018</span><span id="line-1018"> * @param regionsToMerge the regions to merge</span> |
| <span class="source-line-no">1019</span><span id="line-1019"> * @param user the user</span> |
| <span class="source-line-no">1020</span><span id="line-1020"> */</span> |
| <span class="source-line-no">1021</span><span id="line-1021"> public void postRollBackMergeRegionsAction(final RegionInfo[] regionsToMerge, final User user)</span> |
| <span class="source-line-no">1022</span><span id="line-1022"> throws IOException {</span> |
| <span class="source-line-no">1023</span><span id="line-1023"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">1024</span><span id="line-1024"> @Override</span> |
| <span class="source-line-no">1025</span><span id="line-1025"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1026</span><span id="line-1026"> observer.postRollBackMergeRegionsAction(this, regionsToMerge);</span> |
| <span class="source-line-no">1027</span><span id="line-1027"> }</span> |
| <span class="source-line-no">1028</span><span id="line-1028"> });</span> |
| <span class="source-line-no">1029</span><span id="line-1029"> }</span> |
| <span class="source-line-no">1030</span><span id="line-1030"></span> |
| <span class="source-line-no">1031</span><span id="line-1031"> // This hook allows Coprocessor change value of balance switch.</span> |
| <span class="source-line-no">1032</span><span id="line-1032"> public void preBalanceSwitch(final boolean b) throws IOException {</span> |
| <span class="source-line-no">1033</span><span id="line-1033"> if (this.coprocEnvironments.isEmpty()) {</span> |
| <span class="source-line-no">1034</span><span id="line-1034"> return;</span> |
| <span class="source-line-no">1035</span><span id="line-1035"> }</span> |
| <span class="source-line-no">1036</span><span id="line-1036"> execOperation(new MasterObserverOperation() {</span> |
| <span class="source-line-no">1037</span><span id="line-1037"> @Override</span> |
| <span class="source-line-no">1038</span><span id="line-1038"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1039</span><span id="line-1039"> observer.preBalanceSwitch(this, b);</span> |
| <span class="source-line-no">1040</span><span id="line-1040"> }</span> |
| <span class="source-line-no">1041</span><span id="line-1041"> });</span> |
| <span class="source-line-no">1042</span><span id="line-1042"> }</span> |
| <span class="source-line-no">1043</span><span id="line-1043"></span> |
| <span class="source-line-no">1044</span><span id="line-1044"> public void postBalanceSwitch(final boolean oldValue, final boolean newValue) throws IOException {</span> |
| <span class="source-line-no">1045</span><span id="line-1045"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1046</span><span id="line-1046"> @Override</span> |
| <span class="source-line-no">1047</span><span id="line-1047"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1048</span><span id="line-1048"> observer.postBalanceSwitch(this, oldValue, newValue);</span> |
| <span class="source-line-no">1049</span><span id="line-1049"> }</span> |
| <span class="source-line-no">1050</span><span id="line-1050"> });</span> |
| <span class="source-line-no">1051</span><span id="line-1051"> }</span> |
| <span class="source-line-no">1052</span><span id="line-1052"></span> |
| <span class="source-line-no">1053</span><span id="line-1053"> public void preShutdown() throws IOException {</span> |
| <span class="source-line-no">1054</span><span id="line-1054"> // While stopping the cluster all coprocessors method should be executed first then the</span> |
| <span class="source-line-no">1055</span><span id="line-1055"> // coprocessor should be cleaned up.</span> |
| <span class="source-line-no">1056</span><span id="line-1056"> if (coprocEnvironments.isEmpty()) {</span> |
| <span class="source-line-no">1057</span><span id="line-1057"> return;</span> |
| <span class="source-line-no">1058</span><span id="line-1058"> }</span> |
| <span class="source-line-no">1059</span><span id="line-1059"> execShutdown(new MasterObserverOperation() {</span> |
| <span class="source-line-no">1060</span><span id="line-1060"> @Override</span> |
| <span class="source-line-no">1061</span><span id="line-1061"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1062</span><span id="line-1062"> observer.preShutdown(this);</span> |
| <span class="source-line-no">1063</span><span id="line-1063"> }</span> |
| <span class="source-line-no">1064</span><span id="line-1064"></span> |
| <span class="source-line-no">1065</span><span id="line-1065"> @Override</span> |
| <span class="source-line-no">1066</span><span id="line-1066"> public void postEnvCall() {</span> |
| <span class="source-line-no">1067</span><span id="line-1067"> // invoke coprocessor stop method</span> |
| <span class="source-line-no">1068</span><span id="line-1068"> shutdown(this.getEnvironment());</span> |
| <span class="source-line-no">1069</span><span id="line-1069"> }</span> |
| <span class="source-line-no">1070</span><span id="line-1070"> });</span> |
| <span class="source-line-no">1071</span><span id="line-1071"> }</span> |
| <span class="source-line-no">1072</span><span id="line-1072"></span> |
| <span class="source-line-no">1073</span><span id="line-1073"> public void preStopMaster() throws IOException {</span> |
| <span class="source-line-no">1074</span><span id="line-1074"> // While stopping master all coprocessors method should be executed first then the coprocessor</span> |
| <span class="source-line-no">1075</span><span id="line-1075"> // environment should be cleaned up.</span> |
| <span class="source-line-no">1076</span><span id="line-1076"> if (coprocEnvironments.isEmpty()) {</span> |
| <span class="source-line-no">1077</span><span id="line-1077"> return;</span> |
| <span class="source-line-no">1078</span><span id="line-1078"> }</span> |
| <span class="source-line-no">1079</span><span id="line-1079"> execShutdown(new MasterObserverOperation() {</span> |
| <span class="source-line-no">1080</span><span id="line-1080"> @Override</span> |
| <span class="source-line-no">1081</span><span id="line-1081"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1082</span><span id="line-1082"> observer.preStopMaster(this);</span> |
| <span class="source-line-no">1083</span><span id="line-1083"> }</span> |
| <span class="source-line-no">1084</span><span id="line-1084"></span> |
| <span class="source-line-no">1085</span><span id="line-1085"> @Override</span> |
| <span class="source-line-no">1086</span><span id="line-1086"> public void postEnvCall() {</span> |
| <span class="source-line-no">1087</span><span id="line-1087"> // invoke coprocessor stop method</span> |
| <span class="source-line-no">1088</span><span id="line-1088"> shutdown(this.getEnvironment());</span> |
| <span class="source-line-no">1089</span><span id="line-1089"> }</span> |
| <span class="source-line-no">1090</span><span id="line-1090"> });</span> |
| <span class="source-line-no">1091</span><span id="line-1091"> }</span> |
| <span class="source-line-no">1092</span><span id="line-1092"></span> |
| <span class="source-line-no">1093</span><span id="line-1093"> public void preMasterInitialization() throws IOException {</span> |
| <span class="source-line-no">1094</span><span id="line-1094"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1095</span><span id="line-1095"> @Override</span> |
| <span class="source-line-no">1096</span><span id="line-1096"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1097</span><span id="line-1097"> observer.preMasterInitialization(this);</span> |
| <span class="source-line-no">1098</span><span id="line-1098"> }</span> |
| <span class="source-line-no">1099</span><span id="line-1099"> });</span> |
| <span class="source-line-no">1100</span><span id="line-1100"> }</span> |
| <span class="source-line-no">1101</span><span id="line-1101"></span> |
| <span class="source-line-no">1102</span><span id="line-1102"> public void postStartMaster() throws IOException {</span> |
| <span class="source-line-no">1103</span><span id="line-1103"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1104</span><span id="line-1104"> @Override</span> |
| <span class="source-line-no">1105</span><span id="line-1105"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1106</span><span id="line-1106"> observer.postStartMaster(this);</span> |
| <span class="source-line-no">1107</span><span id="line-1107"> }</span> |
| <span class="source-line-no">1108</span><span id="line-1108"> });</span> |
| <span class="source-line-no">1109</span><span id="line-1109"> }</span> |
| <span class="source-line-no">1110</span><span id="line-1110"></span> |
| <span class="source-line-no">1111</span><span id="line-1111"> public void preSnapshot(final SnapshotDescription snapshot,</span> |
| <span class="source-line-no">1112</span><span id="line-1112"> final TableDescriptor hTableDescriptor, final User user) throws IOException {</span> |
| <span class="source-line-no">1113</span><span id="line-1113"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">1114</span><span id="line-1114"> @Override</span> |
| <span class="source-line-no">1115</span><span id="line-1115"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1116</span><span id="line-1116"> observer.preSnapshot(this, snapshot, hTableDescriptor);</span> |
| <span class="source-line-no">1117</span><span id="line-1117"> }</span> |
| <span class="source-line-no">1118</span><span id="line-1118"> });</span> |
| <span class="source-line-no">1119</span><span id="line-1119"> }</span> |
| <span class="source-line-no">1120</span><span id="line-1120"></span> |
| <span class="source-line-no">1121</span><span id="line-1121"> public void postSnapshot(final SnapshotDescription snapshot,</span> |
| <span class="source-line-no">1122</span><span id="line-1122"> final TableDescriptor hTableDescriptor, final User user) throws IOException {</span> |
| <span class="source-line-no">1123</span><span id="line-1123"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation(user) {</span> |
| <span class="source-line-no">1124</span><span id="line-1124"> @Override</span> |
| <span class="source-line-no">1125</span><span id="line-1125"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1126</span><span id="line-1126"> observer.postSnapshot(this, snapshot, hTableDescriptor);</span> |
| <span class="source-line-no">1127</span><span id="line-1127"> }</span> |
| <span class="source-line-no">1128</span><span id="line-1128"> });</span> |
| <span class="source-line-no">1129</span><span id="line-1129"> }</span> |
| <span class="source-line-no">1130</span><span id="line-1130"></span> |
| <span class="source-line-no">1131</span><span id="line-1131"> public void postCompletedSnapshotAction(SnapshotDescription snapshot,</span> |
| <span class="source-line-no">1132</span><span id="line-1132"> TableDescriptor hTableDescriptor) throws IOException {</span> |
| <span class="source-line-no">1133</span><span id="line-1133"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1134</span><span id="line-1134"> @Override</span> |
| <span class="source-line-no">1135</span><span id="line-1135"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1136</span><span id="line-1136"> observer.postCompletedSnapshotAction(this, snapshot, hTableDescriptor);</span> |
| <span class="source-line-no">1137</span><span id="line-1137"> }</span> |
| <span class="source-line-no">1138</span><span id="line-1138"> });</span> |
| <span class="source-line-no">1139</span><span id="line-1139"> }</span> |
| <span class="source-line-no">1140</span><span id="line-1140"></span> |
| <span class="source-line-no">1141</span><span id="line-1141"> public void preListSnapshot(final SnapshotDescription snapshot) throws IOException {</span> |
| <span class="source-line-no">1142</span><span id="line-1142"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1143</span><span id="line-1143"> @Override</span> |
| <span class="source-line-no">1144</span><span id="line-1144"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1145</span><span id="line-1145"> observer.preListSnapshot(this, snapshot);</span> |
| <span class="source-line-no">1146</span><span id="line-1146"> }</span> |
| <span class="source-line-no">1147</span><span id="line-1147"> });</span> |
| <span class="source-line-no">1148</span><span id="line-1148"> }</span> |
| <span class="source-line-no">1149</span><span id="line-1149"></span> |
| <span class="source-line-no">1150</span><span id="line-1150"> public void postListSnapshot(final SnapshotDescription snapshot) throws IOException {</span> |
| <span class="source-line-no">1151</span><span id="line-1151"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1152</span><span id="line-1152"> @Override</span> |
| <span class="source-line-no">1153</span><span id="line-1153"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1154</span><span id="line-1154"> observer.postListSnapshot(this, snapshot);</span> |
| <span class="source-line-no">1155</span><span id="line-1155"> }</span> |
| <span class="source-line-no">1156</span><span id="line-1156"> });</span> |
| <span class="source-line-no">1157</span><span id="line-1157"> }</span> |
| <span class="source-line-no">1158</span><span id="line-1158"></span> |
| <span class="source-line-no">1159</span><span id="line-1159"> public void preCloneSnapshot(final SnapshotDescription snapshot,</span> |
| <span class="source-line-no">1160</span><span id="line-1160"> final TableDescriptor hTableDescriptor) throws IOException {</span> |
| <span class="source-line-no">1161</span><span id="line-1161"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1162</span><span id="line-1162"> @Override</span> |
| <span class="source-line-no">1163</span><span id="line-1163"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1164</span><span id="line-1164"> observer.preCloneSnapshot(this, snapshot, hTableDescriptor);</span> |
| <span class="source-line-no">1165</span><span id="line-1165"> }</span> |
| <span class="source-line-no">1166</span><span id="line-1166"> });</span> |
| <span class="source-line-no">1167</span><span id="line-1167"> }</span> |
| <span class="source-line-no">1168</span><span id="line-1168"></span> |
| <span class="source-line-no">1169</span><span id="line-1169"> public void postCloneSnapshot(final SnapshotDescription snapshot,</span> |
| <span class="source-line-no">1170</span><span id="line-1170"> final TableDescriptor hTableDescriptor) throws IOException {</span> |
| <span class="source-line-no">1171</span><span id="line-1171"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1172</span><span id="line-1172"> @Override</span> |
| <span class="source-line-no">1173</span><span id="line-1173"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1174</span><span id="line-1174"> observer.postCloneSnapshot(this, snapshot, hTableDescriptor);</span> |
| <span class="source-line-no">1175</span><span id="line-1175"> }</span> |
| <span class="source-line-no">1176</span><span id="line-1176"> });</span> |
| <span class="source-line-no">1177</span><span id="line-1177"> }</span> |
| <span class="source-line-no">1178</span><span id="line-1178"></span> |
| <span class="source-line-no">1179</span><span id="line-1179"> public void preRestoreSnapshot(final SnapshotDescription snapshot,</span> |
| <span class="source-line-no">1180</span><span id="line-1180"> final TableDescriptor hTableDescriptor) throws IOException {</span> |
| <span class="source-line-no">1181</span><span id="line-1181"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1182</span><span id="line-1182"> @Override</span> |
| <span class="source-line-no">1183</span><span id="line-1183"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1184</span><span id="line-1184"> observer.preRestoreSnapshot(this, snapshot, hTableDescriptor);</span> |
| <span class="source-line-no">1185</span><span id="line-1185"> }</span> |
| <span class="source-line-no">1186</span><span id="line-1186"> });</span> |
| <span class="source-line-no">1187</span><span id="line-1187"> }</span> |
| <span class="source-line-no">1188</span><span id="line-1188"></span> |
| <span class="source-line-no">1189</span><span id="line-1189"> public void postRestoreSnapshot(final SnapshotDescription snapshot,</span> |
| <span class="source-line-no">1190</span><span id="line-1190"> final TableDescriptor hTableDescriptor) throws IOException {</span> |
| <span class="source-line-no">1191</span><span id="line-1191"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1192</span><span id="line-1192"> @Override</span> |
| <span class="source-line-no">1193</span><span id="line-1193"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1194</span><span id="line-1194"> observer.postRestoreSnapshot(this, snapshot, hTableDescriptor);</span> |
| <span class="source-line-no">1195</span><span id="line-1195"> }</span> |
| <span class="source-line-no">1196</span><span id="line-1196"> });</span> |
| <span class="source-line-no">1197</span><span id="line-1197"> }</span> |
| <span class="source-line-no">1198</span><span id="line-1198"></span> |
| <span class="source-line-no">1199</span><span id="line-1199"> public void preDeleteSnapshot(final SnapshotDescription snapshot) throws IOException {</span> |
| <span class="source-line-no">1200</span><span id="line-1200"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1201</span><span id="line-1201"> @Override</span> |
| <span class="source-line-no">1202</span><span id="line-1202"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1203</span><span id="line-1203"> observer.preDeleteSnapshot(this, snapshot);</span> |
| <span class="source-line-no">1204</span><span id="line-1204"> }</span> |
| <span class="source-line-no">1205</span><span id="line-1205"> });</span> |
| <span class="source-line-no">1206</span><span id="line-1206"> }</span> |
| <span class="source-line-no">1207</span><span id="line-1207"></span> |
| <span class="source-line-no">1208</span><span id="line-1208"> public void postDeleteSnapshot(final SnapshotDescription snapshot) throws IOException {</span> |
| <span class="source-line-no">1209</span><span id="line-1209"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1210</span><span id="line-1210"> @Override</span> |
| <span class="source-line-no">1211</span><span id="line-1211"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1212</span><span id="line-1212"> observer.postDeleteSnapshot(this, snapshot);</span> |
| <span class="source-line-no">1213</span><span id="line-1213"> }</span> |
| <span class="source-line-no">1214</span><span id="line-1214"> });</span> |
| <span class="source-line-no">1215</span><span id="line-1215"> }</span> |
| <span class="source-line-no">1216</span><span id="line-1216"></span> |
| <span class="source-line-no">1217</span><span id="line-1217"> public void preGetTableDescriptors(final List<TableName> tableNamesList,</span> |
| <span class="source-line-no">1218</span><span id="line-1218"> final List<TableDescriptor> descriptors, final String regex) throws IOException {</span> |
| <span class="source-line-no">1219</span><span id="line-1219"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1220</span><span id="line-1220"> @Override</span> |
| <span class="source-line-no">1221</span><span id="line-1221"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1222</span><span id="line-1222"> observer.preGetTableDescriptors(this, tableNamesList, descriptors, regex);</span> |
| <span class="source-line-no">1223</span><span id="line-1223"> }</span> |
| <span class="source-line-no">1224</span><span id="line-1224"> });</span> |
| <span class="source-line-no">1225</span><span id="line-1225"> }</span> |
| <span class="source-line-no">1226</span><span id="line-1226"></span> |
| <span class="source-line-no">1227</span><span id="line-1227"> public void postGetTableDescriptors(final List<TableName> tableNamesList,</span> |
| <span class="source-line-no">1228</span><span id="line-1228"> final List<TableDescriptor> descriptors, final String regex) throws IOException {</span> |
| <span class="source-line-no">1229</span><span id="line-1229"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1230</span><span id="line-1230"> @Override</span> |
| <span class="source-line-no">1231</span><span id="line-1231"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1232</span><span id="line-1232"> observer.postGetTableDescriptors(this, tableNamesList, descriptors, regex);</span> |
| <span class="source-line-no">1233</span><span id="line-1233"> }</span> |
| <span class="source-line-no">1234</span><span id="line-1234"> });</span> |
| <span class="source-line-no">1235</span><span id="line-1235"> }</span> |
| <span class="source-line-no">1236</span><span id="line-1236"></span> |
| <span class="source-line-no">1237</span><span id="line-1237"> public void preGetTableNames(final List<TableDescriptor> descriptors, final String regex)</span> |
| <span class="source-line-no">1238</span><span id="line-1238"> throws IOException {</span> |
| <span class="source-line-no">1239</span><span id="line-1239"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1240</span><span id="line-1240"> @Override</span> |
| <span class="source-line-no">1241</span><span id="line-1241"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1242</span><span id="line-1242"> observer.preGetTableNames(this, descriptors, regex);</span> |
| <span class="source-line-no">1243</span><span id="line-1243"> }</span> |
| <span class="source-line-no">1244</span><span id="line-1244"> });</span> |
| <span class="source-line-no">1245</span><span id="line-1245"> }</span> |
| <span class="source-line-no">1246</span><span id="line-1246"></span> |
| <span class="source-line-no">1247</span><span id="line-1247"> public void postGetTableNames(final List<TableDescriptor> descriptors, final String regex)</span> |
| <span class="source-line-no">1248</span><span id="line-1248"> throws IOException {</span> |
| <span class="source-line-no">1249</span><span id="line-1249"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1250</span><span id="line-1250"> @Override</span> |
| <span class="source-line-no">1251</span><span id="line-1251"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1252</span><span id="line-1252"> observer.postGetTableNames(this, descriptors, regex);</span> |
| <span class="source-line-no">1253</span><span id="line-1253"> }</span> |
| <span class="source-line-no">1254</span><span id="line-1254"> });</span> |
| <span class="source-line-no">1255</span><span id="line-1255"> }</span> |
| <span class="source-line-no">1256</span><span id="line-1256"></span> |
| <span class="source-line-no">1257</span><span id="line-1257"> public void preTableFlush(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">1258</span><span id="line-1258"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1259</span><span id="line-1259"> @Override</span> |
| <span class="source-line-no">1260</span><span id="line-1260"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1261</span><span id="line-1261"> observer.preTableFlush(this, tableName);</span> |
| <span class="source-line-no">1262</span><span id="line-1262"> }</span> |
| <span class="source-line-no">1263</span><span id="line-1263"> });</span> |
| <span class="source-line-no">1264</span><span id="line-1264"> }</span> |
| <span class="source-line-no">1265</span><span id="line-1265"></span> |
| <span class="source-line-no">1266</span><span id="line-1266"> public void postTableFlush(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">1267</span><span id="line-1267"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1268</span><span id="line-1268"> @Override</span> |
| <span class="source-line-no">1269</span><span id="line-1269"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1270</span><span id="line-1270"> observer.postTableFlush(this, tableName);</span> |
| <span class="source-line-no">1271</span><span id="line-1271"> }</span> |
| <span class="source-line-no">1272</span><span id="line-1272"> });</span> |
| <span class="source-line-no">1273</span><span id="line-1273"> }</span> |
| <span class="source-line-no">1274</span><span id="line-1274"></span> |
| <span class="source-line-no">1275</span><span id="line-1275"> public void preMasterStoreFlush() throws IOException {</span> |
| <span class="source-line-no">1276</span><span id="line-1276"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1277</span><span id="line-1277"> @Override</span> |
| <span class="source-line-no">1278</span><span id="line-1278"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1279</span><span id="line-1279"> observer.preMasterStoreFlush(this);</span> |
| <span class="source-line-no">1280</span><span id="line-1280"> }</span> |
| <span class="source-line-no">1281</span><span id="line-1281"> });</span> |
| <span class="source-line-no">1282</span><span id="line-1282"> }</span> |
| <span class="source-line-no">1283</span><span id="line-1283"></span> |
| <span class="source-line-no">1284</span><span id="line-1284"> public void postMasterStoreFlush() throws IOException {</span> |
| <span class="source-line-no">1285</span><span id="line-1285"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1286</span><span id="line-1286"> @Override</span> |
| <span class="source-line-no">1287</span><span id="line-1287"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1288</span><span id="line-1288"> observer.postMasterStoreFlush(this);</span> |
| <span class="source-line-no">1289</span><span id="line-1289"> }</span> |
| <span class="source-line-no">1290</span><span id="line-1290"> });</span> |
| <span class="source-line-no">1291</span><span id="line-1291"> }</span> |
| <span class="source-line-no">1292</span><span id="line-1292"></span> |
| <span class="source-line-no">1293</span><span id="line-1293"> public void preSetUserQuota(final String user, final GlobalQuotaSettings quotas)</span> |
| <span class="source-line-no">1294</span><span id="line-1294"> throws IOException {</span> |
| <span class="source-line-no">1295</span><span id="line-1295"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1296</span><span id="line-1296"> @Override</span> |
| <span class="source-line-no">1297</span><span id="line-1297"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1298</span><span id="line-1298"> observer.preSetUserQuota(this, user, quotas);</span> |
| <span class="source-line-no">1299</span><span id="line-1299"> }</span> |
| <span class="source-line-no">1300</span><span id="line-1300"> });</span> |
| <span class="source-line-no">1301</span><span id="line-1301"> }</span> |
| <span class="source-line-no">1302</span><span id="line-1302"></span> |
| <span class="source-line-no">1303</span><span id="line-1303"> public void postSetUserQuota(final String user, final GlobalQuotaSettings quotas)</span> |
| <span class="source-line-no">1304</span><span id="line-1304"> throws IOException {</span> |
| <span class="source-line-no">1305</span><span id="line-1305"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1306</span><span id="line-1306"> @Override</span> |
| <span class="source-line-no">1307</span><span id="line-1307"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1308</span><span id="line-1308"> observer.postSetUserQuota(this, user, quotas);</span> |
| <span class="source-line-no">1309</span><span id="line-1309"> }</span> |
| <span class="source-line-no">1310</span><span id="line-1310"> });</span> |
| <span class="source-line-no">1311</span><span id="line-1311"> }</span> |
| <span class="source-line-no">1312</span><span id="line-1312"></span> |
| <span class="source-line-no">1313</span><span id="line-1313"> public void preSetUserQuota(final String user, final TableName table,</span> |
| <span class="source-line-no">1314</span><span id="line-1314"> final GlobalQuotaSettings quotas) throws IOException {</span> |
| <span class="source-line-no">1315</span><span id="line-1315"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1316</span><span id="line-1316"> @Override</span> |
| <span class="source-line-no">1317</span><span id="line-1317"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1318</span><span id="line-1318"> observer.preSetUserQuota(this, user, table, quotas);</span> |
| <span class="source-line-no">1319</span><span id="line-1319"> }</span> |
| <span class="source-line-no">1320</span><span id="line-1320"> });</span> |
| <span class="source-line-no">1321</span><span id="line-1321"> }</span> |
| <span class="source-line-no">1322</span><span id="line-1322"></span> |
| <span class="source-line-no">1323</span><span id="line-1323"> public void postSetUserQuota(final String user, final TableName table,</span> |
| <span class="source-line-no">1324</span><span id="line-1324"> final GlobalQuotaSettings quotas) throws IOException {</span> |
| <span class="source-line-no">1325</span><span id="line-1325"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1326</span><span id="line-1326"> @Override</span> |
| <span class="source-line-no">1327</span><span id="line-1327"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1328</span><span id="line-1328"> observer.postSetUserQuota(this, user, table, quotas);</span> |
| <span class="source-line-no">1329</span><span id="line-1329"> }</span> |
| <span class="source-line-no">1330</span><span id="line-1330"> });</span> |
| <span class="source-line-no">1331</span><span id="line-1331"> }</span> |
| <span class="source-line-no">1332</span><span id="line-1332"></span> |
| <span class="source-line-no">1333</span><span id="line-1333"> public void preSetUserQuota(final String user, final String namespace,</span> |
| <span class="source-line-no">1334</span><span id="line-1334"> final GlobalQuotaSettings quotas) throws IOException {</span> |
| <span class="source-line-no">1335</span><span id="line-1335"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1336</span><span id="line-1336"> @Override</span> |
| <span class="source-line-no">1337</span><span id="line-1337"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1338</span><span id="line-1338"> observer.preSetUserQuota(this, user, namespace, quotas);</span> |
| <span class="source-line-no">1339</span><span id="line-1339"> }</span> |
| <span class="source-line-no">1340</span><span id="line-1340"> });</span> |
| <span class="source-line-no">1341</span><span id="line-1341"> }</span> |
| <span class="source-line-no">1342</span><span id="line-1342"></span> |
| <span class="source-line-no">1343</span><span id="line-1343"> public void postSetUserQuota(final String user, final String namespace,</span> |
| <span class="source-line-no">1344</span><span id="line-1344"> final GlobalQuotaSettings quotas) throws IOException {</span> |
| <span class="source-line-no">1345</span><span id="line-1345"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1346</span><span id="line-1346"> @Override</span> |
| <span class="source-line-no">1347</span><span id="line-1347"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1348</span><span id="line-1348"> observer.postSetUserQuota(this, user, namespace, quotas);</span> |
| <span class="source-line-no">1349</span><span id="line-1349"> }</span> |
| <span class="source-line-no">1350</span><span id="line-1350"> });</span> |
| <span class="source-line-no">1351</span><span id="line-1351"> }</span> |
| <span class="source-line-no">1352</span><span id="line-1352"></span> |
| <span class="source-line-no">1353</span><span id="line-1353"> public void preSetTableQuota(final TableName table, final GlobalQuotaSettings quotas)</span> |
| <span class="source-line-no">1354</span><span id="line-1354"> throws IOException {</span> |
| <span class="source-line-no">1355</span><span id="line-1355"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1356</span><span id="line-1356"> @Override</span> |
| <span class="source-line-no">1357</span><span id="line-1357"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1358</span><span id="line-1358"> observer.preSetTableQuota(this, table, quotas);</span> |
| <span class="source-line-no">1359</span><span id="line-1359"> }</span> |
| <span class="source-line-no">1360</span><span id="line-1360"> });</span> |
| <span class="source-line-no">1361</span><span id="line-1361"> }</span> |
| <span class="source-line-no">1362</span><span id="line-1362"></span> |
| <span class="source-line-no">1363</span><span id="line-1363"> public void postSetTableQuota(final TableName table, final GlobalQuotaSettings quotas)</span> |
| <span class="source-line-no">1364</span><span id="line-1364"> throws IOException {</span> |
| <span class="source-line-no">1365</span><span id="line-1365"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1366</span><span id="line-1366"> @Override</span> |
| <span class="source-line-no">1367</span><span id="line-1367"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1368</span><span id="line-1368"> observer.postSetTableQuota(this, table, quotas);</span> |
| <span class="source-line-no">1369</span><span id="line-1369"> }</span> |
| <span class="source-line-no">1370</span><span id="line-1370"> });</span> |
| <span class="source-line-no">1371</span><span id="line-1371"> }</span> |
| <span class="source-line-no">1372</span><span id="line-1372"></span> |
| <span class="source-line-no">1373</span><span id="line-1373"> public void preSetNamespaceQuota(final String namespace, final GlobalQuotaSettings quotas)</span> |
| <span class="source-line-no">1374</span><span id="line-1374"> throws IOException {</span> |
| <span class="source-line-no">1375</span><span id="line-1375"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1376</span><span id="line-1376"> @Override</span> |
| <span class="source-line-no">1377</span><span id="line-1377"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1378</span><span id="line-1378"> observer.preSetNamespaceQuota(this, namespace, quotas);</span> |
| <span class="source-line-no">1379</span><span id="line-1379"> }</span> |
| <span class="source-line-no">1380</span><span id="line-1380"> });</span> |
| <span class="source-line-no">1381</span><span id="line-1381"> }</span> |
| <span class="source-line-no">1382</span><span id="line-1382"></span> |
| <span class="source-line-no">1383</span><span id="line-1383"> public void postSetNamespaceQuota(final String namespace, final GlobalQuotaSettings quotas)</span> |
| <span class="source-line-no">1384</span><span id="line-1384"> throws IOException {</span> |
| <span class="source-line-no">1385</span><span id="line-1385"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1386</span><span id="line-1386"> @Override</span> |
| <span class="source-line-no">1387</span><span id="line-1387"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1388</span><span id="line-1388"> observer.postSetNamespaceQuota(this, namespace, quotas);</span> |
| <span class="source-line-no">1389</span><span id="line-1389"> }</span> |
| <span class="source-line-no">1390</span><span id="line-1390"> });</span> |
| <span class="source-line-no">1391</span><span id="line-1391"> }</span> |
| <span class="source-line-no">1392</span><span id="line-1392"></span> |
| <span class="source-line-no">1393</span><span id="line-1393"> public void preSetRegionServerQuota(final String regionServer, final GlobalQuotaSettings quotas)</span> |
| <span class="source-line-no">1394</span><span id="line-1394"> throws IOException {</span> |
| <span class="source-line-no">1395</span><span id="line-1395"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1396</span><span id="line-1396"> @Override</span> |
| <span class="source-line-no">1397</span><span id="line-1397"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1398</span><span id="line-1398"> observer.preSetRegionServerQuota(this, regionServer, quotas);</span> |
| <span class="source-line-no">1399</span><span id="line-1399"> }</span> |
| <span class="source-line-no">1400</span><span id="line-1400"> });</span> |
| <span class="source-line-no">1401</span><span id="line-1401"> }</span> |
| <span class="source-line-no">1402</span><span id="line-1402"></span> |
| <span class="source-line-no">1403</span><span id="line-1403"> public void postSetRegionServerQuota(final String regionServer, final GlobalQuotaSettings quotas)</span> |
| <span class="source-line-no">1404</span><span id="line-1404"> throws IOException {</span> |
| <span class="source-line-no">1405</span><span id="line-1405"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1406</span><span id="line-1406"> @Override</span> |
| <span class="source-line-no">1407</span><span id="line-1407"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1408</span><span id="line-1408"> observer.postSetRegionServerQuota(this, regionServer, quotas);</span> |
| <span class="source-line-no">1409</span><span id="line-1409"> }</span> |
| <span class="source-line-no">1410</span><span id="line-1410"> });</span> |
| <span class="source-line-no">1411</span><span id="line-1411"> }</span> |
| <span class="source-line-no">1412</span><span id="line-1412"></span> |
| <span class="source-line-no">1413</span><span id="line-1413"> public void preMoveServersAndTables(final Set<Address> servers, final Set<TableName> tables,</span> |
| <span class="source-line-no">1414</span><span id="line-1414"> final String targetGroup) throws IOException {</span> |
| <span class="source-line-no">1415</span><span id="line-1415"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1416</span><span id="line-1416"> @Override</span> |
| <span class="source-line-no">1417</span><span id="line-1417"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1418</span><span id="line-1418"> observer.preMoveServersAndTables(this, servers, tables, targetGroup);</span> |
| <span class="source-line-no">1419</span><span id="line-1419"> }</span> |
| <span class="source-line-no">1420</span><span id="line-1420"> });</span> |
| <span class="source-line-no">1421</span><span id="line-1421"> }</span> |
| <span class="source-line-no">1422</span><span id="line-1422"></span> |
| <span class="source-line-no">1423</span><span id="line-1423"> public void postMoveServersAndTables(final Set<Address> servers, final Set<TableName> tables,</span> |
| <span class="source-line-no">1424</span><span id="line-1424"> final String targetGroup) throws IOException {</span> |
| <span class="source-line-no">1425</span><span id="line-1425"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1426</span><span id="line-1426"> @Override</span> |
| <span class="source-line-no">1427</span><span id="line-1427"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1428</span><span id="line-1428"> observer.postMoveServersAndTables(this, servers, tables, targetGroup);</span> |
| <span class="source-line-no">1429</span><span id="line-1429"> }</span> |
| <span class="source-line-no">1430</span><span id="line-1430"> });</span> |
| <span class="source-line-no">1431</span><span id="line-1431"> }</span> |
| <span class="source-line-no">1432</span><span id="line-1432"></span> |
| <span class="source-line-no">1433</span><span id="line-1433"> public void preMoveServers(final Set<Address> servers, final String targetGroup)</span> |
| <span class="source-line-no">1434</span><span id="line-1434"> throws IOException {</span> |
| <span class="source-line-no">1435</span><span id="line-1435"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1436</span><span id="line-1436"> @Override</span> |
| <span class="source-line-no">1437</span><span id="line-1437"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1438</span><span id="line-1438"> observer.preMoveServers(this, servers, targetGroup);</span> |
| <span class="source-line-no">1439</span><span id="line-1439"> }</span> |
| <span class="source-line-no">1440</span><span id="line-1440"> });</span> |
| <span class="source-line-no">1441</span><span id="line-1441"> }</span> |
| <span class="source-line-no">1442</span><span id="line-1442"></span> |
| <span class="source-line-no">1443</span><span id="line-1443"> public void postMoveServers(final Set<Address> servers, final String targetGroup)</span> |
| <span class="source-line-no">1444</span><span id="line-1444"> throws IOException {</span> |
| <span class="source-line-no">1445</span><span id="line-1445"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1446</span><span id="line-1446"> @Override</span> |
| <span class="source-line-no">1447</span><span id="line-1447"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1448</span><span id="line-1448"> observer.postMoveServers(this, servers, targetGroup);</span> |
| <span class="source-line-no">1449</span><span id="line-1449"> }</span> |
| <span class="source-line-no">1450</span><span id="line-1450"> });</span> |
| <span class="source-line-no">1451</span><span id="line-1451"> }</span> |
| <span class="source-line-no">1452</span><span id="line-1452"></span> |
| <span class="source-line-no">1453</span><span id="line-1453"> public void preMoveTables(final Set<TableName> tables, final String targetGroup)</span> |
| <span class="source-line-no">1454</span><span id="line-1454"> throws IOException {</span> |
| <span class="source-line-no">1455</span><span id="line-1455"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1456</span><span id="line-1456"> @Override</span> |
| <span class="source-line-no">1457</span><span id="line-1457"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1458</span><span id="line-1458"> observer.preMoveTables(this, tables, targetGroup);</span> |
| <span class="source-line-no">1459</span><span id="line-1459"> }</span> |
| <span class="source-line-no">1460</span><span id="line-1460"> });</span> |
| <span class="source-line-no">1461</span><span id="line-1461"> }</span> |
| <span class="source-line-no">1462</span><span id="line-1462"></span> |
| <span class="source-line-no">1463</span><span id="line-1463"> public void postMoveTables(final Set<TableName> tables, final String targetGroup)</span> |
| <span class="source-line-no">1464</span><span id="line-1464"> throws IOException {</span> |
| <span class="source-line-no">1465</span><span id="line-1465"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1466</span><span id="line-1466"> @Override</span> |
| <span class="source-line-no">1467</span><span id="line-1467"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1468</span><span id="line-1468"> observer.postMoveTables(this, tables, targetGroup);</span> |
| <span class="source-line-no">1469</span><span id="line-1469"> }</span> |
| <span class="source-line-no">1470</span><span id="line-1470"> });</span> |
| <span class="source-line-no">1471</span><span id="line-1471"> }</span> |
| <span class="source-line-no">1472</span><span id="line-1472"></span> |
| <span class="source-line-no">1473</span><span id="line-1473"> public void preAddRSGroup(final String name) throws IOException {</span> |
| <span class="source-line-no">1474</span><span id="line-1474"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1475</span><span id="line-1475"> @Override</span> |
| <span class="source-line-no">1476</span><span id="line-1476"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1477</span><span id="line-1477"> observer.preAddRSGroup(this, name);</span> |
| <span class="source-line-no">1478</span><span id="line-1478"> }</span> |
| <span class="source-line-no">1479</span><span id="line-1479"> });</span> |
| <span class="source-line-no">1480</span><span id="line-1480"> }</span> |
| <span class="source-line-no">1481</span><span id="line-1481"></span> |
| <span class="source-line-no">1482</span><span id="line-1482"> public void postAddRSGroup(final String name) throws IOException {</span> |
| <span class="source-line-no">1483</span><span id="line-1483"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1484</span><span id="line-1484"> @Override</span> |
| <span class="source-line-no">1485</span><span id="line-1485"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1486</span><span id="line-1486"> observer.postAddRSGroup(this, name);</span> |
| <span class="source-line-no">1487</span><span id="line-1487"> }</span> |
| <span class="source-line-no">1488</span><span id="line-1488"> });</span> |
| <span class="source-line-no">1489</span><span id="line-1489"> }</span> |
| <span class="source-line-no">1490</span><span id="line-1490"></span> |
| <span class="source-line-no">1491</span><span id="line-1491"> public void preRemoveRSGroup(final String name) throws IOException {</span> |
| <span class="source-line-no">1492</span><span id="line-1492"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1493</span><span id="line-1493"> @Override</span> |
| <span class="source-line-no">1494</span><span id="line-1494"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1495</span><span id="line-1495"> observer.preRemoveRSGroup(this, name);</span> |
| <span class="source-line-no">1496</span><span id="line-1496"> }</span> |
| <span class="source-line-no">1497</span><span id="line-1497"> });</span> |
| <span class="source-line-no">1498</span><span id="line-1498"> }</span> |
| <span class="source-line-no">1499</span><span id="line-1499"></span> |
| <span class="source-line-no">1500</span><span id="line-1500"> public void postRemoveRSGroup(final String name) throws IOException {</span> |
| <span class="source-line-no">1501</span><span id="line-1501"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1502</span><span id="line-1502"> @Override</span> |
| <span class="source-line-no">1503</span><span id="line-1503"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1504</span><span id="line-1504"> observer.postRemoveRSGroup(this, name);</span> |
| <span class="source-line-no">1505</span><span id="line-1505"> }</span> |
| <span class="source-line-no">1506</span><span id="line-1506"> });</span> |
| <span class="source-line-no">1507</span><span id="line-1507"> }</span> |
| <span class="source-line-no">1508</span><span id="line-1508"></span> |
| <span class="source-line-no">1509</span><span id="line-1509"> public void preBalanceRSGroup(final String name, final BalanceRequest request)</span> |
| <span class="source-line-no">1510</span><span id="line-1510"> throws IOException {</span> |
| <span class="source-line-no">1511</span><span id="line-1511"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1512</span><span id="line-1512"> @Override</span> |
| <span class="source-line-no">1513</span><span id="line-1513"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1514</span><span id="line-1514"> observer.preBalanceRSGroup(this, name, request);</span> |
| <span class="source-line-no">1515</span><span id="line-1515"> }</span> |
| <span class="source-line-no">1516</span><span id="line-1516"> });</span> |
| <span class="source-line-no">1517</span><span id="line-1517"> }</span> |
| <span class="source-line-no">1518</span><span id="line-1518"></span> |
| <span class="source-line-no">1519</span><span id="line-1519"> public void postBalanceRSGroup(final String name, final BalanceRequest request,</span> |
| <span class="source-line-no">1520</span><span id="line-1520"> final BalanceResponse response) throws IOException {</span> |
| <span class="source-line-no">1521</span><span id="line-1521"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1522</span><span id="line-1522"> @Override</span> |
| <span class="source-line-no">1523</span><span id="line-1523"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1524</span><span id="line-1524"> observer.postBalanceRSGroup(this, name, request, response);</span> |
| <span class="source-line-no">1525</span><span id="line-1525"> }</span> |
| <span class="source-line-no">1526</span><span id="line-1526"> });</span> |
| <span class="source-line-no">1527</span><span id="line-1527"> }</span> |
| <span class="source-line-no">1528</span><span id="line-1528"></span> |
| <span class="source-line-no">1529</span><span id="line-1529"> public void preRemoveServers(final Set<Address> servers) throws IOException {</span> |
| <span class="source-line-no">1530</span><span id="line-1530"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1531</span><span id="line-1531"> @Override</span> |
| <span class="source-line-no">1532</span><span id="line-1532"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1533</span><span id="line-1533"> observer.preRemoveServers(this, servers);</span> |
| <span class="source-line-no">1534</span><span id="line-1534"> }</span> |
| <span class="source-line-no">1535</span><span id="line-1535"> });</span> |
| <span class="source-line-no">1536</span><span id="line-1536"> }</span> |
| <span class="source-line-no">1537</span><span id="line-1537"></span> |
| <span class="source-line-no">1538</span><span id="line-1538"> public void postRemoveServers(final Set<Address> servers) throws IOException {</span> |
| <span class="source-line-no">1539</span><span id="line-1539"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1540</span><span id="line-1540"> @Override</span> |
| <span class="source-line-no">1541</span><span id="line-1541"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1542</span><span id="line-1542"> observer.postRemoveServers(this, servers);</span> |
| <span class="source-line-no">1543</span><span id="line-1543"> }</span> |
| <span class="source-line-no">1544</span><span id="line-1544"> });</span> |
| <span class="source-line-no">1545</span><span id="line-1545"> }</span> |
| <span class="source-line-no">1546</span><span id="line-1546"></span> |
| <span class="source-line-no">1547</span><span id="line-1547"> public void preGetRSGroupInfo(final String groupName) throws IOException {</span> |
| <span class="source-line-no">1548</span><span id="line-1548"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1549</span><span id="line-1549"> @Override</span> |
| <span class="source-line-no">1550</span><span id="line-1550"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1551</span><span id="line-1551"> observer.preGetRSGroupInfo(this, groupName);</span> |
| <span class="source-line-no">1552</span><span id="line-1552"> }</span> |
| <span class="source-line-no">1553</span><span id="line-1553"> });</span> |
| <span class="source-line-no">1554</span><span id="line-1554"> }</span> |
| <span class="source-line-no">1555</span><span id="line-1555"></span> |
| <span class="source-line-no">1556</span><span id="line-1556"> public void postGetRSGroupInfo(final String groupName) throws IOException {</span> |
| <span class="source-line-no">1557</span><span id="line-1557"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1558</span><span id="line-1558"> @Override</span> |
| <span class="source-line-no">1559</span><span id="line-1559"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1560</span><span id="line-1560"> observer.postGetRSGroupInfo(this, groupName);</span> |
| <span class="source-line-no">1561</span><span id="line-1561"> }</span> |
| <span class="source-line-no">1562</span><span id="line-1562"> });</span> |
| <span class="source-line-no">1563</span><span id="line-1563"> }</span> |
| <span class="source-line-no">1564</span><span id="line-1564"></span> |
| <span class="source-line-no">1565</span><span id="line-1565"> public void preGetRSGroupInfoOfTable(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">1566</span><span id="line-1566"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1567</span><span id="line-1567"> @Override</span> |
| <span class="source-line-no">1568</span><span id="line-1568"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1569</span><span id="line-1569"> observer.preGetRSGroupInfoOfTable(this, tableName);</span> |
| <span class="source-line-no">1570</span><span id="line-1570"> }</span> |
| <span class="source-line-no">1571</span><span id="line-1571"> });</span> |
| <span class="source-line-no">1572</span><span id="line-1572"> }</span> |
| <span class="source-line-no">1573</span><span id="line-1573"></span> |
| <span class="source-line-no">1574</span><span id="line-1574"> public void postGetRSGroupInfoOfTable(final TableName tableName) throws IOException {</span> |
| <span class="source-line-no">1575</span><span id="line-1575"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1576</span><span id="line-1576"> @Override</span> |
| <span class="source-line-no">1577</span><span id="line-1577"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1578</span><span id="line-1578"> observer.postGetRSGroupInfoOfTable(this, tableName);</span> |
| <span class="source-line-no">1579</span><span id="line-1579"> }</span> |
| <span class="source-line-no">1580</span><span id="line-1580"> });</span> |
| <span class="source-line-no">1581</span><span id="line-1581"> }</span> |
| <span class="source-line-no">1582</span><span id="line-1582"></span> |
| <span class="source-line-no">1583</span><span id="line-1583"> public void preListRSGroups() throws IOException {</span> |
| <span class="source-line-no">1584</span><span id="line-1584"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1585</span><span id="line-1585"> @Override</span> |
| <span class="source-line-no">1586</span><span id="line-1586"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1587</span><span id="line-1587"> observer.preListRSGroups(this);</span> |
| <span class="source-line-no">1588</span><span id="line-1588"> }</span> |
| <span class="source-line-no">1589</span><span id="line-1589"> });</span> |
| <span class="source-line-no">1590</span><span id="line-1590"> }</span> |
| <span class="source-line-no">1591</span><span id="line-1591"></span> |
| <span class="source-line-no">1592</span><span id="line-1592"> public void postListRSGroups() throws IOException {</span> |
| <span class="source-line-no">1593</span><span id="line-1593"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1594</span><span id="line-1594"> @Override</span> |
| <span class="source-line-no">1595</span><span id="line-1595"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1596</span><span id="line-1596"> observer.postListRSGroups(this);</span> |
| <span class="source-line-no">1597</span><span id="line-1597"> }</span> |
| <span class="source-line-no">1598</span><span id="line-1598"> });</span> |
| <span class="source-line-no">1599</span><span id="line-1599"> }</span> |
| <span class="source-line-no">1600</span><span id="line-1600"></span> |
| <span class="source-line-no">1601</span><span id="line-1601"> public void preListTablesInRSGroup(final String groupName) throws IOException {</span> |
| <span class="source-line-no">1602</span><span id="line-1602"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1603</span><span id="line-1603"></span> |
| <span class="source-line-no">1604</span><span id="line-1604"> @Override</span> |
| <span class="source-line-no">1605</span><span id="line-1605"> protected void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1606</span><span id="line-1606"> observer.preListTablesInRSGroup(this, groupName);</span> |
| <span class="source-line-no">1607</span><span id="line-1607"> }</span> |
| <span class="source-line-no">1608</span><span id="line-1608"> });</span> |
| <span class="source-line-no">1609</span><span id="line-1609"> }</span> |
| <span class="source-line-no">1610</span><span id="line-1610"></span> |
| <span class="source-line-no">1611</span><span id="line-1611"> public void postListTablesInRSGroup(final String groupName) throws IOException {</span> |
| <span class="source-line-no">1612</span><span id="line-1612"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1613</span><span id="line-1613"></span> |
| <span class="source-line-no">1614</span><span id="line-1614"> @Override</span> |
| <span class="source-line-no">1615</span><span id="line-1615"> protected void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1616</span><span id="line-1616"> observer.postListTablesInRSGroup(this, groupName);</span> |
| <span class="source-line-no">1617</span><span id="line-1617"> }</span> |
| <span class="source-line-no">1618</span><span id="line-1618"> });</span> |
| <span class="source-line-no">1619</span><span id="line-1619"> }</span> |
| <span class="source-line-no">1620</span><span id="line-1620"></span> |
| <span class="source-line-no">1621</span><span id="line-1621"> public void preRenameRSGroup(final String oldName, final String newName) throws IOException {</span> |
| <span class="source-line-no">1622</span><span id="line-1622"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1623</span><span id="line-1623"></span> |
| <span class="source-line-no">1624</span><span id="line-1624"> @Override</span> |
| <span class="source-line-no">1625</span><span id="line-1625"> protected void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1626</span><span id="line-1626"> observer.preRenameRSGroup(this, oldName, newName);</span> |
| <span class="source-line-no">1627</span><span id="line-1627"> }</span> |
| <span class="source-line-no">1628</span><span id="line-1628"> });</span> |
| <span class="source-line-no">1629</span><span id="line-1629"> }</span> |
| <span class="source-line-no">1630</span><span id="line-1630"></span> |
| <span class="source-line-no">1631</span><span id="line-1631"> public void postRenameRSGroup(final String oldName, final String newName) throws IOException {</span> |
| <span class="source-line-no">1632</span><span id="line-1632"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1633</span><span id="line-1633"></span> |
| <span class="source-line-no">1634</span><span id="line-1634"> @Override</span> |
| <span class="source-line-no">1635</span><span id="line-1635"> protected void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1636</span><span id="line-1636"> observer.postRenameRSGroup(this, oldName, newName);</span> |
| <span class="source-line-no">1637</span><span id="line-1637"> }</span> |
| <span class="source-line-no">1638</span><span id="line-1638"> });</span> |
| <span class="source-line-no">1639</span><span id="line-1639"> }</span> |
| <span class="source-line-no">1640</span><span id="line-1640"></span> |
| <span class="source-line-no">1641</span><span id="line-1641"> public void preUpdateRSGroupConfig(final String groupName,</span> |
| <span class="source-line-no">1642</span><span id="line-1642"> final Map<String, String> configuration) throws IOException {</span> |
| <span class="source-line-no">1643</span><span id="line-1643"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1644</span><span id="line-1644"> @Override</span> |
| <span class="source-line-no">1645</span><span id="line-1645"> protected void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1646</span><span id="line-1646"> observer.preUpdateRSGroupConfig(this, groupName, configuration);</span> |
| <span class="source-line-no">1647</span><span id="line-1647"> }</span> |
| <span class="source-line-no">1648</span><span id="line-1648"> });</span> |
| <span class="source-line-no">1649</span><span id="line-1649"> }</span> |
| <span class="source-line-no">1650</span><span id="line-1650"></span> |
| <span class="source-line-no">1651</span><span id="line-1651"> public void postUpdateRSGroupConfig(final String groupName,</span> |
| <span class="source-line-no">1652</span><span id="line-1652"> final Map<String, String> configuration) throws IOException {</span> |
| <span class="source-line-no">1653</span><span id="line-1653"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1654</span><span id="line-1654"> @Override</span> |
| <span class="source-line-no">1655</span><span id="line-1655"> protected void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1656</span><span id="line-1656"> observer.postUpdateRSGroupConfig(this, groupName, configuration);</span> |
| <span class="source-line-no">1657</span><span id="line-1657"> }</span> |
| <span class="source-line-no">1658</span><span id="line-1658"> });</span> |
| <span class="source-line-no">1659</span><span id="line-1659"> }</span> |
| <span class="source-line-no">1660</span><span id="line-1660"></span> |
| <span class="source-line-no">1661</span><span id="line-1661"> public void preGetConfiguredNamespacesAndTablesInRSGroup(final String groupName)</span> |
| <span class="source-line-no">1662</span><span id="line-1662"> throws IOException {</span> |
| <span class="source-line-no">1663</span><span id="line-1663"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1664</span><span id="line-1664"></span> |
| <span class="source-line-no">1665</span><span id="line-1665"> @Override</span> |
| <span class="source-line-no">1666</span><span id="line-1666"> protected void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1667</span><span id="line-1667"> observer.preGetConfiguredNamespacesAndTablesInRSGroup(this, groupName);</span> |
| <span class="source-line-no">1668</span><span id="line-1668"> }</span> |
| <span class="source-line-no">1669</span><span id="line-1669"> });</span> |
| <span class="source-line-no">1670</span><span id="line-1670"> }</span> |
| <span class="source-line-no">1671</span><span id="line-1671"></span> |
| <span class="source-line-no">1672</span><span id="line-1672"> public void postGetConfiguredNamespacesAndTablesInRSGroup(final String groupName)</span> |
| <span class="source-line-no">1673</span><span id="line-1673"> throws IOException {</span> |
| <span class="source-line-no">1674</span><span id="line-1674"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1675</span><span id="line-1675"></span> |
| <span class="source-line-no">1676</span><span id="line-1676"> @Override</span> |
| <span class="source-line-no">1677</span><span id="line-1677"> protected void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1678</span><span id="line-1678"> observer.postGetConfiguredNamespacesAndTablesInRSGroup(this, groupName);</span> |
| <span class="source-line-no">1679</span><span id="line-1679"> }</span> |
| <span class="source-line-no">1680</span><span id="line-1680"> });</span> |
| <span class="source-line-no">1681</span><span id="line-1681"> }</span> |
| <span class="source-line-no">1682</span><span id="line-1682"></span> |
| <span class="source-line-no">1683</span><span id="line-1683"> public void preGetRSGroupInfoOfServer(final Address server) throws IOException {</span> |
| <span class="source-line-no">1684</span><span id="line-1684"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1685</span><span id="line-1685"> @Override</span> |
| <span class="source-line-no">1686</span><span id="line-1686"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1687</span><span id="line-1687"> observer.preGetRSGroupInfoOfServer(this, server);</span> |
| <span class="source-line-no">1688</span><span id="line-1688"> }</span> |
| <span class="source-line-no">1689</span><span id="line-1689"> });</span> |
| <span class="source-line-no">1690</span><span id="line-1690"> }</span> |
| <span class="source-line-no">1691</span><span id="line-1691"></span> |
| <span class="source-line-no">1692</span><span id="line-1692"> public void postGetRSGroupInfoOfServer(final Address server) throws IOException {</span> |
| <span class="source-line-no">1693</span><span id="line-1693"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1694</span><span id="line-1694"> @Override</span> |
| <span class="source-line-no">1695</span><span id="line-1695"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1696</span><span id="line-1696"> observer.postGetRSGroupInfoOfServer(this, server);</span> |
| <span class="source-line-no">1697</span><span id="line-1697"> }</span> |
| <span class="source-line-no">1698</span><span id="line-1698"> });</span> |
| <span class="source-line-no">1699</span><span id="line-1699"> }</span> |
| <span class="source-line-no">1700</span><span id="line-1700"></span> |
| <span class="source-line-no">1701</span><span id="line-1701"> public void preAddReplicationPeer(final String peerId, final ReplicationPeerConfig peerConfig)</span> |
| <span class="source-line-no">1702</span><span id="line-1702"> throws IOException {</span> |
| <span class="source-line-no">1703</span><span id="line-1703"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1704</span><span id="line-1704"> @Override</span> |
| <span class="source-line-no">1705</span><span id="line-1705"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1706</span><span id="line-1706"> observer.preAddReplicationPeer(this, peerId, peerConfig);</span> |
| <span class="source-line-no">1707</span><span id="line-1707"> }</span> |
| <span class="source-line-no">1708</span><span id="line-1708"> });</span> |
| <span class="source-line-no">1709</span><span id="line-1709"> }</span> |
| <span class="source-line-no">1710</span><span id="line-1710"></span> |
| <span class="source-line-no">1711</span><span id="line-1711"> public void postAddReplicationPeer(final String peerId, final ReplicationPeerConfig peerConfig)</span> |
| <span class="source-line-no">1712</span><span id="line-1712"> throws IOException {</span> |
| <span class="source-line-no">1713</span><span id="line-1713"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1714</span><span id="line-1714"> @Override</span> |
| <span class="source-line-no">1715</span><span id="line-1715"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1716</span><span id="line-1716"> observer.postAddReplicationPeer(this, peerId, peerConfig);</span> |
| <span class="source-line-no">1717</span><span id="line-1717"> }</span> |
| <span class="source-line-no">1718</span><span id="line-1718"> });</span> |
| <span class="source-line-no">1719</span><span id="line-1719"> }</span> |
| <span class="source-line-no">1720</span><span id="line-1720"></span> |
| <span class="source-line-no">1721</span><span id="line-1721"> public void preRemoveReplicationPeer(final String peerId) throws IOException {</span> |
| <span class="source-line-no">1722</span><span id="line-1722"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1723</span><span id="line-1723"> @Override</span> |
| <span class="source-line-no">1724</span><span id="line-1724"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1725</span><span id="line-1725"> observer.preRemoveReplicationPeer(this, peerId);</span> |
| <span class="source-line-no">1726</span><span id="line-1726"> }</span> |
| <span class="source-line-no">1727</span><span id="line-1727"> });</span> |
| <span class="source-line-no">1728</span><span id="line-1728"> }</span> |
| <span class="source-line-no">1729</span><span id="line-1729"></span> |
| <span class="source-line-no">1730</span><span id="line-1730"> public void postRemoveReplicationPeer(final String peerId) throws IOException {</span> |
| <span class="source-line-no">1731</span><span id="line-1731"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1732</span><span id="line-1732"> @Override</span> |
| <span class="source-line-no">1733</span><span id="line-1733"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1734</span><span id="line-1734"> observer.postRemoveReplicationPeer(this, peerId);</span> |
| <span class="source-line-no">1735</span><span id="line-1735"> }</span> |
| <span class="source-line-no">1736</span><span id="line-1736"> });</span> |
| <span class="source-line-no">1737</span><span id="line-1737"> }</span> |
| <span class="source-line-no">1738</span><span id="line-1738"></span> |
| <span class="source-line-no">1739</span><span id="line-1739"> public void preEnableReplicationPeer(final String peerId) throws IOException {</span> |
| <span class="source-line-no">1740</span><span id="line-1740"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1741</span><span id="line-1741"> @Override</span> |
| <span class="source-line-no">1742</span><span id="line-1742"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1743</span><span id="line-1743"> observer.preEnableReplicationPeer(this, peerId);</span> |
| <span class="source-line-no">1744</span><span id="line-1744"> }</span> |
| <span class="source-line-no">1745</span><span id="line-1745"> });</span> |
| <span class="source-line-no">1746</span><span id="line-1746"> }</span> |
| <span class="source-line-no">1747</span><span id="line-1747"></span> |
| <span class="source-line-no">1748</span><span id="line-1748"> public void postEnableReplicationPeer(final String peerId) throws IOException {</span> |
| <span class="source-line-no">1749</span><span id="line-1749"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1750</span><span id="line-1750"> @Override</span> |
| <span class="source-line-no">1751</span><span id="line-1751"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1752</span><span id="line-1752"> observer.postEnableReplicationPeer(this, peerId);</span> |
| <span class="source-line-no">1753</span><span id="line-1753"> }</span> |
| <span class="source-line-no">1754</span><span id="line-1754"> });</span> |
| <span class="source-line-no">1755</span><span id="line-1755"> }</span> |
| <span class="source-line-no">1756</span><span id="line-1756"></span> |
| <span class="source-line-no">1757</span><span id="line-1757"> public void preDisableReplicationPeer(final String peerId) throws IOException {</span> |
| <span class="source-line-no">1758</span><span id="line-1758"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1759</span><span id="line-1759"> @Override</span> |
| <span class="source-line-no">1760</span><span id="line-1760"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1761</span><span id="line-1761"> observer.preDisableReplicationPeer(this, peerId);</span> |
| <span class="source-line-no">1762</span><span id="line-1762"> }</span> |
| <span class="source-line-no">1763</span><span id="line-1763"> });</span> |
| <span class="source-line-no">1764</span><span id="line-1764"> }</span> |
| <span class="source-line-no">1765</span><span id="line-1765"></span> |
| <span class="source-line-no">1766</span><span id="line-1766"> public void postDisableReplicationPeer(final String peerId) throws IOException {</span> |
| <span class="source-line-no">1767</span><span id="line-1767"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1768</span><span id="line-1768"> @Override</span> |
| <span class="source-line-no">1769</span><span id="line-1769"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1770</span><span id="line-1770"> observer.postDisableReplicationPeer(this, peerId);</span> |
| <span class="source-line-no">1771</span><span id="line-1771"> }</span> |
| <span class="source-line-no">1772</span><span id="line-1772"> });</span> |
| <span class="source-line-no">1773</span><span id="line-1773"> }</span> |
| <span class="source-line-no">1774</span><span id="line-1774"></span> |
| <span class="source-line-no">1775</span><span id="line-1775"> public void preGetReplicationPeerConfig(final String peerId) throws IOException {</span> |
| <span class="source-line-no">1776</span><span id="line-1776"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1777</span><span id="line-1777"> @Override</span> |
| <span class="source-line-no">1778</span><span id="line-1778"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1779</span><span id="line-1779"> observer.preGetReplicationPeerConfig(this, peerId);</span> |
| <span class="source-line-no">1780</span><span id="line-1780"> }</span> |
| <span class="source-line-no">1781</span><span id="line-1781"> });</span> |
| <span class="source-line-no">1782</span><span id="line-1782"> }</span> |
| <span class="source-line-no">1783</span><span id="line-1783"></span> |
| <span class="source-line-no">1784</span><span id="line-1784"> public void postGetReplicationPeerConfig(final String peerId) throws IOException {</span> |
| <span class="source-line-no">1785</span><span id="line-1785"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1786</span><span id="line-1786"> @Override</span> |
| <span class="source-line-no">1787</span><span id="line-1787"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1788</span><span id="line-1788"> observer.postGetReplicationPeerConfig(this, peerId);</span> |
| <span class="source-line-no">1789</span><span id="line-1789"> }</span> |
| <span class="source-line-no">1790</span><span id="line-1790"> });</span> |
| <span class="source-line-no">1791</span><span id="line-1791"> }</span> |
| <span class="source-line-no">1792</span><span id="line-1792"></span> |
| <span class="source-line-no">1793</span><span id="line-1793"> public void preUpdateReplicationPeerConfig(final String peerId,</span> |
| <span class="source-line-no">1794</span><span id="line-1794"> final ReplicationPeerConfig peerConfig) throws IOException {</span> |
| <span class="source-line-no">1795</span><span id="line-1795"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1796</span><span id="line-1796"> @Override</span> |
| <span class="source-line-no">1797</span><span id="line-1797"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1798</span><span id="line-1798"> observer.preUpdateReplicationPeerConfig(this, peerId, peerConfig);</span> |
| <span class="source-line-no">1799</span><span id="line-1799"> }</span> |
| <span class="source-line-no">1800</span><span id="line-1800"> });</span> |
| <span class="source-line-no">1801</span><span id="line-1801"> }</span> |
| <span class="source-line-no">1802</span><span id="line-1802"></span> |
| <span class="source-line-no">1803</span><span id="line-1803"> public void postUpdateReplicationPeerConfig(final String peerId,</span> |
| <span class="source-line-no">1804</span><span id="line-1804"> final ReplicationPeerConfig peerConfig) throws IOException {</span> |
| <span class="source-line-no">1805</span><span id="line-1805"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1806</span><span id="line-1806"> @Override</span> |
| <span class="source-line-no">1807</span><span id="line-1807"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1808</span><span id="line-1808"> observer.postUpdateReplicationPeerConfig(this, peerId, peerConfig);</span> |
| <span class="source-line-no">1809</span><span id="line-1809"> }</span> |
| <span class="source-line-no">1810</span><span id="line-1810"> });</span> |
| <span class="source-line-no">1811</span><span id="line-1811"> }</span> |
| <span class="source-line-no">1812</span><span id="line-1812"></span> |
| <span class="source-line-no">1813</span><span id="line-1813"> public void preListReplicationPeers(final String regex) throws IOException {</span> |
| <span class="source-line-no">1814</span><span id="line-1814"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1815</span><span id="line-1815"> @Override</span> |
| <span class="source-line-no">1816</span><span id="line-1816"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1817</span><span id="line-1817"> observer.preListReplicationPeers(this, regex);</span> |
| <span class="source-line-no">1818</span><span id="line-1818"> }</span> |
| <span class="source-line-no">1819</span><span id="line-1819"> });</span> |
| <span class="source-line-no">1820</span><span id="line-1820"> }</span> |
| <span class="source-line-no">1821</span><span id="line-1821"></span> |
| <span class="source-line-no">1822</span><span id="line-1822"> public void postListReplicationPeers(final String regex) throws IOException {</span> |
| <span class="source-line-no">1823</span><span id="line-1823"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1824</span><span id="line-1824"> @Override</span> |
| <span class="source-line-no">1825</span><span id="line-1825"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1826</span><span id="line-1826"> observer.postListReplicationPeers(this, regex);</span> |
| <span class="source-line-no">1827</span><span id="line-1827"> }</span> |
| <span class="source-line-no">1828</span><span id="line-1828"> });</span> |
| <span class="source-line-no">1829</span><span id="line-1829"> }</span> |
| <span class="source-line-no">1830</span><span id="line-1830"></span> |
| <span class="source-line-no">1831</span><span id="line-1831"> public void preTransitReplicationPeerSyncReplicationState(String peerId,</span> |
| <span class="source-line-no">1832</span><span id="line-1832"> SyncReplicationState state) throws IOException {</span> |
| <span class="source-line-no">1833</span><span id="line-1833"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1834</span><span id="line-1834"> @Override</span> |
| <span class="source-line-no">1835</span><span id="line-1835"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1836</span><span id="line-1836"> observer.preTransitReplicationPeerSyncReplicationState(this, peerId, state);</span> |
| <span class="source-line-no">1837</span><span id="line-1837"> }</span> |
| <span class="source-line-no">1838</span><span id="line-1838"> });</span> |
| <span class="source-line-no">1839</span><span id="line-1839"> }</span> |
| <span class="source-line-no">1840</span><span id="line-1840"></span> |
| <span class="source-line-no">1841</span><span id="line-1841"> public void postTransitReplicationPeerSyncReplicationState(String peerId,</span> |
| <span class="source-line-no">1842</span><span id="line-1842"> SyncReplicationState from, SyncReplicationState to) throws IOException {</span> |
| <span class="source-line-no">1843</span><span id="line-1843"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1844</span><span id="line-1844"> @Override</span> |
| <span class="source-line-no">1845</span><span id="line-1845"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1846</span><span id="line-1846"> observer.postTransitReplicationPeerSyncReplicationState(this, peerId, from, to);</span> |
| <span class="source-line-no">1847</span><span id="line-1847"> }</span> |
| <span class="source-line-no">1848</span><span id="line-1848"> });</span> |
| <span class="source-line-no">1849</span><span id="line-1849"> }</span> |
| <span class="source-line-no">1850</span><span id="line-1850"></span> |
| <span class="source-line-no">1851</span><span id="line-1851"> public void preRequestLock(String namespace, TableName tableName, RegionInfo[] regionInfos,</span> |
| <span class="source-line-no">1852</span><span id="line-1852"> LockType type, String description) throws IOException {</span> |
| <span class="source-line-no">1853</span><span id="line-1853"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1854</span><span id="line-1854"> @Override</span> |
| <span class="source-line-no">1855</span><span id="line-1855"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1856</span><span id="line-1856"> observer.preRequestLock(this, namespace, tableName, regionInfos, description);</span> |
| <span class="source-line-no">1857</span><span id="line-1857"> }</span> |
| <span class="source-line-no">1858</span><span id="line-1858"> });</span> |
| <span class="source-line-no">1859</span><span id="line-1859"> }</span> |
| <span class="source-line-no">1860</span><span id="line-1860"></span> |
| <span class="source-line-no">1861</span><span id="line-1861"> public void postRequestLock(String namespace, TableName tableName, RegionInfo[] regionInfos,</span> |
| <span class="source-line-no">1862</span><span id="line-1862"> LockType type, String description) throws IOException {</span> |
| <span class="source-line-no">1863</span><span id="line-1863"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1864</span><span id="line-1864"> @Override</span> |
| <span class="source-line-no">1865</span><span id="line-1865"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1866</span><span id="line-1866"> observer.postRequestLock(this, namespace, tableName, regionInfos, description);</span> |
| <span class="source-line-no">1867</span><span id="line-1867"> }</span> |
| <span class="source-line-no">1868</span><span id="line-1868"> });</span> |
| <span class="source-line-no">1869</span><span id="line-1869"> }</span> |
| <span class="source-line-no">1870</span><span id="line-1870"></span> |
| <span class="source-line-no">1871</span><span id="line-1871"> public void preLockHeartbeat(LockProcedure proc, boolean keepAlive) throws IOException {</span> |
| <span class="source-line-no">1872</span><span id="line-1872"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1873</span><span id="line-1873"> @Override</span> |
| <span class="source-line-no">1874</span><span id="line-1874"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1875</span><span id="line-1875"> observer.preLockHeartbeat(this, proc.getTableName(), proc.getDescription());</span> |
| <span class="source-line-no">1876</span><span id="line-1876"> }</span> |
| <span class="source-line-no">1877</span><span id="line-1877"> });</span> |
| <span class="source-line-no">1878</span><span id="line-1878"> }</span> |
| <span class="source-line-no">1879</span><span id="line-1879"></span> |
| <span class="source-line-no">1880</span><span id="line-1880"> public void postLockHeartbeat(LockProcedure proc, boolean keepAlive) throws IOException {</span> |
| <span class="source-line-no">1881</span><span id="line-1881"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1882</span><span id="line-1882"> @Override</span> |
| <span class="source-line-no">1883</span><span id="line-1883"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1884</span><span id="line-1884"> observer.postLockHeartbeat(this);</span> |
| <span class="source-line-no">1885</span><span id="line-1885"> }</span> |
| <span class="source-line-no">1886</span><span id="line-1886"> });</span> |
| <span class="source-line-no">1887</span><span id="line-1887"> }</span> |
| <span class="source-line-no">1888</span><span id="line-1888"></span> |
| <span class="source-line-no">1889</span><span id="line-1889"> public void preGetClusterMetrics() throws IOException {</span> |
| <span class="source-line-no">1890</span><span id="line-1890"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1891</span><span id="line-1891"> @Override</span> |
| <span class="source-line-no">1892</span><span id="line-1892"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1893</span><span id="line-1893"> observer.preGetClusterMetrics(this);</span> |
| <span class="source-line-no">1894</span><span id="line-1894"> }</span> |
| <span class="source-line-no">1895</span><span id="line-1895"> });</span> |
| <span class="source-line-no">1896</span><span id="line-1896"> }</span> |
| <span class="source-line-no">1897</span><span id="line-1897"></span> |
| <span class="source-line-no">1898</span><span id="line-1898"> public void postGetClusterMetrics(ClusterMetrics status) throws IOException {</span> |
| <span class="source-line-no">1899</span><span id="line-1899"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1900</span><span id="line-1900"> @Override</span> |
| <span class="source-line-no">1901</span><span id="line-1901"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1902</span><span id="line-1902"> observer.postGetClusterMetrics(this, status);</span> |
| <span class="source-line-no">1903</span><span id="line-1903"> }</span> |
| <span class="source-line-no">1904</span><span id="line-1904"> });</span> |
| <span class="source-line-no">1905</span><span id="line-1905"> }</span> |
| <span class="source-line-no">1906</span><span id="line-1906"></span> |
| <span class="source-line-no">1907</span><span id="line-1907"> public void preClearDeadServers() throws IOException {</span> |
| <span class="source-line-no">1908</span><span id="line-1908"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1909</span><span id="line-1909"> @Override</span> |
| <span class="source-line-no">1910</span><span id="line-1910"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1911</span><span id="line-1911"> observer.preClearDeadServers(this);</span> |
| <span class="source-line-no">1912</span><span id="line-1912"> }</span> |
| <span class="source-line-no">1913</span><span id="line-1913"> });</span> |
| <span class="source-line-no">1914</span><span id="line-1914"> }</span> |
| <span class="source-line-no">1915</span><span id="line-1915"></span> |
| <span class="source-line-no">1916</span><span id="line-1916"> public void postClearDeadServers(List<ServerName> servers, List<ServerName> notClearedServers)</span> |
| <span class="source-line-no">1917</span><span id="line-1917"> throws IOException {</span> |
| <span class="source-line-no">1918</span><span id="line-1918"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1919</span><span id="line-1919"> @Override</span> |
| <span class="source-line-no">1920</span><span id="line-1920"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1921</span><span id="line-1921"> observer.postClearDeadServers(this, servers, notClearedServers);</span> |
| <span class="source-line-no">1922</span><span id="line-1922"> }</span> |
| <span class="source-line-no">1923</span><span id="line-1923"> });</span> |
| <span class="source-line-no">1924</span><span id="line-1924"> }</span> |
| <span class="source-line-no">1925</span><span id="line-1925"></span> |
| <span class="source-line-no">1926</span><span id="line-1926"> public void preDecommissionRegionServers(List<ServerName> servers, boolean offload)</span> |
| <span class="source-line-no">1927</span><span id="line-1927"> throws IOException {</span> |
| <span class="source-line-no">1928</span><span id="line-1928"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1929</span><span id="line-1929"> @Override</span> |
| <span class="source-line-no">1930</span><span id="line-1930"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1931</span><span id="line-1931"> observer.preDecommissionRegionServers(this, servers, offload);</span> |
| <span class="source-line-no">1932</span><span id="line-1932"> }</span> |
| <span class="source-line-no">1933</span><span id="line-1933"> });</span> |
| <span class="source-line-no">1934</span><span id="line-1934"> }</span> |
| <span class="source-line-no">1935</span><span id="line-1935"></span> |
| <span class="source-line-no">1936</span><span id="line-1936"> public void postDecommissionRegionServers(List<ServerName> servers, boolean offload)</span> |
| <span class="source-line-no">1937</span><span id="line-1937"> throws IOException {</span> |
| <span class="source-line-no">1938</span><span id="line-1938"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1939</span><span id="line-1939"> @Override</span> |
| <span class="source-line-no">1940</span><span id="line-1940"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1941</span><span id="line-1941"> observer.postDecommissionRegionServers(this, servers, offload);</span> |
| <span class="source-line-no">1942</span><span id="line-1942"> }</span> |
| <span class="source-line-no">1943</span><span id="line-1943"> });</span> |
| <span class="source-line-no">1944</span><span id="line-1944"> }</span> |
| <span class="source-line-no">1945</span><span id="line-1945"></span> |
| <span class="source-line-no">1946</span><span id="line-1946"> public void preListDecommissionedRegionServers() throws IOException {</span> |
| <span class="source-line-no">1947</span><span id="line-1947"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1948</span><span id="line-1948"> @Override</span> |
| <span class="source-line-no">1949</span><span id="line-1949"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1950</span><span id="line-1950"> observer.preListDecommissionedRegionServers(this);</span> |
| <span class="source-line-no">1951</span><span id="line-1951"> }</span> |
| <span class="source-line-no">1952</span><span id="line-1952"> });</span> |
| <span class="source-line-no">1953</span><span id="line-1953"> }</span> |
| <span class="source-line-no">1954</span><span id="line-1954"></span> |
| <span class="source-line-no">1955</span><span id="line-1955"> public void postListDecommissionedRegionServers() throws IOException {</span> |
| <span class="source-line-no">1956</span><span id="line-1956"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1957</span><span id="line-1957"> @Override</span> |
| <span class="source-line-no">1958</span><span id="line-1958"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1959</span><span id="line-1959"> observer.postListDecommissionedRegionServers(this);</span> |
| <span class="source-line-no">1960</span><span id="line-1960"> }</span> |
| <span class="source-line-no">1961</span><span id="line-1961"> });</span> |
| <span class="source-line-no">1962</span><span id="line-1962"> }</span> |
| <span class="source-line-no">1963</span><span id="line-1963"></span> |
| <span class="source-line-no">1964</span><span id="line-1964"> public void preRecommissionRegionServer(ServerName server, List<byte[]> encodedRegionNames)</span> |
| <span class="source-line-no">1965</span><span id="line-1965"> throws IOException {</span> |
| <span class="source-line-no">1966</span><span id="line-1966"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1967</span><span id="line-1967"> @Override</span> |
| <span class="source-line-no">1968</span><span id="line-1968"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1969</span><span id="line-1969"> observer.preRecommissionRegionServer(this, server, encodedRegionNames);</span> |
| <span class="source-line-no">1970</span><span id="line-1970"> }</span> |
| <span class="source-line-no">1971</span><span id="line-1971"> });</span> |
| <span class="source-line-no">1972</span><span id="line-1972"> }</span> |
| <span class="source-line-no">1973</span><span id="line-1973"></span> |
| <span class="source-line-no">1974</span><span id="line-1974"> public void postRecommissionRegionServer(ServerName server, List<byte[]> encodedRegionNames)</span> |
| <span class="source-line-no">1975</span><span id="line-1975"> throws IOException {</span> |
| <span class="source-line-no">1976</span><span id="line-1976"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1977</span><span id="line-1977"> @Override</span> |
| <span class="source-line-no">1978</span><span id="line-1978"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1979</span><span id="line-1979"> observer.postRecommissionRegionServer(this, server, encodedRegionNames);</span> |
| <span class="source-line-no">1980</span><span id="line-1980"> }</span> |
| <span class="source-line-no">1981</span><span id="line-1981"> });</span> |
| <span class="source-line-no">1982</span><span id="line-1982"> }</span> |
| <span class="source-line-no">1983</span><span id="line-1983"></span> |
| <span class="source-line-no">1984</span><span id="line-1984"> public void preSwitchRpcThrottle(boolean enable) throws IOException {</span> |
| <span class="source-line-no">1985</span><span id="line-1985"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1986</span><span id="line-1986"> @Override</span> |
| <span class="source-line-no">1987</span><span id="line-1987"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1988</span><span id="line-1988"> observer.preSwitchRpcThrottle(this, enable);</span> |
| <span class="source-line-no">1989</span><span id="line-1989"> }</span> |
| <span class="source-line-no">1990</span><span id="line-1990"> });</span> |
| <span class="source-line-no">1991</span><span id="line-1991"> }</span> |
| <span class="source-line-no">1992</span><span id="line-1992"></span> |
| <span class="source-line-no">1993</span><span id="line-1993"> public void postSwitchRpcThrottle(final boolean oldValue, final boolean newValue)</span> |
| <span class="source-line-no">1994</span><span id="line-1994"> throws IOException {</span> |
| <span class="source-line-no">1995</span><span id="line-1995"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">1996</span><span id="line-1996"> @Override</span> |
| <span class="source-line-no">1997</span><span id="line-1997"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">1998</span><span id="line-1998"> observer.postSwitchRpcThrottle(this, oldValue, newValue);</span> |
| <span class="source-line-no">1999</span><span id="line-1999"> }</span> |
| <span class="source-line-no">2000</span><span id="line-2000"> });</span> |
| <span class="source-line-no">2001</span><span id="line-2001"> }</span> |
| <span class="source-line-no">2002</span><span id="line-2002"></span> |
| <span class="source-line-no">2003</span><span id="line-2003"> public void preIsRpcThrottleEnabled() throws IOException {</span> |
| <span class="source-line-no">2004</span><span id="line-2004"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2005</span><span id="line-2005"> @Override</span> |
| <span class="source-line-no">2006</span><span id="line-2006"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2007</span><span id="line-2007"> observer.preIsRpcThrottleEnabled(this);</span> |
| <span class="source-line-no">2008</span><span id="line-2008"> }</span> |
| <span class="source-line-no">2009</span><span id="line-2009"> });</span> |
| <span class="source-line-no">2010</span><span id="line-2010"> }</span> |
| <span class="source-line-no">2011</span><span id="line-2011"></span> |
| <span class="source-line-no">2012</span><span id="line-2012"> public void postIsRpcThrottleEnabled(boolean enabled) throws IOException {</span> |
| <span class="source-line-no">2013</span><span id="line-2013"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2014</span><span id="line-2014"> @Override</span> |
| <span class="source-line-no">2015</span><span id="line-2015"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2016</span><span id="line-2016"> observer.postIsRpcThrottleEnabled(this, enabled);</span> |
| <span class="source-line-no">2017</span><span id="line-2017"> }</span> |
| <span class="source-line-no">2018</span><span id="line-2018"> });</span> |
| <span class="source-line-no">2019</span><span id="line-2019"> }</span> |
| <span class="source-line-no">2020</span><span id="line-2020"></span> |
| <span class="source-line-no">2021</span><span id="line-2021"> public void preSwitchExceedThrottleQuota(boolean enable) throws IOException {</span> |
| <span class="source-line-no">2022</span><span id="line-2022"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2023</span><span id="line-2023"> @Override</span> |
| <span class="source-line-no">2024</span><span id="line-2024"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2025</span><span id="line-2025"> observer.preSwitchExceedThrottleQuota(this, enable);</span> |
| <span class="source-line-no">2026</span><span id="line-2026"> }</span> |
| <span class="source-line-no">2027</span><span id="line-2027"> });</span> |
| <span class="source-line-no">2028</span><span id="line-2028"> }</span> |
| <span class="source-line-no">2029</span><span id="line-2029"></span> |
| <span class="source-line-no">2030</span><span id="line-2030"> public void postSwitchExceedThrottleQuota(final boolean oldValue, final boolean newValue)</span> |
| <span class="source-line-no">2031</span><span id="line-2031"> throws IOException {</span> |
| <span class="source-line-no">2032</span><span id="line-2032"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2033</span><span id="line-2033"> @Override</span> |
| <span class="source-line-no">2034</span><span id="line-2034"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2035</span><span id="line-2035"> observer.postSwitchExceedThrottleQuota(this, oldValue, newValue);</span> |
| <span class="source-line-no">2036</span><span id="line-2036"> }</span> |
| <span class="source-line-no">2037</span><span id="line-2037"> });</span> |
| <span class="source-line-no">2038</span><span id="line-2038"> }</span> |
| <span class="source-line-no">2039</span><span id="line-2039"></span> |
| <span class="source-line-no">2040</span><span id="line-2040"> public void preGrant(UserPermission userPermission, boolean mergeExistingPermissions)</span> |
| <span class="source-line-no">2041</span><span id="line-2041"> throws IOException {</span> |
| <span class="source-line-no">2042</span><span id="line-2042"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2043</span><span id="line-2043"> @Override</span> |
| <span class="source-line-no">2044</span><span id="line-2044"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2045</span><span id="line-2045"> observer.preGrant(this, userPermission, mergeExistingPermissions);</span> |
| <span class="source-line-no">2046</span><span id="line-2046"> }</span> |
| <span class="source-line-no">2047</span><span id="line-2047"> });</span> |
| <span class="source-line-no">2048</span><span id="line-2048"> }</span> |
| <span class="source-line-no">2049</span><span id="line-2049"></span> |
| <span class="source-line-no">2050</span><span id="line-2050"> public void postGrant(UserPermission userPermission, boolean mergeExistingPermissions)</span> |
| <span class="source-line-no">2051</span><span id="line-2051"> throws IOException {</span> |
| <span class="source-line-no">2052</span><span id="line-2052"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2053</span><span id="line-2053"> @Override</span> |
| <span class="source-line-no">2054</span><span id="line-2054"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2055</span><span id="line-2055"> observer.postGrant(this, userPermission, mergeExistingPermissions);</span> |
| <span class="source-line-no">2056</span><span id="line-2056"> }</span> |
| <span class="source-line-no">2057</span><span id="line-2057"> });</span> |
| <span class="source-line-no">2058</span><span id="line-2058"> }</span> |
| <span class="source-line-no">2059</span><span id="line-2059"></span> |
| <span class="source-line-no">2060</span><span id="line-2060"> public void preRevoke(UserPermission userPermission) throws IOException {</span> |
| <span class="source-line-no">2061</span><span id="line-2061"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2062</span><span id="line-2062"> @Override</span> |
| <span class="source-line-no">2063</span><span id="line-2063"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2064</span><span id="line-2064"> observer.preRevoke(this, userPermission);</span> |
| <span class="source-line-no">2065</span><span id="line-2065"> }</span> |
| <span class="source-line-no">2066</span><span id="line-2066"> });</span> |
| <span class="source-line-no">2067</span><span id="line-2067"> }</span> |
| <span class="source-line-no">2068</span><span id="line-2068"></span> |
| <span class="source-line-no">2069</span><span id="line-2069"> public void postRevoke(UserPermission userPermission) throws IOException {</span> |
| <span class="source-line-no">2070</span><span id="line-2070"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2071</span><span id="line-2071"> @Override</span> |
| <span class="source-line-no">2072</span><span id="line-2072"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2073</span><span id="line-2073"> observer.postRevoke(this, userPermission);</span> |
| <span class="source-line-no">2074</span><span id="line-2074"> }</span> |
| <span class="source-line-no">2075</span><span id="line-2075"> });</span> |
| <span class="source-line-no">2076</span><span id="line-2076"> }</span> |
| <span class="source-line-no">2077</span><span id="line-2077"></span> |
| <span class="source-line-no">2078</span><span id="line-2078"> public void preGetUserPermissions(String userName, String namespace, TableName tableName,</span> |
| <span class="source-line-no">2079</span><span id="line-2079"> byte[] family, byte[] qualifier) throws IOException {</span> |
| <span class="source-line-no">2080</span><span id="line-2080"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2081</span><span id="line-2081"> @Override</span> |
| <span class="source-line-no">2082</span><span id="line-2082"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2083</span><span id="line-2083"> observer.preGetUserPermissions(this, userName, namespace, tableName, family, qualifier);</span> |
| <span class="source-line-no">2084</span><span id="line-2084"> }</span> |
| <span class="source-line-no">2085</span><span id="line-2085"> });</span> |
| <span class="source-line-no">2086</span><span id="line-2086"> }</span> |
| <span class="source-line-no">2087</span><span id="line-2087"></span> |
| <span class="source-line-no">2088</span><span id="line-2088"> public void postGetUserPermissions(String userName, String namespace, TableName tableName,</span> |
| <span class="source-line-no">2089</span><span id="line-2089"> byte[] family, byte[] qualifier) throws IOException {</span> |
| <span class="source-line-no">2090</span><span id="line-2090"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2091</span><span id="line-2091"> @Override</span> |
| <span class="source-line-no">2092</span><span id="line-2092"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2093</span><span id="line-2093"> observer.postGetUserPermissions(this, userName, namespace, tableName, family, qualifier);</span> |
| <span class="source-line-no">2094</span><span id="line-2094"> }</span> |
| <span class="source-line-no">2095</span><span id="line-2095"> });</span> |
| <span class="source-line-no">2096</span><span id="line-2096"> }</span> |
| <span class="source-line-no">2097</span><span id="line-2097"></span> |
| <span class="source-line-no">2098</span><span id="line-2098"> public void preHasUserPermissions(String userName, List<Permission> permissions)</span> |
| <span class="source-line-no">2099</span><span id="line-2099"> throws IOException {</span> |
| <span class="source-line-no">2100</span><span id="line-2100"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2101</span><span id="line-2101"> @Override</span> |
| <span class="source-line-no">2102</span><span id="line-2102"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2103</span><span id="line-2103"> observer.preHasUserPermissions(this, userName, permissions);</span> |
| <span class="source-line-no">2104</span><span id="line-2104"> }</span> |
| <span class="source-line-no">2105</span><span id="line-2105"> });</span> |
| <span class="source-line-no">2106</span><span id="line-2106"> }</span> |
| <span class="source-line-no">2107</span><span id="line-2107"></span> |
| <span class="source-line-no">2108</span><span id="line-2108"> public void postHasUserPermissions(String userName, List<Permission> permissions)</span> |
| <span class="source-line-no">2109</span><span id="line-2109"> throws IOException {</span> |
| <span class="source-line-no">2110</span><span id="line-2110"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2111</span><span id="line-2111"> @Override</span> |
| <span class="source-line-no">2112</span><span id="line-2112"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2113</span><span id="line-2113"> observer.postHasUserPermissions(this, userName, permissions);</span> |
| <span class="source-line-no">2114</span><span id="line-2114"> }</span> |
| <span class="source-line-no">2115</span><span id="line-2115"> });</span> |
| <span class="source-line-no">2116</span><span id="line-2116"> }</span> |
| <span class="source-line-no">2117</span><span id="line-2117"></span> |
| <span class="source-line-no">2118</span><span id="line-2118"> public void preUpdateConfiguration(Configuration preReloadConf) throws IOException {</span> |
| <span class="source-line-no">2119</span><span id="line-2119"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2120</span><span id="line-2120"> @Override</span> |
| <span class="source-line-no">2121</span><span id="line-2121"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2122</span><span id="line-2122"> observer.preUpdateMasterConfiguration(this, preReloadConf);</span> |
| <span class="source-line-no">2123</span><span id="line-2123"> }</span> |
| <span class="source-line-no">2124</span><span id="line-2124"> });</span> |
| <span class="source-line-no">2125</span><span id="line-2125"> }</span> |
| <span class="source-line-no">2126</span><span id="line-2126"></span> |
| <span class="source-line-no">2127</span><span id="line-2127"> public void postUpdateConfiguration(Configuration postReloadConf) throws IOException {</span> |
| <span class="source-line-no">2128</span><span id="line-2128"> execOperation(coprocEnvironments.isEmpty() ? null : new MasterObserverOperation() {</span> |
| <span class="source-line-no">2129</span><span id="line-2129"> @Override</span> |
| <span class="source-line-no">2130</span><span id="line-2130"> public void call(MasterObserver observer) throws IOException {</span> |
| <span class="source-line-no">2131</span><span id="line-2131"> observer.postUpdateMasterConfiguration(this, postReloadConf);</span> |
| <span class="source-line-no">2132</span><span id="line-2132"> }</span> |
| <span class="source-line-no">2133</span><span id="line-2133"> });</span> |
| <span class="source-line-no">2134</span><span id="line-2134"> }</span> |
| <span class="source-line-no">2135</span><span id="line-2135">}</span> |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| </pre> |
| </div> |
| </main> |
| </body> |
| </html> |
