Searched refs:picker2 (Results 1 – 3 of 3) sorted by relevance
546 SubchannelPicker picker2 = mock(SubchannelPicker.class); in reprocess_newStreamRacesWithReprocess() local547 when(picker2.pickSubchannel(any(PickSubchannelArgs.class))) in reprocess_newStreamRacesWithReprocess()549 delayedTransport.reprocess(picker2); in reprocess_newStreamRacesWithReprocess()551 verify(picker2).pickSubchannel(args); in reprocess_newStreamRacesWithReprocess()553 verify(picker2, never()).pickSubchannel(args2); in reprocess_newStreamRacesWithReprocess()561 verify(picker2, timeout(5000)).pickSubchannel(args2); in reprocess_newStreamRacesWithReprocess()566 verify(picker2).pickSubchannel(args); in reprocess_newStreamRacesWithReprocess()567 verify(picker2).pickSubchannel(args); in reprocess_newStreamRacesWithReprocess()
511 SubchannelPicker picker2 = mock(SubchannelPicker.class); in subtestCallsAndShutdown() local512 when(picker2.pickSubchannel(new PickSubchannelArgsImpl(method, headers, CallOptions.DEFAULT))) in subtestCallsAndShutdown()514 helper.updateBalancingState(READY, picker2); in subtestCallsAndShutdown()1029 SubchannelPicker picker2 = mock(SubchannelPicker.class); in allServersFailedToConnect() local1030 when(picker2.pickSubchannel(any(PickSubchannelArgs.class))) in allServersFailedToConnect()1032 helper.updateBalancingState(TRANSIENT_FAILURE, picker2); in allServersFailedToConnect()
905 RoundRobinPicker picker2 = (RoundRobinPicker) pickerCaptor.getValue(); in grpclbWorking() local906 assertThat(picker2.dropList).containsExactly(null, null); in grpclbWorking()907 assertThat(picker2.pickList).containsExactly( in grpclbWorking()