Searched refs:operationTimeoutMillis (Results 1 – 2 of 2) sorted by relevance
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | AbstractInteropTest.java | 609 responseObserver.awaitCompletion(operationTimeoutMillis(), TimeUnit.MILLISECONDS); in clientCompressedStreaming()
735 Object actualResponse = queue.poll(operationTimeoutMillis(), TimeUnit.MILLISECONDS); in pingPong()
743 assertEquals("Completed", queue.poll(operationTimeoutMillis(), TimeUnit.MILLISECONDS)); in pingPong()
752 responseObserver.awaitCompletion(operationTimeoutMillis(), TimeUnit.MILLISECONDS); in emptyStream()
800 responseObserver.awaitCompletion(operationTimeoutMillis(), TimeUnit.MILLISECONDS); in cancelAfterFirstResponse()
926 queue.poll(operationTimeoutMillis(), TimeUnit.MILLISECONDS)); in serverStreamingShouldBeFlowControlled()
939 queue.poll(operationTimeoutMillis(), TimeUnit.MILLISECONDS)); in serverStreamingShouldBeFlowControlled()
940 assertEquals(Status.OK, queue.poll(operationTimeoutMillis(), TimeUnit.MILLISECONDS)); in serverStreamingShouldBeFlowControlled()
1372 goldenResponses.get(0), responses.poll(operationTimeoutMillis(), TimeUnit.MILLISECONDS)); in gracefulShutdown()
1377 goldenResponses.get(1), responses.poll(operationTimeoutMillis(), TimeUnit.MILLISECONDS)); in gracefulShutdown()
[all …]
|
| D | StressTestClient.java | 519 protected int operationTimeoutMillis() { in operationTimeoutMillis() method in StressTestClient.Worker.Tester
|