private boolean isActionDone()

in adb3client/src/main/java/com/alibaba/cloud/analyticdb/adb3client/impl/collector/TableShardCollector.java [149:177]

28 lines of code
6 McCabe index (conditional complexity)


	private boolean isActionDone() throws AdbClientException {
		if (activeAction != null) {
			try {
				if (activeAction.getFuture().isDone()) {
					//LOGGER.info("Pair Done:{}",readable.getPutAction().getFuture());
					try {
						activeAction.getFuture().get();
					} finally {
						clearActiveAction();
					}
					return true;
				} else {
					return false;
				}
			} catch (ExecutionException e) {
				Throwable cause = e.getCause();
				clearActiveAction();
				if (cause instanceof AdbClientException) {
					throw (AdbClientException) cause;
				} else {
					throw new AdbClientException(ExceptionCode.INTERNAL_ERROR, "unknow exception", cause);
				}
			} catch (InterruptedException e) {
				return false;
			}
		} else {
			return true;
		}
	}