flasn4nt
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Upgrade to Mockito 3.3.3 

verifyZeroInteractions has the same behavior as verifyNoMoreInteractions. It
was deprecated in Mockito 3.0.1 and replaced with verifyNoInteractions, which
does not change behavior depending on previous verify() calls. All instances
were replaced with verifyNoInteractions, except those in
ApplicationThreadDeframerTest which were replaced with verifyNoMoreInteractions
since there is a verify() call in `@Before`.
This commit is contained in:
Eric Anderson 2020-08-03 10:01:37 -07:00 committed by Eric Anderson
parent d4166f0a02
commit 80d62bfce2
16 changed files with 54 additions and 55 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
api/src/test/java/io/grpc/ServerInterceptorsTest.java
View File

@ -25,8 +25,8 @@ import static org.mockito.ArgumentMatchers.same;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import io.grpc.MethodDescriptor.Marshaller; import io.grpc.MethodDescriptor.Marshaller;
import io.grpc.MethodDescriptor.MethodType; import io.grpc.MethodDescriptor.MethodType;
@ -102,9 +102,9 @@ public class ServerInterceptorsTest {
/** Final checks for all tests. */ /** Final checks for all tests. */
@After @After
public void makeSureExpectedMocksUnused() { public void makeSureExpectedMocksUnused() {
verifyZeroInteractions(requestMarshaller); verifyNoInteractions(requestMarshaller);
verifyZeroInteractions(responseMarshaller); verifyNoInteractions(responseMarshaller);
verifyZeroInteractions(listener); verifyNoInteractions(listener);
} }
@Test @Test

2
build.gradle
View File

@ -179,7 +179,7 @@ subprojects {
// Test dependencies. // Test dependencies.
junit: 'junit:junit:4.12', junit: 'junit:junit:4.12',
mockito: 'org.mockito:mockito-core:2.28.2', mockito: 'org.mockito:mockito-core:3.3.3',
truth: 'com.google.truth:truth:1.0.1', truth: 'com.google.truth:truth:1.0.1',
guava_testlib: "com.google.guava:guava-testlib:${guavaVersion}", guava_testlib: "com.google.guava:guava-testlib:${guavaVersion}",
androidx_test: "androidx.test:core:1.2.0", androidx_test: "androidx.test:core:1.2.0",

4
census/src/test/java/io/grpc/census/CensusModulesTest.java
View File

@ -37,8 +37,8 @@ import static org.mockito.Mockito.reset;
import static org.mockito.Mockito.spy; import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableList;
@ -1039,7 +1039,7 @@ public class CensusModulesTest {
ServerStreamTracer.Factory tracerFactory = censusTracing.getServerTracerFactory(); ServerStreamTracer.Factory tracerFactory = censusTracing.getServerTracerFactory();
ServerStreamTracer serverStreamTracer = ServerStreamTracer serverStreamTracer =
tracerFactory.newServerStreamTracer(method.getFullMethodName(), new Metadata()); tracerFactory.newServerStreamTracer(method.getFullMethodName(), new Metadata());
verifyZeroInteractions(mockTracingPropagationHandler); verifyNoInteractions(mockTracingPropagationHandler);
verify(tracer).spanBuilderWithRemoteParent( verify(tracer).spanBuilderWithRemoteParent(
eq("Recv.package1.service2.method3"), ArgumentMatchers.<SpanContext>isNull()); eq("Recv.package1.service2.method3"), ArgumentMatchers.<SpanContext>isNull());
verify(spyServerSpanBuilder).setRecordEvents(eq(true)); verify(spyServerSpanBuilder).setRecordEvents(eq(true));

7
core/src/test/java/io/grpc/internal/ApplicationThreadDeframerTest.java
View File

@ -24,7 +24,6 @@ import static org.junit.Assert.assertTrue;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import com.google.common.io.ByteStreams; import com.google.common.io.ByteStreams;
import com.google.common.primitives.Bytes; import com.google.common.primitives.Bytes;
@ -57,7 +56,7 @@ public class ApplicationThreadDeframerTest {
@Test @Test
public void requestInvokesMessagesAvailableOnListener() { public void requestInvokesMessagesAvailableOnListener() {
applicationThreadDeframer.request(1); applicationThreadDeframer.request(1);
verifyZeroInteractions(mockDeframer); verifyNoMoreInteractions(mockDeframer);
listener.runStoredProducer(); listener.runStoredProducer();
verify(mockDeframer).request(1); verify(mockDeframer).request(1);
} }
@ -66,7 +65,7 @@ public class ApplicationThreadDeframerTest {
public void deframeInvokesMessagesAvailableOnListener() { public void deframeInvokesMessagesAvailableOnListener() {
ReadableBuffer frame = ReadableBuffers.wrap(new byte[1]); ReadableBuffer frame = ReadableBuffers.wrap(new byte[1]);
applicationThreadDeframer.deframe(frame); applicationThreadDeframer.deframe(frame);
verifyZeroInteractions(mockDeframer); verifyNoMoreInteractions(mockDeframer);
listener.runStoredProducer(); listener.runStoredProducer();
verify(mockDeframer).deframe(frame); verify(mockDeframer).deframe(frame);
} }
@ -74,7 +73,7 @@ public class ApplicationThreadDeframerTest {
@Test @Test
public void closeWhenCompleteInvokesMessagesAvailableOnListener() { public void closeWhenCompleteInvokesMessagesAvailableOnListener() {
applicationThreadDeframer.closeWhenComplete(); applicationThreadDeframer.closeWhenComplete();
verifyZeroInteractions(mockDeframer); verifyNoMoreInteractions(mockDeframer);
listener.runStoredProducer(); listener.runStoredProducer();
verify(mockDeframer).closeWhenComplete(); verify(mockDeframer).closeWhenComplete();
} }

4
core/src/test/java/io/grpc/internal/AutoConfiguredLoadBalancerFactoryTest.java
View File

@ -27,8 +27,8 @@ import static org.mockito.Mockito.atLeast;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
import com.google.common.base.Preconditions; import com.google.common.base.Preconditions;
@ -634,7 +634,7 @@ public class AutoConfiguredLoadBalancerFactoryTest {
PolicySelection policySelection = (PolicySelection) parsed.getConfig(); PolicySelection policySelection = (PolicySelection) parsed.getConfig();
assertThat(policySelection.config).isNotNull(); assertThat(policySelection.config).isNotNull();
assertThat(policySelection.provider).isInstanceOf(GrpclbLoadBalancerProvider.class); assertThat(policySelection.provider).isInstanceOf(GrpclbLoadBalancerProvider.class);
verifyZeroInteractions(channelLogger); verifyNoInteractions(channelLogger);
} }
public static class ForwardingLoadBalancer extends LoadBalancer { public static class ForwardingLoadBalancer extends LoadBalancer {

8
core/src/test/java/io/grpc/internal/ClientCallImplTest.java
View File

@ -35,7 +35,7 @@ import static org.mockito.Mockito.never;
import static org.mockito.Mockito.timeout; import static org.mockito.Mockito.timeout;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyZeroInteractions; import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
import com.google.common.collect.ImmutableSet; import com.google.common.collect.ImmutableSet;
@ -154,7 +154,7 @@ public class ClientCallImplTest {
@After @After
public void tearDown() { public void tearDown() {
verifyZeroInteractions(streamTracerFactory); verifyNoInteractions(streamTracerFactory);
} }
@Test @Test
@ -696,7 +696,7 @@ public class ClientCallImplTest {
call.halfClose(); call.halfClose();
// Stream should never be created. // Stream should never be created.
verifyZeroInteractions(clientStreamProvider); verifyNoInteractions(clientStreamProvider);
try { try {
call.sendMessage(null); call.sendMessage(null);
@ -729,7 +729,7 @@ public class ClientCallImplTest {
assertEquals(Status.Code.DEADLINE_EXCEEDED, statusCaptor.getValue().getCode()); assertEquals(Status.Code.DEADLINE_EXCEEDED, statusCaptor.getValue().getCode());
assertThat(statusCaptor.getValue().getDescription()) assertThat(statusCaptor.getValue().getDescription())
.startsWith("ClientCall started after deadline exceeded"); .startsWith("ClientCall started after deadline exceeded");
verifyZeroInteractions(clientStreamProvider); verifyNoInteractions(clientStreamProvider);
} }
@Test @Test

22
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java
View File

@ -46,8 +46,8 @@ import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never; import static org.mockito.Mockito.never;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
import com.google.common.base.Throwables; import com.google.common.base.Throwables;
@ -1192,7 +1192,7 @@ public class ManagedChannelImplTest {
if (shouldFail) { if (shouldFail) {
verify(mockCallListener).onClose(same(status), any(Metadata.class)); verify(mockCallListener).onClose(same(status), any(Metadata.class));
} else { } else {
verifyZeroInteractions(mockCallListener); verifyNoInteractions(mockCallListener);
} }
// This call doesn't involve delayed transport // This call doesn't involve delayed transport
@ -1203,7 +1203,7 @@ public class ManagedChannelImplTest {
if (shouldFail) { if (shouldFail) {
verify(mockCallListener2).onClose(same(status), any(Metadata.class)); verify(mockCallListener2).onClose(same(status), any(Metadata.class));
} else { } else {
verifyZeroInteractions(mockCallListener2); verifyNoInteractions(mockCallListener2);
} }
} }
@ -1691,7 +1691,7 @@ public class ManagedChannelImplTest {
verify(mockTransport, never()).newStream( verify(mockTransport, never()).newStream(
any(MethodDescriptor.class), any(Metadata.class), any(CallOptions.class)); any(MethodDescriptor.class), any(Metadata.class), any(CallOptions.class));
verifyZeroInteractions(mockCallListener); verifyNoInteractions(mockCallListener);
assertEquals(1, balancerRpcExecutor.runDueTasks()); assertEquals(1, balancerRpcExecutor.runDueTasks());
verify(mockCallListener).onClose( verify(mockCallListener).onClose(
same(SubchannelChannel.NOT_READY_ERROR), any(Metadata.class)); same(SubchannelChannel.NOT_READY_ERROR), any(Metadata.class));
@ -1723,7 +1723,7 @@ public class ManagedChannelImplTest {
verify(mockTransport, never()).newStream( verify(mockTransport, never()).newStream(
any(MethodDescriptor.class), any(Metadata.class), any(CallOptions.class)); any(MethodDescriptor.class), any(Metadata.class), any(CallOptions.class));
verifyZeroInteractions(mockCallListener); verifyNoInteractions(mockCallListener);
assertEquals(1, balancerRpcExecutor.runDueTasks()); assertEquals(1, balancerRpcExecutor.runDueTasks());
verify(mockCallListener).onClose( verify(mockCallListener).onClose(
same(SubchannelChannel.WAIT_FOR_READY_ERROR), any(Metadata.class)); same(SubchannelChannel.WAIT_FOR_READY_ERROR), any(Metadata.class));
@ -1994,8 +1994,8 @@ public class ManagedChannelImplTest {
Arrays.asList(factory1, factory2), Arrays.asList(factory1, factory2),
callOptionsCaptor.getValue().getStreamTracerFactories()); callOptionsCaptor.getValue().getStreamTracerFactories());
// The factories are safely not stubbed because we do not expect any usage of them. // The factories are safely not stubbed because we do not expect any usage of them.
verifyZeroInteractions(factory1); verifyNoInteractions(factory1);
verifyZeroInteractions(factory2); verifyNoInteractions(factory2);
} }
@Test @Test
@ -2030,8 +2030,8 @@ public class ManagedChannelImplTest {
Arrays.asList(factory1, factory2), Arrays.asList(factory1, factory2),
callOptionsCaptor.getValue().getStreamTracerFactories()); callOptionsCaptor.getValue().getStreamTracerFactories());
// The factories are safely not stubbed because we do not expect any usage of them. // The factories are safely not stubbed because we do not expect any usage of them.
verifyZeroInteractions(factory1); verifyNoInteractions(factory1);
verifyZeroInteractions(factory2); verifyNoInteractions(factory2);
} }
@Test @Test
@ -2261,7 +2261,7 @@ public class ManagedChannelImplTest {
assertEquals(SHUTDOWN, channel.getState(false)); assertEquals(SHUTDOWN, channel.getState(false));
// We didn't stub mockPicker, because it should have never been called in this test. // We didn't stub mockPicker, because it should have never been called in this test.
verifyZeroInteractions(mockPicker); verifyNoInteractions(mockPicker);
} }
@Test @Test
@ -2282,7 +2282,7 @@ public class ManagedChannelImplTest {
call2.start(mockCallListener2, new Metadata()); call2.start(mockCallListener2, new Metadata());
executor.runDueTasks(); executor.runDueTasks();
verifyZeroInteractions(mockCallListener, mockCallListener2); verifyNoInteractions(mockCallListener, mockCallListener2);
// Enter panic // Enter panic
final Throwable panicReason = new Exception("Simulated uncaught exception"); final Throwable panicReason = new Exception("Simulated uncaught exception");

4
core/src/test/java/io/grpc/internal/MessageFramerTest.java
View File

@ -23,8 +23,8 @@ import static org.junit.Assert.fail;
import static org.mockito.ArgumentMatchers.eq; import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import io.grpc.Codec; import io.grpc.Codec;
import io.grpc.StreamTracer; import io.grpc.StreamTracer;
@ -177,7 +177,7 @@ public class MessageFramerTest {
@Test @Test
public void emptyUnknownLengthPayloadYieldsFrame() { public void emptyUnknownLengthPayloadYieldsFrame() {
writeUnknownLength(framer, new byte[0]); writeUnknownLength(framer, new byte[0]);
verifyZeroInteractions(sink); verifyNoInteractions(sink);
framer.flush(); framer.flush();
verify(sink).deliverFrame(toWriteBuffer(new byte[] {0, 0, 0, 0, 0}), false, true, 1); verify(sink).deliverFrame(toWriteBuffer(new byte[] {0, 0, 0, 0, 0}), false, true, 1);
// One alloc for the header // One alloc for the header

4
core/src/test/java/io/grpc/util/MutableHandlerRegistryTest.java
View File

@ -99,8 +99,8 @@ public class MutableHandlerRegistryTest {
/** Final checks for all tests. */ /** Final checks for all tests. */
@After @After
public void makeSureMocksUnused() { public void makeSureMocksUnused() {
Mockito.verifyZeroInteractions(requestMarshaller); Mockito.verifyNoInteractions(requestMarshaller);
Mockito.verifyZeroInteractions(responseMarshaller); Mockito.verifyNoInteractions(responseMarshaller);
Mockito.verifyNoMoreInteractions(flowHandler); Mockito.verifyNoMoreInteractions(flowHandler);
Mockito.verifyNoMoreInteractions(coupleHandler); Mockito.verifyNoMoreInteractions(coupleHandler);
Mockito.verifyNoMoreInteractions(fewHandler); Mockito.verifyNoMoreInteractions(fewHandler);

6
netty/src/test/java/io/grpc/netty/NettyServerStreamTest.java
View File

@ -28,8 +28,8 @@ import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.never; import static org.mockito.Mockito.never;
import static org.mockito.Mockito.reset; import static org.mockito.Mockito.reset;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
import com.google.common.collect.ImmutableListMultimap; import com.google.common.collect.ImmutableListMultimap;
@ -160,7 +160,7 @@ public class NettyServerStreamTest extends NettyStreamTestBase<NettyServerStream
assertThat(ImmutableListMultimap.copyOf(sendHeaders.headers())) assertThat(ImmutableListMultimap.copyOf(sendHeaders.headers()))
.containsExactlyEntriesIn(expectedHeaders); .containsExactlyEntriesIn(expectedHeaders);
assertThat(sendHeaders.endOfStream()).isTrue(); assertThat(sendHeaders.endOfStream()).isTrue();
verifyZeroInteractions(serverListener); verifyNoInteractions(serverListener);
// Sending complete. Listener gets closed() // Sending complete. Listener gets closed()
stream().transportState().complete(); stream().transportState().complete();
@ -188,7 +188,7 @@ public class NettyServerStreamTest extends NettyStreamTestBase<NettyServerStream
assertThat(ImmutableListMultimap.copyOf(sendHeaders.headers())) assertThat(ImmutableListMultimap.copyOf(sendHeaders.headers()))
.containsExactlyEntriesIn(expectedHeaders); .containsExactlyEntriesIn(expectedHeaders);
assertThat(sendHeaders.endOfStream()).isTrue(); assertThat(sendHeaders.endOfStream()).isTrue();
verifyZeroInteractions(serverListener); verifyNoInteractions(serverListener);
// Sending complete. Listener gets closed() // Sending complete. Listener gets closed()
stream().transportState().complete(); stream().transportState().complete();

4
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java
View File

@ -44,8 +44,8 @@ import static org.mockito.Mockito.never;
import static org.mockito.Mockito.reset; import static org.mockito.Mockito.reset;
import static org.mockito.Mockito.timeout; import static org.mockito.Mockito.timeout;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import com.google.common.base.Stopwatch; import com.google.common.base.Stopwatch;
import com.google.common.base.Supplier; import com.google.common.base.Supplier;
@ -1586,7 +1586,7 @@ public class OkHttpClientTransportTest {
@Test @Test
public void transportReady() throws Exception { public void transportReady() throws Exception {
initTransport(); initTransport();
verifyZeroInteractions(transportListener); verifyNoInteractions(transportListener);
frameHandler().settings(false, new Settings()); frameHandler().settings(false, new Settings());
verify(transportListener).transportReady(); verify(transportListener).transportReady();
shutdownAndVerify(); shutdownAndVerify();

6
services/src/test/java/io/grpc/services/HealthCheckingLoadBalancerFactoryTest.java
View File

@ -34,8 +34,8 @@ import static org.mockito.Mockito.inOrder;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
import com.google.common.util.concurrent.MoreExecutors; import com.google.common.util.concurrent.MoreExecutors;
@ -364,7 +364,7 @@ public class HealthCheckingLoadBalancerFactoryTest {
assertThat(healthImpls[i].calls).hasSize(1); assertThat(healthImpls[i].calls).hasSize(1);
} }
verifyZeroInteractions(backoffPolicyProvider); verifyNoInteractions(backoffPolicyProvider);
} }
@Test @Test
@ -433,7 +433,7 @@ public class HealthCheckingLoadBalancerFactoryTest {
unavailableStateWithMsg("Health-check service responded SERVICE_UNKNOWN for 'BarService'")); unavailableStateWithMsg("Health-check service responded SERVICE_UNKNOWN for 'BarService'"));
verifyNoMoreInteractions(origLb, mockStateListeners[0], mockStateListeners[1]); verifyNoMoreInteractions(origLb, mockStateListeners[0], mockStateListeners[1]);
verifyZeroInteractions(backoffPolicyProvider); verifyNoInteractions(backoffPolicyProvider);
} }
@Test @Test

8
xds/src/test/java/io/grpc/xds/OrcaOobUtilTest.java
View File

@ -30,8 +30,8 @@ import static org.mockito.Mockito.inOrder;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
import com.github.udpa.udpa.data.orca.v1.OrcaLoadReport; import com.github.udpa.udpa.data.orca.v1.OrcaLoadReport;
@ -302,7 +302,7 @@ public class OrcaOobUtilTest {
assertThat(orcaServiceImps[i].calls).hasSize(1); assertThat(orcaServiceImps[i].calls).hasSize(1);
} }
verifyZeroInteractions(backoffPolicyProvider); verifyNoInteractions(backoffPolicyProvider);
} }
@Test @Test
@ -388,7 +388,7 @@ public class OrcaOobUtilTest {
assertThat(orcaServiceImps[i].calls).hasSize(1); assertThat(orcaServiceImps[i].calls).hasSize(1);
} }
verifyZeroInteractions(backoffPolicyProvider); verifyNoInteractions(backoffPolicyProvider);
} }
@Test @Test
@ -424,7 +424,7 @@ public class OrcaOobUtilTest {
assertLog(subchannel.logs, "DEBUG: Received an ORCA report: " + report); assertLog(subchannel.logs, "DEBUG: Received an ORCA report: " + report);
verify(mockOrcaListener0).onLoadReport(eq(report)); verify(mockOrcaListener0).onLoadReport(eq(report));
verifyZeroInteractions(backoffPolicyProvider); verifyNoInteractions(backoffPolicyProvider);
} }
@Test @Test

6
xds/src/test/java/io/grpc/xds/OrcaPerRequestUtilTest.java
View File

@ -23,8 +23,8 @@ import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doNothing; import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
import com.github.udpa.udpa.data.orca.v1.OrcaLoadReport; import com.github.udpa.udpa.data.orca.v1.OrcaLoadReport;
@ -164,7 +164,7 @@ public class OrcaPerRequestUtilTest {
OrcaLoadReport.getDefaultInstance()); OrcaLoadReport.getDefaultInstance());
parentTracer.inboundTrailers(trailer); parentTracer.inboundTrailers(trailer);
verify(orcaListener1).onLoadReport(eq(OrcaLoadReport.getDefaultInstance())); verify(orcaListener1).onLoadReport(eq(OrcaLoadReport.getDefaultInstance()));
verifyZeroInteractions(childFactory); verifyNoInteractions(childFactory);
verifyZeroInteractions(orcaListener2); verifyNoInteractions(orcaListener2);
} }
} }

