| /external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/batching/ |
| D | FlowControllerTest.java | 66 FlowController flowController = in testReserveRelease_ok() local
80 FlowController flowController = in testInvalidArguments() local
119 FlowController flowController = in testReserveRelease_noLimits_ok() local
131 FlowController flowController = in testReserveRelease_ignore_ok() local
145 FlowController flowController = in testReserveRelease_blockedByElementCount() local
158 FlowController flowController = in testReserveRelease_blockedByElementCount_noBytesLimit() local
170 FlowController flowController = in testReserveRelease_blockedByNumberOfBytes() local
183 FlowController flowController = in testReserveRelease_blockedByNumberOfBytes_noElementCountLimit() local
194 final FlowController flowController, final int maxElementCount, final int maxNumBytes) in testBlockingReserveRelease()
225 FlowController flowController = in testReserveRelease_rejectedByElementCount() local
[all …]
|
| D | BatcherImplTest.java | 821 FlowController flowController = in testConstructors() local
827 try (BatcherImpl batcher2 = createDefaultBatcherImpl(batchingSettings, flowController)) { in testConstructors() argument
839 FlowController flowController = in testThrottlingBlocking() local
861 flowController, in testThrottlingBlocking() argument
915 FlowController flowController = in testThrottlingNonBlocking() local
922 createDefaultBatcherImpl(settings, flowController)) { in testThrottlingNonBlocking() argument
992 FlowController flowController = new FlowController(batchingSettings.getFlowControlSettings()); in testAddDoesNotHangIfExceptionThrowStartingACall() local
1024 BatchingSettings settings, FlowController flowController) { in createDefaultBatcherImpl()
|
| /external/grpc-grpc-java/binder/src/test/java/io/grpc/binder/internal/ |
| D | FlowControllerTest.java | 30 FlowController flowController = new FlowController(100); in shouldReportTransmitWindowInitiallyNonFull() local
36 FlowController flowController = new FlowController(100); in shouldReportTransmitWindowFull() local
47 FlowController flowController = new FlowController(100); in shouldHandleAck() local
61 FlowController flowController = new FlowController(100); in shouldHandleAcksOutOfOrder() local
73 FlowController flowController = new FlowController(2); in shouldHandleAckOverflow() local
|
| /external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/rpc/ |
| D | BatchingCallSettingsTest.java | 84 FlowController flowController = Mockito.mock(FlowController.class); in testBuilder() local
128 FlowController flowController = Mockito.mock(FlowController.class); in testBuilderFromSettings() local
185 FlowController flowController = Mockito.mock(FlowController.class); in testToString() local
|
| D | BatchingCallableTest.java | 79 FlowController flowController = new FlowController(flowControlSettings); in testBatchedCall() local
118 FlowController flowController = new FlowController(flowControlSettings); in testUnbatchedCall() local
|
| D | BatcherFactoryTest.java | 78 FlowController flowController = new FlowController(flowControlSettings); in testGetPushingBatcher() local
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/rpc/ |
| D | BatchingCallSettings.java | 49 private final FlowController flowController; field in BatchingCallSettings
98 private FlowController flowController; field in BatchingCallSettings.Builder
125 public Builder<RequestT, ResponseT> setFlowController(FlowController flowController) { in setFlowController()
|
| D | BatcherFactory.java | 62 private final FlowController flowController; field in BatcherFactory
70 FlowController flowController) { in BatcherFactory()
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/batching/ |
| D | BatchingFlowController.java | 39 private final FlowController flowController; field in BatchingFlowController
44 FlowController flowController, in BatchingFlowController()
|
| D | ThresholdBatcher.java | 82 private final BatchingFlowController<E> flowController; field in ThresholdBatcher
109 private BatchingFlowController<E> flowController; field in ThresholdBatcher.Builder
139 public Builder<E> setFlowController(BatchingFlowController<E> flowController) { in setFlowController()
|
| D | BatcherImpl.java | 95 private final FlowController flowController; field in BatcherImpl
135 @Nullable FlowController flowController) { in BatcherImpl()
163 @Nullable FlowController flowController, in BatcherImpl()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientStreamTest.java | 73 @Mock private OutboundFlowController flowController; field in OkHttpClientStreamTest
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/http2/ |
| D | Http2MultiplexedChannelPoolTest.java | 237 Http2LocalFlowController flowController = in acquire_shouldExpandConnectionWindowSizeProportionally() local
|
| /external/grpc-grpc-java/binder/src/main/java/io/grpc/binder/internal/ |
| D | BinderTransport.java | 207 private final FlowController flowController; field in BinderTransport
|