http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b5e107c3/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html b/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html index bcb1724..c6caa9b 100644 --- a/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/wal/package-tree.html @@ -191,8 +191,8 @@ <ul> <li type="circle">java.lang.<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true"; title="class or interface in java.lang"><span class="typeNameLink">Enum</span></a><E> (implements java.lang.<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true"; title="class or interface in java.lang">Comparable</a><T>, java.io.<a href="https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a>) <ul> -<li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/RegionGroupingProvider.Strategies.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">RegionGroupingProvider.Strategies</span></a></li> <li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/WALFactory.Providers.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">WALFactory.Providers</span></a></li> +<li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/RegionGroupingProvider.Strategies.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">RegionGroupingProvider.Strategies</span></a></li> </ul> </li> </ul>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b5e107c3/devapidocs/overview-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/overview-tree.html b/devapidocs/overview-tree.html index 739fe90..ef6ce1e 100644 --- a/devapidocs/overview-tree.html +++ b/devapidocs/overview-tree.html @@ -4113,6 +4113,7 @@ <li type="circle">org.apache.hadoop.hbase.metrics.impl.<a href="org/apache/hadoop/hbase/metrics/impl/TimerImpl.html" title="class in org.apache.hadoop.hbase.metrics.impl"><span class="typeNameLink">TimerImpl</span></a> (implements org.apache.hadoop.hbase.metrics.<a href="org/apache/hadoop/hbase/metrics/Timer.html" title="interface in org.apache.hadoop.hbase.metrics">Timer</a>)</li> <li type="circle">java.util.<a href="https://docs.oracle.com/javase/8/docs/api/java/util/TimerTask.html?is-external=true"; title="class or interface in java.util"><span class="typeNameLink">TimerTask</span></a> (implements java.lang.<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a>) <ul> +<li type="circle">org.apache.hadoop.hbase.regionserver.<a href="org/apache/hadoop/hbase/regionserver/HRegionServer.SystemExitWhenAbortTimeout.html" title="class in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">HRegionServer.SystemExitWhenAbortTimeout</span></a></li> <li type="circle">org.apache.hadoop.hbase.master.snapshot.<a href="org/apache/hadoop/hbase/master/snapshot/SnapshotFileCache.RefreshCacheTask.html" title="class in org.apache.hadoop.hbase.master.snapshot"><span class="typeNameLink">SnapshotFileCache.RefreshCacheTask</span></a></li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b5e107c3/devapidocs/src-html/org/apache/hadoop/hbase/Version.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html index 1744076..be92dc1 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html @@ -18,9 +18,9 @@ <span class="sourceLineNo">010</span> public static final String version = "3.0.0-SNAPSHOT";<a name="line.10"></a> <span class="sourceLineNo">011</span> public static final String revision = "";<a name="line.11"></a> <span class="sourceLineNo">012</span> public static final String user = "jenkins";<a name="line.12"></a> -<span class="sourceLineNo">013</span> public static final String date = "Sat Oct 27 14:43:02 UTC 2018";<a name="line.13"></a> +<span class="sourceLineNo">013</span> public static final String date = "Mon Oct 29 14:45:45 UTC 2018";<a name="line.13"></a> <span class="sourceLineNo">014</span> public static final String url = "git://jenkins-websites1.apache.org/home/jenkins/jenkins-slave/workspace/hbase_generate_website/hbase";<a name="line.14"></a> -<span class="sourceLineNo">015</span> public static final String srcChecksum = "88dc213e178575682ffa8953862eb7c9";<a name="line.15"></a> +<span class="sourceLineNo">015</span> public static final String srcChecksum = "882a162a713e1dbec1cf454c214efe7d";<a name="line.15"></a> <span class="sourceLineNo">016</span>}<a name="line.16"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b5e107c3/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.WALStoreLeaseRecovery.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.WALStoreLeaseRecovery.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.WALStoreLeaseRecovery.html index acd402d..1350a3f 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.WALStoreLeaseRecovery.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.WALStoreLeaseRecovery.html @@ -91,72 +91,73 @@ <span class="sourceLineNo">083</span> public MasterProcedureEnv(final MasterServices master,<a name="line.83"></a> <span class="sourceLineNo">084</span> final RSProcedureDispatcher remoteDispatcher) {<a name="line.84"></a> <span class="sourceLineNo">085</span> this.master = master;<a name="line.85"></a> -<span class="sourceLineNo">086</span> this.procSched = new MasterProcedureScheduler();<a name="line.86"></a> -<span class="sourceLineNo">087</span> this.remoteDispatcher = remoteDispatcher;<a name="line.87"></a> -<span class="sourceLineNo">088</span> }<a name="line.88"></a> -<span class="sourceLineNo">089</span><a name="line.89"></a> -<span class="sourceLineNo">090</span> public User getRequestUser() {<a name="line.90"></a> -<span class="sourceLineNo">091</span> return RpcServer.getRequestUser().orElse(Superusers.getSystemUser());<a name="line.91"></a> -<span class="sourceLineNo">092</span> }<a name="line.92"></a> -<span class="sourceLineNo">093</span><a name="line.93"></a> -<span class="sourceLineNo">094</span> public MasterServices getMasterServices() {<a name="line.94"></a> -<span class="sourceLineNo">095</span> return master;<a name="line.95"></a> -<span class="sourceLineNo">096</span> }<a name="line.96"></a> -<span class="sourceLineNo">097</span><a name="line.97"></a> -<span class="sourceLineNo">098</span> public Configuration getMasterConfiguration() {<a name="line.98"></a> -<span class="sourceLineNo">099</span> return master.getConfiguration();<a name="line.99"></a> -<span class="sourceLineNo">100</span> }<a name="line.100"></a> -<span class="sourceLineNo">101</span><a name="line.101"></a> -<span class="sourceLineNo">102</span> public AssignmentManager getAssignmentManager() {<a name="line.102"></a> -<span class="sourceLineNo">103</span> return master.getAssignmentManager();<a name="line.103"></a> -<span class="sourceLineNo">104</span> }<a name="line.104"></a> -<span class="sourceLineNo">105</span><a name="line.105"></a> -<span class="sourceLineNo">106</span> public MasterCoprocessorHost getMasterCoprocessorHost() {<a name="line.106"></a> -<span class="sourceLineNo">107</span> return master.getMasterCoprocessorHost();<a name="line.107"></a> -<span class="sourceLineNo">108</span> }<a name="line.108"></a> -<span class="sourceLineNo">109</span><a name="line.109"></a> -<span class="sourceLineNo">110</span> public MasterProcedureScheduler getProcedureScheduler() {<a name="line.110"></a> -<span class="sourceLineNo">111</span> return procSched;<a name="line.111"></a> -<span class="sourceLineNo">112</span> }<a name="line.112"></a> -<span class="sourceLineNo">113</span><a name="line.113"></a> -<span class="sourceLineNo">114</span> public RSProcedureDispatcher getRemoteDispatcher() {<a name="line.114"></a> -<span class="sourceLineNo">115</span> return remoteDispatcher;<a name="line.115"></a> -<span class="sourceLineNo">116</span> }<a name="line.116"></a> -<span class="sourceLineNo">117</span><a name="line.117"></a> -<span class="sourceLineNo">118</span> public ReplicationPeerManager getReplicationPeerManager() {<a name="line.118"></a> -<span class="sourceLineNo">119</span> return master.getReplicationPeerManager();<a name="line.119"></a> -<span class="sourceLineNo">120</span> }<a name="line.120"></a> -<span class="sourceLineNo">121</span><a name="line.121"></a> -<span class="sourceLineNo">122</span> public MasterFileSystem getMasterFileSystem() {<a name="line.122"></a> -<span class="sourceLineNo">123</span> return master.getMasterFileSystem();<a name="line.123"></a> -<span class="sourceLineNo">124</span> }<a name="line.124"></a> -<span class="sourceLineNo">125</span><a name="line.125"></a> -<span class="sourceLineNo">126</span> public boolean isRunning() {<a name="line.126"></a> -<span class="sourceLineNo">127</span> if (this.master == null || this.master.getMasterProcedureExecutor() == null) return false;<a name="line.127"></a> -<span class="sourceLineNo">128</span> return master.getMasterProcedureExecutor().isRunning();<a name="line.128"></a> -<span class="sourceLineNo">129</span> }<a name="line.129"></a> -<span class="sourceLineNo">130</span><a name="line.130"></a> -<span class="sourceLineNo">131</span> public boolean isInitialized() {<a name="line.131"></a> -<span class="sourceLineNo">132</span> return master.isInitialized();<a name="line.132"></a> -<span class="sourceLineNo">133</span> }<a name="line.133"></a> -<span class="sourceLineNo">134</span><a name="line.134"></a> -<span class="sourceLineNo">135</span> public boolean waitInitialized(Procedure<?> proc) {<a name="line.135"></a> -<span class="sourceLineNo">136</span> return master.getInitializedEvent().suspendIfNotReady(proc);<a name="line.136"></a> -<span class="sourceLineNo">137</span> }<a name="line.137"></a> -<span class="sourceLineNo">138</span><a name="line.138"></a> -<span class="sourceLineNo">139</span> public void setEventReady(ProcedureEvent<?> event, boolean isReady) {<a name="line.139"></a> -<span class="sourceLineNo">140</span> if (isReady) {<a name="line.140"></a> -<span class="sourceLineNo">141</span> event.wake(procSched);<a name="line.141"></a> -<span class="sourceLineNo">142</span> } else {<a name="line.142"></a> -<span class="sourceLineNo">143</span> event.suspend();<a name="line.143"></a> -<span class="sourceLineNo">144</span> }<a name="line.144"></a> -<span class="sourceLineNo">145</span> }<a name="line.145"></a> -<span class="sourceLineNo">146</span><a name="line.146"></a> -<span class="sourceLineNo">147</span> @Override<a name="line.147"></a> -<span class="sourceLineNo">148</span> public void onConfigurationChange(Configuration conf) {<a name="line.148"></a> -<span class="sourceLineNo">149</span> master.getMasterProcedureExecutor().refreshConfiguration(conf);<a name="line.149"></a> -<span class="sourceLineNo">150</span> }<a name="line.150"></a> -<span class="sourceLineNo">151</span>}<a name="line.151"></a> +<span class="sourceLineNo">086</span> this.procSched = new MasterProcedureScheduler(<a name="line.86"></a> +<span class="sourceLineNo">087</span> procId -> master.getMasterProcedureExecutor().getProcedure(procId));<a name="line.87"></a> +<span class="sourceLineNo">088</span> this.remoteDispatcher = remoteDispatcher;<a name="line.88"></a> +<span class="sourceLineNo">089</span> }<a name="line.89"></a> +<span class="sourceLineNo">090</span><a name="line.90"></a> +<span class="sourceLineNo">091</span> public User getRequestUser() {<a name="line.91"></a> +<span class="sourceLineNo">092</span> return RpcServer.getRequestUser().orElse(Superusers.getSystemUser());<a name="line.92"></a> +<span class="sourceLineNo">093</span> }<a name="line.93"></a> +<span class="sourceLineNo">094</span><a name="line.94"></a> +<span class="sourceLineNo">095</span> public MasterServices getMasterServices() {<a name="line.95"></a> +<span class="sourceLineNo">096</span> return master;<a name="line.96"></a> +<span class="sourceLineNo">097</span> }<a name="line.97"></a> +<span class="sourceLineNo">098</span><a name="line.98"></a> +<span class="sourceLineNo">099</span> public Configuration getMasterConfiguration() {<a name="line.99"></a> +<span class="sourceLineNo">100</span> return master.getConfiguration();<a name="line.100"></a> +<span class="sourceLineNo">101</span> }<a name="line.101"></a> +<span class="sourceLineNo">102</span><a name="line.102"></a> +<span class="sourceLineNo">103</span> public AssignmentManager getAssignmentManager() {<a name="line.103"></a> +<span class="sourceLineNo">104</span> return master.getAssignmentManager();<a name="line.104"></a> +<span class="sourceLineNo">105</span> }<a name="line.105"></a> +<span class="sourceLineNo">106</span><a name="line.106"></a> +<span class="sourceLineNo">107</span> public MasterCoprocessorHost getMasterCoprocessorHost() {<a name="line.107"></a> +<span class="sourceLineNo">108</span> return master.getMasterCoprocessorHost();<a name="line.108"></a> +<span class="sourceLineNo">109</span> }<a name="line.109"></a> +<span class="sourceLineNo">110</span><a name="line.110"></a> +<span class="sourceLineNo">111</span> public MasterProcedureScheduler getProcedureScheduler() {<a name="line.111"></a> +<span class="sourceLineNo">112</span> return procSched;<a name="line.112"></a> +<span class="sourceLineNo">113</span> }<a name="line.113"></a> +<span class="sourceLineNo">114</span><a name="line.114"></a> +<span class="sourceLineNo">115</span> public RSProcedureDispatcher getRemoteDispatcher() {<a name="line.115"></a> +<span class="sourceLineNo">116</span> return remoteDispatcher;<a name="line.116"></a> +<span class="sourceLineNo">117</span> }<a name="line.117"></a> +<span class="sourceLineNo">118</span><a name="line.118"></a> +<span class="sourceLineNo">119</span> public ReplicationPeerManager getReplicationPeerManager() {<a name="line.119"></a> +<span class="sourceLineNo">120</span> return master.getReplicationPeerManager();<a name="line.120"></a> +<span class="sourceLineNo">121</span> }<a name="line.121"></a> +<span class="sourceLineNo">122</span><a name="line.122"></a> +<span class="sourceLineNo">123</span> public MasterFileSystem getMasterFileSystem() {<a name="line.123"></a> +<span class="sourceLineNo">124</span> return master.getMasterFileSystem();<a name="line.124"></a> +<span class="sourceLineNo">125</span> }<a name="line.125"></a> +<span class="sourceLineNo">126</span><a name="line.126"></a> +<span class="sourceLineNo">127</span> public boolean isRunning() {<a name="line.127"></a> +<span class="sourceLineNo">128</span> if (this.master == null || this.master.getMasterProcedureExecutor() == null) return false;<a name="line.128"></a> +<span class="sourceLineNo">129</span> return master.getMasterProcedureExecutor().isRunning();<a name="line.129"></a> +<span class="sourceLineNo">130</span> }<a name="line.130"></a> +<span class="sourceLineNo">131</span><a name="line.131"></a> +<span class="sourceLineNo">132</span> public boolean isInitialized() {<a name="line.132"></a> +<span class="sourceLineNo">133</span> return master.isInitialized();<a name="line.133"></a> +<span class="sourceLineNo">134</span> }<a name="line.134"></a> +<span class="sourceLineNo">135</span><a name="line.135"></a> +<span class="sourceLineNo">136</span> public boolean waitInitialized(Procedure<?> proc) {<a name="line.136"></a> +<span class="sourceLineNo">137</span> return master.getInitializedEvent().suspendIfNotReady(proc);<a name="line.137"></a> +<span class="sourceLineNo">138</span> }<a name="line.138"></a> +<span class="sourceLineNo">139</span><a name="line.139"></a> +<span class="sourceLineNo">140</span> public void setEventReady(ProcedureEvent<?> event, boolean isReady) {<a name="line.140"></a> +<span class="sourceLineNo">141</span> if (isReady) {<a name="line.141"></a> +<span class="sourceLineNo">142</span> event.wake(procSched);<a name="line.142"></a> +<span class="sourceLineNo">143</span> } else {<a name="line.143"></a> +<span class="sourceLineNo">144</span> event.suspend();<a name="line.144"></a> +<span class="sourceLineNo">145</span> }<a name="line.145"></a> +<span class="sourceLineNo">146</span> }<a name="line.146"></a> +<span class="sourceLineNo">147</span><a name="line.147"></a> +<span class="sourceLineNo">148</span> @Override<a name="line.148"></a> +<span class="sourceLineNo">149</span> public void onConfigurationChange(Configuration conf) {<a name="line.149"></a> +<span class="sourceLineNo">150</span> master.getMasterProcedureExecutor().refreshConfiguration(conf);<a name="line.150"></a> +<span class="sourceLineNo">151</span> }<a name="line.151"></a> +<span class="sourceLineNo">152</span>}<a name="line.152"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b5e107c3/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.html index acd402d..1350a3f 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.html @@ -91,72 +91,73 @@ <span class="sourceLineNo">083</span> public MasterProcedureEnv(final MasterServices master,<a name="line.83"></a> <span class="sourceLineNo">084</span> final RSProcedureDispatcher remoteDispatcher) {<a name="line.84"></a> <span class="sourceLineNo">085</span> this.master = master;<a name="line.85"></a> -<span class="sourceLineNo">086</span> this.procSched = new MasterProcedureScheduler();<a name="line.86"></a> -<span class="sourceLineNo">087</span> this.remoteDispatcher = remoteDispatcher;<a name="line.87"></a> -<span class="sourceLineNo">088</span> }<a name="line.88"></a> -<span class="sourceLineNo">089</span><a name="line.89"></a> -<span class="sourceLineNo">090</span> public User getRequestUser() {<a name="line.90"></a> -<span class="sourceLineNo">091</span> return RpcServer.getRequestUser().orElse(Superusers.getSystemUser());<a name="line.91"></a> -<span class="sourceLineNo">092</span> }<a name="line.92"></a> -<span class="sourceLineNo">093</span><a name="line.93"></a> -<span class="sourceLineNo">094</span> public MasterServices getMasterServices() {<a name="line.94"></a> -<span class="sourceLineNo">095</span> return master;<a name="line.95"></a> -<span class="sourceLineNo">096</span> }<a name="line.96"></a> -<span class="sourceLineNo">097</span><a name="line.97"></a> -<span class="sourceLineNo">098</span> public Configuration getMasterConfiguration() {<a name="line.98"></a> -<span class="sourceLineNo">099</span> return master.getConfiguration();<a name="line.99"></a> -<span class="sourceLineNo">100</span> }<a name="line.100"></a> -<span class="sourceLineNo">101</span><a name="line.101"></a> -<span class="sourceLineNo">102</span> public AssignmentManager getAssignmentManager() {<a name="line.102"></a> -<span class="sourceLineNo">103</span> return master.getAssignmentManager();<a name="line.103"></a> -<span class="sourceLineNo">104</span> }<a name="line.104"></a> -<span class="sourceLineNo">105</span><a name="line.105"></a> -<span class="sourceLineNo">106</span> public MasterCoprocessorHost getMasterCoprocessorHost() {<a name="line.106"></a> -<span class="sourceLineNo">107</span> return master.getMasterCoprocessorHost();<a name="line.107"></a> -<span class="sourceLineNo">108</span> }<a name="line.108"></a> -<span class="sourceLineNo">109</span><a name="line.109"></a> -<span class="sourceLineNo">110</span> public MasterProcedureScheduler getProcedureScheduler() {<a name="line.110"></a> -<span class="sourceLineNo">111</span> return procSched;<a name="line.111"></a> -<span class="sourceLineNo">112</span> }<a name="line.112"></a> -<span class="sourceLineNo">113</span><a name="line.113"></a> -<span class="sourceLineNo">114</span> public RSProcedureDispatcher getRemoteDispatcher() {<a name="line.114"></a> -<span class="sourceLineNo">115</span> return remoteDispatcher;<a name="line.115"></a> -<span class="sourceLineNo">116</span> }<a name="line.116"></a> -<span class="sourceLineNo">117</span><a name="line.117"></a> -<span class="sourceLineNo">118</span> public ReplicationPeerManager getReplicationPeerManager() {<a name="line.118"></a> -<span class="sourceLineNo">119</span> return master.getReplicationPeerManager();<a name="line.119"></a> -<span class="sourceLineNo">120</span> }<a name="line.120"></a> -<span class="sourceLineNo">121</span><a name="line.121"></a> -<span class="sourceLineNo">122</span> public MasterFileSystem getMasterFileSystem() {<a name="line.122"></a> -<span class="sourceLineNo">123</span> return master.getMasterFileSystem();<a name="line.123"></a> -<span class="sourceLineNo">124</span> }<a name="line.124"></a> -<span class="sourceLineNo">125</span><a name="line.125"></a> -<span class="sourceLineNo">126</span> public boolean isRunning() {<a name="line.126"></a> -<span class="sourceLineNo">127</span> if (this.master == null || this.master.getMasterProcedureExecutor() == null) return false;<a name="line.127"></a> -<span class="sourceLineNo">128</span> return master.getMasterProcedureExecutor().isRunning();<a name="line.128"></a> -<span class="sourceLineNo">129</span> }<a name="line.129"></a> -<span class="sourceLineNo">130</span><a name="line.130"></a> -<span class="sourceLineNo">131</span> public boolean isInitialized() {<a name="line.131"></a> -<span class="sourceLineNo">132</span> return master.isInitialized();<a name="line.132"></a> -<span class="sourceLineNo">133</span> }<a name="line.133"></a> -<span class="sourceLineNo">134</span><a name="line.134"></a> -<span class="sourceLineNo">135</span> public boolean waitInitialized(Procedure<?> proc) {<a name="line.135"></a> -<span class="sourceLineNo">136</span> return master.getInitializedEvent().suspendIfNotReady(proc);<a name="line.136"></a> -<span class="sourceLineNo">137</span> }<a name="line.137"></a> -<span class="sourceLineNo">138</span><a name="line.138"></a> -<span class="sourceLineNo">139</span> public void setEventReady(ProcedureEvent<?> event, boolean isReady) {<a name="line.139"></a> -<span class="sourceLineNo">140</span> if (isReady) {<a name="line.140"></a> -<span class="sourceLineNo">141</span> event.wake(procSched);<a name="line.141"></a> -<span class="sourceLineNo">142</span> } else {<a name="line.142"></a> -<span class="sourceLineNo">143</span> event.suspend();<a name="line.143"></a> -<span class="sourceLineNo">144</span> }<a name="line.144"></a> -<span class="sourceLineNo">145</span> }<a name="line.145"></a> -<span class="sourceLineNo">146</span><a name="line.146"></a> -<span class="sourceLineNo">147</span> @Override<a name="line.147"></a> -<span class="sourceLineNo">148</span> public void onConfigurationChange(Configuration conf) {<a name="line.148"></a> -<span class="sourceLineNo">149</span> master.getMasterProcedureExecutor().refreshConfiguration(conf);<a name="line.149"></a> -<span class="sourceLineNo">150</span> }<a name="line.150"></a> -<span class="sourceLineNo">151</span>}<a name="line.151"></a> +<span class="sourceLineNo">086</span> this.procSched = new MasterProcedureScheduler(<a name="line.86"></a> +<span class="sourceLineNo">087</span> procId -> master.getMasterProcedureExecutor().getProcedure(procId));<a name="line.87"></a> +<span class="sourceLineNo">088</span> this.remoteDispatcher = remoteDispatcher;<a name="line.88"></a> +<span class="sourceLineNo">089</span> }<a name="line.89"></a> +<span class="sourceLineNo">090</span><a name="line.90"></a> +<span class="sourceLineNo">091</span> public User getRequestUser() {<a name="line.91"></a> +<span class="sourceLineNo">092</span> return RpcServer.getRequestUser().orElse(Superusers.getSystemUser());<a name="line.92"></a> +<span class="sourceLineNo">093</span> }<a name="line.93"></a> +<span class="sourceLineNo">094</span><a name="line.94"></a> +<span class="sourceLineNo">095</span> public MasterServices getMasterServices() {<a name="line.95"></a> +<span class="sourceLineNo">096</span> return master;<a name="line.96"></a> +<span class="sourceLineNo">097</span> }<a name="line.97"></a> +<span class="sourceLineNo">098</span><a name="line.98"></a> +<span class="sourceLineNo">099</span> public Configuration getMasterConfiguration() {<a name="line.99"></a> +<span class="sourceLineNo">100</span> return master.getConfiguration();<a name="line.100"></a> +<span class="sourceLineNo">101</span> }<a name="line.101"></a> +<span class="sourceLineNo">102</span><a name="line.102"></a> +<span class="sourceLineNo">103</span> public AssignmentManager getAssignmentManager() {<a name="line.103"></a> +<span class="sourceLineNo">104</span> return master.getAssignmentManager();<a name="line.104"></a> +<span class="sourceLineNo">105</span> }<a name="line.105"></a> +<span class="sourceLineNo">106</span><a name="line.106"></a> +<span class="sourceLineNo">107</span> public MasterCoprocessorHost getMasterCoprocessorHost() {<a name="line.107"></a> +<span class="sourceLineNo">108</span> return master.getMasterCoprocessorHost();<a name="line.108"></a> +<span class="sourceLineNo">109</span> }<a name="line.109"></a> +<span class="sourceLineNo">110</span><a name="line.110"></a> +<span class="sourceLineNo">111</span> public MasterProcedureScheduler getProcedureScheduler() {<a name="line.111"></a> +<span class="sourceLineNo">112</span> return procSched;<a name="line.112"></a> +<span class="sourceLineNo">113</span> }<a name="line.113"></a> +<span class="sourceLineNo">114</span><a name="line.114"></a> +<span class="sourceLineNo">115</span> public RSProcedureDispatcher getRemoteDispatcher() {<a name="line.115"></a> +<span class="sourceLineNo">116</span> return remoteDispatcher;<a name="line.116"></a> +<span class="sourceLineNo">117</span> }<a name="line.117"></a> +<span class="sourceLineNo">118</span><a name="line.118"></a> +<span class="sourceLineNo">119</span> public ReplicationPeerManager getReplicationPeerManager() {<a name="line.119"></a> +<span class="sourceLineNo">120</span> return master.getReplicationPeerManager();<a name="line.120"></a> +<span class="sourceLineNo">121</span> }<a name="line.121"></a> +<span class="sourceLineNo">122</span><a name="line.122"></a> +<span class="sourceLineNo">123</span> public MasterFileSystem getMasterFileSystem() {<a name="line.123"></a> +<span class="sourceLineNo">124</span> return master.getMasterFileSystem();<a name="line.124"></a> +<span class="sourceLineNo">125</span> }<a name="line.125"></a> +<span class="sourceLineNo">126</span><a name="line.126"></a> +<span class="sourceLineNo">127</span> public boolean isRunning() {<a name="line.127"></a> +<span class="sourceLineNo">128</span> if (this.master == null || this.master.getMasterProcedureExecutor() == null) return false;<a name="line.128"></a> +<span class="sourceLineNo">129</span> return master.getMasterProcedureExecutor().isRunning();<a name="line.129"></a> +<span class="sourceLineNo">130</span> }<a name="line.130"></a> +<span class="sourceLineNo">131</span><a name="line.131"></a> +<span class="sourceLineNo">132</span> public boolean isInitialized() {<a name="line.132"></a> +<span class="sourceLineNo">133</span> return master.isInitialized();<a name="line.133"></a> +<span class="sourceLineNo">134</span> }<a name="line.134"></a> +<span class="sourceLineNo">135</span><a name="line.135"></a> +<span class="sourceLineNo">136</span> public boolean waitInitialized(Procedure<?> proc) {<a name="line.136"></a> +<span class="sourceLineNo">137</span> return master.getInitializedEvent().suspendIfNotReady(proc);<a name="line.137"></a> +<span class="sourceLineNo">138</span> }<a name="line.138"></a> +<span class="sourceLineNo">139</span><a name="line.139"></a> +<span class="sourceLineNo">140</span> public void setEventReady(ProcedureEvent<?> event, boolean isReady) {<a name="line.140"></a> +<span class="sourceLineNo">141</span> if (isReady) {<a name="line.141"></a> +<span class="sourceLineNo">142</span> event.wake(procSched);<a name="line.142"></a> +<span class="sourceLineNo">143</span> } else {<a name="line.143"></a> +<span class="sourceLineNo">144</span> event.suspend();<a name="line.144"></a> +<span class="sourceLineNo">145</span> }<a name="line.145"></a> +<span class="sourceLineNo">146</span> }<a name="line.146"></a> +<span class="sourceLineNo">147</span><a name="line.147"></a> +<span class="sourceLineNo">148</span> @Override<a name="line.148"></a> +<span class="sourceLineNo">149</span> public void onConfigurationChange(Configuration conf) {<a name="line.149"></a> +<span class="sourceLineNo">150</span> master.getMasterProcedureExecutor().refreshConfiguration(conf);<a name="line.150"></a> +<span class="sourceLineNo">151</span> }<a name="line.151"></a> +<span class="sourceLineNo">152</span>}<a name="line.152"></a>
