public static void main()

in continuous_load_testing/src/main/java/com/google/net/grpc/testing/directpath/continuous_load_testing/Client.java [77:115]


  public static void main(String[] args) {
    logger.info("DirectPath Continuous Load Testing Client Started.");
    initializeLogManager();
    parseArgs(args);
    GrpcOpenTelemetry grpcOpenTelemetry = initializeOpenTelemetry();

    ChannelCredentials credentials = GoogleDefaultChannelCredentials.create();
    String backend = disable_directpath ? CLOUDPATH_BACKEND : DIRECTPATH_BACKEND;
    ManagedChannelBuilder<?> builder = Grpc.newChannelBuilder(backend, credentials);
    grpcOpenTelemetry.configureChannelBuilder(builder);
    TestServiceStub stub = TestServiceGrpc.newStub(builder.build());

    if (methods.contains(Method.EmptyCall)) {
      ExecuteEmptyCalls(stub);
    }
    if (methods.contains(Method.UnaryCall)) {
      ExecuteUnaryCalls(stub);
    }
    if (methods.contains(Method.StreamingInputCall)) {
      ExecuteStreamingInputCalls(stub);
    }
    if (methods.contains(Method.StreamingOutputCall)) {
      ExecuteStreamingOutputCalls(stub);
    }
    if (methods.contains(Method.FullDuplexCall)) {
      ExecuteFullDuplexCalls(stub);
    }
    if (methods.contains(Method.HalfDuplexCall)) {
      ExecuteHalfDuplexCalls(stub);
    }

    try {
      synchronized (Client.class) {
        Client.class.wait();
      }
    } catch (InterruptedException e) {
      throw new RuntimeException(e);
    }
  }