You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by gi...@apache.org on 2018/09/09 14:52:11 UTC
[12/27] hbase-site git commit: Published site at
a51c333856c358d97706e10bcb1a46ba569b27fb.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/66c38917/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.ProcedureFuture.WaitForStateCallable.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.ProcedureFuture.WaitForStateCallable.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.ProcedureFuture.WaitForStateCallable.html
index 136b7bc..a5789e0 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.ProcedureFuture.WaitForStateCallable.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.ProcedureFuture.WaitForStateCallable.html
@@ -3318,1033 +3318,1040 @@
<span class="sourceLineNo">3310</span> @Override<a name="line.3310"></a>
<span class="sourceLineNo">3311</span> public CompactionState getCompactionState(final TableName tableName, CompactType compactType)<a name="line.3311"></a>
<span class="sourceLineNo">3312</span> throws IOException {<a name="line.3312"></a>
-<span class="sourceLineNo">3313</span> AdminProtos.GetRegionInfoResponse.CompactionState state =<a name="line.3313"></a>
-<span class="sourceLineNo">3314</span> AdminProtos.GetRegionInfoResponse.CompactionState.NONE;<a name="line.3314"></a>
-<span class="sourceLineNo">3315</span> checkTableExists(tableName);<a name="line.3315"></a>
-<span class="sourceLineNo">3316</span> // TODO: There is no timeout on this controller. Set one!<a name="line.3316"></a>
-<span class="sourceLineNo">3317</span> HBaseRpcController rpcController = rpcControllerFactory.newController();<a name="line.3317"></a>
-<span class="sourceLineNo">3318</span> switch (compactType) {<a name="line.3318"></a>
-<span class="sourceLineNo">3319</span> case MOB:<a name="line.3319"></a>
-<span class="sourceLineNo">3320</span> final AdminProtos.AdminService.BlockingInterface masterAdmin =<a name="line.3320"></a>
-<span class="sourceLineNo">3321</span> this.connection.getAdminForMaster();<a name="line.3321"></a>
-<span class="sourceLineNo">3322</span> Callable<AdminProtos.GetRegionInfoResponse.CompactionState> callable =<a name="line.3322"></a>
-<span class="sourceLineNo">3323</span> new Callable<AdminProtos.GetRegionInfoResponse.CompactionState>() {<a name="line.3323"></a>
-<span class="sourceLineNo">3324</span> @Override<a name="line.3324"></a>
-<span class="sourceLineNo">3325</span> public AdminProtos.GetRegionInfoResponse.CompactionState call() throws Exception {<a name="line.3325"></a>
-<span class="sourceLineNo">3326</span> RegionInfo info = RegionInfo.createMobRegionInfo(tableName);<a name="line.3326"></a>
-<span class="sourceLineNo">3327</span> GetRegionInfoRequest request =<a name="line.3327"></a>
-<span class="sourceLineNo">3328</span> RequestConverter.buildGetRegionInfoRequest(info.getRegionName(), true);<a name="line.3328"></a>
-<span class="sourceLineNo">3329</span> GetRegionInfoResponse response = masterAdmin.getRegionInfo(rpcController, request);<a name="line.3329"></a>
-<span class="sourceLineNo">3330</span> return response.getCompactionState();<a name="line.3330"></a>
-<span class="sourceLineNo">3331</span> }<a name="line.3331"></a>
-<span class="sourceLineNo">3332</span> };<a name="line.3332"></a>
-<span class="sourceLineNo">3333</span> state = ProtobufUtil.call(callable);<a name="line.3333"></a>
-<span class="sourceLineNo">3334</span> break;<a name="line.3334"></a>
-<span class="sourceLineNo">3335</span> case NORMAL:<a name="line.3335"></a>
-<span class="sourceLineNo">3336</span> for (HRegionLocation loc : connection.locateRegions(tableName, false, false)) {<a name="line.3336"></a>
-<span class="sourceLineNo">3337</span> ServerName sn = loc.getServerName();<a name="line.3337"></a>
-<span class="sourceLineNo">3338</span> if (sn == null) {<a name="line.3338"></a>
-<span class="sourceLineNo">3339</span> continue;<a name="line.3339"></a>
-<span class="sourceLineNo">3340</span> }<a name="line.3340"></a>
-<span class="sourceLineNo">3341</span> byte[] regionName = loc.getRegion().getRegionName();<a name="line.3341"></a>
-<span class="sourceLineNo">3342</span> AdminService.BlockingInterface snAdmin = this.connection.getAdmin(sn);<a name="line.3342"></a>
-<span class="sourceLineNo">3343</span> try {<a name="line.3343"></a>
-<span class="sourceLineNo">3344</span> Callable<GetRegionInfoResponse> regionInfoCallable =<a name="line.3344"></a>
-<span class="sourceLineNo">3345</span> new Callable<GetRegionInfoResponse>() {<a name="line.3345"></a>
-<span class="sourceLineNo">3346</span> @Override<a name="line.3346"></a>
-<span class="sourceLineNo">3347</span> public GetRegionInfoResponse call() throws Exception {<a name="line.3347"></a>
-<span class="sourceLineNo">3348</span> GetRegionInfoRequest request =<a name="line.3348"></a>
-<span class="sourceLineNo">3349</span> RequestConverter.buildGetRegionInfoRequest(regionName, true);<a name="line.3349"></a>
-<span class="sourceLineNo">3350</span> return snAdmin.getRegionInfo(rpcController, request);<a name="line.3350"></a>
-<span class="sourceLineNo">3351</span> }<a name="line.3351"></a>
-<span class="sourceLineNo">3352</span> };<a name="line.3352"></a>
-<span class="sourceLineNo">3353</span> GetRegionInfoResponse response = ProtobufUtil.call(regionInfoCallable);<a name="line.3353"></a>
-<span class="sourceLineNo">3354</span> switch (response.getCompactionState()) {<a name="line.3354"></a>
-<span class="sourceLineNo">3355</span> case MAJOR_AND_MINOR:<a name="line.3355"></a>
-<span class="sourceLineNo">3356</span> return CompactionState.MAJOR_AND_MINOR;<a name="line.3356"></a>
-<span class="sourceLineNo">3357</span> case MAJOR:<a name="line.3357"></a>
-<span class="sourceLineNo">3358</span> if (state == AdminProtos.GetRegionInfoResponse.CompactionState.MINOR) {<a name="line.3358"></a>
-<span class="sourceLineNo">3359</span> return CompactionState.MAJOR_AND_MINOR;<a name="line.3359"></a>
-<span class="sourceLineNo">3360</span> }<a name="line.3360"></a>
-<span class="sourceLineNo">3361</span> state = AdminProtos.GetRegionInfoResponse.CompactionState.MAJOR;<a name="line.3361"></a>
-<span class="sourceLineNo">3362</span> break;<a name="line.3362"></a>
-<span class="sourceLineNo">3363</span> case MINOR:<a name="line.3363"></a>
-<span class="sourceLineNo">3364</span> if (state == AdminProtos.GetRegionInfoResponse.CompactionState.MAJOR) {<a name="line.3364"></a>
-<span class="sourceLineNo">3365</span> return CompactionState.MAJOR_AND_MINOR;<a name="line.3365"></a>
-<span class="sourceLineNo">3366</span> }<a name="line.3366"></a>
-<span class="sourceLineNo">3367</span> state = AdminProtos.GetRegionInfoResponse.CompactionState.MINOR;<a name="line.3367"></a>
-<span class="sourceLineNo">3368</span> break;<a name="line.3368"></a>
-<span class="sourceLineNo">3369</span> case NONE:<a name="line.3369"></a>
-<span class="sourceLineNo">3370</span> default: // nothing, continue<a name="line.3370"></a>
-<span class="sourceLineNo">3371</span> }<a name="line.3371"></a>
-<span class="sourceLineNo">3372</span> } catch (NotServingRegionException e) {<a name="line.3372"></a>
-<span class="sourceLineNo">3373</span> if (LOG.isDebugEnabled()) {<a name="line.3373"></a>
-<span class="sourceLineNo">3374</span> LOG.debug("Trying to get compaction state of " + loc.getRegion() + ": " +<a name="line.3374"></a>
-<span class="sourceLineNo">3375</span> StringUtils.stringifyException(e));<a name="line.3375"></a>
-<span class="sourceLineNo">3376</span> }<a name="line.3376"></a>
-<span class="sourceLineNo">3377</span> } catch (RemoteException e) {<a name="line.3377"></a>
-<span class="sourceLineNo">3378</span> if (e.getMessage().indexOf(NotServingRegionException.class.getName()) >= 0) {<a name="line.3378"></a>
-<span class="sourceLineNo">3379</span> if (LOG.isDebugEnabled()) {<a name="line.3379"></a>
-<span class="sourceLineNo">3380</span> LOG.debug("Trying to get compaction state of " + loc.getRegion() + ": " +<a name="line.3380"></a>
-<span class="sourceLineNo">3381</span> StringUtils.stringifyException(e));<a name="line.3381"></a>
-<span class="sourceLineNo">3382</span> }<a name="line.3382"></a>
-<span class="sourceLineNo">3383</span> } else {<a name="line.3383"></a>
-<span class="sourceLineNo">3384</span> throw e;<a name="line.3384"></a>
-<span class="sourceLineNo">3385</span> }<a name="line.3385"></a>
-<span class="sourceLineNo">3386</span> }<a name="line.3386"></a>
-<span class="sourceLineNo">3387</span> }<a name="line.3387"></a>
-<span class="sourceLineNo">3388</span> break;<a name="line.3388"></a>
-<span class="sourceLineNo">3389</span> default:<a name="line.3389"></a>
-<span class="sourceLineNo">3390</span> throw new IllegalArgumentException("Unknown compactType: " + compactType);<a name="line.3390"></a>
-<span class="sourceLineNo">3391</span> }<a name="line.3391"></a>
-<span class="sourceLineNo">3392</span> if (state != null) {<a name="line.3392"></a>
-<span class="sourceLineNo">3393</span> return ProtobufUtil.createCompactionState(state);<a name="line.3393"></a>
-<span class="sourceLineNo">3394</span> }<a name="line.3394"></a>
-<span class="sourceLineNo">3395</span> return null;<a name="line.3395"></a>
-<span class="sourceLineNo">3396</span> }<a name="line.3396"></a>
-<span class="sourceLineNo">3397</span><a name="line.3397"></a>
-<span class="sourceLineNo">3398</span> /**<a name="line.3398"></a>
-<span class="sourceLineNo">3399</span> * Future that waits on a procedure result.<a name="line.3399"></a>
-<span class="sourceLineNo">3400</span> * Returned by the async version of the Admin calls,<a name="line.3400"></a>
-<span class="sourceLineNo">3401</span> * and used internally by the sync calls to wait on the result of the procedure.<a name="line.3401"></a>
-<span class="sourceLineNo">3402</span> */<a name="line.3402"></a>
-<span class="sourceLineNo">3403</span> @InterfaceAudience.Private<a name="line.3403"></a>
-<span class="sourceLineNo">3404</span> @InterfaceStability.Evolving<a name="line.3404"></a>
-<span class="sourceLineNo">3405</span> protected static class ProcedureFuture<V> implements Future<V> {<a name="line.3405"></a>
-<span class="sourceLineNo">3406</span> private ExecutionException exception = null;<a name="line.3406"></a>
-<span class="sourceLineNo">3407</span> private boolean procResultFound = false;<a name="line.3407"></a>
-<span class="sourceLineNo">3408</span> private boolean done = false;<a name="line.3408"></a>
-<span class="sourceLineNo">3409</span> private boolean cancelled = false;<a name="line.3409"></a>
-<span class="sourceLineNo">3410</span> private V result = null;<a name="line.3410"></a>
-<span class="sourceLineNo">3411</span><a name="line.3411"></a>
-<span class="sourceLineNo">3412</span> private final HBaseAdmin admin;<a name="line.3412"></a>
-<span class="sourceLineNo">3413</span> protected final Long procId;<a name="line.3413"></a>
-<span class="sourceLineNo">3414</span><a name="line.3414"></a>
-<span class="sourceLineNo">3415</span> public ProcedureFuture(final HBaseAdmin admin, final Long procId) {<a name="line.3415"></a>
-<span class="sourceLineNo">3416</span> this.admin = admin;<a name="line.3416"></a>
-<span class="sourceLineNo">3417</span> this.procId = procId;<a name="line.3417"></a>
-<span class="sourceLineNo">3418</span> }<a name="line.3418"></a>
-<span class="sourceLineNo">3419</span><a name="line.3419"></a>
-<span class="sourceLineNo">3420</span> @Override<a name="line.3420"></a>
-<span class="sourceLineNo">3421</span> public boolean cancel(boolean mayInterruptIfRunning) {<a name="line.3421"></a>
-<span class="sourceLineNo">3422</span> AbortProcedureRequest abortProcRequest = AbortProcedureRequest.newBuilder()<a name="line.3422"></a>
-<span class="sourceLineNo">3423</span> .setProcId(procId).setMayInterruptIfRunning(mayInterruptIfRunning).build();<a name="line.3423"></a>
-<span class="sourceLineNo">3424</span> try {<a name="line.3424"></a>
-<span class="sourceLineNo">3425</span> cancelled = abortProcedureResult(abortProcRequest).getIsProcedureAborted();<a name="line.3425"></a>
-<span class="sourceLineNo">3426</span> if (cancelled) {<a name="line.3426"></a>
-<span class="sourceLineNo">3427</span> done = true;<a name="line.3427"></a>
-<span class="sourceLineNo">3428</span> }<a name="line.3428"></a>
-<span class="sourceLineNo">3429</span> } catch (IOException e) {<a name="line.3429"></a>
-<span class="sourceLineNo">3430</span> // Cancell thrown exception for some reason. At this time, we are not sure whether<a name="line.3430"></a>
-<span class="sourceLineNo">3431</span> // the cancell succeeds or fails. We assume that it is failed, but print out a warning<a name="line.3431"></a>
-<span class="sourceLineNo">3432</span> // for debugging purpose.<a name="line.3432"></a>
-<span class="sourceLineNo">3433</span> LOG.warn(<a name="line.3433"></a>
-<span class="sourceLineNo">3434</span> "Cancelling the procedure with procId=" + procId + " throws exception " + e.getMessage(),<a name="line.3434"></a>
-<span class="sourceLineNo">3435</span> e);<a name="line.3435"></a>
-<span class="sourceLineNo">3436</span> cancelled = false;<a name="line.3436"></a>
-<span class="sourceLineNo">3437</span> }<a name="line.3437"></a>
-<span class="sourceLineNo">3438</span> return cancelled;<a name="line.3438"></a>
-<span class="sourceLineNo">3439</span> }<a name="line.3439"></a>
-<span class="sourceLineNo">3440</span><a name="line.3440"></a>
-<span class="sourceLineNo">3441</span> @Override<a name="line.3441"></a>
-<span class="sourceLineNo">3442</span> public boolean isCancelled() {<a name="line.3442"></a>
-<span class="sourceLineNo">3443</span> return cancelled;<a name="line.3443"></a>
-<span class="sourceLineNo">3444</span> }<a name="line.3444"></a>
-<span class="sourceLineNo">3445</span><a name="line.3445"></a>
-<span class="sourceLineNo">3446</span> protected AbortProcedureResponse abortProcedureResult(<a name="line.3446"></a>
-<span class="sourceLineNo">3447</span> final AbortProcedureRequest request) throws IOException {<a name="line.3447"></a>
-<span class="sourceLineNo">3448</span> return admin.executeCallable(new MasterCallable<AbortProcedureResponse>(<a name="line.3448"></a>
-<span class="sourceLineNo">3449</span> admin.getConnection(), admin.getRpcControllerFactory()) {<a name="line.3449"></a>
-<span class="sourceLineNo">3450</span> @Override<a name="line.3450"></a>
-<span class="sourceLineNo">3451</span> protected AbortProcedureResponse rpcCall() throws Exception {<a name="line.3451"></a>
-<span class="sourceLineNo">3452</span> return master.abortProcedure(getRpcController(), request);<a name="line.3452"></a>
-<span class="sourceLineNo">3453</span> }<a name="line.3453"></a>
-<span class="sourceLineNo">3454</span> });<a name="line.3454"></a>
-<span class="sourceLineNo">3455</span> }<a name="line.3455"></a>
-<span class="sourceLineNo">3456</span><a name="line.3456"></a>
-<span class="sourceLineNo">3457</span> @Override<a name="line.3457"></a>
-<span class="sourceLineNo">3458</span> public V get() throws InterruptedException, ExecutionException {<a name="line.3458"></a>
-<span class="sourceLineNo">3459</span> // TODO: should we ever spin forever?<a name="line.3459"></a>
-<span class="sourceLineNo">3460</span> throw new UnsupportedOperationException();<a name="line.3460"></a>
-<span class="sourceLineNo">3461</span> }<a name="line.3461"></a>
-<span class="sourceLineNo">3462</span><a name="line.3462"></a>
-<span class="sourceLineNo">3463</span> @Override<a name="line.3463"></a>
-<span class="sourceLineNo">3464</span> public V get(long timeout, TimeUnit unit)<a name="line.3464"></a>
-<span class="sourceLineNo">3465</span> throws InterruptedException, ExecutionException, TimeoutException {<a name="line.3465"></a>
-<span class="sourceLineNo">3466</span> if (!done) {<a name="line.3466"></a>
-<span class="sourceLineNo">3467</span> long deadlineTs = EnvironmentEdgeManager.currentTime() + unit.toMillis(timeout);<a name="line.3467"></a>
-<span class="sourceLineNo">3468</span> try {<a name="line.3468"></a>
-<span class="sourceLineNo">3469</span> try {<a name="line.3469"></a>
-<span class="sourceLineNo">3470</span> // if the master support procedures, try to wait the result<a name="line.3470"></a>
-<span class="sourceLineNo">3471</span> if (procId != null) {<a name="line.3471"></a>
-<span class="sourceLineNo">3472</span> result = waitProcedureResult(procId, deadlineTs);<a name="line.3472"></a>
-<span class="sourceLineNo">3473</span> }<a name="line.3473"></a>
-<span class="sourceLineNo">3474</span> // if we don't have a proc result, try the compatibility wait<a name="line.3474"></a>
-<span class="sourceLineNo">3475</span> if (!procResultFound) {<a name="line.3475"></a>
-<span class="sourceLineNo">3476</span> result = waitOperationResult(deadlineTs);<a name="line.3476"></a>
-<span class="sourceLineNo">3477</span> }<a name="line.3477"></a>
-<span class="sourceLineNo">3478</span> result = postOperationResult(result, deadlineTs);<a name="line.3478"></a>
-<span class="sourceLineNo">3479</span> done = true;<a name="line.3479"></a>
-<span class="sourceLineNo">3480</span> } catch (IOException e) {<a name="line.3480"></a>
-<span class="sourceLineNo">3481</span> result = postOperationFailure(e, deadlineTs);<a name="line.3481"></a>
-<span class="sourceLineNo">3482</span> done = true;<a name="line.3482"></a>
-<span class="sourceLineNo">3483</span> }<a name="line.3483"></a>
-<span class="sourceLineNo">3484</span> } catch (IOException e) {<a name="line.3484"></a>
-<span class="sourceLineNo">3485</span> exception = new ExecutionException(e);<a name="line.3485"></a>
-<span class="sourceLineNo">3486</span> done = true;<a name="line.3486"></a>
-<span class="sourceLineNo">3487</span> }<a name="line.3487"></a>
-<span class="sourceLineNo">3488</span> }<a name="line.3488"></a>
-<span class="sourceLineNo">3489</span> if (exception != null) {<a name="line.3489"></a>
-<span class="sourceLineNo">3490</span> throw exception;<a name="line.3490"></a>
-<span class="sourceLineNo">3491</span> }<a name="line.3491"></a>
-<span class="sourceLineNo">3492</span> return result;<a name="line.3492"></a>
-<span class="sourceLineNo">3493</span> }<a name="line.3493"></a>
-<span class="sourceLineNo">3494</span><a name="line.3494"></a>
-<span class="sourceLineNo">3495</span> @Override<a name="line.3495"></a>
-<span class="sourceLineNo">3496</span> public boolean isDone() {<a name="line.3496"></a>
-<span class="sourceLineNo">3497</span> return done;<a name="line.3497"></a>
-<span class="sourceLineNo">3498</span> }<a name="line.3498"></a>
-<span class="sourceLineNo">3499</span><a name="line.3499"></a>
-<span class="sourceLineNo">3500</span> protected HBaseAdmin getAdmin() {<a name="line.3500"></a>
-<span class="sourceLineNo">3501</span> return admin;<a name="line.3501"></a>
-<span class="sourceLineNo">3502</span> }<a name="line.3502"></a>
-<span class="sourceLineNo">3503</span><a name="line.3503"></a>
-<span class="sourceLineNo">3504</span> private V waitProcedureResult(long procId, long deadlineTs)<a name="line.3504"></a>
-<span class="sourceLineNo">3505</span> throws IOException, TimeoutException, InterruptedException {<a name="line.3505"></a>
-<span class="sourceLineNo">3506</span> GetProcedureResultRequest request = GetProcedureResultRequest.newBuilder()<a name="line.3506"></a>
-<span class="sourceLineNo">3507</span> .setProcId(procId)<a name="line.3507"></a>
-<span class="sourceLineNo">3508</span> .build();<a name="line.3508"></a>
-<span class="sourceLineNo">3509</span><a name="line.3509"></a>
-<span class="sourceLineNo">3510</span> int tries = 0;<a name="line.3510"></a>
-<span class="sourceLineNo">3511</span> IOException serviceEx = null;<a name="line.3511"></a>
-<span class="sourceLineNo">3512</span> while (EnvironmentEdgeManager.currentTime() < deadlineTs) {<a name="line.3512"></a>
-<span class="sourceLineNo">3513</span> GetProcedureResultResponse response = null;<a name="line.3513"></a>
-<span class="sourceLineNo">3514</span> try {<a name="line.3514"></a>
-<span class="sourceLineNo">3515</span> // Try to fetch the result<a name="line.3515"></a>
-<span class="sourceLineNo">3516</span> response = getProcedureResult(request);<a name="line.3516"></a>
-<span class="sourceLineNo">3517</span> } catch (IOException e) {<a name="line.3517"></a>
-<span class="sourceLineNo">3518</span> serviceEx = unwrapException(e);<a name="line.3518"></a>
-<span class="sourceLineNo">3519</span><a name="line.3519"></a>
-<span class="sourceLineNo">3520</span> // the master may be down<a name="line.3520"></a>
-<span class="sourceLineNo">3521</span> LOG.warn("failed to get the procedure result procId=" + procId, serviceEx);<a name="line.3521"></a>
-<span class="sourceLineNo">3522</span><a name="line.3522"></a>
-<span class="sourceLineNo">3523</span> // Not much to do, if we have a DoNotRetryIOException<a name="line.3523"></a>
-<span class="sourceLineNo">3524</span> if (serviceEx instanceof DoNotRetryIOException) {<a name="line.3524"></a>
-<span class="sourceLineNo">3525</span> // TODO: looks like there is no way to unwrap this exception and get the proper<a name="line.3525"></a>
-<span class="sourceLineNo">3526</span> // UnsupportedOperationException aside from looking at the message.<a name="line.3526"></a>
-<span class="sourceLineNo">3527</span> // anyway, if we fail here we just failover to the compatibility side<a name="line.3527"></a>
-<span class="sourceLineNo">3528</span> // and that is always a valid solution.<a name="line.3528"></a>
-<span class="sourceLineNo">3529</span> LOG.warn("Proc-v2 is unsupported on this master: " + serviceEx.getMessage(), serviceEx);<a name="line.3529"></a>
-<span class="sourceLineNo">3530</span> procResultFound = false;<a name="line.3530"></a>
-<span class="sourceLineNo">3531</span> return null;<a name="line.3531"></a>
-<span class="sourceLineNo">3532</span> }<a name="line.3532"></a>
-<span class="sourceLineNo">3533</span> }<a name="line.3533"></a>
-<span class="sourceLineNo">3534</span><a name="line.3534"></a>
-<span class="sourceLineNo">3535</span> // If the procedure is no longer running, we should have a result<a name="line.3535"></a>
-<span class="sourceLineNo">3536</span> if (response != null && response.getState() != GetProcedureResultResponse.State.RUNNING) {<a name="line.3536"></a>
-<span class="sourceLineNo">3537</span> procResultFound = response.getState() != GetProcedureResultResponse.State.NOT_FOUND;<a name="line.3537"></a>
-<span class="sourceLineNo">3538</span> return convertResult(response);<a name="line.3538"></a>
-<span class="sourceLineNo">3539</span> }<a name="line.3539"></a>
-<span class="sourceLineNo">3540</span><a name="line.3540"></a>
-<span class="sourceLineNo">3541</span> try {<a name="line.3541"></a>
-<span class="sourceLineNo">3542</span> Thread.sleep(getAdmin().getPauseTime(tries++));<a name="line.3542"></a>
-<span class="sourceLineNo">3543</span> } catch (InterruptedException e) {<a name="line.3543"></a>
-<span class="sourceLineNo">3544</span> throw new InterruptedException(<a name="line.3544"></a>
-<span class="sourceLineNo">3545</span> "Interrupted while waiting for the result of proc " + procId);<a name="line.3545"></a>
+<span class="sourceLineNo">3313</span> checkTableExists(tableName);<a name="line.3313"></a>
+<span class="sourceLineNo">3314</span> if (!isTableEnabled(tableName)) {<a name="line.3314"></a>
+<span class="sourceLineNo">3315</span> // If the table is disabled, the compaction state of the table should always be NONE<a name="line.3315"></a>
+<span class="sourceLineNo">3316</span> return ProtobufUtil.createCompactionState(<a name="line.3316"></a>
+<span class="sourceLineNo">3317</span> AdminProtos.GetRegionInfoResponse.CompactionState.NONE);<a name="line.3317"></a>
+<span class="sourceLineNo">3318</span> }<a name="line.3318"></a>
+<span class="sourceLineNo">3319</span><a name="line.3319"></a>
+<span class="sourceLineNo">3320</span> AdminProtos.GetRegionInfoResponse.CompactionState state =<a name="line.3320"></a>
+<span class="sourceLineNo">3321</span> AdminProtos.GetRegionInfoResponse.CompactionState.NONE;<a name="line.3321"></a>
+<span class="sourceLineNo">3322</span><a name="line.3322"></a>
+<span class="sourceLineNo">3323</span> // TODO: There is no timeout on this controller. Set one!<a name="line.3323"></a>
+<span class="sourceLineNo">3324</span> HBaseRpcController rpcController = rpcControllerFactory.newController();<a name="line.3324"></a>
+<span class="sourceLineNo">3325</span> switch (compactType) {<a name="line.3325"></a>
+<span class="sourceLineNo">3326</span> case MOB:<a name="line.3326"></a>
+<span class="sourceLineNo">3327</span> final AdminProtos.AdminService.BlockingInterface masterAdmin =<a name="line.3327"></a>
+<span class="sourceLineNo">3328</span> this.connection.getAdminForMaster();<a name="line.3328"></a>
+<span class="sourceLineNo">3329</span> Callable<AdminProtos.GetRegionInfoResponse.CompactionState> callable =<a name="line.3329"></a>
+<span class="sourceLineNo">3330</span> new Callable<AdminProtos.GetRegionInfoResponse.CompactionState>() {<a name="line.3330"></a>
+<span class="sourceLineNo">3331</span> @Override<a name="line.3331"></a>
+<span class="sourceLineNo">3332</span> public AdminProtos.GetRegionInfoResponse.CompactionState call() throws Exception {<a name="line.3332"></a>
+<span class="sourceLineNo">3333</span> RegionInfo info = RegionInfo.createMobRegionInfo(tableName);<a name="line.3333"></a>
+<span class="sourceLineNo">3334</span> GetRegionInfoRequest request =<a name="line.3334"></a>
+<span class="sourceLineNo">3335</span> RequestConverter.buildGetRegionInfoRequest(info.getRegionName(), true);<a name="line.3335"></a>
+<span class="sourceLineNo">3336</span> GetRegionInfoResponse response = masterAdmin.getRegionInfo(rpcController, request);<a name="line.3336"></a>
+<span class="sourceLineNo">3337</span> return response.getCompactionState();<a name="line.3337"></a>
+<span class="sourceLineNo">3338</span> }<a name="line.3338"></a>
+<span class="sourceLineNo">3339</span> };<a name="line.3339"></a>
+<span class="sourceLineNo">3340</span> state = ProtobufUtil.call(callable);<a name="line.3340"></a>
+<span class="sourceLineNo">3341</span> break;<a name="line.3341"></a>
+<span class="sourceLineNo">3342</span> case NORMAL:<a name="line.3342"></a>
+<span class="sourceLineNo">3343</span> for (HRegionLocation loc : connection.locateRegions(tableName, false, false)) {<a name="line.3343"></a>
+<span class="sourceLineNo">3344</span> ServerName sn = loc.getServerName();<a name="line.3344"></a>
+<span class="sourceLineNo">3345</span> if (sn == null) {<a name="line.3345"></a>
+<span class="sourceLineNo">3346</span> continue;<a name="line.3346"></a>
+<span class="sourceLineNo">3347</span> }<a name="line.3347"></a>
+<span class="sourceLineNo">3348</span> byte[] regionName = loc.getRegion().getRegionName();<a name="line.3348"></a>
+<span class="sourceLineNo">3349</span> AdminService.BlockingInterface snAdmin = this.connection.getAdmin(sn);<a name="line.3349"></a>
+<span class="sourceLineNo">3350</span> try {<a name="line.3350"></a>
+<span class="sourceLineNo">3351</span> Callable<GetRegionInfoResponse> regionInfoCallable =<a name="line.3351"></a>
+<span class="sourceLineNo">3352</span> new Callable<GetRegionInfoResponse>() {<a name="line.3352"></a>
+<span class="sourceLineNo">3353</span> @Override<a name="line.3353"></a>
+<span class="sourceLineNo">3354</span> public GetRegionInfoResponse call() throws Exception {<a name="line.3354"></a>
+<span class="sourceLineNo">3355</span> GetRegionInfoRequest request =<a name="line.3355"></a>
+<span class="sourceLineNo">3356</span> RequestConverter.buildGetRegionInfoRequest(regionName, true);<a name="line.3356"></a>
+<span class="sourceLineNo">3357</span> return snAdmin.getRegionInfo(rpcController, request);<a name="line.3357"></a>
+<span class="sourceLineNo">3358</span> }<a name="line.3358"></a>
+<span class="sourceLineNo">3359</span> };<a name="line.3359"></a>
+<span class="sourceLineNo">3360</span> GetRegionInfoResponse response = ProtobufUtil.call(regionInfoCallable);<a name="line.3360"></a>
+<span class="sourceLineNo">3361</span> switch (response.getCompactionState()) {<a name="line.3361"></a>
+<span class="sourceLineNo">3362</span> case MAJOR_AND_MINOR:<a name="line.3362"></a>
+<span class="sourceLineNo">3363</span> return CompactionState.MAJOR_AND_MINOR;<a name="line.3363"></a>
+<span class="sourceLineNo">3364</span> case MAJOR:<a name="line.3364"></a>
+<span class="sourceLineNo">3365</span> if (state == AdminProtos.GetRegionInfoResponse.CompactionState.MINOR) {<a name="line.3365"></a>
+<span class="sourceLineNo">3366</span> return CompactionState.MAJOR_AND_MINOR;<a name="line.3366"></a>
+<span class="sourceLineNo">3367</span> }<a name="line.3367"></a>
+<span class="sourceLineNo">3368</span> state = AdminProtos.GetRegionInfoResponse.CompactionState.MAJOR;<a name="line.3368"></a>
+<span class="sourceLineNo">3369</span> break;<a name="line.3369"></a>
+<span class="sourceLineNo">3370</span> case MINOR:<a name="line.3370"></a>
+<span class="sourceLineNo">3371</span> if (state == AdminProtos.GetRegionInfoResponse.CompactionState.MAJOR) {<a name="line.3371"></a>
+<span class="sourceLineNo">3372</span> return CompactionState.MAJOR_AND_MINOR;<a name="line.3372"></a>
+<span class="sourceLineNo">3373</span> }<a name="line.3373"></a>
+<span class="sourceLineNo">3374</span> state = AdminProtos.GetRegionInfoResponse.CompactionState.MINOR;<a name="line.3374"></a>
+<span class="sourceLineNo">3375</span> break;<a name="line.3375"></a>
+<span class="sourceLineNo">3376</span> case NONE:<a name="line.3376"></a>
+<span class="sourceLineNo">3377</span> default: // nothing, continue<a name="line.3377"></a>
+<span class="sourceLineNo">3378</span> }<a name="line.3378"></a>
+<span class="sourceLineNo">3379</span> } catch (NotServingRegionException e) {<a name="line.3379"></a>
+<span class="sourceLineNo">3380</span> if (LOG.isDebugEnabled()) {<a name="line.3380"></a>
+<span class="sourceLineNo">3381</span> LOG.debug("Trying to get compaction state of " + loc.getRegion() + ": " +<a name="line.3381"></a>
+<span class="sourceLineNo">3382</span> StringUtils.stringifyException(e));<a name="line.3382"></a>
+<span class="sourceLineNo">3383</span> }<a name="line.3383"></a>
+<span class="sourceLineNo">3384</span> } catch (RemoteException e) {<a name="line.3384"></a>
+<span class="sourceLineNo">3385</span> if (e.getMessage().indexOf(NotServingRegionException.class.getName()) >= 0) {<a name="line.3385"></a>
+<span class="sourceLineNo">3386</span> if (LOG.isDebugEnabled()) {<a name="line.3386"></a>
+<span class="sourceLineNo">3387</span> LOG.debug("Trying to get compaction state of " + loc.getRegion() + ": " +<a name="line.3387"></a>
+<span class="sourceLineNo">3388</span> StringUtils.stringifyException(e));<a name="line.3388"></a>
+<span class="sourceLineNo">3389</span> }<a name="line.3389"></a>
+<span class="sourceLineNo">3390</span> } else {<a name="line.3390"></a>
+<span class="sourceLineNo">3391</span> throw e;<a name="line.3391"></a>
+<span class="sourceLineNo">3392</span> }<a name="line.3392"></a>
+<span class="sourceLineNo">3393</span> }<a name="line.3393"></a>
+<span class="sourceLineNo">3394</span> }<a name="line.3394"></a>
+<span class="sourceLineNo">3395</span> break;<a name="line.3395"></a>
+<span class="sourceLineNo">3396</span> default:<a name="line.3396"></a>
+<span class="sourceLineNo">3397</span> throw new IllegalArgumentException("Unknown compactType: " + compactType);<a name="line.3397"></a>
+<span class="sourceLineNo">3398</span> }<a name="line.3398"></a>
+<span class="sourceLineNo">3399</span> if (state != null) {<a name="line.3399"></a>
+<span class="sourceLineNo">3400</span> return ProtobufUtil.createCompactionState(state);<a name="line.3400"></a>
+<span class="sourceLineNo">3401</span> }<a name="line.3401"></a>
+<span class="sourceLineNo">3402</span> return null;<a name="line.3402"></a>
+<span class="sourceLineNo">3403</span> }<a name="line.3403"></a>
+<span class="sourceLineNo">3404</span><a name="line.3404"></a>
+<span class="sourceLineNo">3405</span> /**<a name="line.3405"></a>
+<span class="sourceLineNo">3406</span> * Future that waits on a procedure result.<a name="line.3406"></a>
+<span class="sourceLineNo">3407</span> * Returned by the async version of the Admin calls,<a name="line.3407"></a>
+<span class="sourceLineNo">3408</span> * and used internally by the sync calls to wait on the result of the procedure.<a name="line.3408"></a>
+<span class="sourceLineNo">3409</span> */<a name="line.3409"></a>
+<span class="sourceLineNo">3410</span> @InterfaceAudience.Private<a name="line.3410"></a>
+<span class="sourceLineNo">3411</span> @InterfaceStability.Evolving<a name="line.3411"></a>
+<span class="sourceLineNo">3412</span> protected static class ProcedureFuture<V> implements Future<V> {<a name="line.3412"></a>
+<span class="sourceLineNo">3413</span> private ExecutionException exception = null;<a name="line.3413"></a>
+<span class="sourceLineNo">3414</span> private boolean procResultFound = false;<a name="line.3414"></a>
+<span class="sourceLineNo">3415</span> private boolean done = false;<a name="line.3415"></a>
+<span class="sourceLineNo">3416</span> private boolean cancelled = false;<a name="line.3416"></a>
+<span class="sourceLineNo">3417</span> private V result = null;<a name="line.3417"></a>
+<span class="sourceLineNo">3418</span><a name="line.3418"></a>
+<span class="sourceLineNo">3419</span> private final HBaseAdmin admin;<a name="line.3419"></a>
+<span class="sourceLineNo">3420</span> protected final Long procId;<a name="line.3420"></a>
+<span class="sourceLineNo">3421</span><a name="line.3421"></a>
+<span class="sourceLineNo">3422</span> public ProcedureFuture(final HBaseAdmin admin, final Long procId) {<a name="line.3422"></a>
+<span class="sourceLineNo">3423</span> this.admin = admin;<a name="line.3423"></a>
+<span class="sourceLineNo">3424</span> this.procId = procId;<a name="line.3424"></a>
+<span class="sourceLineNo">3425</span> }<a name="line.3425"></a>
+<span class="sourceLineNo">3426</span><a name="line.3426"></a>
+<span class="sourceLineNo">3427</span> @Override<a name="line.3427"></a>
+<span class="sourceLineNo">3428</span> public boolean cancel(boolean mayInterruptIfRunning) {<a name="line.3428"></a>
+<span class="sourceLineNo">3429</span> AbortProcedureRequest abortProcRequest = AbortProcedureRequest.newBuilder()<a name="line.3429"></a>
+<span class="sourceLineNo">3430</span> .setProcId(procId).setMayInterruptIfRunning(mayInterruptIfRunning).build();<a name="line.3430"></a>
+<span class="sourceLineNo">3431</span> try {<a name="line.3431"></a>
+<span class="sourceLineNo">3432</span> cancelled = abortProcedureResult(abortProcRequest).getIsProcedureAborted();<a name="line.3432"></a>
+<span class="sourceLineNo">3433</span> if (cancelled) {<a name="line.3433"></a>
+<span class="sourceLineNo">3434</span> done = true;<a name="line.3434"></a>
+<span class="sourceLineNo">3435</span> }<a name="line.3435"></a>
+<span class="sourceLineNo">3436</span> } catch (IOException e) {<a name="line.3436"></a>
+<span class="sourceLineNo">3437</span> // Cancell thrown exception for some reason. At this time, we are not sure whether<a name="line.3437"></a>
+<span class="sourceLineNo">3438</span> // the cancell succeeds or fails. We assume that it is failed, but print out a warning<a name="line.3438"></a>
+<span class="sourceLineNo">3439</span> // for debugging purpose.<a name="line.3439"></a>
+<span class="sourceLineNo">3440</span> LOG.warn(<a name="line.3440"></a>
+<span class="sourceLineNo">3441</span> "Cancelling the procedure with procId=" + procId + " throws exception " + e.getMessage(),<a name="line.3441"></a>
+<span class="sourceLineNo">3442</span> e);<a name="line.3442"></a>
+<span class="sourceLineNo">3443</span> cancelled = false;<a name="line.3443"></a>
+<span class="sourceLineNo">3444</span> }<a name="line.3444"></a>
+<span class="sourceLineNo">3445</span> return cancelled;<a name="line.3445"></a>
+<span class="sourceLineNo">3446</span> }<a name="line.3446"></a>
+<span class="sourceLineNo">3447</span><a name="line.3447"></a>
+<span class="sourceLineNo">3448</span> @Override<a name="line.3448"></a>
+<span class="sourceLineNo">3449</span> public boolean isCancelled() {<a name="line.3449"></a>
+<span class="sourceLineNo">3450</span> return cancelled;<a name="line.3450"></a>
+<span class="sourceLineNo">3451</span> }<a name="line.3451"></a>
+<span class="sourceLineNo">3452</span><a name="line.3452"></a>
+<span class="sourceLineNo">3453</span> protected AbortProcedureResponse abortProcedureResult(<a name="line.3453"></a>
+<span class="sourceLineNo">3454</span> final AbortProcedureRequest request) throws IOException {<a name="line.3454"></a>
+<span class="sourceLineNo">3455</span> return admin.executeCallable(new MasterCallable<AbortProcedureResponse>(<a name="line.3455"></a>
+<span class="sourceLineNo">3456</span> admin.getConnection(), admin.getRpcControllerFactory()) {<a name="line.3456"></a>
+<span class="sourceLineNo">3457</span> @Override<a name="line.3457"></a>
+<span class="sourceLineNo">3458</span> protected AbortProcedureResponse rpcCall() throws Exception {<a name="line.3458"></a>
+<span class="sourceLineNo">3459</span> return master.abortProcedure(getRpcController(), request);<a name="line.3459"></a>
+<span class="sourceLineNo">3460</span> }<a name="line.3460"></a>
+<span class="sourceLineNo">3461</span> });<a name="line.3461"></a>
+<span class="sourceLineNo">3462</span> }<a name="line.3462"></a>
+<span class="sourceLineNo">3463</span><a name="line.3463"></a>
+<span class="sourceLineNo">3464</span> @Override<a name="line.3464"></a>
+<span class="sourceLineNo">3465</span> public V get() throws InterruptedException, ExecutionException {<a name="line.3465"></a>
+<span class="sourceLineNo">3466</span> // TODO: should we ever spin forever?<a name="line.3466"></a>
+<span class="sourceLineNo">3467</span> throw new UnsupportedOperationException();<a name="line.3467"></a>
+<span class="sourceLineNo">3468</span> }<a name="line.3468"></a>
+<span class="sourceLineNo">3469</span><a name="line.3469"></a>
+<span class="sourceLineNo">3470</span> @Override<a name="line.3470"></a>
+<span class="sourceLineNo">3471</span> public V get(long timeout, TimeUnit unit)<a name="line.3471"></a>
+<span class="sourceLineNo">3472</span> throws InterruptedException, ExecutionException, TimeoutException {<a name="line.3472"></a>
+<span class="sourceLineNo">3473</span> if (!done) {<a name="line.3473"></a>
+<span class="sourceLineNo">3474</span> long deadlineTs = EnvironmentEdgeManager.currentTime() + unit.toMillis(timeout);<a name="line.3474"></a>
+<span class="sourceLineNo">3475</span> try {<a name="line.3475"></a>
+<span class="sourceLineNo">3476</span> try {<a name="line.3476"></a>
+<span class="sourceLineNo">3477</span> // if the master support procedures, try to wait the result<a name="line.3477"></a>
+<span class="sourceLineNo">3478</span> if (procId != null) {<a name="line.3478"></a>
+<span class="sourceLineNo">3479</span> result = waitProcedureResult(procId, deadlineTs);<a name="line.3479"></a>
+<span class="sourceLineNo">3480</span> }<a name="line.3480"></a>
+<span class="sourceLineNo">3481</span> // if we don't have a proc result, try the compatibility wait<a name="line.3481"></a>
+<span class="sourceLineNo">3482</span> if (!procResultFound) {<a name="line.3482"></a>
+<span class="sourceLineNo">3483</span> result = waitOperationResult(deadlineTs);<a name="line.3483"></a>
+<span class="sourceLineNo">3484</span> }<a name="line.3484"></a>
+<span class="sourceLineNo">3485</span> result = postOperationResult(result, deadlineTs);<a name="line.3485"></a>
+<span class="sourceLineNo">3486</span> done = true;<a name="line.3486"></a>
+<span class="sourceLineNo">3487</span> } catch (IOException e) {<a name="line.3487"></a>
+<span class="sourceLineNo">3488</span> result = postOperationFailure(e, deadlineTs);<a name="line.3488"></a>
+<span class="sourceLineNo">3489</span> done = true;<a name="line.3489"></a>
+<span class="sourceLineNo">3490</span> }<a name="line.3490"></a>
+<span class="sourceLineNo">3491</span> } catch (IOException e) {<a name="line.3491"></a>
+<span class="sourceLineNo">3492</span> exception = new ExecutionException(e);<a name="line.3492"></a>
+<span class="sourceLineNo">3493</span> done = true;<a name="line.3493"></a>
+<span class="sourceLineNo">3494</span> }<a name="line.3494"></a>
+<span class="sourceLineNo">3495</span> }<a name="line.3495"></a>
+<span class="sourceLineNo">3496</span> if (exception != null) {<a name="line.3496"></a>
+<span class="sourceLineNo">3497</span> throw exception;<a name="line.3497"></a>
+<span class="sourceLineNo">3498</span> }<a name="line.3498"></a>
+<span class="sourceLineNo">3499</span> return result;<a name="line.3499"></a>
+<span class="sourceLineNo">3500</span> }<a name="line.3500"></a>
+<span class="sourceLineNo">3501</span><a name="line.3501"></a>
+<span class="sourceLineNo">3502</span> @Override<a name="line.3502"></a>
+<span class="sourceLineNo">3503</span> public boolean isDone() {<a name="line.3503"></a>
+<span class="sourceLineNo">3504</span> return done;<a name="line.3504"></a>
+<span class="sourceLineNo">3505</span> }<a name="line.3505"></a>
+<span class="sourceLineNo">3506</span><a name="line.3506"></a>
+<span class="sourceLineNo">3507</span> protected HBaseAdmin getAdmin() {<a name="line.3507"></a>
+<span class="sourceLineNo">3508</span> return admin;<a name="line.3508"></a>
+<span class="sourceLineNo">3509</span> }<a name="line.3509"></a>
+<span class="sourceLineNo">3510</span><a name="line.3510"></a>
+<span class="sourceLineNo">3511</span> private V waitProcedureResult(long procId, long deadlineTs)<a name="line.3511"></a>
+<span class="sourceLineNo">3512</span> throws IOException, TimeoutException, InterruptedException {<a name="line.3512"></a>
+<span class="sourceLineNo">3513</span> GetProcedureResultRequest request = GetProcedureResultRequest.newBuilder()<a name="line.3513"></a>
+<span class="sourceLineNo">3514</span> .setProcId(procId)<a name="line.3514"></a>
+<span class="sourceLineNo">3515</span> .build();<a name="line.3515"></a>
+<span class="sourceLineNo">3516</span><a name="line.3516"></a>
+<span class="sourceLineNo">3517</span> int tries = 0;<a name="line.3517"></a>
+<span class="sourceLineNo">3518</span> IOException serviceEx = null;<a name="line.3518"></a>
+<span class="sourceLineNo">3519</span> while (EnvironmentEdgeManager.currentTime() < deadlineTs) {<a name="line.3519"></a>
+<span class="sourceLineNo">3520</span> GetProcedureResultResponse response = null;<a name="line.3520"></a>
+<span class="sourceLineNo">3521</span> try {<a name="line.3521"></a>
+<span class="sourceLineNo">3522</span> // Try to fetch the result<a name="line.3522"></a>
+<span class="sourceLineNo">3523</span> response = getProcedureResult(request);<a name="line.3523"></a>
+<span class="sourceLineNo">3524</span> } catch (IOException e) {<a name="line.3524"></a>
+<span class="sourceLineNo">3525</span> serviceEx = unwrapException(e);<a name="line.3525"></a>
+<span class="sourceLineNo">3526</span><a name="line.3526"></a>
+<span class="sourceLineNo">3527</span> // the master may be down<a name="line.3527"></a>
+<span class="sourceLineNo">3528</span> LOG.warn("failed to get the procedure result procId=" + procId, serviceEx);<a name="line.3528"></a>
+<span class="sourceLineNo">3529</span><a name="line.3529"></a>
+<span class="sourceLineNo">3530</span> // Not much to do, if we have a DoNotRetryIOException<a name="line.3530"></a>
+<span class="sourceLineNo">3531</span> if (serviceEx instanceof DoNotRetryIOException) {<a name="line.3531"></a>
+<span class="sourceLineNo">3532</span> // TODO: looks like there is no way to unwrap this exception and get the proper<a name="line.3532"></a>
+<span class="sourceLineNo">3533</span> // UnsupportedOperationException aside from looking at the message.<a name="line.3533"></a>
+<span class="sourceLineNo">3534</span> // anyway, if we fail here we just failover to the compatibility side<a name="line.3534"></a>
+<span class="sourceLineNo">3535</span> // and that is always a valid solution.<a name="line.3535"></a>
+<span class="sourceLineNo">3536</span> LOG.warn("Proc-v2 is unsupported on this master: " + serviceEx.getMessage(), serviceEx);<a name="line.3536"></a>
+<span class="sourceLineNo">3537</span> procResultFound = false;<a name="line.3537"></a>
+<span class="sourceLineNo">3538</span> return null;<a name="line.3538"></a>
+<span class="sourceLineNo">3539</span> }<a name="line.3539"></a>
+<span class="sourceLineNo">3540</span> }<a name="line.3540"></a>
+<span class="sourceLineNo">3541</span><a name="line.3541"></a>
+<span class="sourceLineNo">3542</span> // If the procedure is no longer running, we should have a result<a name="line.3542"></a>
+<span class="sourceLineNo">3543</span> if (response != null && response.getState() != GetProcedureResultResponse.State.RUNNING) {<a name="line.3543"></a>
+<span class="sourceLineNo">3544</span> procResultFound = response.getState() != GetProcedureResultResponse.State.NOT_FOUND;<a name="line.3544"></a>
+<span class="sourceLineNo">3545</span> return convertResult(response);<a name="line.3545"></a>
<span class="sourceLineNo">3546</span> }<a name="line.3546"></a>
-<span class="sourceLineNo">3547</span> }<a name="line.3547"></a>
-<span class="sourceLineNo">3548</span> if (serviceEx != null) {<a name="line.3548"></a>
-<span class="sourceLineNo">3549</span> throw serviceEx;<a name="line.3549"></a>
-<span class="sourceLineNo">3550</span> } else {<a name="line.3550"></a>
-<span class="sourceLineNo">3551</span> throw new TimeoutException("The procedure " + procId + " is still running");<a name="line.3551"></a>
-<span class="sourceLineNo">3552</span> }<a name="line.3552"></a>
-<span class="sourceLineNo">3553</span> }<a name="line.3553"></a>
-<span class="sourceLineNo">3554</span><a name="line.3554"></a>
-<span class="sourceLineNo">3555</span> private static IOException unwrapException(IOException e) {<a name="line.3555"></a>
-<span class="sourceLineNo">3556</span> if (e instanceof RemoteException) {<a name="line.3556"></a>
-<span class="sourceLineNo">3557</span> return ((RemoteException)e).unwrapRemoteException();<a name="line.3557"></a>
-<span class="sourceLineNo">3558</span> }<a name="line.3558"></a>
-<span class="sourceLineNo">3559</span> return e;<a name="line.3559"></a>
+<span class="sourceLineNo">3547</span><a name="line.3547"></a>
+<span class="sourceLineNo">3548</span> try {<a name="line.3548"></a>
+<span class="sourceLineNo">3549</span> Thread.sleep(getAdmin().getPauseTime(tries++));<a name="line.3549"></a>
+<span class="sourceLineNo">3550</span> } catch (InterruptedException e) {<a name="line.3550"></a>
+<span class="sourceLineNo">3551</span> throw new InterruptedException(<a name="line.3551"></a>
+<span class="sourceLineNo">3552</span> "Interrupted while waiting for the result of proc " + procId);<a name="line.3552"></a>
+<span class="sourceLineNo">3553</span> }<a name="line.3553"></a>
+<span class="sourceLineNo">3554</span> }<a name="line.3554"></a>
+<span class="sourceLineNo">3555</span> if (serviceEx != null) {<a name="line.3555"></a>
+<span class="sourceLineNo">3556</span> throw serviceEx;<a name="line.3556"></a>
+<span class="sourceLineNo">3557</span> } else {<a name="line.3557"></a>
+<span class="sourceLineNo">3558</span> throw new TimeoutException("The procedure " + procId + " is still running");<a name="line.3558"></a>
+<span class="sourceLineNo">3559</span> }<a name="line.3559"></a>
<span class="sourceLineNo">3560</span> }<a name="line.3560"></a>
<span class="sourceLineNo">3561</span><a name="line.3561"></a>
-<span class="sourceLineNo">3562</span> protected GetProcedureResultResponse getProcedureResult(final GetProcedureResultRequest request)<a name="line.3562"></a>
-<span class="sourceLineNo">3563</span> throws IOException {<a name="line.3563"></a>
-<span class="sourceLineNo">3564</span> return admin.executeCallable(new MasterCallable<GetProcedureResultResponse>(<a name="line.3564"></a>
-<span class="sourceLineNo">3565</span> admin.getConnection(), admin.getRpcControllerFactory()) {<a name="line.3565"></a>
-<span class="sourceLineNo">3566</span> @Override<a name="line.3566"></a>
-<span class="sourceLineNo">3567</span> protected GetProcedureResultResponse rpcCall() throws Exception {<a name="line.3567"></a>
-<span class="sourceLineNo">3568</span> return master.getProcedureResult(getRpcController(), request);<a name="line.3568"></a>
-<span class="sourceLineNo">3569</span> }<a name="line.3569"></a>
-<span class="sourceLineNo">3570</span> });<a name="line.3570"></a>
-<span class="sourceLineNo">3571</span> }<a name="line.3571"></a>
-<span class="sourceLineNo">3572</span><a name="line.3572"></a>
-<span class="sourceLineNo">3573</span> /**<a name="line.3573"></a>
-<span class="sourceLineNo">3574</span> * Convert the procedure result response to a specified type.<a name="line.3574"></a>
-<span class="sourceLineNo">3575</span> * @param response the procedure result object to parse<a name="line.3575"></a>
-<span class="sourceLineNo">3576</span> * @return the result data of the procedure.<a name="line.3576"></a>
-<span class="sourceLineNo">3577</span> */<a name="line.3577"></a>
-<span class="sourceLineNo">3578</span> protected V convertResult(final GetProcedureResultResponse response) throws IOException {<a name="line.3578"></a>
-<span class="sourceLineNo">3579</span> if (response.hasException()) {<a name="line.3579"></a>
-<span class="sourceLineNo">3580</span> throw ForeignExceptionUtil.toIOException(response.getException());<a name="line.3580"></a>
-<span class="sourceLineNo">3581</span> }<a name="line.3581"></a>
-<span class="sourceLineNo">3582</span> return null;<a name="line.3582"></a>
-<span class="sourceLineNo">3583</span> }<a name="line.3583"></a>
-<span class="sourceLineNo">3584</span><a name="line.3584"></a>
-<span class="sourceLineNo">3585</span> /**<a name="line.3585"></a>
-<span class="sourceLineNo">3586</span> * Fallback implementation in case the procedure is not supported by the server.<a name="line.3586"></a>
-<span class="sourceLineNo">3587</span> * It should try to wait until the operation is completed.<a name="line.3587"></a>
-<span class="sourceLineNo">3588</span> * @param deadlineTs the timestamp after which this method should throw a TimeoutException<a name="line.3588"></a>
-<span class="sourceLineNo">3589</span> * @return the result data of the operation<a name="line.3589"></a>
-<span class="sourceLineNo">3590</span> */<a name="line.3590"></a>
-<span class="sourceLineNo">3591</span> protected V waitOperationResult(final long deadlineTs)<a name="line.3591"></a>
-<span class="sourceLineNo">3592</span> throws IOException, TimeoutException {<a name="line.3592"></a>
-<span class="sourceLineNo">3593</span> return null;<a name="line.3593"></a>
-<span class="sourceLineNo">3594</span> }<a name="line.3594"></a>
-<span class="sourceLineNo">3595</span><a name="line.3595"></a>
-<span class="sourceLineNo">3596</span> /**<a name="line.3596"></a>
-<span class="sourceLineNo">3597</span> * Called after the operation is completed and the result fetched. this allows to perform extra<a name="line.3597"></a>
-<span class="sourceLineNo">3598</span> * steps after the procedure is completed. it allows to apply transformations to the result that<a name="line.3598"></a>
-<span class="sourceLineNo">3599</span> * will be returned by get().<a name="line.3599"></a>
-<span class="sourceLineNo">3600</span> * @param result the result of the procedure<a name="line.3600"></a>
-<span class="sourceLineNo">3601</span> * @param deadlineTs the timestamp after which this method should throw a TimeoutException<a name="line.3601"></a>
-<span class="sourceLineNo">3602</span> * @return the result of the procedure, which may be the same as the passed one<a name="line.3602"></a>
-<span class="sourceLineNo">3603</span> */<a name="line.3603"></a>
-<span class="sourceLineNo">3604</span> protected V postOperationResult(final V result, final long deadlineTs)<a name="line.3604"></a>
-<span class="sourceLineNo">3605</span> throws IOException, TimeoutException {<a name="line.3605"></a>
-<span class="sourceLineNo">3606</span> return result;<a name="line.3606"></a>
-<span class="sourceLineNo">3607</span> }<a name="line.3607"></a>
-<span class="sourceLineNo">3608</span><a name="line.3608"></a>
-<span class="sourceLineNo">3609</span> /**<a name="line.3609"></a>
-<span class="sourceLineNo">3610</span> * Called after the operation is terminated with a failure.<a name="line.3610"></a>
-<span class="sourceLineNo">3611</span> * this allows to perform extra steps after the procedure is terminated.<a name="line.3611"></a>
-<span class="sourceLineNo">3612</span> * it allows to apply transformations to the result that will be returned by get().<a name="line.3612"></a>
-<span class="sourceLineNo">3613</span> * The default implementation will rethrow the exception<a name="line.3613"></a>
-<span class="sourceLineNo">3614</span> * @param exception the exception got from fetching the result<a name="line.3614"></a>
-<span class="sourceLineNo">3615</span> * @param deadlineTs the timestamp after which this method should throw a TimeoutException<a name="line.3615"></a>
-<span class="sourceLineNo">3616</span> * @return the result of the procedure, which may be the same as the passed one<a name="line.3616"></a>
-<span class="sourceLineNo">3617</span> */<a name="line.3617"></a>
-<span class="sourceLineNo">3618</span> protected V postOperationFailure(final IOException exception, final long deadlineTs)<a name="line.3618"></a>
-<span class="sourceLineNo">3619</span> throws IOException, TimeoutException {<a name="line.3619"></a>
-<span class="sourceLineNo">3620</span> throw exception;<a name="line.3620"></a>
-<span class="sourceLineNo">3621</span> }<a name="line.3621"></a>
-<span class="sourceLineNo">3622</span><a name="line.3622"></a>
-<span class="sourceLineNo">3623</span> protected interface WaitForStateCallable {<a name="line.3623"></a>
-<span class="sourceLineNo">3624</span> boolean checkState(int tries) throws IOException;<a name="line.3624"></a>
-<span class="sourceLineNo">3625</span> void throwInterruptedException() throws InterruptedIOException;<a name="line.3625"></a>
-<span class="sourceLineNo">3626</span> void throwTimeoutException(long elapsed) throws TimeoutException;<a name="line.3626"></a>
-<span class="sourceLineNo">3627</span> }<a name="line.3627"></a>
-<span class="sourceLineNo">3628</span><a name="line.3628"></a>
-<span class="sourceLineNo">3629</span> protected void waitForState(final long deadlineTs, final WaitForStateCallable callable)<a name="line.3629"></a>
-<span class="sourceLineNo">3630</span> throws IOException, TimeoutException {<a name="line.3630"></a>
-<span class="sourceLineNo">3631</span> int tries = 0;<a name="line.3631"></a>
-<span class="sourceLineNo">3632</span> IOException serverEx = null;<a name="line.3632"></a>
-<span class="sourceLineNo">3633</span> long startTime = EnvironmentEdgeManager.currentTime();<a name="line.3633"></a>
-<span class="sourceLineNo">3634</span> while (EnvironmentEdgeManager.currentTime() < deadlineTs) {<a name="line.3634"></a>
-<span class="sourceLineNo">3635</span> serverEx = null;<a name="line.3635"></a>
-<span class="sourceLineNo">3636</span> try {<a name="line.3636"></a>
-<span class="sourceLineNo">3637</span> if (callable.checkState(tries)) {<a name="line.3637"></a>
-<span class="sourceLineNo">3638</span> return;<a name="line.3638"></a>
-<span class="sourceLineNo">3639</span> }<a name="line.3639"></a>
-<span class="sourceLineNo">3640</span> } catch (IOException e) {<a name="line.3640"></a>
-<span class="sourceLineNo">3641</span> serverEx = e;<a name="line.3641"></a>
-<span class="sourceLineNo">3642</span> }<a name="line.3642"></a>
+<span class="sourceLineNo">3562</span> private static IOException unwrapException(IOException e) {<a name="line.3562"></a>
+<span class="sourceLineNo">3563</span> if (e instanceof RemoteException) {<a name="line.3563"></a>
+<span class="sourceLineNo">3564</span> return ((RemoteException)e).unwrapRemoteException();<a name="line.3564"></a>
+<span class="sourceLineNo">3565</span> }<a name="line.3565"></a>
+<span class="sourceLineNo">3566</span> return e;<a name="line.3566"></a>
+<span class="sourceLineNo">3567</span> }<a name="line.3567"></a>
+<span class="sourceLineNo">3568</span><a name="line.3568"></a>
+<span class="sourceLineNo">3569</span> protected GetProcedureResultResponse getProcedureResult(final GetProcedureResultRequest request)<a name="line.3569"></a>
+<span class="sourceLineNo">3570</span> throws IOException {<a name="line.3570"></a>
+<span class="sourceLineNo">3571</span> return admin.executeCallable(new MasterCallable<GetProcedureResultResponse>(<a name="line.3571"></a>
+<span class="sourceLineNo">3572</span> admin.getConnection(), admin.getRpcControllerFactory()) {<a name="line.3572"></a>
+<span class="sourceLineNo">3573</span> @Override<a name="line.3573"></a>
+<span class="sourceLineNo">3574</span> protected GetProcedureResultResponse rpcCall() throws Exception {<a name="line.3574"></a>
+<span class="sourceLineNo">3575</span> return master.getProcedureResult(getRpcController(), request);<a name="line.3575"></a>
+<span class="sourceLineNo">3576</span> }<a name="line.3576"></a>
+<span class="sourceLineNo">3577</span> });<a name="line.3577"></a>
+<span class="sourceLineNo">3578</span> }<a name="line.3578"></a>
+<span class="sourceLineNo">3579</span><a name="line.3579"></a>
+<span class="sourceLineNo">3580</span> /**<a name="line.3580"></a>
+<span class="sourceLineNo">3581</span> * Convert the procedure result response to a specified type.<a name="line.3581"></a>
+<span class="sourceLineNo">3582</span> * @param response the procedure result object to parse<a name="line.3582"></a>
+<span class="sourceLineNo">3583</span> * @return the result data of the procedure.<a name="line.3583"></a>
+<span class="sourceLineNo">3584</span> */<a name="line.3584"></a>
+<span class="sourceLineNo">3585</span> protected V convertResult(final GetProcedureResultResponse response) throws IOException {<a name="line.3585"></a>
+<span class="sourceLineNo">3586</span> if (response.hasException()) {<a name="line.3586"></a>
+<span class="sourceLineNo">3587</span> throw ForeignExceptionUtil.toIOException(response.getException());<a name="line.3587"></a>
+<span class="sourceLineNo">3588</span> }<a name="line.3588"></a>
+<span class="sourceLineNo">3589</span> return null;<a name="line.3589"></a>
+<span class="sourceLineNo">3590</span> }<a name="line.3590"></a>
+<span class="sourceLineNo">3591</span><a name="line.3591"></a>
+<span class="sourceLineNo">3592</span> /**<a name="line.3592"></a>
+<span class="sourceLineNo">3593</span> * Fallback implementation in case the procedure is not supported by the server.<a name="line.3593"></a>
+<span class="sourceLineNo">3594</span> * It should try to wait until the operation is completed.<a name="line.3594"></a>
+<span class="sourceLineNo">3595</span> * @param deadlineTs the timestamp after which this method should throw a TimeoutException<a name="line.3595"></a>
+<span class="sourceLineNo">3596</span> * @return the result data of the operation<a name="line.3596"></a>
+<span class="sourceLineNo">3597</span> */<a name="line.3597"></a>
+<span class="sourceLineNo">3598</span> protected V waitOperationResult(final long deadlineTs)<a name="line.3598"></a>
+<span class="sourceLineNo">3599</span> throws IOException, TimeoutException {<a name="line.3599"></a>
+<span class="sourceLineNo">3600</span> return null;<a name="line.3600"></a>
+<span class="sourceLineNo">3601</span> }<a name="line.3601"></a>
+<span class="sourceLineNo">3602</span><a name="line.3602"></a>
+<span class="sourceLineNo">3603</span> /**<a name="line.3603"></a>
+<span class="sourceLineNo">3604</span> * Called after the operation is completed and the result fetched. this allows to perform extra<a name="line.3604"></a>
+<span class="sourceLineNo">3605</span> * steps after the procedure is completed. it allows to apply transformations to the result that<a name="line.3605"></a>
+<span class="sourceLineNo">3606</span> * will be returned by get().<a name="line.3606"></a>
+<span class="sourceLineNo">3607</span> * @param result the result of the procedure<a name="line.3607"></a>
+<span class="sourceLineNo">3608</span> * @param deadlineTs the timestamp after which this method should throw a TimeoutException<a name="line.3608"></a>
+<span class="sourceLineNo">3609</span> * @return the result of the procedure, which may be the same as the passed one<a name="line.3609"></a>
+<span class="sourceLineNo">3610</span> */<a name="line.3610"></a>
+<span class="sourceLineNo">3611</span> protected V postOperationResult(final V result, final long deadlineTs)<a name="line.3611"></a>
+<span class="sourceLineNo">3612</span> throws IOException, TimeoutException {<a name="line.3612"></a>
+<span class="sourceLineNo">3613</span> return result;<a name="line.3613"></a>
+<span class="sourceLineNo">3614</span> }<a name="line.3614"></a>
+<span class="sourceLineNo">3615</span><a name="line.3615"></a>
+<span class="sourceLineNo">3616</span> /**<a name="line.3616"></a>
+<span class="sourceLineNo">3617</span> * Called after the operation is terminated with a failure.<a name="line.3617"></a>
+<span class="sourceLineNo">3618</span> * this allows to perform extra steps after the procedure is terminated.<a name="line.3618"></a>
+<span class="sourceLineNo">3619</span> * it allows to apply transformations to the result that will be returned by get().<a name="line.3619"></a>
+<span class="sourceLineNo">3620</span> * The default implementation will rethrow the exception<a name="line.3620"></a>
+<span class="sourceLineNo">3621</span> * @param exception the exception got from fetching the result<a name="line.3621"></a>
+<span class="sourceLineNo">3622</span> * @param deadlineTs the timestamp after which this method should throw a TimeoutException<a name="line.3622"></a>
+<span class="sourceLineNo">3623</span> * @return the result of the procedure, which may be the same as the passed one<a name="line.3623"></a>
+<span class="sourceLineNo">3624</span> */<a name="line.3624"></a>
+<span class="sourceLineNo">3625</span> protected V postOperationFailure(final IOException exception, final long deadlineTs)<a name="line.3625"></a>
+<span class="sourceLineNo">3626</span> throws IOException, TimeoutException {<a name="line.3626"></a>
+<span class="sourceLineNo">3627</span> throw exception;<a name="line.3627"></a>
+<span class="sourceLineNo">3628</span> }<a name="line.3628"></a>
+<span class="sourceLineNo">3629</span><a name="line.3629"></a>
+<span class="sourceLineNo">3630</span> protected interface WaitForStateCallable {<a name="line.3630"></a>
+<span class="sourceLineNo">3631</span> boolean checkState(int tries) throws IOException;<a name="line.3631"></a>
+<span class="sourceLineNo">3632</span> void throwInterruptedException() throws InterruptedIOException;<a name="line.3632"></a>
+<span class="sourceLineNo">3633</span> void throwTimeoutException(long elapsed) throws TimeoutException;<a name="line.3633"></a>
+<span class="sourceLineNo">3634</span> }<a name="line.3634"></a>
+<span class="sourceLineNo">3635</span><a name="line.3635"></a>
+<span class="sourceLineNo">3636</span> protected void waitForState(final long deadlineTs, final WaitForStateCallable callable)<a name="line.3636"></a>
+<span class="sourceLineNo">3637</span> throws IOException, TimeoutException {<a name="line.3637"></a>
+<span class="sourceLineNo">3638</span> int tries = 0;<a name="line.3638"></a>
+<span class="sourceLineNo">3639</span> IOException serverEx = null;<a name="line.3639"></a>
+<span class="sourceLineNo">3640</span> long startTime = EnvironmentEdgeManager.currentTime();<a name="line.3640"></a>
+<span class="sourceLineNo">3641</span> while (EnvironmentEdgeManager.currentTime() < deadlineTs) {<a name="line.3641"></a>
+<span class="sourceLineNo">3642</span> serverEx = null;<a name="line.3642"></a>
<span class="sourceLineNo">3643</span> try {<a name="line.3643"></a>
-<span class="sourceLineNo">3644</span> Thread.sleep(getAdmin().getPauseTime(tries++));<a name="line.3644"></a>
-<span class="sourceLineNo">3645</span> } catch (InterruptedException e) {<a name="line.3645"></a>
-<span class="sourceLineNo">3646</span> callable.throwInterruptedException();<a name="line.3646"></a>
-<span class="sourceLineNo">3647</span> }<a name="line.3647"></a>
-<span class="sourceLineNo">3648</span> }<a name="line.3648"></a>
-<span class="sourceLineNo">3649</span> if (serverEx != null) {<a name="line.3649"></a>
-<span class="sourceLineNo">3650</span> throw unwrapException(serverEx);<a name="line.3650"></a>
-<span class="sourceLineNo">3651</span> } else {<a name="line.3651"></a>
-<span class="sourceLineNo">3652</span> callable.throwTimeoutException(EnvironmentEdgeManager.currentTime() - startTime);<a name="line.3652"></a>
-<span class="sourceLineNo">3653</span> }<a name="line.3653"></a>
-<span class="sourceLineNo">3654</span> }<a name="line.3654"></a>
-<span class="sourceLineNo">3655</span> }<a name="line.3655"></a>
-<span class="sourceLineNo">3656</span><a name="line.3656"></a>
-<span class="sourceLineNo">3657</span> @InterfaceAudience.Private<a name="line.3657"></a>
-<span class="sourceLineNo">3658</span> @InterfaceStability.Evolving<a name="line.3658"></a>
-<span class="sourceLineNo">3659</span> protected static abstract class TableFuture<V> extends ProcedureFuture<V> {<a name="line.3659"></a>
-<span class="sourceLineNo">3660</span> private final TableName tableName;<a name="line.3660"></a>
-<span class="sourceLineNo">3661</span><a name="line.3661"></a>
-<span class="sourceLineNo">3662</span> public TableFuture(final HBaseAdmin admin, final TableName tableName, final Long procId) {<a name="line.3662"></a>
-<span class="sourceLineNo">3663</span> super(admin, procId);<a name="line.3663"></a>
-<span class="sourceLineNo">3664</span> this.tableName = tableName;<a name="line.3664"></a>
-<span class="sourceLineNo">3665</span> }<a name="line.3665"></a>
-<span class="sourceLineNo">3666</span><a name="line.3666"></a>
-<span class="sourceLineNo">3667</span> @Override<a name="line.3667"></a>
-<span class="sourceLineNo">3668</span> public String toString() {<a name="line.3668"></a>
-<span class="sourceLineNo">3669</span> return getDescription();<a name="line.3669"></a>
-<span class="sourceLineNo">3670</span> }<a name="line.3670"></a>
-<span class="sourceLineNo">3671</span><a name="line.3671"></a>
-<span class="sourceLineNo">3672</span> /**<a name="line.3672"></a>
-<span class="sourceLineNo">3673</span> * @return the table name<a name="line.3673"></a>
-<span class="sourceLineNo">3674</span> */<a name="line.3674"></a>
-<span class="sourceLineNo">3675</span> protected TableName getTableName() {<a name="line.3675"></a>
-<span class="sourceLineNo">3676</span> return tableName;<a name="line.3676"></a>
+<span class="sourceLineNo">3644</span> if (callable.checkState(tries)) {<a name="line.3644"></a>
+<span class="sourceLineNo">3645</span> return;<a name="line.3645"></a>
+<span class="sourceLineNo">3646</span> }<a name="line.3646"></a>
+<span class="sourceLineNo">3647</span> } catch (IOException e) {<a name="line.3647"></a>
+<span class="sourceLineNo">3648</span> serverEx = e;<a name="line.3648"></a>
+<span class="sourceLineNo">3649</span> }<a name="line.3649"></a>
+<span class="sourceLineNo">3650</span> try {<a name="line.3650"></a>
+<span class="sourceLineNo">3651</span> Thread.sleep(getAdmin().getPauseTime(tries++));<a name="line.3651"></a>
+<span class="sourceLineNo">3652</span> } catch (InterruptedException e) {<a name="line.3652"></a>
+<span class="sourceLineNo">3653</span> callable.throwInterruptedException();<a name="line.3653"></a>
+<span class="sourceLineNo">3654</span> }<a name="line.3654"></a>
+<span class="sourceLineNo">3655</span> }<a name="line.3655"></a>
+<span class="sourceLineNo">3656</span> if (serverEx != null) {<a name="line.3656"></a>
+<span class="sourceLineNo">3657</span> throw unwrapException(serverEx);<a name="line.3657"></a>
+<span class="sourceLineNo">3658</span> } else {<a name="line.3658"></a>
+<span class="sourceLineNo">3659</span> callable.throwTimeoutException(EnvironmentEdgeManager.currentTime() - startTime);<a name="line.3659"></a>
+<span class="sourceLineNo">3660</span> }<a name="line.3660"></a>
+<span class="sourceLineNo">3661</span> }<a name="line.3661"></a>
+<span class="sourceLineNo">3662</span> }<a name="line.3662"></a>
+<span class="sourceLineNo">3663</span><a name="line.3663"></a>
+<span class="sourceLineNo">3664</span> @InterfaceAudience.Private<a name="line.3664"></a>
+<span class="sourceLineNo">3665</span> @InterfaceStability.Evolving<a name="line.3665"></a>
+<span class="sourceLineNo">3666</span> protected static abstract class TableFuture<V> extends ProcedureFuture<V> {<a name="line.3666"></a>
+<span class="sourceLineNo">3667</span> private final TableName tableName;<a name="line.3667"></a>
+<span class="sourceLineNo">3668</span><a name="line.3668"></a>
+<span class="sourceLineNo">3669</span> public TableFuture(final HBaseAdmin admin, final TableName tableName, final Long procId) {<a name="line.3669"></a>
+<span class="sourceLineNo">3670</span> super(admin, procId);<a name="line.3670"></a>
+<span class="sourceLineNo">3671</span> this.tableName = tableName;<a name="line.3671"></a>
+<span class="sourceLineNo">3672</span> }<a name="line.3672"></a>
+<span class="sourceLineNo">3673</span><a name="line.3673"></a>
+<span class="sourceLineNo">3674</span> @Override<a name="line.3674"></a>
+<span class="sourceLineNo">3675</span> public String toString() {<a name="line.3675"></a>
+<span class="sourceLineNo">3676</span> return getDescription();<a name="line.3676"></a>
<span class="sourceLineNo">3677</span> }<a name="line.3677"></a>
<span class="sourceLineNo">3678</span><a name="line.3678"></a>
<span class="sourceLineNo">3679</span> /**<a name="line.3679"></a>
-<span class="sourceLineNo">3680</span> * @return the table descriptor<a name="line.3680"></a>
+<span class="sourceLineNo">3680</span> * @return the table name<a name="line.3680"></a>
<span class="sourceLineNo">3681</span> */<a name="line.3681"></a>
-<span class="sourceLineNo">3682</span> protected TableDescriptor getTableDescriptor() throws IOException {<a name="line.3682"></a>
-<span class="sourceLineNo">3683</span> return getAdmin().getDescriptor(getTableName());<a name="line.3683"></a>
+<span class="sourceLineNo">3682</span> protected TableName getTableName() {<a name="line.3682"></a>
+<span class="sourceLineNo">3683</span> return tableName;<a name="line.3683"></a>
<span class="sourceLineNo">3684</span> }<a name="line.3684"></a>
<span class="sourceLineNo">3685</span><a name="line.3685"></a>
<span class="sourceLineNo">3686</span> /**<a name="line.3686"></a>
-<span class="sourceLineNo">3687</span> * @return the operation type like CREATE, DELETE, DISABLE etc.<a name="line.3687"></a>
+<span class="sourceLineNo">3687</span> * @return the table descriptor<a name="line.3687"></a>
<span class="sourceLineNo">3688</span> */<a name="line.3688"></a>
-<span class="sourceLineNo">3689</span> public abstract String getOperationType();<a name="line.3689"></a>
-<span class="sourceLineNo">3690</span><a name="line.3690"></a>
-<span class="sourceLineNo">3691</span> /**<a name="line.3691"></a>
-<span class="sourceLineNo">3692</span> * @return a description of the operation<a name="line.3692"></a>
-<span class="sourceLineNo">3693</span> */<a name="line.3693"></a>
-<span class="sourceLineNo">3694</span> protected String getDescription() {<a name="line.3694"></a>
-<span class="sourceLineNo">3695</span> return "Operation: " + getOperationType() + ", " + "Table Name: " +<a name="line.3695"></a>
-<span class="sourceLineNo">3696</span> tableName.getNameWithNamespaceInclAsString() + ", procId: " + procId;<a name="line.3696"></a>
-<span class="sourceLineNo">3697</span> }<a name="line.3697"></a>
-<span class="sourceLineNo">3698</span><a name="line.3698"></a>
-<span class="sourceLineNo">3699</span> protected abstract class TableWaitForStateCallable implements WaitForStateCallable {<a name="line.3699"></a>
-<span class="sourceLineNo">3700</span> @Override<a name="line.3700"></a>
-<span class="sourceLineNo">3701</span> public void throwInterruptedException() throws InterruptedIOException {<a name="line.3701"></a>
-<span class="sourceLineNo">3702</span> throw new InterruptedIOException("Interrupted while waiting for " + getDescription());<a name="line.3702"></a>
-<span class="sourceLineNo">3703</span> }<a name="line.3703"></a>
-<span class="sourceLineNo">3704</span><a name="line.3704"></a>
-<span class="sourceLineNo">3705</span> @Override<a name="line.3705"></a>
-<span class="sourceLineNo">3706</span> public void throwTimeoutException(long elapsedTime) throws TimeoutException {<a name="line.3706"></a>
-<span class="sourceLineNo">3707</span> throw new TimeoutException(<a name="line.3707"></a>
-<span class="sourceLineNo">3708</span> getDescription() + " has not completed after " + elapsedTime + "ms");<a name="line.3708"></a>
-<span class="sourceLineNo">3709</span> }<a name="line.3709"></a>
-<span class="sourceLineNo">3710</span> }<a name="line.3710"></a>
+<span class="sourceLineNo">3689</span> protected TableDescriptor getTableDescriptor() throws IOException {<a name="line.3689"></a>
+<span class="sourceLineNo">3690</span> return getAdmin().getDescriptor(getTableName());<a name="line.3690"></a>
+<span class="sourceLineNo">3691</span> }<a name="line.3691"></a>
+<span class="sourceLineNo">3692</span><a name="line.3692"></a>
+<span class="sourceLineNo">3693</span> /**<a name="line.3693"></a>
+<span class="sourceLineNo">3694</span> * @return the operation type like CREATE, DELETE, DISABLE etc.<a name="line.3694"></a>
+<span class="sourceLineNo">3695</span> */<a name="line.3695"></a>
+<span class="sourceLineNo">3696</span> public abstract String getOperationType();<a name="line.3696"></a>
+<span class="sourceLineNo">3697</span><a name="line.3697"></a>
+<span class="sourceLineNo">3698</span> /**<a name="line.3698"></a>
+<span class="sourceLineNo">3699</span> * @return a description of the operation<a name="line.3699"></a>
+<span class="sourceLineNo">3700</span> */<a name="line.3700"></a>
+<span class="sourceLineNo">3701</span> protected String getDescription() {<a name="line.3701"></a>
+<span class="sourceLineNo">3702</span> return "Operation: " + getOperationType() + ", " + "Table Name: " +<a name="line.3702"></a>
+<span class="sourceLineNo">3703</span> tableName.getNameWithNamespaceInclAsString() + ", procId: " + procId;<a name="line.3703"></a>
+<span class="sourceLineNo">3704</span> }<a name="line.3704"></a>
+<span class="sourceLineNo">3705</span><a name="line.3705"></a>
+<span class="sourceLineNo">3706</span> protected abstract class TableWaitForStateCallable implements WaitForStateCallable {<a name="line.3706"></a>
+<span class="sourceLineNo">3707</span> @Override<a name="line.3707"></a>
+<span class="sourceLineNo">3708</span> public void throwInterruptedException() throws InterruptedIOException {<a name="line.3708"></a>
+<span class="sourceLineNo">3709</span> throw new InterruptedIOException("Interrupted while waiting for " + getDescription());<a name="line.3709"></a>
+<span class="sourceLineNo">3710</span> }<a name="line.3710"></a>
<span class="sourceLineNo">3711</span><a name="line.3711"></a>
-<span class="sourceLineNo">3712</span> @Override<a name="line.3712"></a>
-<span class="sourceLineNo">3713</span> protected V postOperationResult(final V result, final long deadlineTs)<a name="line.3713"></a>
-<span class="sourceLineNo">3714</span> throws IOException, TimeoutException {<a name="line.3714"></a>
-<span class="sourceLineNo">3715</span> LOG.info(getDescription() + " completed");<a name="line.3715"></a>
-<span class="sourceLineNo">3716</span> return super.postOperationResult(result, deadlineTs);<a name="line.3716"></a>
+<span class="sourceLineNo">3712</span> @Override<a name="line.3712"></a>
+<span class="sourceLineNo">3713</span> public void throwTimeoutException(long elapsedTime) throws TimeoutException {<a name="line.3713"></a>
+<span class="sourceLineNo">3714</span> throw new TimeoutException(<a name="line.3714"></a>
+<span class="sourceLineNo">3715</span> getDescription() + " has not completed after " + elapsedTime + "ms");<a name="line.3715"></a>
+<span class="sourceLineNo">3716</span> }<a name="line.3716"></a>
<span class="sourceLineNo">3717</span> }<a name="line.3717"></a>
<span class="sourceLineNo">3718</span><a name="line.3718"></a>
<span class="sourceLineNo">3719</span> @Override<a name="line.3719"></a>
-<span class="sourceLineNo">3720</span> protected V postOperationFailure(final IOException exception, final long deadlineTs)<a name="line.3720"></a>
+<span class="sourceLineNo">3720</span> protected V postOperationResult(final V result, final long deadlineTs)<a name="line.3720"></a>
<span class="sourceLineNo">3721</span> throws IOException, TimeoutException {<a name="line.3721"></a>
-<span class="sourceLineNo">3722</span> LOG.info(getDescription() + " failed with " + exception.getMessage());<a name="line.3722"></a>
-<span class="sourceLineNo">3723</span> return super.postOperationFailure(exception, deadlineTs);<a name="line.3723"></a>
+<span class="sourceLineNo">3722</span> LOG.info(getDescription() + " completed");<a name="line.3722"></a>
+<span class="sourceLineNo">3723</span> return super.postOperationResult(result, deadlineTs);<a name="line.3723"></a>
<span class="sourceLineNo">3724</span> }<a name="line.3724"></a>
<span class="sourceLineNo">3725</span><a name="line.3725"></a>
-<span class="sourceLineNo">3726</span> protected void waitForTableEnabled(final long deadlineTs)<a name="line.3726"></a>
-<span class="sourceLineNo">3727</span> throws IOException, TimeoutException {<a name="line.3727"></a>
-<span class="sourceLineNo">3728</span> waitForState(deadlineTs, new TableWaitForStateCallable() {<a name="line.3728"></a>
-<span class="sourceLineNo">3729</span> @Override<a name="line.3729"></a>
-<span class="sourceLineNo">3730</span> public boolean checkState(int tries) throws IOException {<a name="line.3730"></a>
-<span class="sourceLineNo">3731</span> try {<a name="line.3731"></a>
-<span class="sourceLineNo">3732</span> if (getAdmin().isTableAvailable(tableName)) {<a name="line.3732"></a>
-<span class="sourceLineNo">3733</span> return true;<a name="line.3733"></a>
-<span class="sourceLineNo">3734</span> }<a name="line.3734"></a>
-<span class="sourceLineNo">3735</span> } catch (TableNotFoundException tnfe) {<a name="line.3735"></a>
-<span class="sourceLineNo">3736</span> LOG.debug("Table " + tableName.getNameWithNamespaceInclAsString()<a name="line.3736"></a>
-<span class="sourceLineNo">3737</span> + " was not enabled, sleeping. tries=" + tries);<a name="line.3737"></a>
-<span class="sourceLineNo">3738</span> }<a name="line.3738"></a>
-<span class="sourceLineNo">3739</span> return false;<a name="line.3739"></a>
-<span class="sourceLineNo">3740</span> }<a name="line.3740"></a>
-<span class="sourceLineNo">3741</span> });<a name="line.3741"></a>
-<span class="sourceLineNo">3742</span> }<a name="line.3742"></a>
-<span class="sourceLineNo">3743</span><a name="line.3743"></a>
-<span class="sourceLineNo">3744</span> protected void waitForTableDisabled(final long deadlineTs)<a name="line.3744"></a>
-<span class="sourceLineNo">3745</span> throws IOException, TimeoutException {<a name="line.3745"></a>
-<span class="sourceLineNo">3746</span> waitForState(deadlineTs, new TableWaitForStateCallable() {<a name="line.3746"></a>
-<span class="sourceLineNo">3747</span> @Override<a name="line.3747"></a>
-<span class="sourceLineNo">3748</span> public boolean checkState(int tries) throws IOException {<a name="line.3748"></a>
-<span class="sourceLineNo">3749</span> return getAdmin().isTableDisabled(tableName);<a name="line.3749"></a>
-<span class="sourceLineNo">3750</span> }<a name="line.3750"></a>
-<span class="sourceLineNo">3751</span> });<a name="line.3751"></a>
-<span class="sourceLineNo">3752</span> }<a name="line.3752"></a>
-<span class="sourceLineNo">3753</span><a name="line.3753"></a>
-<span class="sourceLineNo">3754</span> protected void waitTableNotFound(final long deadlineTs)<a name="line.3754"></a>
-<span class="sourceLineNo">3755</span> throws IOException, TimeoutException {<a name="line.3755"></a>
-<span class="sourceLineNo">3756</span> waitForState(deadlineTs, new TableWaitForStateCallable() {<a name="line.3756"></a>
-<span class="sourceLineNo">3757</span> @Override<a name="line.3757"></a>
-<span class="sourceLineNo">3758</span> public boolean checkState(int tries) throws IOException {<a name="line.3758"></a>
-<span class="sourceLineNo">3759</span> return !getAdmin().tableExists(tableName);<a name="line.3759"></a>
-<span class="sourceLineNo">3760</span> }<a name="line.3760"></a>
-<span class="sourceLineNo">3761</span> });<a name="line.3761"></a>
-<span class="sourceLineNo">3762</span> }<a name="line.3762"></a>
-<span class="sourceLineNo">3763</span><a name="line.3763"></a>
-<span class="sourceLineNo">3764</span> protected void waitForSchemaUpdate(final long deadlineTs)<a name="line.3764"></a>
-<span class="sourceLineNo">3765</span> throws IOException, TimeoutException {<a name="line.3765"></a>
-<span class="sourceLineNo">3766</span> waitForState(deadlineTs, new TableWaitForStateCallable() {<a name="line.3766"></a>
-<span class="sourceLineNo">3767</span> @Override<a name="line.3767"></a>
-<span class="sourceLineNo">3768</span> public boolean checkState(int tries) throws IOException {<a name="line.3768"></a>
-<span class="sourceLineNo">3769</span> return getAdmin().getAlterStatus(tableName).getFirst() == 0;<a name="line.3769"></a>
-<span class="sourceLineNo">3770</span> }<a name="line.3770"></a>
-<span class="sourceLineNo">3771</span> });<a name="line.3771"></a>
-<span class="sourceLineNo">3772</span> }<a name="line.3772"></a>
-<span class="sourceLineNo">3773</span><a name="line.3773"></a>
-<span class="sourceLineNo">3774</span> protected void waitForAllRegionsOnline(final long deadlineTs, final byte[][] splitKeys)<a name="line.3774"></a>
-<span class="sourceLineNo">3775</span> throws IOException, TimeoutException {<a name="line.3775"></a>
-<span class="sourceLineNo">3776</span> final TableDescriptor desc = getTableDescriptor();<a name="line.3776"></a>
-<span class="sourceLineNo">3777</span> final AtomicInteger actualRegCount = new AtomicInteger(0);<a name="line.3777"></a>
-<span class="sourceLineNo">3778</span> final MetaTableAccessor.Visitor visitor = new MetaTableAccessor.Visitor() {<a name="line.3778"></a>
-<span class="sourceLineNo">3779</span> @Override<a name="line.3779"></a>
-<span class="sourceLineNo">3780</span> public boolean visit(Result rowResult) throws IOException {<a name="line.3780"></a>
-<span class="sourceLineNo">3781</span> RegionLocations list = MetaTableAccessor.getRegionLocations(rowResult);<a name="line.3781"></a>
-<span class="sourceLineNo">3782</span> if (list == null) {<a name="line.3782"></a>
-<span class="sourceLineNo">3783</span> LOG.warn("No serialized HRegionInfo in " + rowResult);<a name="line.3783"></a>
-<span class="sourceLineNo">3784</span> return true;<a name="line.3784"></a>
-<span class="sourceLineNo">3785</span> }<a name="line.3785"></a>
-<span class="sourceLineNo">3786</span> HRegionLocation l = list.getRegionLocation();<a name="line.3786"></a>
-<span class="sourceLineNo">3787</span> if (l == null) {<a name="line.3787"></a>
-<span class="sourceLineNo">3788</span> return true;<a name="line.3788"></a>
-<span class="sourceLineNo">3789</span> }<a name=
<TRUNCATED>