public void failed()

in tablestore/src/main/java/com/alicloud/openservices/tablestore/core/AsyncCompletion.java [63:105]
43 lines of code
7 McCabe index (conditional complexity)

    public void failed(Exception ex) {
        try {
            final Exception e;
            String requestId = null;
            if (ex instanceof TableStoreException) {
                e = ex;
                requestId = ((TableStoreException) ex).getRequestId();
                ((TableStoreException) e).setTraceId(tracer.getTraceId());
            } else if (ex instanceof ClientException) {
                e = ex;
                ((ClientException) e).setTraceId(tracer.getTraceId());
            } else {
                e = new ClientException("Unexpected error: " + ex, ex, tracer.getTraceId());
            }
            long nextPause = retry.nextPause(request.getOperationName(), e);
            LogUtil.logOnFailed(tracer, retry, e, requestId, nextPause > 0);
            if (nextPause <= 0) {
                tracer.printLog();
                if (e instanceof PartialResultFailedException) {
                    onCompleted(this.request, (Res) ((PartialResultFailedException) e).getResult());
                } else {
                    onFailed(request, e);
                }
            } else {
                final AsyncCompletion<Req, Res> self = this;
                retryExecutor.schedule(
                    new Runnable() {
                        @Override
                        public void run() {
                            try {
                                Req requestForRetry = (Req) launcher.getRequestForRetry(e);
                                launcher.fire(requestForRetry, self);
                            } catch (Exception ex) {
                                failed(new ClientException("Fail to retry.", ex));
                            }
                        }
                    },
                    nextPause, TimeUnit.MILLISECONDS);
            }
        } catch (Exception exception) {
            LogUtil.LOG.error("unknown error in failed, future or user callback may not be notified", exception);
        }
    }