8
xds/src/test/java/io/grpc/xds/XdsClientImplTest.java
View File

@ -38,8 +38,8 @@ import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never; import static org.mockito.Mockito.never;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableList;
@ -1866,7 +1866,7 @@ public class XdsClientImplTest {
assertThat(fakeClock.getPendingTasks(CDS_RESOURCE_FETCH_TIMEOUT_TASK_FILTER)).isEmpty(); assertThat(fakeClock.getPendingTasks(CDS_RESOURCE_FETCH_TIMEOUT_TASK_FILTER)).isEmpty();
assertThat(timeoutTask.isCancelled()).isTrue(); assertThat(timeoutTask.isCancelled()).isTrue();
verifyZeroInteractions(watcher3, watcher4); verifyNoInteractions(watcher3, watcher4);
} }
@Test @Test
@ -2133,7 +2133,7 @@ public class XdsClientImplTest {
new LbEndpoint("192.168.0.1", 8080, new LbEndpoint("192.168.0.1", 8080,
2, true)), 1, 0)); 2, true)), 1, 0));
verifyZeroInteractions(watcher3); verifyNoInteractions(watcher3);
// Management server sends back another EDS response contains ClusterLoadAssignment for the // Management server sends back another EDS response contains ClusterLoadAssignment for the
// other requested cluster. // other requested cluster.
@ -2517,7 +2517,7 @@ public class XdsClientImplTest {
assertThat(fakeClock.getPendingTasks(EDS_RESOURCE_FETCH_TIMEOUT_TASK_FILTER)).isEmpty(); assertThat(fakeClock.getPendingTasks(EDS_RESOURCE_FETCH_TIMEOUT_TASK_FILTER)).isEmpty();
assertThat(timeoutTask.isCancelled()).isTrue(); assertThat(timeoutTask.isCancelled()).isTrue();
verifyZeroInteractions(watcher3, watcher4); verifyNoInteractions(watcher3, watcher4);
} }
@Test @Test

