Home
last modified time | relevance | path

Searched refs:clientExecutor (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DConcurrencyTest.java143 private ExecutorService clientExecutor; field in ConcurrencyTest
148 clientExecutor = Executors.newFixedThreadPool(NUM_CONCURRENT_REQUESTS); in setUp()
167 MoreExecutors.shutdownAndAwaitTermination(clientExecutor, 5, TimeUnit.SECONDS); in tearDown()
179 clientExecutor.execute(new ClientWorker(startBarrier, responsesDoneSignal)); in serverStreamingTest()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/
DUtils.java174 private static ExecutorService clientExecutor; field in Utils
177 if (clientExecutor == null) { in getExecutor()
178 clientExecutor = new ForkJoinPool( in getExecutor()
191 return clientExecutor; in getExecutor()
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
DFlowControlledMessagesPerSecondBenchmark.java52 public ExecutorType clientExecutor = ExecutorType.DIRECT; field in FlowControlledMessagesPerSecondBenchmark
85 super.setup(clientExecutor, in setup()
DAbstractBenchmark.java187 public void setup(ExecutorType clientExecutor, in setup() argument
216 if (clientExecutor == ExecutorType.DIRECT) { in setup()
/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/
DRealWebSocketTest.java51 private final Executor clientExecutor = new SynchronousExecutor(); field in RealWebSocketTest
69 clientExecutor, clientListener, url) { in setUp()