Method startServer

xds/src/test/java/io/grpc/xds/DataPlaneRule.java:128–180

(Map<String, ?> bootstrapOverride)

  }

  private void startServer(Map<String, ?> bootstrapOverride) throws Exception {
    final String[] authority = new String[1];
    ServerInterceptor metadataInterceptor = new ServerInterceptor() {
      @Override
      public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call,
          Metadata requestHeaders, ServerCallHandler<ReqT, RespT> next) {
        authority[0] = call.getAuthority();
        logger.fine("Received following metadata: " + requestHeaders);

        // Make a copy of the headers so that it can be read in a thread-safe manner when copying
        // it to the response headers.
        Metadata headersToReturn = new Metadata();
        headersToReturn.merge(requestHeaders);

        return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) {
          @Override
          public void sendHeaders(Metadata responseHeaders) {
            responseHeaders.merge(headersToReturn);
            super.sendHeaders(responseHeaders);
          }

          @Override
          public void close(Status status, Metadata trailers) {
            super.close(status, trailers);
          }
        }, requestHeaders);
      }
    };

    SimpleServiceGrpc.SimpleServiceImplBase simpleServiceImpl =
        new SimpleServiceGrpc.SimpleServiceImplBase() {
          @Override
          public void unaryRpc(
              SimpleRequest request, StreamObserver<SimpleResponse> responseObserver) {
            String responseMsg = "Hi, xDS!";
            if (authority[0] != null) {
              responseMsg += " Authority= " + authority[0];
            }
            SimpleResponse response =
                SimpleResponse.newBuilder().setResponseMessage(responseMsg).build();
            responseObserver.onNext(response);
            responseObserver.onCompleted();
          }
        };

    XdsServerBuilder serverBuilder = XdsServerBuilder.forPort(
            0, InsecureServerCredentials.create())
        .addService(simpleServiceImpl)
        .intercept(metadataInterceptor)
        .overrideBootstrapForTest(bootstrapOverride);
    server = serverBuilder.build().start();
    logger.log(Level.FINE, "data plane server started");
  }
}