Home
last modified time | relevance | path

Searched refs:pickerCaptor (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DPickFirstLoadBalancerTest.java68 private ArgumentCaptor<SubchannelPicker> pickerCaptor; field in PickFirstLoadBalancerTest
106 verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterResolved()
109 assertEquals(pickerCaptor.getValue().pickSubchannel(mockArgs), in pickAfterResolved()
110 pickerCaptor.getValue().pickSubchannel(mockArgs)); in pickAfterResolved()
143 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterResolvedAndChanged()
145 assertEquals(mockSubchannel, pickerCaptor.getValue().pickSubchannel(mockArgs).getSubchannel()); in pickAfterResolvedAndChanged()
164 verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterStateChangeAfterResolution()
165 Subchannel subchannel = pickerCaptor.getValue().pickSubchannel(mockArgs).getSubchannel(); in pickAfterStateChangeAfterResolution()
173 inOrder.verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in pickAfterStateChangeAfterResolution()
174 assertEquals(error, pickerCaptor.getValue().pickSubchannel(mockArgs).getStatus()); in pickAfterStateChangeAfterResolution()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java99 private ArgumentCaptor<SubchannelPicker> pickerCaptor; field in RoundRobinLoadBalancerTest
159 .updateBalancingState(stateCaptor.capture(), pickerCaptor.capture()); in pickAfterResolved()
163 assertThat(getList(pickerCaptor.getValue())).containsExactly(readySubchannel); in pickAfterResolved()
206 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterResolvedUpdatedHosts()
207 SubchannelPicker picker = pickerCaptor.getValue(); in pickAfterResolvedUpdatedHosts()
238 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterResolvedUpdatedHosts()
240 picker = pickerCaptor.getValue(); in pickAfterResolvedUpdatedHosts()
247 inOrder.verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in pickAfterResolvedUpdatedHosts()
248 assertEquals(PickResult.withNoResult(), pickerCaptor.getValue().pickSubchannel(mockArgs)); in pickAfterResolvedUpdatedHosts()
266 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterStateChange()
[all …]
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java164 private ArgumentCaptor<SubchannelPicker> pickerCaptor; field in GrpclbLoadBalancerTest
443 .updateBalancingState(eq(READY), pickerCaptor.capture()); in loadReporting()
444 RoundRobinPicker picker = (RoundRobinPicker) pickerCaptor.getValue(); in loadReporting()
598 helperInOrder.verify(helper).updateBalancingState(eq(READY), pickerCaptor.capture()); in loadReporting()
599 picker = (RoundRobinPicker) pickerCaptor.getValue(); in loadReporting()
721 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionFailsThenRecoverToDelegate()
722 RoundRobinPicker picker = (RoundRobinPicker) pickerCaptor.getValue(); in nameResolutionFailsThenRecoverToDelegate()
737 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionFailsThenRecoverToGrpclb()
738 RoundRobinPicker picker = (RoundRobinPicker) pickerCaptor.getValue(); in nameResolutionFailsThenRecoverToGrpclb()
771 inOrder.verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in grpclbThenNameResolutionFails()
[all …]