Method call

src/tsd/QueryExecutor.java:590–627

(final Exception e)

  /** This has to be attached to callbacks or we may never respond to clients */
  class ErrorCB implements Callback<Object, Exception> {
    public Object call(final Exception e) throws Exception {
      QueryRpc.query_exceptions.incrementAndGet();
      Throwable ex = e;
      try {
        LOG.error("Query exception: ", e);
        if (e instanceof DeferredGroupException) {
          ex = e.getCause();
          while (ex != null && ex instanceof DeferredGroupException) {
            ex = ex.getCause();
          }
          if (ex == null) {
            LOG.error("The deferred group exception didn't have a cause???");
          }
        }
        if (ex instanceof RpcTimedOutException) {
          QueryExecutor.this.http_query.badRequest(new BadRequestException(
              HttpResponseStatus.REQUEST_TIMEOUT, ex.getMessage()));
        } else if (ex instanceof HBaseException) {
          QueryExecutor.this.http_query.badRequest(new BadRequestException(
              HttpResponseStatus.FAILED_DEPENDENCY, ex.getMessage()));
        } else if (ex instanceof QueryException) {
          QueryExecutor.this.http_query.badRequest(new BadRequestException(
              ((QueryException)ex).getStatus(), ex.getMessage()));
        } else if (ex instanceof BadRequestException) {
          QueryExecutor.this.http_query.badRequest((BadRequestException)ex);
        } else if (ex instanceof NoSuchUniqueName) {
          QueryExecutor.this.http_query.badRequest(new BadRequestException(ex));
        } else {
          QueryExecutor.this.http_query.badRequest(new BadRequestException(ex));
        }
        
      } catch (RuntimeException ex2) {
        LOG.error("Exception thrown during exception handling", ex2);
        QueryExecutor.this.http_query.sendReply
          (HttpResponseStatus.INTERNAL_SERVER_ERROR, ex2.getMessage().getBytes());
      }
      return null;
    }
  }
  
  /**