http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.CompletedProcedureCleaner.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.CompletedProcedureCleaner.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.CompletedProcedureCleaner.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.CompletedProcedureCleaner.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.CompletedProcedureCleaner.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.CompletedProcedureRetainer.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.CompletedProcedureRetainer.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.CompletedProcedureRetainer.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.CompletedProcedureRetainer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.CompletedProcedureRetainer.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.DelayedProcedure.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.DelayedProcedure.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.DelayedProcedure.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.DelayedProcedure.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.DelayedProcedure.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.FailedProcedure.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.FailedProcedure.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.FailedProcedure.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.FailedProcedure.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.FailedProcedure.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.InlineChore.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.InlineChore.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.InlineChore.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.InlineChore.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.InlineChore.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.ProcedureExecutorListener.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.ProcedureExecutorListener.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.ProcedureExecutorListener.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.ProcedureExecutorListener.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.ProcedureExecutorListener.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.StoppableThread.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.StoppableThread.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.StoppableThread.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.StoppableThread.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.StoppableThread.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.Testing.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.Testing.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.Testing.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.Testing.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.Testing.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.TimeoutExecutorThread.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.TimeoutExecutorThread.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.TimeoutExecutorThread.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.TimeoutExecutorThread.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.TimeoutExecutorThread.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerMonitor.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerMonitor.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerMonitor.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerMonitor.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerMonitor.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerThread.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerThread.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerThread.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerThread.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerThread.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/346adc37/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.html index 904b921..3531f22 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.html @@ -323,7 +323,7 @@ <span class="sourceLineNo">315</span> @Override<a name="line.315"></a> <span class="sourceLineNo">316</span> public void setMaxProcId(long maxProcId) {<a name="line.316"></a> <span class="sourceLineNo">317</span> assert lastProcId.get() < 0 : "expected only one call to setMaxProcId()";<a name="line.317"></a> -<span class="sourceLineNo">318</span> LOG.debug("Load maxProcId=" + maxProcId);<a name="line.318"></a> +<span class="sourceLineNo">318</span> LOG.debug("Load max pid=" + maxProcId);<a name="line.318"></a> <span class="sourceLineNo">319</span> lastProcId.set(maxProcId);<a name="line.319"></a> <span class="sourceLineNo">320</span> }<a name="line.320"></a> <span class="sourceLineNo">321</span><a name="line.321"></a> @@ -735,7 +735,7 @@ <span class="sourceLineNo">727</span> !(procedures.containsKey(oldProcId) || completed.containsKey(oldProcId)) &&<a name="line.727"></a> <span class="sourceLineNo">728</span> nonceKeysToProcIdsMap.containsKey(nonceKey)) {<a name="line.728"></a> <span class="sourceLineNo">729</span> if (traceEnabled) {<a name="line.729"></a> -<span class="sourceLineNo">730</span> LOG.trace("Waiting for procId=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> +<span class="sourceLineNo">730</span> LOG.trace("Waiting for pid=" + oldProcId.longValue() + " to be submitted");<a name="line.730"></a> <span class="sourceLineNo">731</span> }<a name="line.731"></a> <span class="sourceLineNo">732</span> Threads.sleep(100);<a name="line.732"></a> <span class="sourceLineNo">733</span> }<a name="line.733"></a> @@ -1007,9 +1007,9 @@ <span class="sourceLineNo">999</span> public void removeResult(final long procId) {<a name="line.999"></a> <span class="sourceLineNo">1000</span> CompletedProcedureRetainer retainer = completed.get(procId);<a name="line.1000"></a> <span class="sourceLineNo">1001</span> if (retainer == null) {<a name="line.1001"></a> -<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "procId=" + procId + " is still running";<a name="line.1002"></a> +<span class="sourceLineNo">1002</span> assert !procedures.containsKey(procId) : "pid=" + procId + " is still running";<a name="line.1002"></a> <span class="sourceLineNo">1003</span> if (LOG.isDebugEnabled()) {<a name="line.1003"></a> -<span class="sourceLineNo">1004</span> LOG.debug("procId=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> +<span class="sourceLineNo">1004</span> LOG.debug("pid=" + procId + " already removed by the cleaner.");<a name="line.1004"></a> <span class="sourceLineNo">1005</span> }<a name="line.1005"></a> <span class="sourceLineNo">1006</span> return;<a name="line.1006"></a> <span class="sourceLineNo">1007</span> }<a name="line.1007"></a> @@ -1357,7 +1357,7 @@ <span class="sourceLineNo">1349</span> return LockState.LOCK_YIELD_WAIT;<a name="line.1349"></a> <span class="sourceLineNo">1350</span> } catch (Throwable e) {<a name="line.1350"></a> <span class="sourceLineNo">1351</span> // Catch NullPointerExceptions or similar errors...<a name="line.1351"></a> -<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception fo " + proc, e);<a name="line.1352"></a> +<span class="sourceLineNo">1352</span> LOG.fatal("CODE-BUG: Uncaught runtime exception for " + proc, e);<a name="line.1352"></a> <span class="sourceLineNo">1353</span> }<a name="line.1353"></a> <span class="sourceLineNo">1354</span><a name="line.1354"></a> <span class="sourceLineNo">1355</span> // allows to kill the executor before something is stored to the wal.<a name="line.1355"></a>
