Method handleRequest

xds/src/main/java/io/grpc/xds/CsdsService.java:120–162

(
      ClientStatusRequest request, StreamObserver<ClientStatusResponse> responseObserver)

  }

  private boolean handleRequest(
      ClientStatusRequest request, StreamObserver<ClientStatusResponse> responseObserver) {
    StatusException error = null;

    if (request.getNodeMatchersCount() > 0) {
      error = new StatusException(
          Status.INVALID_ARGUMENT.withDescription("node_matchers not supported"));
    } else {
      List<String> targets = xdsClientPoolFactory.getTargets();
      List<ClientConfig> clientConfigs = new ArrayList<>(targets.size());

      for (int i = 0; i < targets.size() && error == null; i++) {
        try {
          ClientConfig clientConfig = getConfigForRequest(targets.get(i));
          if (clientConfig != null) {
            clientConfigs.add(clientConfig);
          }
        } catch (InterruptedException e) {
          Thread.currentThread().interrupt();
          logger.log(Level.FINE, "Server interrupted while building CSDS config dump", e);
          error = Status.ABORTED.withDescription("Thread interrupted").withCause(e).asException();
        } catch (RuntimeException e) {
          logger.log(Level.WARNING, "Unexpected error while building CSDS config dump", e);
          error = Status.INTERNAL.withDescription("Unexpected internal error").withCause(e)
              .asException();
        }
      }

      try {
        responseObserver.onNext(getStatusResponse(clientConfigs));
      } catch (RuntimeException e) {
        logger.log(Level.WARNING, "Unexpected error while processing CSDS config dump", e);
        error = Status.INTERNAL.withDescription("Unexpected internal error").withCause(e)
            .asException();
      }
    }

    if (error == null) {
      return true; // All clients reported without error
    }
    responseObserver.onError(error);
    return false;
  }

  private ClientConfig getConfigForRequest(String target) throws InterruptedException {
    ObjectPool<XdsClient> xdsClientPool = xdsClientPoolFactory.get(target);