You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2013/04/06 08:06:09 UTC
svn commit: r1465198 [39/41] - in /hbase/hbase.apache.org/trunk: ./ css/
hbase-assembly/ images/ xref-test/ xref-test/org/apache/hadoop/hbase/
xref-test/org/apache/hadoop/hbase/client/
xref-test/org/apache/hadoop/hbase/client/replication/ xref-test/org...
Modified: hbase/hbase.apache.org/trunk/xref/org/apache/hadoop/hbase/util/FSHDFSUtils.html
URL: http://svn.apache.org/viewvc/hbase/hbase.apache.org/trunk/xref/org/apache/hadoop/hbase/util/FSHDFSUtils.html?rev=1465198&r1=1465197&r2=1465198&view=diff
==============================================================================
--- hbase/hbase.apache.org/trunk/xref/org/apache/hadoop/hbase/util/FSHDFSUtils.html (original)
+++ hbase/hbase.apache.org/trunk/xref/org/apache/hadoop/hbase/util/FSHDFSUtils.html Sat Apr 6 06:06:07 2013
@@ -28,125 +28,87 @@
<a class="jxr_linenumber" name="18" href="#18">18</a>
<a class="jxr_linenumber" name="19" href="#19">19</a> <strong class="jxr_keyword">package</strong> org.apache.hadoop.hbase.util;
<a class="jxr_linenumber" name="20" href="#20">20</a>
-<a class="jxr_linenumber" name="21" href="#21">21</a> <strong class="jxr_keyword">import</strong> java.io.FileNotFoundException;
-<a class="jxr_linenumber" name="22" href="#22">22</a> <strong class="jxr_keyword">import</strong> java.io.IOException;
-<a class="jxr_linenumber" name="23" href="#23">23</a> <strong class="jxr_keyword">import</strong> java.io.InterruptedIOException;
-<a class="jxr_linenumber" name="24" href="#24">24</a> <strong class="jxr_keyword">import</strong> java.lang.reflect.InvocationTargetException;
-<a class="jxr_linenumber" name="25" href="#25">25</a>
-<a class="jxr_linenumber" name="26" href="#26">26</a> <strong class="jxr_keyword">import</strong> org.apache.commons.logging.Log;
-<a class="jxr_linenumber" name="27" href="#27">27</a> <strong class="jxr_keyword">import</strong> org.apache.commons.logging.LogFactory;
-<a class="jxr_linenumber" name="28" href="#28">28</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.classification.InterfaceAudience;
-<a class="jxr_linenumber" name="29" href="#29">29</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.classification.InterfaceStability;
-<a class="jxr_linenumber" name="30" href="#30">30</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.conf.Configuration;
-<a class="jxr_linenumber" name="31" href="#31">31</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.fs.FSDataOutputStream;
-<a class="jxr_linenumber" name="32" href="#32">32</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.fs.FileSystem;
-<a class="jxr_linenumber" name="33" href="#33">33</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.fs.Path;
-<a class="jxr_linenumber" name="34" href="#34">34</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.RemoteExceptionHandler;
-<a class="jxr_linenumber" name="35" href="#35">35</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hdfs.DistributedFileSystem;
-<a class="jxr_linenumber" name="36" href="#36">36</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hdfs.protocol.AlreadyBeingCreatedException;
-<a class="jxr_linenumber" name="37" href="#37">37</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hdfs.server.namenode.LeaseExpiredException;
-<a class="jxr_linenumber" name="38" href="#38">38</a>
-<a class="jxr_linenumber" name="39" href="#39">39</a>
-<a class="jxr_linenumber" name="40" href="#40">40</a> <em class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="41" href="#41">41</a> <em class="jxr_javadoccomment"> * Implementation for hdfs</em>
-<a class="jxr_linenumber" name="42" href="#42">42</a> <em class="jxr_javadoccomment"> */</em>
-<a class="jxr_linenumber" name="43" href="#43">43</a> @InterfaceAudience.Public
-<a class="jxr_linenumber" name="44" href="#44">44</a> @InterfaceStability.Evolving
-<a class="jxr_linenumber" name="45" href="#45">45</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/hadoop/hbase/util/FSHDFSUtils.html">FSHDFSUtils</a> <strong class="jxr_keyword">extends</strong> <a href="../../../../../org/apache/hadoop/hbase/util/FSUtils.html">FSUtils</a>{
-<a class="jxr_linenumber" name="46" href="#46">46</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> Log LOG = LogFactory.getLog(FSHDFSUtils.<strong class="jxr_keyword">class</strong>);
-<a class="jxr_linenumber" name="47" href="#47">47</a>
-<a class="jxr_linenumber" name="48" href="#48">48</a> <em class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="49" href="#49">49</a> <em class="jxr_javadoccomment"> * Lease timeout constant, sourced from HDFS upstream.</em>
-<a class="jxr_linenumber" name="50" href="#50">50</a> <em class="jxr_javadoccomment"> * The upstream constant is defined in a private interface, so we</em>
-<a class="jxr_linenumber" name="51" href="#51">51</a> <em class="jxr_javadoccomment"> * can't reuse for compatibility reasons.</em>
-<a class="jxr_linenumber" name="52" href="#52">52</a> <em class="jxr_javadoccomment"> * NOTE: On versions earlier than Hadoop 0.23, the constant is in</em>
-<a class="jxr_linenumber" name="53" href="#53">53</a> <em class="jxr_javadoccomment"> * o.a.h.hdfs.protocol.FSConstants, while for 0.23 and above it is</em>
-<a class="jxr_linenumber" name="54" href="#54">54</a> <em class="jxr_javadoccomment"> * in o.a.h.hdfs.protocol.HdfsConstants cause of HDFS-1620.</em>
-<a class="jxr_linenumber" name="55" href="#55">55</a> <em class="jxr_javadoccomment"> */</em>
-<a class="jxr_linenumber" name="56" href="#56">56</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">long</strong> LEASE_SOFTLIMIT_PERIOD = 60 * 1000;
-<a class="jxr_linenumber" name="57" href="#57">57</a>
-<a class="jxr_linenumber" name="58" href="#58">58</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> String TEST_TRIGGER_DFS_APPEND = <span class="jxr_string">"hbase.test.trigger.dfs.append"</span>;
-<a class="jxr_linenumber" name="59" href="#59">59</a>
-<a class="jxr_linenumber" name="60" href="#60">60</a> @Override
-<a class="jxr_linenumber" name="61" href="#61">61</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> recoverFileLease(<strong class="jxr_keyword">final</strong> FileSystem fs, <strong class="jxr_keyword">final</strong> Path p, Configuration conf)
-<a class="jxr_linenumber" name="62" href="#62">62</a> <strong class="jxr_keyword">throws</strong> IOException{
-<a class="jxr_linenumber" name="63" href="#63">63</a> <strong class="jxr_keyword">if</strong> (!isAppendSupported(conf)) {
-<a class="jxr_linenumber" name="64" href="#64">64</a> LOG.warn(<span class="jxr_string">"Running on HDFS without append enabled may result in data loss"</span>);
-<a class="jxr_linenumber" name="65" href="#65">65</a> <strong class="jxr_keyword">return</strong>;
-<a class="jxr_linenumber" name="66" href="#66">66</a> }
-<a class="jxr_linenumber" name="67" href="#67">67</a> <em class="jxr_comment">// lease recovery not needed for local file system case.</em>
-<a class="jxr_linenumber" name="68" href="#68">68</a> <em class="jxr_comment">// currently, local file system doesn't implement append either.</em>
-<a class="jxr_linenumber" name="69" href="#69">69</a> <strong class="jxr_keyword">if</strong> (!(fs instanceof DistributedFileSystem)) {
-<a class="jxr_linenumber" name="70" href="#70">70</a> <strong class="jxr_keyword">return</strong>;
-<a class="jxr_linenumber" name="71" href="#71">71</a> }
-<a class="jxr_linenumber" name="72" href="#72">72</a> LOG.info(<span class="jxr_string">"Recovering file "</span> + p);
-<a class="jxr_linenumber" name="73" href="#73">73</a> <strong class="jxr_keyword">long</strong> startWaiting = System.currentTimeMillis();
-<a class="jxr_linenumber" name="74" href="#74">74</a>
-<a class="jxr_linenumber" name="75" href="#75">75</a> <em class="jxr_comment">// Trying recovery</em>
-<a class="jxr_linenumber" name="76" href="#76">76</a> <strong class="jxr_keyword">boolean</strong> recovered = false;
-<a class="jxr_linenumber" name="77" href="#77">77</a> <strong class="jxr_keyword">long</strong> recoveryTimeout = conf.getInt(<span class="jxr_string">"hbase.lease.recovery.timeout"</span>, 300000);
-<a class="jxr_linenumber" name="78" href="#78">78</a> <em class="jxr_comment">// conf parameter passed from unit test, indicating whether fs.append() should be triggered</em>
-<a class="jxr_linenumber" name="79" href="#79">79</a> <strong class="jxr_keyword">boolean</strong> triggerAppend = conf.getBoolean(TEST_TRIGGER_DFS_APPEND, false);
-<a class="jxr_linenumber" name="80" href="#80">80</a> Exception ex = <strong class="jxr_keyword">null</strong>;
-<a class="jxr_linenumber" name="81" href="#81">81</a> <strong class="jxr_keyword">while</strong> (!recovered) {
-<a class="jxr_linenumber" name="82" href="#82">82</a> <strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="83" href="#83">83</a> <strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="84" href="#84">84</a> DistributedFileSystem dfs = (DistributedFileSystem) fs;
-<a class="jxr_linenumber" name="85" href="#85">85</a> <strong class="jxr_keyword">if</strong> (triggerAppend) <strong class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> IOException();
-<a class="jxr_linenumber" name="86" href="#86">86</a> <strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="87" href="#87">87</a> recovered = (Boolean) DistributedFileSystem.<strong class="jxr_keyword">class</strong>.getMethod(
-<a class="jxr_linenumber" name="88" href="#88">88</a> <span class="jxr_string">"recoverLease"</span>, <strong class="jxr_keyword">new</strong> Class[] { Path.<strong class="jxr_keyword">class</strong> }).invoke(dfs, p);
-<a class="jxr_linenumber" name="89" href="#89">89</a> <strong class="jxr_keyword">if</strong> (!recovered) LOG.debug(<span class="jxr_string">"recoverLease returned false"</span>);
-<a class="jxr_linenumber" name="90" href="#90">90</a> } <strong class="jxr_keyword">catch</strong> (InvocationTargetException ite) {
-<a class="jxr_linenumber" name="91" href="#91">91</a> <em class="jxr_comment">// function was properly called, but threw it's own exception</em>
-<a class="jxr_linenumber" name="92" href="#92">92</a> <strong class="jxr_keyword">throw</strong> (IOException) ite.getCause();
-<a class="jxr_linenumber" name="93" href="#93">93</a> }
-<a class="jxr_linenumber" name="94" href="#94">94</a> } <strong class="jxr_keyword">catch</strong> (Exception e) {
-<a class="jxr_linenumber" name="95" href="#95">95</a> LOG.debug(<span class="jxr_string">"Failed fs.recoverLease invocation, "</span> + e.toString() +
-<a class="jxr_linenumber" name="96" href="#96">96</a> <span class="jxr_string">", trying fs.append instead"</span>);
-<a class="jxr_linenumber" name="97" href="#97">97</a> ex = e;
-<a class="jxr_linenumber" name="98" href="#98">98</a> }
-<a class="jxr_linenumber" name="99" href="#99">99</a> <strong class="jxr_keyword">if</strong> (ex != <strong class="jxr_keyword">null</strong> || System.currentTimeMillis() - startWaiting > recoveryTimeout) {
-<a class="jxr_linenumber" name="100" href="#100">100</a> LOG.debug(<span class="jxr_string">"trying fs.append for "</span> + p + <span class="jxr_string">" with "</span> + ex);
-<a class="jxr_linenumber" name="101" href="#101">101</a> ex = <strong class="jxr_keyword">null</strong>; <em class="jxr_comment">// assume the following append() call would succeed</em>
-<a class="jxr_linenumber" name="102" href="#102">102</a> FSDataOutputStream out = fs.append(p);
-<a class="jxr_linenumber" name="103" href="#103">103</a> out.close();
-<a class="jxr_linenumber" name="104" href="#104">104</a> recovered = <strong class="jxr_keyword">true</strong>;
-<a class="jxr_linenumber" name="105" href="#105">105</a> LOG.debug(<span class="jxr_string">"fs.append passed"</span>);
-<a class="jxr_linenumber" name="106" href="#106">106</a> }
-<a class="jxr_linenumber" name="107" href="#107">107</a> <strong class="jxr_keyword">if</strong> (recovered) <strong class="jxr_keyword">break</strong>;
-<a class="jxr_linenumber" name="108" href="#108">108</a> } <strong class="jxr_keyword">catch</strong> (IOException e) {
-<a class="jxr_linenumber" name="109" href="#109">109</a> e = RemoteExceptionHandler.checkIOException(e);
-<a class="jxr_linenumber" name="110" href="#110">110</a> <strong class="jxr_keyword">if</strong> (e instanceof AlreadyBeingCreatedException) {
-<a class="jxr_linenumber" name="111" href="#111">111</a> <em class="jxr_comment">// We expect that we'll get this message while the lease is still</em>
-<a class="jxr_linenumber" name="112" href="#112">112</a> <em class="jxr_comment">// within its soft limit, but if we get it past that, it means</em>
-<a class="jxr_linenumber" name="113" href="#113">113</a> <em class="jxr_comment">// that the RS is holding onto the file even though it lost its</em>
-<a class="jxr_linenumber" name="114" href="#114">114</a> <em class="jxr_comment">// znode. We could potentially abort after some time here.</em>
-<a class="jxr_linenumber" name="115" href="#115">115</a> <strong class="jxr_keyword">long</strong> waitedFor = System.currentTimeMillis() - startWaiting;
-<a class="jxr_linenumber" name="116" href="#116">116</a> <strong class="jxr_keyword">if</strong> (waitedFor > LEASE_SOFTLIMIT_PERIOD) {
-<a class="jxr_linenumber" name="117" href="#117">117</a> LOG.warn(<span class="jxr_string">"Waited "</span> + waitedFor + <span class="jxr_string">"ms for lease recovery on "</span> + p +
-<a class="jxr_linenumber" name="118" href="#118">118</a> <span class="jxr_string">":"</span> + e.getMessage());
-<a class="jxr_linenumber" name="119" href="#119">119</a> }
-<a class="jxr_linenumber" name="120" href="#120">120</a> } <strong class="jxr_keyword">else</strong> <strong class="jxr_keyword">if</strong> (e instanceof LeaseExpiredException &&
-<a class="jxr_linenumber" name="121" href="#121">121</a> e.getMessage().contains(<span class="jxr_string">"File does not exist"</span>)) {
-<a class="jxr_linenumber" name="122" href="#122">122</a> <em class="jxr_comment">// This exception comes out instead of FNFE, fix it</em>
-<a class="jxr_linenumber" name="123" href="#123">123</a> <strong class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> FileNotFoundException(
-<a class="jxr_linenumber" name="124" href="#124">124</a> <span class="jxr_string">"The given HLog wasn't found at "</span> + p.toString());
-<a class="jxr_linenumber" name="125" href="#125">125</a> } <strong class="jxr_keyword">else</strong> {
-<a class="jxr_linenumber" name="126" href="#126">126</a> <strong class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> IOException(<span class="jxr_string">"Failed to open "</span> + p + <span class="jxr_string">" for append"</span>, e);
-<a class="jxr_linenumber" name="127" href="#127">127</a> }
-<a class="jxr_linenumber" name="128" href="#128">128</a> }
-<a class="jxr_linenumber" name="129" href="#129">129</a> <strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="130" href="#130">130</a> Thread.sleep(1000);
-<a class="jxr_linenumber" name="131" href="#131">131</a> } <strong class="jxr_keyword">catch</strong> (InterruptedException ie) {
-<a class="jxr_linenumber" name="132" href="#132">132</a> InterruptedIOException iioe = <strong class="jxr_keyword">new</strong> InterruptedIOException();
-<a class="jxr_linenumber" name="133" href="#133">133</a> iioe.initCause(ie);
-<a class="jxr_linenumber" name="134" href="#134">134</a> <strong class="jxr_keyword">throw</strong> iioe;
-<a class="jxr_linenumber" name="135" href="#135">135</a> }
-<a class="jxr_linenumber" name="136" href="#136">136</a> }
-<a class="jxr_linenumber" name="137" href="#137">137</a> LOG.info(<span class="jxr_string">"Finished lease recover attempt for "</span> + p);
-<a class="jxr_linenumber" name="138" href="#138">138</a> }
-<a class="jxr_linenumber" name="139" href="#139">139</a> }
+<a class="jxr_linenumber" name="21" href="#21">21</a> <strong class="jxr_keyword">import</strong> org.apache.commons.logging.Log;
+<a class="jxr_linenumber" name="22" href="#22">22</a> <strong class="jxr_keyword">import</strong> org.apache.commons.logging.LogFactory;
+<a class="jxr_linenumber" name="23" href="#23">23</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.classification.InterfaceAudience;
+<a class="jxr_linenumber" name="24" href="#24">24</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.classification.InterfaceStability;
+<a class="jxr_linenumber" name="25" href="#25">25</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.conf.Configuration;
+<a class="jxr_linenumber" name="26" href="#26">26</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.fs.FileSystem;
+<a class="jxr_linenumber" name="27" href="#27">27</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.fs.Path;
+<a class="jxr_linenumber" name="28" href="#28">28</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hdfs.DistributedFileSystem;
+<a class="jxr_linenumber" name="29" href="#29">29</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hdfs.server.namenode.LeaseExpiredException;
+<a class="jxr_linenumber" name="30" href="#30">30</a>
+<a class="jxr_linenumber" name="31" href="#31">31</a> <strong class="jxr_keyword">import</strong> java.io.FileNotFoundException;
+<a class="jxr_linenumber" name="32" href="#32">32</a> <strong class="jxr_keyword">import</strong> java.io.IOException;
+<a class="jxr_linenumber" name="33" href="#33">33</a> <strong class="jxr_keyword">import</strong> java.io.InterruptedIOException;
+<a class="jxr_linenumber" name="34" href="#34">34</a>
+<a class="jxr_linenumber" name="35" href="#35">35</a>
+<a class="jxr_linenumber" name="36" href="#36">36</a> <em class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="37" href="#37">37</a> <em class="jxr_javadoccomment"> * Implementation for hdfs</em>
+<a class="jxr_linenumber" name="38" href="#38">38</a> <em class="jxr_javadoccomment"> */</em>
+<a class="jxr_linenumber" name="39" href="#39">39</a> @InterfaceAudience.Private
+<a class="jxr_linenumber" name="40" href="#40">40</a> @InterfaceStability.Evolving
+<a class="jxr_linenumber" name="41" href="#41">41</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/hadoop/hbase/util/FSHDFSUtils.html">FSHDFSUtils</a> <strong class="jxr_keyword">extends</strong> <a href="../../../../../org/apache/hadoop/hbase/util/FSUtils.html">FSUtils</a>{
+<a class="jxr_linenumber" name="42" href="#42">42</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> Log LOG = LogFactory.getLog(FSHDFSUtils.<strong class="jxr_keyword">class</strong>);
+<a class="jxr_linenumber" name="43" href="#43">43</a>
+<a class="jxr_linenumber" name="44" href="#44">44</a> <em class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="45" href="#45">45</a> <em class="jxr_javadoccomment"> * Recover the lease from HDFS, retrying multiple times.</em>
+<a class="jxr_linenumber" name="46" href="#46">46</a> <em class="jxr_javadoccomment"> */</em>
+<a class="jxr_linenumber" name="47" href="#47">47</a> @Override
+<a class="jxr_linenumber" name="48" href="#48">48</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> recoverFileLease(<strong class="jxr_keyword">final</strong> FileSystem fs, <strong class="jxr_keyword">final</strong> Path p, Configuration conf)
+<a class="jxr_linenumber" name="49" href="#49">49</a> <strong class="jxr_keyword">throws</strong> IOException {
+<a class="jxr_linenumber" name="50" href="#50">50</a> <em class="jxr_comment">// lease recovery not needed for local file system case.</em>
+<a class="jxr_linenumber" name="51" href="#51">51</a> <strong class="jxr_keyword">if</strong> (!(fs instanceof DistributedFileSystem)) {
+<a class="jxr_linenumber" name="52" href="#52">52</a> <strong class="jxr_keyword">return</strong>;
+<a class="jxr_linenumber" name="53" href="#53">53</a> }
+<a class="jxr_linenumber" name="54" href="#54">54</a> DistributedFileSystem dfs = (DistributedFileSystem) fs;
+<a class="jxr_linenumber" name="55" href="#55">55</a>
+<a class="jxr_linenumber" name="56" href="#56">56</a> LOG.info(<span class="jxr_string">"Recovering file "</span> + p);
+<a class="jxr_linenumber" name="57" href="#57">57</a> <strong class="jxr_keyword">long</strong> startWaiting = EnvironmentEdgeManager.currentTimeMillis();
+<a class="jxr_linenumber" name="58" href="#58">58</a> <em class="jxr_comment">// Default is 15 minutes. It's huge, but the idea is that if we have a major issue, HDFS</em>
+<a class="jxr_linenumber" name="59" href="#59">59</a> <em class="jxr_comment">// usually needs 10 minutes before marking the nodes as dead. So we're putting ourselves</em>
+<a class="jxr_linenumber" name="60" href="#60">60</a> <em class="jxr_comment">// beyond that limit 'to be safe'.</em>
+<a class="jxr_linenumber" name="61" href="#61">61</a> <strong class="jxr_keyword">long</strong> recoveryTimeout = conf.getInt(<span class="jxr_string">"hbase.lease.recovery.timeout"</span>, 900000) + startWaiting;
+<a class="jxr_linenumber" name="62" href="#62">62</a> <strong class="jxr_keyword">boolean</strong> recovered = false;
+<a class="jxr_linenumber" name="63" href="#63">63</a> <strong class="jxr_keyword">int</strong> nbAttempt = 0;
+<a class="jxr_linenumber" name="64" href="#64">64</a> <strong class="jxr_keyword">while</strong> (!recovered) {
+<a class="jxr_linenumber" name="65" href="#65">65</a> nbAttempt++;
+<a class="jxr_linenumber" name="66" href="#66">66</a> <strong class="jxr_keyword">try</strong> {
+<a class="jxr_linenumber" name="67" href="#67">67</a> <em class="jxr_comment">// recoverLease is asynchronous. We expect it to return true at the first call if the</em>
+<a class="jxr_linenumber" name="68" href="#68">68</a> <em class="jxr_comment">// file is closed. So, it returns:</em>
+<a class="jxr_linenumber" name="69" href="#69">69</a> <em class="jxr_comment">// - false when it starts the lease recovery (i.e. lease recovery not *yet* done</em>
+<a class="jxr_linenumber" name="70" href="#70">70</a> <em class="jxr_comment">// - true when the lease recovery has succeeded or the file is closed.</em>
+<a class="jxr_linenumber" name="71" href="#71">71</a> recovered = dfs.recoverLease(p);
+<a class="jxr_linenumber" name="72" href="#72">72</a> LOG.info(<span class="jxr_string">"Attempt "</span> + nbAttempt + <span class="jxr_string">" to recoverLease on file "</span> + p +
+<a class="jxr_linenumber" name="73" href="#73">73</a> <span class="jxr_string">" returned "</span> + recovered + <span class="jxr_string">", trying for "</span> +
+<a class="jxr_linenumber" name="74" href="#74">74</a> (EnvironmentEdgeManager.currentTimeMillis() - startWaiting) + <span class="jxr_string">"ms"</span>);
+<a class="jxr_linenumber" name="75" href="#75">75</a> } <strong class="jxr_keyword">catch</strong> (IOException e) {
+<a class="jxr_linenumber" name="76" href="#76">76</a> <strong class="jxr_keyword">if</strong> (e instanceof LeaseExpiredException && e.getMessage().contains(<span class="jxr_string">"File does not exist"</span>)) {
+<a class="jxr_linenumber" name="77" href="#77">77</a> <em class="jxr_comment">// This exception comes out instead of FNFE, fix it</em>
+<a class="jxr_linenumber" name="78" href="#78">78</a> <strong class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> FileNotFoundException(<span class="jxr_string">"The given HLog wasn't found at "</span> + p);
+<a class="jxr_linenumber" name="79" href="#79">79</a> }
+<a class="jxr_linenumber" name="80" href="#80">80</a> LOG.warn(<span class="jxr_string">"Got IOException on attempt "</span> + nbAttempt + <span class="jxr_string">" to recover lease for file "</span> + p +
+<a class="jxr_linenumber" name="81" href="#81">81</a> <span class="jxr_string">", retrying."</span>, e);
+<a class="jxr_linenumber" name="82" href="#82">82</a> }
+<a class="jxr_linenumber" name="83" href="#83">83</a> <strong class="jxr_keyword">if</strong> (!recovered) {
+<a class="jxr_linenumber" name="84" href="#84">84</a> <em class="jxr_comment">// try at least twice.</em>
+<a class="jxr_linenumber" name="85" href="#85">85</a> <strong class="jxr_keyword">if</strong> (nbAttempt > 2 && recoveryTimeout < EnvironmentEdgeManager.currentTimeMillis()) {
+<a class="jxr_linenumber" name="86" href="#86">86</a> LOG.error(<span class="jxr_string">"Can't recoverLease after "</span> + nbAttempt + <span class="jxr_string">" attempts and "</span> +
+<a class="jxr_linenumber" name="87" href="#87">87</a> (EnvironmentEdgeManager.currentTimeMillis() - startWaiting) + <span class="jxr_string">"ms "</span> + <span class="jxr_string">" for "</span> + p +
+<a class="jxr_linenumber" name="88" href="#88">88</a> <span class="jxr_string">" - continuing without the lease, but we could have a data loss."</span>);
+<a class="jxr_linenumber" name="89" href="#89">89</a> } <strong class="jxr_keyword">else</strong> {
+<a class="jxr_linenumber" name="90" href="#90">90</a> <strong class="jxr_keyword">try</strong> {
+<a class="jxr_linenumber" name="91" href="#91">91</a> Thread.sleep(nbAttempt < 3 ? 500 : 1000);
+<a class="jxr_linenumber" name="92" href="#92">92</a> } <strong class="jxr_keyword">catch</strong> (InterruptedException ie) {
+<a class="jxr_linenumber" name="93" href="#93">93</a> InterruptedIOException iioe = <strong class="jxr_keyword">new</strong> InterruptedIOException();
+<a class="jxr_linenumber" name="94" href="#94">94</a> iioe.initCause(ie);
+<a class="jxr_linenumber" name="95" href="#95">95</a> <strong class="jxr_keyword">throw</strong> iioe;
+<a class="jxr_linenumber" name="96" href="#96">96</a> }
+<a class="jxr_linenumber" name="97" href="#97">97</a> }
+<a class="jxr_linenumber" name="98" href="#98">98</a> }
+<a class="jxr_linenumber" name="99" href="#99">99</a> }
+<a class="jxr_linenumber" name="100" href="#100">100</a> }
+<a class="jxr_linenumber" name="101" href="#101">101</a> }
</pre>
<hr/><div id="footer">This page was automatically generated by <a href="http://maven.apache.org/">Maven</a></div></body>
</html>