Searched refs:mockPicker (Results 1 – 3 of 3) sorted by relevance
187 private SubchannelPicker mockPicker; field in ManagedChannelImplTest450 when(mockPicker.pickSubchannel( in subtestCallsAndShutdown()453 when(mockPicker.pickSubchannel( in subtestCallsAndShutdown()456 helper.updateBalancingState(READY, mockPicker); in subtestCallsAndShutdown()648 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in callOptionsExecutor()651 helper.updateBalancingState(READY, mockPicker); in callOptionsExecutor()853 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in firstResolvedServerFailedToConnect()885 helper.updateBalancingState(READY, mockPicker); in firstResolvedServerFailedToConnect()998 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in allServersFailedToConnect()1442 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in informationPropagatedToNewStreamAndCallCredentials()[all …]
70 @Mock private SubchannelPicker mockPicker; field in DelayedClientTransportTest108 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in setUp()130 delayedTransport.reprocess(mockPicker); in streamStartThenAssignTransport()146 delayedTransport.reprocess(mockPicker); in newStreamThenAssignTransportThenShutdown()161 delayedTransport.reprocess(mockPicker); in transportTerminatedThenAssignTransport()166 delayedTransport.reprocess(mockPicker); in assignTransportThenShutdownThenNewStream()178 delayedTransport.reprocess(mockPicker); in assignTransportThenShutdownNowThenNewStream()220 delayedTransport.reprocess(mockPicker); in newStreamThenShutdownTransportThenAssignTransport()
270 SubchannelPicker mockPicker = mock(SubchannelPicker.class); in realTransportsHoldsOffIdleness() local271 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in realTransportsHoldsOffIdleness()273 helper.updateBalancingState(READY, mockPicker); in realTransportsHoldsOffIdleness()