8
xds/src/test/java/io/grpc/xds/XdsClientImplTestV2.java
View File

@ -38,8 +38,8 @@ import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never; import static org.mockito.Mockito.never;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableList;
@ -1875,7 +1875,7 @@ public class XdsClientImplTestV2 {
assertThat(fakeClock.getPendingTasks(CDS_RESOURCE_FETCH_TIMEOUT_TASK_FILTER)).isEmpty(); assertThat(fakeClock.getPendingTasks(CDS_RESOURCE_FETCH_TIMEOUT_TASK_FILTER)).isEmpty();
assertThat(timeoutTask.isCancelled()).isTrue(); assertThat(timeoutTask.isCancelled()).isTrue();
verifyZeroInteractions(watcher3, watcher4); verifyNoInteractions(watcher3, watcher4);
} }
@Test @Test
@ -2142,7 +2142,7 @@ public class XdsClientImplTestV2 {
new LbEndpoint("192.168.0.1", 8080, new LbEndpoint("192.168.0.1", 8080,
2, true)), 1, 0)); 2, true)), 1, 0));
verifyZeroInteractions(watcher3); verifyNoInteractions(watcher3);
// Management server sends back another EDS response contains ClusterLoadAssignment for the // Management server sends back another EDS response contains ClusterLoadAssignment for the
// other requested cluster. // other requested cluster.
@ -2526,7 +2526,7 @@ public class XdsClientImplTestV2 {
assertThat(fakeClock.getPendingTasks(EDS_RESOURCE_FETCH_TIMEOUT_TASK_FILTER)).isEmpty(); assertThat(fakeClock.getPendingTasks(EDS_RESOURCE_FETCH_TIMEOUT_TASK_FILTER)).isEmpty();
assertThat(timeoutTask.isCancelled()).isTrue(); assertThat(timeoutTask.isCancelled()).isTrue();
verifyZeroInteractions(watcher3, watcher4); verifyNoInteractions(watcher3, watcher4);
} }
@Test @Test