Searched refs:mockPicker (Results 1 – 3 of 3) sorted by relevance
188 private SubchannelPicker mockPicker; field in ManagedChannelImplTest451 when(mockPicker.pickSubchannel( in subtestCallsAndShutdown()454 when(mockPicker.pickSubchannel( in subtestCallsAndShutdown()457 helper.updateBalancingState(READY, mockPicker); in subtestCallsAndShutdown()649 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in callOptionsExecutor()652 helper.updateBalancingState(READY, mockPicker); in callOptionsExecutor()854 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in firstResolvedServerFailedToConnect()886 helper.updateBalancingState(READY, mockPicker); in firstResolvedServerFailedToConnect()999 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()