From b0f423295b4674cb5247a6143fd211b050ef0065 Mon Sep 17 00:00:00 2001 From: Carl Mastrangelo Date: Fri, 14 Sep 2018 13:52:29 -0700 Subject: all: use Java7 brackets --- .../io/grpc/alts/internal/AltsClientOptions.java | 4 ++-- .../alts/internal/AltsTsiFrameProtectorTest.java | 2 +- .../InteropInstrumentationTest.java | 2 +- .../android/integrationtest/TesterActivity.java | 2 +- .../auth/GoogleAuthLibraryCallCredentialsTest.java | 4 ++-- .../benchmarks/netty/HandlerRegistryBenchmark.java | 2 +- .../qps/AbstractConfigurationBuilder.java | 2 +- .../java/io/grpc/benchmarks/qps/AsyncClient.java | 4 ++-- context/src/jmh/java/io/grpc/ReadBenchmark.java | 2 +- context/src/main/java/io/grpc/Context.java | 2 +- core/src/main/java/io/grpc/ClientInterceptors.java | 2 +- .../main/java/io/grpc/EquivalentAddressGroup.java | 2 +- core/src/main/java/io/grpc/InternalChannelz.java | 4 ++-- .../main/java/io/grpc/NameResolverProvider.java | 2 +- core/src/main/java/io/grpc/ServerInterceptors.java | 2 +- core/src/main/java/io/grpc/ServiceProviders.java | 4 ++-- core/src/main/java/io/grpc/Status.java | 2 +- .../java/io/grpc/inprocess/InProcessTransport.java | 2 +- .../AbstractManagedChannelImplBuilder.java | 4 ++-- .../grpc/internal/AbstractServerImplBuilder.java | 6 +++--- .../main/java/io/grpc/internal/ChannelTracer.java | 2 +- .../io/grpc/internal/ConnectivityStateManager.java | 4 ++-- .../io/grpc/internal/DelayedClientTransport.java | 4 ++-- .../main/java/io/grpc/internal/DelayedStream.java | 8 ++++---- .../java/io/grpc/internal/DnsNameResolver.java | 2 +- .../io/grpc/internal/InternalHandlerRegistry.java | 2 +- .../java/io/grpc/internal/InternalSubchannel.java | 7 +++---- .../grpc/internal/JndiResourceResolverFactory.java | 8 ++++---- .../src/main/java/io/grpc/internal/JsonParser.java | 2 +- .../java/io/grpc/internal/ManagedChannelImpl.java | 4 ++-- .../main/java/io/grpc/internal/MessageFramer.java | 2 +- .../java/io/grpc/internal/RetriableStream.java | 6 +++--- .../src/main/java/io/grpc/internal/ServerImpl.java | 8 ++++---- .../java/io/grpc/internal/StatsTraceContext.java | 2 +- .../java/io/grpc/util/MutableHandlerRegistry.java | 2 +- .../grpc/util/RoundRobinLoadBalancerFactory.java | 2 +- .../test/java/io/grpc/ClientInterceptorsTest.java | 10 +++++----- core/src/test/java/io/grpc/ContextsTest.java | 2 +- .../test/java/io/grpc/ServerInterceptorsTest.java | 6 +++--- .../java/io/grpc/internal/DnsNameResolverTest.java | 22 +++++++++++----------- core/src/test/java/io/grpc/internal/FakeClock.java | 4 ++-- .../test/java/io/grpc/internal/JsonParserTest.java | 2 +- .../internal/ManagedChannelImplIdlenessTest.java | 4 ++-- .../io/grpc/internal/ManagedChannelImplTest.java | 6 +++--- .../internal/ManagedChannelOrphanWrapperTest.java | 2 +- .../java/io/grpc/internal/RetriableStreamTest.java | 2 +- .../SerializeReentrantCallsDirectExecutorTest.java | 4 ++-- .../io/grpc/internal/SerializingExecutorTest.java | 2 +- .../io/grpc/util/RoundRobinLoadBalancerTest.java | 2 +- .../java/io/grpc/cronet/CronetCallOptions.java | 4 ++-- .../java/io/grpc/cronet/CronetClientStream.java | 2 +- .../java/io/grpc/cronet/CronetClientTransport.java | 2 +- .../SafeMethodCachingInterceptorTest.java | 2 +- .../grpc/routeguideexample/RouteGuideActivity.java | 2 +- .../examples/routeguide/RouteGuideClientTest.java | 10 +++++----- .../examples/routeguide/RouteGuideServerTest.java | 2 +- .../java/io/grpc/grpclb/GrpclbLoadBalancer.java | 4 ++-- .../src/main/java/io/grpc/grpclb/GrpclbState.java | 16 ++++++++-------- .../io/grpc/grpclb/CachedSubchannelPoolTest.java | 2 +- .../io/grpc/grpclb/GrpclbLoadBalancerTest.java | 16 ++++++++-------- .../testing/integration/AbstractInteropTest.java | 6 +++--- .../io/grpc/testing/integration/Http2Client.java | 2 +- .../grpc/testing/integration/StressTestClient.java | 12 ++++++------ .../java/io/grpc/netty/GrpcHttp2HeadersUtils.java | 2 +- .../io/grpc/netty/NettyClientTransportTest.java | 6 +++--- okhttp/src/main/java/io/grpc/okhttp/Headers.java | 2 +- .../io/grpc/okhttp/OkHttpClientTransportTest.java | 2 +- .../grpc/okhttp/internal/OkHostnameVerifier.java | 4 ++-- .../java/io/grpc/okhttp/internal/Platform.java | 4 ++-- .../main/java/io/grpc/okhttp/internal/Util.java | 4 ++-- .../io/grpc/okhttp/internal/framed/HpackTest.java | 2 +- .../java/io/grpc/services/ChannelzProtoUtil.java | 4 ++-- .../services/ProtoReflectionServiceTest.java | 2 +- .../io/grpc/services/BinaryLogProviderTest.java | 6 +++--- .../test/java/io/grpc/stub/ClientCallsTest.java | 10 +++++----- .../test/java/io/grpc/stub/ServerCallsTest.java | 4 ++-- .../java/io/grpc/internal/testing/TestUtils.java | 2 +- .../main/java/io/grpc/testing/GrpcCleanupRule.java | 2 +- .../src/main/java/io/grpc/testing/TestUtils.java | 2 +- 79 files changed, 164 insertions(+), 165 deletions(-) diff --git a/alts/src/main/java/io/grpc/alts/internal/AltsClientOptions.java b/alts/src/main/java/io/grpc/alts/internal/AltsClientOptions.java index 8474c8900..e0e506a08 100644 --- a/alts/src/main/java/io/grpc/alts/internal/AltsClientOptions.java +++ b/alts/src/main/java/io/grpc/alts/internal/AltsClientOptions.java @@ -36,7 +36,7 @@ public final class AltsClientOptions extends AltsHandshakerOptions { super(builder.rpcProtocolVersions); targetName = builder.targetName; targetServiceAccounts = - Collections.unmodifiableList(new ArrayList(builder.targetServiceAccounts)); + Collections.unmodifiableList(new ArrayList<>(builder.targetServiceAccounts)); } public String getTargetName() { @@ -51,7 +51,7 @@ public final class AltsClientOptions extends AltsHandshakerOptions { public static final class Builder { @Nullable private String targetName; @Nullable private RpcProtocolVersions rpcProtocolVersions; - private ArrayList targetServiceAccounts = new ArrayList(); + private ArrayList targetServiceAccounts = new ArrayList<>(); public Builder setTargetName(String targetName) { this.targetName = targetName; diff --git a/alts/src/test/java/io/grpc/alts/internal/AltsTsiFrameProtectorTest.java b/alts/src/test/java/io/grpc/alts/internal/AltsTsiFrameProtectorTest.java index 460ec03b8..4405a99ef 100644 --- a/alts/src/test/java/io/grpc/alts/internal/AltsTsiFrameProtectorTest.java +++ b/alts/src/test/java/io/grpc/alts/internal/AltsTsiFrameProtectorTest.java @@ -45,7 +45,7 @@ public class AltsTsiFrameProtectorTest { private static final int FRAME_MIN_SIZE = AltsTsiFrameProtector.getHeaderTypeFieldBytes() + FakeChannelCrypter.getTagBytes(); - private final List references = new ArrayList(); + private final List references = new ArrayList<>(); private final RegisterRef ref = new RegisterRef() { @Override diff --git a/android-interop-testing/app/src/androidTest/java/io/grpc/android/integrationtest/InteropInstrumentationTest.java b/android-interop-testing/app/src/androidTest/java/io/grpc/android/integrationtest/InteropInstrumentationTest.java index 47f6fc72d..0d88341b2 100644 --- a/android-interop-testing/app/src/androidTest/java/io/grpc/android/integrationtest/InteropInstrumentationTest.java +++ b/android-interop-testing/app/src/androidTest/java/io/grpc/android/integrationtest/InteropInstrumentationTest.java @@ -127,7 +127,7 @@ public class InteropInstrumentationTest { new InteropTask( listener, TesterOkHttpChannelBuilder.build(host, port, serverHostOverride, useTls, testCa), - new ArrayList(), + new ArrayList<>(), testCase) .execute(); String result = resultFuture.get(TIMEOUT_SECONDS, TimeUnit.SECONDS); diff --git a/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/TesterActivity.java b/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/TesterActivity.java index cbf63e3ca..e365f048e 100644 --- a/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/TesterActivity.java +++ b/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/TesterActivity.java @@ -129,7 +129,7 @@ public class TesterActivity extends AppCompatActivity ManagedChannel channel = TesterOkHttpChannelBuilder.build(host, port, serverHostOverride, true, testCert); - List interceptors = new ArrayList(); + List interceptors = new ArrayList<>(); if (getCheckBox.isChecked()) { interceptors.add(new SafeMethodChannelInterceptor()); } diff --git a/auth/src/test/java/io/grpc/auth/GoogleAuthLibraryCallCredentialsTest.java b/auth/src/test/java/io/grpc/auth/GoogleAuthLibraryCallCredentialsTest.java index 1b6056731..438dab0ff 100644 --- a/auth/src/test/java/io/grpc/auth/GoogleAuthLibraryCallCredentialsTest.java +++ b/auth/src/test/java/io/grpc/auth/GoogleAuthLibraryCallCredentialsTest.java @@ -111,7 +111,7 @@ public class GoogleAuthLibraryCallCredentialsTest { .set(CallCredentials.ATTR_SECURITY_LEVEL, SecurityLevel.PRIVACY_AND_INTEGRITY) .build(); - private ArrayList pendingRunnables = new ArrayList(); + private ArrayList pendingRunnables = new ArrayList<>(); @Before public void setUp() throws Exception { @@ -424,7 +424,7 @@ public class GoogleAuthLibraryCallCredentialsTest { private int runPendingRunnables() { ArrayList savedPendingRunnables = pendingRunnables; - pendingRunnables = new ArrayList(); + pendingRunnables = new ArrayList<>(); for (Runnable r : savedPendingRunnables) { r.run(); } diff --git a/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/HandlerRegistryBenchmark.java b/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/HandlerRegistryBenchmark.java index 76d20c9fc..ff8497968 100644 --- a/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/HandlerRegistryBenchmark.java +++ b/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/HandlerRegistryBenchmark.java @@ -64,7 +64,7 @@ public class HandlerRegistryBenchmark { @Setup(Level.Trial) public void setup() throws Exception { registry = new MutableHandlerRegistry(); - fullMethodNames = new ArrayList(serviceCount * methodCountPerService); + fullMethodNames = new ArrayList<>(serviceCount * methodCountPerService); for (int serviceIndex = 0; serviceIndex < serviceCount; ++serviceIndex) { String serviceName = randomString(); ServerServiceDefinition.Builder serviceBuilder = ServerServiceDefinition.builder(serviceName); diff --git a/benchmarks/src/main/java/io/grpc/benchmarks/qps/AbstractConfigurationBuilder.java b/benchmarks/src/main/java/io/grpc/benchmarks/qps/AbstractConfigurationBuilder.java index d095e9090..378c1609a 100644 --- a/benchmarks/src/main/java/io/grpc/benchmarks/qps/AbstractConfigurationBuilder.java +++ b/benchmarks/src/main/java/io/grpc/benchmarks/qps/AbstractConfigurationBuilder.java @@ -149,7 +149,7 @@ public abstract class AbstractConfigurationBuilder public final void printUsage() { System.out.println("Usage: [ARGS...]"); int column1Width = 0; - List params = new ArrayList(); + List params = new ArrayList<>(); params.add(HELP); params.addAll(getParams()); diff --git a/benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java b/benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java index 413fe889c..e453dd8bc 100644 --- a/benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java +++ b/benchmarks/src/main/java/io/grpc/benchmarks/qps/AsyncClient.java @@ -74,7 +74,7 @@ public class AsyncClient { SimpleRequest req = newRequest(); - List channels = new ArrayList(config.channels); + List channels = new ArrayList<>(config.channels); for (int i = 0; i < config.channels; i++) { channels.add(config.newChannel()); } @@ -130,7 +130,7 @@ public class AsyncClient { } } // Wait for completion - List histograms = new ArrayList(futures.size()); + List histograms = new ArrayList<>(futures.size()); for (Future future : futures) { histograms.add(future.get()); } diff --git a/context/src/jmh/java/io/grpc/ReadBenchmark.java b/context/src/jmh/java/io/grpc/ReadBenchmark.java index 237aa6f8e..fa078ce79 100644 --- a/context/src/jmh/java/io/grpc/ReadBenchmark.java +++ b/context/src/jmh/java/io/grpc/ReadBenchmark.java @@ -34,7 +34,7 @@ public class ReadBenchmark { @State(Scope.Benchmark) public static class ContextState { List> keys = new ArrayList>(); - List contexts = new ArrayList(); + List contexts = new ArrayList<>(); @Setup public void setup() { diff --git a/context/src/main/java/io/grpc/Context.java b/context/src/main/java/io/grpc/Context.java index 0e76c08e1..4df0e0f6c 100644 --- a/context/src/main/java/io/grpc/Context.java +++ b/context/src/main/java/io/grpc/Context.java @@ -471,7 +471,7 @@ public class Context { if (listeners == null) { // Now that we have a listener we need to listen to our parent so // we can cascade listener notification. - listeners = new ArrayList(); + listeners = new ArrayList<>(); listeners.add(executableListener); if (cancellableAncestor != null) { cancellableAncestor.addListener(parentListener, DirectExecutor.INSTANCE); diff --git a/core/src/main/java/io/grpc/ClientInterceptors.java b/core/src/main/java/io/grpc/ClientInterceptors.java index 6301e16c4..b6fe077f7 100644 --- a/core/src/main/java/io/grpc/ClientInterceptors.java +++ b/core/src/main/java/io/grpc/ClientInterceptors.java @@ -56,7 +56,7 @@ public class ClientInterceptors { */ public static Channel interceptForward(Channel channel, List interceptors) { - List copy = new ArrayList(interceptors); + List copy = new ArrayList<>(interceptors); Collections.reverse(copy); return intercept(channel, copy); } diff --git a/core/src/main/java/io/grpc/EquivalentAddressGroup.java b/core/src/main/java/io/grpc/EquivalentAddressGroup.java index 38fea9737..2218a7fae 100644 --- a/core/src/main/java/io/grpc/EquivalentAddressGroup.java +++ b/core/src/main/java/io/grpc/EquivalentAddressGroup.java @@ -52,7 +52,7 @@ public final class EquivalentAddressGroup { */ public EquivalentAddressGroup(List addrs, Attributes attrs) { Preconditions.checkArgument(!addrs.isEmpty(), "addrs is empty"); - this.addrs = Collections.unmodifiableList(new ArrayList(addrs)); + this.addrs = Collections.unmodifiableList(new ArrayList<>(addrs)); this.attrs = Preconditions.checkNotNull(attrs, "attrs"); // Attributes may contain mutable objects, which means Attributes' hashCode may change over // time, thus we don't cache Attributes' hashCode. diff --git a/core/src/main/java/io/grpc/InternalChannelz.java b/core/src/main/java/io/grpc/InternalChannelz.java index fee7136bb..3902a7b03 100644 --- a/core/src/main/java/io/grpc/InternalChannelz.java +++ b/core/src/main/java/io/grpc/InternalChannelz.java @@ -186,7 +186,7 @@ public final class InternalChannelz { if (serverSockets == null) { return null; } - List socketList = new ArrayList(maxPageSize); + List socketList = new ArrayList<>(maxPageSize); Iterator> iterator = serverSockets.tailMap(fromId).values().iterator(); while (socketList.size() < maxPageSize && iterator.hasNext()) { @@ -504,7 +504,7 @@ public final class InternalChannelz { } public Builder setEvents(List events) { - this.events = Collections.unmodifiableList(new ArrayList(events)); + this.events = Collections.unmodifiableList(new ArrayList<>(events)); return this; } diff --git a/core/src/main/java/io/grpc/NameResolverProvider.java b/core/src/main/java/io/grpc/NameResolverProvider.java index ed9c281d3..f0b76ea70 100644 --- a/core/src/main/java/io/grpc/NameResolverProvider.java +++ b/core/src/main/java/io/grpc/NameResolverProvider.java @@ -101,7 +101,7 @@ public abstract class NameResolverProvider extends NameResolver.Factory { private final List providers; NameResolverFactory(List providers) { - this.providers = Collections.unmodifiableList(new ArrayList(providers)); + this.providers = Collections.unmodifiableList(new ArrayList<>(providers)); } @Override diff --git a/core/src/main/java/io/grpc/ServerInterceptors.java b/core/src/main/java/io/grpc/ServerInterceptors.java index d146ac03c..8f457554b 100644 --- a/core/src/main/java/io/grpc/ServerInterceptors.java +++ b/core/src/main/java/io/grpc/ServerInterceptors.java @@ -62,7 +62,7 @@ public final class ServerInterceptors { public static ServerServiceDefinition interceptForward( ServerServiceDefinition serviceDef, List interceptors) { - List copy = new ArrayList(interceptors); + List copy = new ArrayList<>(interceptors); Collections.reverse(copy); return intercept(serviceDef, copy); } diff --git a/core/src/main/java/io/grpc/ServiceProviders.java b/core/src/main/java/io/grpc/ServiceProviders.java index 367c10143..f776c4931 100644 --- a/core/src/main/java/io/grpc/ServiceProviders.java +++ b/core/src/main/java/io/grpc/ServiceProviders.java @@ -63,7 +63,7 @@ final class ServiceProviders { } else { candidates = getCandidatesViaServiceLoader(klass, cl); } - List list = new ArrayList(); + List list = new ArrayList<>(); for (T current: candidates) { if (!priorityAccessor.isAvailable(current)) { continue; @@ -115,7 +115,7 @@ final class ServiceProviders { */ @VisibleForTesting static Iterable getCandidatesViaHardCoded(Class klass, Iterable> hardcoded) { - List list = new ArrayList(); + List list = new ArrayList<>(); for (Class candidate : hardcoded) { list.add(create(klass, candidate)); } diff --git a/core/src/main/java/io/grpc/Status.java b/core/src/main/java/io/grpc/Status.java index 5e95c9884..27e13f091 100644 --- a/core/src/main/java/io/grpc/Status.java +++ b/core/src/main/java/io/grpc/Status.java @@ -238,7 +238,7 @@ public final class Status { + replaced.getCode().name() + " & " + code.name()); } } - return Collections.unmodifiableList(new ArrayList(canonicalizer.values())); + return Collections.unmodifiableList(new ArrayList<>(canonicalizer.values())); } // A pseudo-enum of Status instances mapped 1:1 with values in Code. This simplifies construction diff --git a/core/src/main/java/io/grpc/inprocess/InProcessTransport.java b/core/src/main/java/io/grpc/inprocess/InProcessTransport.java index 1c157f7ee..7cf1a89ba 100644 --- a/core/src/main/java/io/grpc/inprocess/InProcessTransport.java +++ b/core/src/main/java/io/grpc/inprocess/InProcessTransport.java @@ -207,7 +207,7 @@ final class InProcessTransport implements ServerTransport, ConnectionClientTrans if (terminated) { return; } - streamsCopy = new ArrayList(streams); + streamsCopy = new ArrayList<>(streams); } for (InProcessStream stream : streamsCopy) { stream.clientStream.cancel(reason); diff --git a/core/src/main/java/io/grpc/internal/AbstractManagedChannelImplBuilder.java b/core/src/main/java/io/grpc/internal/AbstractManagedChannelImplBuilder.java index ada5a2ba9..2f12574b8 100644 --- a/core/src/main/java/io/grpc/internal/AbstractManagedChannelImplBuilder.java +++ b/core/src/main/java/io/grpc/internal/AbstractManagedChannelImplBuilder.java @@ -97,7 +97,7 @@ public abstract class AbstractManagedChannelImplBuilder ObjectPool executorPool = DEFAULT_EXECUTOR_POOL; - private final List interceptors = new ArrayList(); + private final List interceptors = new ArrayList<>(); // Access via getter, which may perform authority override as needed private NameResolver.Factory nameResolverFactory = DEFAULT_NAME_RESOLVER_FACTORY; @@ -418,7 +418,7 @@ public abstract class AbstractManagedChannelImplBuilder @VisibleForTesting final List getEffectiveInterceptors() { List effectiveInterceptors = - new ArrayList(this.interceptors); + new ArrayList<>(this.interceptors); temporarilyDisableRetry = false; if (statsEnabled) { temporarilyDisableRetry = true; diff --git a/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java b/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java index 3e1b7afbe..72744d800 100644 --- a/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java +++ b/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java @@ -82,12 +82,12 @@ public abstract class AbstractServerImplBuilder transportFilters = - new ArrayList(); + new ArrayList<>(); - final List interceptors = new ArrayList(); + final List interceptors = new ArrayList<>(); private final List notifyOnBuildList = - new ArrayList(); + new ArrayList<>(); private final List streamTracerFactories = new ArrayList(); diff --git a/core/src/main/java/io/grpc/internal/ChannelTracer.java b/core/src/main/java/io/grpc/internal/ChannelTracer.java index 6e8fb92eb..be9f4a998 100644 --- a/core/src/main/java/io/grpc/internal/ChannelTracer.java +++ b/core/src/main/java/io/grpc/internal/ChannelTracer.java @@ -82,7 +82,7 @@ final class ChannelTracer { int eventsLoggedSnapshot; synchronized (lock) { eventsLoggedSnapshot = eventsLogged; - eventsSnapshot = new ArrayList(events); + eventsSnapshot = new ArrayList<>(events); } builder.setChannelTrace(new ChannelTrace.Builder() .setNumEventsLogged(eventsLoggedSnapshot) diff --git a/core/src/main/java/io/grpc/internal/ConnectivityStateManager.java b/core/src/main/java/io/grpc/internal/ConnectivityStateManager.java index 0a0ef91df..c67c5e76a 100644 --- a/core/src/main/java/io/grpc/internal/ConnectivityStateManager.java +++ b/core/src/main/java/io/grpc/internal/ConnectivityStateManager.java @@ -33,7 +33,7 @@ import javax.annotation.concurrent.NotThreadSafe; */ @NotThreadSafe final class ConnectivityStateManager { - private ArrayList listeners = new ArrayList(); + private ArrayList listeners = new ArrayList<>(); private volatile ConnectivityState state = ConnectivityState.IDLE; @@ -69,7 +69,7 @@ final class ConnectivityStateManager { // Swap out callback list before calling them, because a callback may register new callbacks, // if run in direct executor, can cause ConcurrentModificationException. ArrayList savedListeners = listeners; - listeners = new ArrayList(); + listeners = new ArrayList<>(); for (Listener listener : savedListeners) { listener.runInExecutor(); } diff --git a/core/src/main/java/io/grpc/internal/DelayedClientTransport.java b/core/src/main/java/io/grpc/internal/DelayedClientTransport.java index c768a95d4..dbe195ff8 100644 --- a/core/src/main/java/io/grpc/internal/DelayedClientTransport.java +++ b/core/src/main/java/io/grpc/internal/DelayedClientTransport.java @@ -281,9 +281,9 @@ final class DelayedClientTransport implements ManagedClientTransport { if (picker == null || !hasPendingStreams()) { return; } - toProcess = new ArrayList(pendingStreams); + toProcess = new ArrayList<>(pendingStreams); } - ArrayList toRemove = new ArrayList(); + ArrayList toRemove = new ArrayList<>(); for (final PendingStream stream : toProcess) { PickResult pickResult = picker.pickSubchannel(stream.args); diff --git a/core/src/main/java/io/grpc/internal/DelayedStream.java b/core/src/main/java/io/grpc/internal/DelayedStream.java index c52b5d92e..549e47d35 100644 --- a/core/src/main/java/io/grpc/internal/DelayedStream.java +++ b/core/src/main/java/io/grpc/internal/DelayedStream.java @@ -52,7 +52,7 @@ class DelayedStream implements ClientStream { @GuardedBy("this") private Status error; @GuardedBy("this") - private List pendingCalls = new ArrayList(); + private List pendingCalls = new ArrayList<>(); @GuardedBy("this") private DelayedStreamListener delayedListener; @@ -120,7 +120,7 @@ class DelayedStream implements ClientStream { private void drainPendingCalls() { assert realStream != null; assert !passThrough; - List toRun = new ArrayList(); + List toRun = new ArrayList<>(); DelayedStreamListener delayedListener = null; while (true) { synchronized (this) { @@ -367,7 +367,7 @@ class DelayedStream implements ClientStream { private final ClientStreamListener realListener; private volatile boolean passThrough; @GuardedBy("this") - private List pendingCallbacks = new ArrayList(); + private List pendingCallbacks = new ArrayList<>(); public DelayedStreamListener(ClientStreamListener listener) { this.realListener = listener; @@ -445,7 +445,7 @@ class DelayedStream implements ClientStream { public void drainPendingCallbacks() { assert !passThrough; - List toRun = new ArrayList(); + List toRun = new ArrayList<>(); while (true) { synchronized (this) { if (pendingCallbacks.isEmpty()) { diff --git a/core/src/main/java/io/grpc/internal/DnsNameResolver.java b/core/src/main/java/io/grpc/internal/DnsNameResolver.java index ac53a71a7..490bd8255 100644 --- a/core/src/main/java/io/grpc/internal/DnsNameResolver.java +++ b/core/src/main/java/io/grpc/internal/DnsNameResolver.java @@ -244,7 +244,7 @@ final class DnsNameResolver extends NameResolver { return; } // Each address forms an EAG - List servers = new ArrayList(); + List servers = new ArrayList<>(); for (InetAddress inetAddr : resolutionResults.addresses) { servers.add(new EquivalentAddressGroup(new InetSocketAddress(inetAddr, port))); } diff --git a/core/src/main/java/io/grpc/internal/InternalHandlerRegistry.java b/core/src/main/java/io/grpc/internal/InternalHandlerRegistry.java index faf2720cd..91f3311d6 100644 --- a/core/src/main/java/io/grpc/internal/InternalHandlerRegistry.java +++ b/core/src/main/java/io/grpc/internal/InternalHandlerRegistry.java @@ -73,7 +73,7 @@ final class InternalHandlerRegistry extends HandlerRegistry { } } return new InternalHandlerRegistry( - Collections.unmodifiableList(new ArrayList(services.values())), + Collections.unmodifiableList(new ArrayList<>(services.values())), Collections.unmodifiableMap(map)); } } diff --git a/core/src/main/java/io/grpc/internal/InternalSubchannel.java b/core/src/main/java/io/grpc/internal/InternalSubchannel.java index 31bee8471..879b7d873 100644 --- a/core/src/main/java/io/grpc/internal/InternalSubchannel.java +++ b/core/src/main/java/io/grpc/internal/InternalSubchannel.java @@ -125,8 +125,7 @@ final class InternalSubchannel implements InternalInstrumented { * also be present. */ @GuardedBy("lock") - private final Collection transports = - new ArrayList(); + private final Collection transports = new ArrayList<>(); // Must only be used from channelExecutor private final InUseStateAggregator inUseStateAggregator = @@ -172,7 +171,7 @@ final class InternalSubchannel implements InternalInstrumented { Preconditions.checkArgument(!addressGroups.isEmpty(), "addressGroups is empty"); checkListHasNoNulls(addressGroups, "addressGroups contains null entry"); this.addressIndex = new Index( - Collections.unmodifiableList(new ArrayList(addressGroups))); + Collections.unmodifiableList(new ArrayList<>(addressGroups))); this.authority = authority; this.userAgent = userAgent; this.backoffPolicyProvider = backoffPolicyProvider; @@ -352,7 +351,7 @@ final class InternalSubchannel implements InternalInstrumented { checkListHasNoNulls(newAddressGroups, "newAddressGroups contains null entry"); Preconditions.checkArgument(!newAddressGroups.isEmpty(), "newAddressGroups is empty"); newAddressGroups = - Collections.unmodifiableList(new ArrayList(newAddressGroups)); + Collections.unmodifiableList(new ArrayList<>(newAddressGroups)); ManagedClientTransport savedTransport = null; try { synchronized (lock) { diff --git a/core/src/main/java/io/grpc/internal/JndiResourceResolverFactory.java b/core/src/main/java/io/grpc/internal/JndiResourceResolverFactory.java index 998cfe6a9..b095266a0 100644 --- a/core/src/main/java/io/grpc/internal/JndiResourceResolverFactory.java +++ b/core/src/main/java/io/grpc/internal/JndiResourceResolverFactory.java @@ -116,7 +116,7 @@ final class JndiResourceResolverFactory implements DnsNameResolver.ResourceResol Level.FINER, "Found {0} TXT records", new Object[]{serviceConfigRawTxtRecords.size()}); } List serviceConfigTxtRecords = - new ArrayList(serviceConfigRawTxtRecords.size()); + new ArrayList<>(serviceConfigRawTxtRecords.size()); for (String serviceConfigRawTxtRecord : serviceConfigRawTxtRecords) { serviceConfigTxtRecords.add(unquote(serviceConfigRawTxtRecord)); } @@ -138,7 +138,7 @@ final class JndiResourceResolverFactory implements DnsNameResolver.ResourceResol Level.FINER, "Found {0} SRV records", new Object[]{grpclbSrvRecords.size()}); } List balancerAddresses = - new ArrayList(grpclbSrvRecords.size()); + new ArrayList<>(grpclbSrvRecords.size()); Exception first = null; Level level = Level.WARNING; for (String srvRecord : grpclbSrvRecords) { @@ -146,7 +146,7 @@ final class JndiResourceResolverFactory implements DnsNameResolver.ResourceResol SrvRecord record = parseSrvRecord(srvRecord); List addrs = addressResolver.resolveAddress(record.host); - List sockaddrs = new ArrayList(addrs.size()); + List sockaddrs = new ArrayList<>(addrs.size()); for (InetAddress addr : addrs) { sockaddrs.add(new InetSocketAddress(addr, record.port)); } @@ -199,7 +199,7 @@ final class JndiResourceResolverFactory implements DnsNameResolver.ResourceResol private static List getAllRecords(String recordType, String name) throws NamingException { String[] rrType = new String[]{recordType}; - List records = new ArrayList(); + List records = new ArrayList<>(); @SuppressWarnings("JdkObsolete") Hashtable env = new Hashtable(); diff --git a/core/src/main/java/io/grpc/internal/JsonParser.java b/core/src/main/java/io/grpc/internal/JsonParser.java index a3790e08d..c6daf2136 100644 --- a/core/src/main/java/io/grpc/internal/JsonParser.java +++ b/core/src/main/java/io/grpc/internal/JsonParser.java @@ -92,7 +92,7 @@ public final class JsonParser { private static List parseJsonArray(JsonReader jr) throws IOException { jr.beginArray(); - List array = new ArrayList(); + List array = new ArrayList<>(); while (jr.hasNext()) { Object value = parseRecursive(jr); array.add(value); diff --git a/core/src/main/java/io/grpc/internal/ManagedChannelImpl.java b/core/src/main/java/io/grpc/internal/ManagedChannelImpl.java index 579c68c3b..dc203b016 100644 --- a/core/src/main/java/io/grpc/internal/ManagedChannelImpl.java +++ b/core/src/main/java/io/grpc/internal/ManagedChannelImpl.java @@ -308,7 +308,7 @@ final class ManagedChannelImpl extends ManagedChannel implements channelTracer.updateBuilder(builder); } builder.setTarget(target).setState(channelStateManager.getState()); - List children = new ArrayList(); + List children = new ArrayList<>(); children.addAll(subchannels); children.addAll(oobChannels); builder.setSubchannels(children); @@ -963,7 +963,7 @@ final class ManagedChannelImpl extends ManagedChannel implements Collection streams; synchronized (lock) { - streams = new ArrayList(uncommittedRetriableStreams); + streams = new ArrayList<>(uncommittedRetriableStreams); } for (ClientStream stream : streams) { diff --git a/core/src/main/java/io/grpc/internal/MessageFramer.java b/core/src/main/java/io/grpc/internal/MessageFramer.java index 1512d9f89..dfac24e79 100644 --- a/core/src/main/java/io/grpc/internal/MessageFramer.java +++ b/core/src/main/java/io/grpc/internal/MessageFramer.java @@ -381,7 +381,7 @@ public class MessageFramer implements Framer { * {@link OutputStream}. */ private final class BufferChainOutputStream extends OutputStream { - private final List bufferList = new ArrayList(); + private final List bufferList = new ArrayList<>(); private WritableBuffer current; /** diff --git a/core/src/main/java/io/grpc/internal/RetriableStream.java b/core/src/main/java/io/grpc/internal/RetriableStream.java index 563434bc7..cde86356e 100644 --- a/core/src/main/java/io/grpc/internal/RetriableStream.java +++ b/core/src/main/java/io/grpc/internal/RetriableStream.java @@ -220,7 +220,7 @@ abstract class RetriableStream implements ClientStream { int stop = Math.min(index + chunk, savedState.buffer.size()); if (list == null) { - list = new ArrayList(savedState.buffer.subList(index, stop)); + list = new ArrayList<>(savedState.buffer.subList(index, stop)); } else { list.clear(); list.addAll(savedState.buffer.subList(index, stop)); @@ -761,7 +761,7 @@ abstract class RetriableStream implements ClientStream { // optimize for 0-retry, which is most of the cases. drainedSubstreams = Collections.singletonList(substream); } else { - drainedSubstreams = new ArrayList(this.drainedSubstreams); + drainedSubstreams = new ArrayList<>(this.drainedSubstreams); drainedSubstreams.add(substream); drainedSubstreams = Collections.unmodifiableCollection(drainedSubstreams); } @@ -784,7 +784,7 @@ abstract class RetriableStream implements ClientStream { State substreamClosed(Substream substream) { substream.closed = true; if (this.drainedSubstreams.contains(substream)) { - Collection drainedSubstreams = new ArrayList(this.drainedSubstreams); + Collection drainedSubstreams = new ArrayList<>(this.drainedSubstreams); drainedSubstreams.remove(substream); drainedSubstreams = Collections.unmodifiableCollection(drainedSubstreams); return new State(buffer, drainedSubstreams, winningSubstream, cancelled, passThrough); diff --git a/core/src/main/java/io/grpc/internal/ServerImpl.java b/core/src/main/java/io/grpc/internal/ServerImpl.java index 55c5f6644..b4c29c792 100644 --- a/core/src/main/java/io/grpc/internal/ServerImpl.java +++ b/core/src/main/java/io/grpc/internal/ServerImpl.java @@ -139,7 +139,7 @@ public final class ServerImpl extends io.grpc.Server implements InternalInstrume this.decompressorRegistry = builder.decompressorRegistry; this.compressorRegistry = builder.compressorRegistry; this.transportFilters = Collections.unmodifiableList( - new ArrayList(builder.transportFilters)); + new ArrayList<>(builder.transportFilters)); this.interceptors = builder.interceptors.toArray(new ServerInterceptor[builder.interceptors.size()]); this.handshakeTimeoutMillis = builder.handshakeTimeoutMillis; @@ -188,7 +188,7 @@ public final class ServerImpl extends io.grpc.Server implements InternalInstrume List registryServices = registry.getServices(); int servicesCount = registryServices.size() + fallbackServices.size(); List services = - new ArrayList(servicesCount); + new ArrayList<>(servicesCount); services.addAll(registryServices); services.addAll(fallbackServices); return Collections.unmodifiableList(services); @@ -241,7 +241,7 @@ public final class ServerImpl extends io.grpc.Server implements InternalInstrume return this; } shutdownNowStatus = nowStatus; - transportsCopy = new ArrayList(transports); + transportsCopy = new ArrayList<>(transports); savedServerShutdownCallbackInvoked = serverShutdownCallbackInvoked; } // Short-circuiting not strictly necessary, but prevents transports from needing to handle @@ -343,7 +343,7 @@ public final class ServerImpl extends io.grpc.Server implements InternalInstrume synchronized (lock) { // transports collection can be modified during shutdown(), even if we hold the lock, due // to reentrancy. - copiedTransports = new ArrayList(transports); + copiedTransports = new ArrayList<>(transports); shutdownNowStatusCopy = shutdownNowStatus; serverShutdownCallbackInvoked = true; } diff --git a/core/src/main/java/io/grpc/internal/StatsTraceContext.java b/core/src/main/java/io/grpc/internal/StatsTraceContext.java index 8021a9722..52c2666d4 100644 --- a/core/src/main/java/io/grpc/internal/StatsTraceContext.java +++ b/core/src/main/java/io/grpc/internal/StatsTraceContext.java @@ -85,7 +85,7 @@ public final class StatsTraceContext { */ @VisibleForTesting public List getTracersForTest() { - return new ArrayList(Arrays.asList(tracers)); + return new ArrayList<>(Arrays.asList(tracers)); } /** diff --git a/core/src/main/java/io/grpc/util/MutableHandlerRegistry.java b/core/src/main/java/io/grpc/util/MutableHandlerRegistry.java index 4eaafbac2..a068cdccf 100644 --- a/core/src/main/java/io/grpc/util/MutableHandlerRegistry.java +++ b/core/src/main/java/io/grpc/util/MutableHandlerRegistry.java @@ -79,7 +79,7 @@ public final class MutableHandlerRegistry extends HandlerRegistry { @Override @ExperimentalApi("https://github.com/grpc/grpc-java/issues/2222") public List getServices() { - return Collections.unmodifiableList(new ArrayList(services.values())); + return Collections.unmodifiableList(new ArrayList<>(services.values())); } /** diff --git a/core/src/main/java/io/grpc/util/RoundRobinLoadBalancerFactory.java b/core/src/main/java/io/grpc/util/RoundRobinLoadBalancerFactory.java index 2e6e5e053..e46c5e575 100644 --- a/core/src/main/java/io/grpc/util/RoundRobinLoadBalancerFactory.java +++ b/core/src/main/java/io/grpc/util/RoundRobinLoadBalancerFactory.java @@ -273,7 +273,7 @@ public final class RoundRobinLoadBalancerFactory extends LoadBalancer.Factory { */ private static List filterNonFailingSubchannels( Collection subchannels) { - List readySubchannels = new ArrayList(subchannels.size()); + List readySubchannels = new ArrayList<>(subchannels.size()); for (Subchannel subchannel : subchannels) { if (isReady(subchannel)) { readySubchannels.add(subchannel); diff --git a/core/src/test/java/io/grpc/ClientInterceptorsTest.java b/core/src/test/java/io/grpc/ClientInterceptorsTest.java index 755b3a0b5..a71b6c774 100644 --- a/core/src/test/java/io/grpc/ClientInterceptorsTest.java +++ b/core/src/test/java/io/grpc/ClientInterceptorsTest.java @@ -130,7 +130,7 @@ public class ClientInterceptorsTest { @Test public void ordered() { - final List order = new ArrayList(); + final List order = new ArrayList<>(); channel = new Channel() { @SuppressWarnings("unchecked") @Override @@ -172,7 +172,7 @@ public class ClientInterceptorsTest { @Test public void orderedForward() { - final List order = new ArrayList(); + final List order = new ArrayList<>(); channel = new Channel() { @SuppressWarnings("unchecked") @Override @@ -267,7 +267,7 @@ public class ClientInterceptorsTest { @Test public void examineInboundHeaders() { - final List examinedHeaders = new ArrayList(); + final List examinedHeaders = new ArrayList<>(); ClientInterceptor interceptor = new ClientInterceptor() { @Override public ClientCall interceptCall( @@ -423,8 +423,8 @@ public class ClientInterceptorsTest { private boolean done; private ClientCall.Listener listener; private Metadata headers; - private List requests = new ArrayList(); - private List messages = new ArrayList(); + private List requests = new ArrayList<>(); + private List messages = new ArrayList<>(); private boolean halfClosed; private Throwable cancelCause; private String cancelMessage; diff --git a/core/src/test/java/io/grpc/ContextsTest.java b/core/src/test/java/io/grpc/ContextsTest.java index d2dc23394..4a4ae3500 100644 --- a/core/src/test/java/io/grpc/ContextsTest.java +++ b/core/src/test/java/io/grpc/ContextsTest.java @@ -55,7 +55,7 @@ public class ContextsTest { public void interceptCall_basic() { Context origContext = Context.current(); final Object message = new Object(); - final List methodCalls = new ArrayList(); + final List methodCalls = new ArrayList<>(); final ServerCall.Listener listener = new ServerCall.Listener() { @Override public void onMessage(Object messageIn) { assertSame(message, messageIn); diff --git a/core/src/test/java/io/grpc/ServerInterceptorsTest.java b/core/src/test/java/io/grpc/ServerInterceptorsTest.java index 992fe8f75..e34c9df28 100644 --- a/core/src/test/java/io/grpc/ServerInterceptorsTest.java +++ b/core/src/test/java/io/grpc/ServerInterceptorsTest.java @@ -184,7 +184,7 @@ public class ServerInterceptorsTest { @Test public void ordered() { - final List order = new ArrayList(); + final List order = new ArrayList<>(); handler = new ServerCallHandler() { @Override public ServerCall.Listener startCall( @@ -226,7 +226,7 @@ public class ServerInterceptorsTest { @Test public void orderedForward() { - final List order = new ArrayList(); + final List order = new ArrayList<>(); handler = new ServerCallHandler() { @Override public ServerCall.Listener startCall( @@ -296,7 +296,7 @@ public class ServerInterceptorsTest { @Test @SuppressWarnings("unchecked") public void typedMarshalledMessages() { - final List order = new ArrayList(); + final List order = new ArrayList<>(); Marshaller marshaller = new Marshaller() { @Override public InputStream stream(Holder value) { diff --git a/core/src/test/java/io/grpc/internal/DnsNameResolverTest.java b/core/src/test/java/io/grpc/internal/DnsNameResolverTest.java index b8ec6ed97..44bde2222 100644 --- a/core/src/test/java/io/grpc/internal/DnsNameResolverTest.java +++ b/core/src/test/java/io/grpc/internal/DnsNameResolverTest.java @@ -533,7 +533,7 @@ public class DnsNameResolverTest { @Test public void maybeChooseServiceConfig_clientLanguageMatchesJava() { Map choice = new LinkedHashMap(); - List langs = new ArrayList(); + List langs = new ArrayList<>(); langs.add("java"); choice.put("clientLanguage", langs); choice.put("serviceConfig", serviceConfig); @@ -544,7 +544,7 @@ public class DnsNameResolverTest { @Test public void maybeChooseServiceConfig_clientLanguageDoesntMatchGo() { Map choice = new LinkedHashMap(); - List langs = new ArrayList(); + List langs = new ArrayList<>(); langs.add("go"); choice.put("clientLanguage", langs); choice.put("serviceConfig", serviceConfig); @@ -555,7 +555,7 @@ public class DnsNameResolverTest { @Test public void maybeChooseServiceConfig_clientLanguageCaseInsensitive() { Map choice = new LinkedHashMap(); - List langs = new ArrayList(); + List langs = new ArrayList<>(); langs.add("JAVA"); choice.put("clientLanguage", langs); choice.put("serviceConfig", serviceConfig); @@ -566,7 +566,7 @@ public class DnsNameResolverTest { @Test public void maybeChooseServiceConfig_clientLanguageMatchesEmtpy() { Map choice = new LinkedHashMap(); - List langs = new ArrayList(); + List langs = new ArrayList<>(); choice.put("clientLanguage", langs); choice.put("serviceConfig", serviceConfig); @@ -576,7 +576,7 @@ public class DnsNameResolverTest { @Test public void maybeChooseServiceConfig_clientLanguageMatchesMulti() { Map choice = new LinkedHashMap(); - List langs = new ArrayList(); + List langs = new ArrayList<>(); langs.add("go"); langs.add("java"); choice.put("clientLanguage", langs); @@ -702,7 +702,7 @@ public class DnsNameResolverTest { @Test public void maybeChooseServiceConfig_hostnameMatches() { Map choice = new LinkedHashMap(); - List hosts = new ArrayList(); + List hosts = new ArrayList<>(); hosts.add("localhost"); choice.put("clientHostname", hosts); choice.put("serviceConfig", serviceConfig); @@ -713,7 +713,7 @@ public class DnsNameResolverTest { @Test public void maybeChooseServiceConfig_hostnameDoesntMatch() { Map choice = new LinkedHashMap(); - List hosts = new ArrayList(); + List hosts = new ArrayList<>(); hosts.add("localhorse"); choice.put("clientHostname", hosts); choice.put("serviceConfig", serviceConfig); @@ -724,7 +724,7 @@ public class DnsNameResolverTest { @Test public void maybeChooseServiceConfig_clientLanguageCaseSensitive() { Map choice = new LinkedHashMap(); - List hosts = new ArrayList(); + List hosts = new ArrayList<>(); hosts.add("LOCALHOST"); choice.put("clientHostname", hosts); choice.put("serviceConfig", serviceConfig); @@ -735,7 +735,7 @@ public class DnsNameResolverTest { @Test public void maybeChooseServiceConfig_hostnameMatchesEmtpy() { Map choice = new LinkedHashMap(); - List hosts = new ArrayList(); + List hosts = new ArrayList<>(); choice.put("clientHostname", hosts); choice.put("serviceConfig", serviceConfig); @@ -745,7 +745,7 @@ public class DnsNameResolverTest { @Test public void maybeChooseServiceConfig_hostnameMatchesMulti() { Map choice = new LinkedHashMap(); - List hosts = new ArrayList(); + List hosts = new ArrayList<>(); hosts.add("localhorse"); hosts.add("localhost"); choice.put("clientHostname", hosts); @@ -773,7 +773,7 @@ public class DnsNameResolverTest { private byte lastByte = 0; private List createAddressList(int n) throws UnknownHostException { - List list = new ArrayList(n); + List list = new ArrayList<>(n); for (int i = 0; i < n; i++) { list.add(InetAddress.getByAddress(new byte[] {127, 0, 0, ++lastByte})); } diff --git a/core/src/test/java/io/grpc/internal/FakeClock.java b/core/src/test/java/io/grpc/internal/FakeClock.java index 706a7d3b3..38936e087 100644 --- a/core/src/test/java/io/grpc/internal/FakeClock.java +++ b/core/src/test/java/io/grpc/internal/FakeClock.java @@ -233,7 +233,7 @@ public final class FakeClock { * Return all due tasks. */ public Collection getDueTasks() { - ArrayList result = new ArrayList(); + ArrayList result = new ArrayList<>(); for (ScheduledTask task : tasks) { if (task.dueTimeNanos > currentTimeNanos) { continue; @@ -254,7 +254,7 @@ public final class FakeClock { * Return all unrun tasks accepted by the given filter. */ public Collection getPendingTasks(TaskFilter filter) { - ArrayList result = new ArrayList(); + ArrayList result = new ArrayList<>(); for (ScheduledTask task : tasks) { if (filter.shouldAccept(task.command)) { result.add(task); diff --git a/core/src/test/java/io/grpc/internal/JsonParserTest.java b/core/src/test/java/io/grpc/internal/JsonParserTest.java index 5e690c9c2..7ffeeb807 100644 --- a/core/src/test/java/io/grpc/internal/JsonParserTest.java +++ b/core/src/test/java/io/grpc/internal/JsonParserTest.java @@ -45,7 +45,7 @@ public class JsonParserTest { @Test public void emptyArray() throws IOException { - assertEquals(new ArrayList(), JsonParser.parse("[]")); + assertEquals(new ArrayList<>(), JsonParser.parse("[]")); } @Test diff --git a/core/src/test/java/io/grpc/internal/ManagedChannelImplIdlenessTest.java b/core/src/test/java/io/grpc/internal/ManagedChannelImplIdlenessTest.java index 9e2ae7a7a..d0ced5faa 100644 --- a/core/src/test/java/io/grpc/internal/ManagedChannelImplIdlenessTest.java +++ b/core/src/test/java/io/grpc/internal/ManagedChannelImplIdlenessTest.java @@ -327,7 +327,7 @@ public class ManagedChannelImplIdlenessTest { MockClientTransportInfo t0 = newTransports.poll(); t0.listener.transportReady(); - List changedList = new ArrayList(servers.get(0).getAddresses()); + List changedList = new ArrayList<>(servers.get(0).getAddresses()); changedList.add(new FakeSocketAddress("aDifferentServer")); helper.updateSubchannelAddresses(subchannel, new EquivalentAddressGroup(changedList)); @@ -417,7 +417,7 @@ public class ManagedChannelImplIdlenessTest { MockClientTransportInfo t0 = newTransports.poll(); t0.listener.transportReady(); - List changedList = new ArrayList(servers.get(0).getAddresses()); + List changedList = new ArrayList<>(servers.get(0).getAddresses()); changedList.add(new FakeSocketAddress("aDifferentServer")); helper.updateOobChannelAddresses(oobChannel, new EquivalentAddressGroup(changedList)); diff --git a/core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java b/core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java index 9f1d784c9..ffc92b1bf 100644 --- a/core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java +++ b/core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java @@ -2188,7 +2188,7 @@ public class ManagedChannelImplTest { public void channelTracing_nameResolvedEvent_zeorAndNonzeroBackends() throws Exception { timer.forwardNanos(1234); channelBuilder.maxTraceEvents(10); - List servers = new ArrayList(); + List servers = new ArrayList<>(); servers.add(new EquivalentAddressGroup(socketAddress)); FakeNameResolverFactory nameResolverFactory = new FakeNameResolverFactory.Builder(expectedUri).setServers(servers).build(); @@ -2222,7 +2222,7 @@ public class ManagedChannelImplTest { public void channelTracing_serviceConfigChange() throws Exception { timer.forwardNanos(1234); channelBuilder.maxTraceEvents(10); - List servers = new ArrayList(); + List servers = new ArrayList<>(); servers.add(new EquivalentAddressGroup(socketAddress)); FakeNameResolverFactory nameResolverFactory = new FakeNameResolverFactory.Builder(expectedUri).setServers(servers).build(); @@ -2836,7 +2836,7 @@ public class ManagedChannelImplTest { final List servers; final boolean resolvedAtStart; final Status error; - final ArrayList resolvers = new ArrayList(); + final ArrayList resolvers = new ArrayList<>(); // The Attributes argument of the next invocation of listener.onAddresses(servers, attrs) final AtomicReference nextResolvedAttributes = new AtomicReference(Attributes.EMPTY); diff --git a/core/src/test/java/io/grpc/internal/ManagedChannelOrphanWrapperTest.java b/core/src/test/java/io/grpc/internal/ManagedChannelOrphanWrapperTest.java index 3873256ac..9f9dc276e 100644 --- a/core/src/test/java/io/grpc/internal/ManagedChannelOrphanWrapperTest.java +++ b/core/src/test/java/io/grpc/internal/ManagedChannelOrphanWrapperTest.java @@ -57,7 +57,7 @@ public final class ManagedChannelOrphanWrapperTest { // Try to capture the log output but without causing terminal noise. Adding the filter must // be done before clearing the ref or else it might be missed. - final List records = new ArrayList(1); + final List records = new ArrayList<>(1); Logger orphanLogger = Logger.getLogger(ManagedChannelOrphanWrapper.class.getName()); Filter oldFilter = orphanLogger.getFilter(); orphanLogger.setFilter(new Filter() { diff --git a/core/src/test/java/io/grpc/internal/RetriableStreamTest.java b/core/src/test/java/io/grpc/internal/RetriableStreamTest.java index 289430f5a..fc13d10a2 100644 --- a/core/src/test/java/io/grpc/internal/RetriableStreamTest.java +++ b/core/src/test/java/io/grpc/internal/RetriableStreamTest.java @@ -745,7 +745,7 @@ public class RetriableStreamTest { public void isReady_whileDraining() { final AtomicReference sublistenerCaptor1 = new AtomicReference(); - final List readiness = new ArrayList(); + final List readiness = new ArrayList<>(); ClientStream mockStream1 = mock( ClientStream.class, diff --git a/core/src/test/java/io/grpc/internal/SerializeReentrantCallsDirectExecutorTest.java b/core/src/test/java/io/grpc/internal/SerializeReentrantCallsDirectExecutorTest.java index 8f89fea64..493f79c4b 100644 --- a/core/src/test/java/io/grpc/internal/SerializeReentrantCallsDirectExecutorTest.java +++ b/core/src/test/java/io/grpc/internal/SerializeReentrantCallsDirectExecutorTest.java @@ -40,7 +40,7 @@ public class SerializeReentrantCallsDirectExecutorTest { } @Test public void reentrantCallsShouldBeSerialized() { - final List callOrder = new ArrayList(4); + final List callOrder = new ArrayList<>(4); executor.execute(new Runnable() { @Override public void run() { @@ -105,7 +105,7 @@ public class SerializeReentrantCallsDirectExecutorTest { @Test public void executeCanBeRepeated() { - final List executes = new ArrayList(); + final List executes = new ArrayList<>(); executor.execute(new Runnable() { @Override public void run() { diff --git a/core/src/test/java/io/grpc/internal/SerializingExecutorTest.java b/core/src/test/java/io/grpc/internal/SerializingExecutorTest.java index fe3f5666f..55f408192 100644 --- a/core/src/test/java/io/grpc/internal/SerializingExecutorTest.java +++ b/core/src/test/java/io/grpc/internal/SerializingExecutorTest.java @@ -35,7 +35,7 @@ import org.junit.runners.JUnit4; public class SerializingExecutorTest { private SingleExecutor singleExecutor = new SingleExecutor(); private SerializingExecutor executor = new SerializingExecutor(singleExecutor); - private List runs = new ArrayList(); + private List runs = new ArrayList<>(); private class AddToRuns implements Runnable { private final int val; diff --git a/core/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java b/core/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java index aea42c98f..fdca3b339 100644 --- a/core/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java +++ b/core/src/test/java/io/grpc/util/RoundRobinLoadBalancerTest.java @@ -675,7 +675,7 @@ public class RoundRobinLoadBalancerTest { assertEquals(sc2, loadBalancer.getStickinessMapForTest().get("my-sticky-value").value); // shutdown channel via name resolver change - List newServers = new ArrayList(servers); + List newServers = new ArrayList<>(servers); newServers.remove(sc2.getAddresses()); loadBalancer.handleResolvedAddressGroups(newServers, attributes); diff --git a/cronet/src/main/java/io/grpc/cronet/CronetCallOptions.java b/cronet/src/main/java/io/grpc/cronet/CronetCallOptions.java index 46f002804..d361d0b4d 100644 --- a/cronet/src/main/java/io/grpc/cronet/CronetCallOptions.java +++ b/cronet/src/main/java/io/grpc/cronet/CronetCallOptions.java @@ -51,9 +51,9 @@ public final class CronetCallOptions { Collection existingAnnotations = callOptions.getOption(CRONET_ANNOTATIONS_KEY); ArrayList newAnnotations; if (existingAnnotations == null) { - newAnnotations = new ArrayList(); + newAnnotations = new ArrayList<>(); } else { - newAnnotations = new ArrayList(existingAnnotations); + newAnnotations = new ArrayList<>(existingAnnotations); } newAnnotations.add(annotation); return callOptions.withOption( diff --git a/cronet/src/main/java/io/grpc/cronet/CronetClientStream.java b/cronet/src/main/java/io/grpc/cronet/CronetClientStream.java index de0bc629b..b9a8a43b2 100644 --- a/cronet/src/main/java/io/grpc/cronet/CronetClientStream.java +++ b/cronet/src/main/java/io/grpc/cronet/CronetClientStream.java @@ -504,7 +504,7 @@ class CronetClientStream extends AbstractClientStream { private void reportHeaders(List> headers, boolean endOfStream) { // TODO(ericgribkoff): create new utility methods to eliminate all these conversions - List headerList = new ArrayList(); + List headerList = new ArrayList<>(); for (Map.Entry entry : headers) { headerList.add(entry.getKey()); headerList.add(entry.getValue()); diff --git a/cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java b/cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java index 63190e714..38b871d33 100644 --- a/cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java +++ b/cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java @@ -188,7 +188,7 @@ class CronetClientTransport implements ConnectionClientTransport { synchronized (lock) { // A copy is always necessary since cancel() can call finishStream() which calls // streams.remove() - streamsCopy = new ArrayList(streams); + streamsCopy = new ArrayList<>(streams); } for (int i = 0; i < streamsCopy.size(); i++) { // Avoid deadlock by calling into stream without lock held diff --git a/examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptorTest.java b/examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptorTest.java index 4fd5bdb0c..63e8a3290 100644 --- a/examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptorTest.java +++ b/examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptorTest.java @@ -79,7 +79,7 @@ public class SafeMethodCachingInterceptorTest { } }; - private final List cacheControlDirectives = new ArrayList(); + private final List cacheControlDirectives = new ArrayList<>(); private ServerInterceptor injectCacheControlInterceptor = new ServerInterceptor() { @Override diff --git a/examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java b/examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java index 1a223bf04..f892057fe 100644 --- a/examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java +++ b/examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java @@ -261,7 +261,7 @@ public class RouteGuideActivity extends AppCompatActivity { @Override public String run(RouteGuideBlockingStub blockingStub, RouteGuideStub asyncStub) throws Exception { - List points = new ArrayList(); + List points = new ArrayList<>(); points.add(Point.newBuilder().setLatitude(407838351).setLongitude(-746143763).build()); points.add(Point.newBuilder().setLatitude(408122808).setLongitude(-743999179).build()); points.add(Point.newBuilder().setLatitude(413628156).setLongitude(-749015468).build()); diff --git a/examples/src/test/java/io/grpc/examples/routeguide/RouteGuideClientTest.java b/examples/src/test/java/io/grpc/examples/routeguide/RouteGuideClientTest.java index 8900b52ba..9f9b04daf 100644 --- a/examples/src/test/java/io/grpc/examples/routeguide/RouteGuideClientTest.java +++ b/examples/src/test/java/io/grpc/examples/routeguide/RouteGuideClientTest.java @@ -254,7 +254,7 @@ public class RouteGuideClientTest { Feature.newBuilder().setLocation(point3).build(); final List features = Arrays.asList( requestFeature1, requestFeature2, requestFeature3); - final List pointsDelivered = new ArrayList(); + final List pointsDelivered = new ArrayList<>(); final RouteSummary fakeResponse = RouteSummary .newBuilder() .setPointCount(7) @@ -357,8 +357,8 @@ public class RouteGuideClientTest { public void routeChat_simpleResponse() throws Exception { RouteNote fakeResponse1 = RouteNote.newBuilder().setMessage("dummy msg1").build(); RouteNote fakeResponse2 = RouteNote.newBuilder().setMessage("dummy msg2").build(); - final List messagesDelivered = new ArrayList(); - final List locationsDelivered = new ArrayList(); + final List messagesDelivered = new ArrayList<>(); + final List locationsDelivered = new ArrayList<>(); final AtomicReference> responseObserverRef = new AtomicReference>(); final CountDownLatch allRequestsDelivered = new CountDownLatch(1); @@ -428,7 +428,7 @@ public class RouteGuideClientTest { */ @Test public void routeChat_echoResponse() throws Exception { - final List notesDelivered = new ArrayList(); + final List notesDelivered = new ArrayList<>(); // implement the fake service RouteGuideImplBase routeChatImpl = @@ -476,7 +476,7 @@ public class RouteGuideClientTest { */ @Test public void routeChat_errorResponse() throws Exception { - final List notesDelivered = new ArrayList(); + final List notesDelivered = new ArrayList<>(); final StatusRuntimeException fakeError = new StatusRuntimeException(Status.PERMISSION_DENIED); // implement the fake service diff --git a/examples/src/test/java/io/grpc/examples/routeguide/RouteGuideServerTest.java b/examples/src/test/java/io/grpc/examples/routeguide/RouteGuideServerTest.java index 09543ec5e..cd6ee1f11 100644 --- a/examples/src/test/java/io/grpc/examples/routeguide/RouteGuideServerTest.java +++ b/examples/src/test/java/io/grpc/examples/routeguide/RouteGuideServerTest.java @@ -68,7 +68,7 @@ public class RouteGuideServerTest { public void setUp() throws Exception { // Generate a unique in-process server name. String serverName = InProcessServerBuilder.generateName(); - features = new ArrayList(); + features = new ArrayList<>(); // Use directExecutor for both InProcessServerBuilder and InProcessChannelBuilder can reduce the // usage timeouts and latches in test. But we still add timeout and latches where they would be // needed if no directExecutor were used, just for demo purpose. diff --git a/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java b/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java index 4d069c0b7..a97b2ded9 100644 --- a/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java +++ b/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java @@ -87,8 +87,8 @@ class GrpclbLoadBalancer extends LoadBalancer implements InternalWithLogId { public void handleResolvedAddressGroups( List updatedServers, Attributes attributes) { // LB addresses and backend addresses are treated separately - List newLbAddressGroups = new ArrayList(); - List newBackendServers = new ArrayList(); + List newLbAddressGroups = new ArrayList<>(); + List newBackendServers = new ArrayList<>(); for (EquivalentAddressGroup server : updatedServers) { String lbAddrAuthority = server.getAttributes().get(GrpcAttributes.ATTR_LB_ADDR_AUTHORITY); if (lbAddrAuthority != null) { diff --git a/grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java b/grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java index bf170cd9a..95ad81341 100644 --- a/grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java +++ b/grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java @@ -238,8 +238,8 @@ final class GrpclbState { usingFallbackBackends = true; logger.log(Level.INFO, "[{0}] Using fallback: {1}", new Object[] {logId, fallbackBackendList}); - List newDropList = new ArrayList(); - List newBackendAddrList = new ArrayList(); + List newDropList = new ArrayList<>(); + List newBackendAddrList = new ArrayList<>(); for (EquivalentAddressGroup eag : fallbackBackendList) { newDropList.add(null); newBackendAddrList.add(new BackendAddressGroup(eag, null)); @@ -348,7 +348,7 @@ final class GrpclbState { new Object[] {logId, newBackendAddrList, newDropList}); HashMap newSubchannelMap = new HashMap(); - List newBackendList = new ArrayList(); + List newBackendList = new ArrayList<>(); for (BackendAddressGroup backendAddr : newBackendAddrList) { EquivalentAddressGroup eag = backendAddr.getAddresses(); @@ -572,8 +572,8 @@ final class GrpclbState { balancerWorking = true; // TODO(zhangkun83): handle delegate from initialResponse ServerList serverList = response.getServerList(); - List newDropList = new ArrayList(); - List newBackendAddrList = new ArrayList(); + List newDropList = new ArrayList<>(); + List newBackendAddrList = new ArrayList<>(); // Construct the new collections. Create new Subchannels when necessary. for (Server server : serverList.getServersList()) { String token = server.getLoadBalanceToken(); @@ -673,7 +673,7 @@ final class GrpclbState { * changed since the last picker created. */ private void maybeUpdatePicker() { - List pickList = new ArrayList(backendList.size()); + List pickList = new ArrayList<>(backendList.size()); Status error = null; boolean hasIdle = false; for (BackendEntry entry : backendList) { @@ -728,7 +728,7 @@ final class GrpclbState { private LbAddressGroup flattenLbAddressGroups(List groupList) { assert !groupList.isEmpty(); - List eags = new ArrayList(groupList.size()); + List eags = new ArrayList<>(groupList.size()); String authority = groupList.get(0).getAuthority(); for (LbAddressGroup group : groupList) { if (!authority.equals(group.getAuthority())) { @@ -758,7 +758,7 @@ final class GrpclbState { */ private static EquivalentAddressGroup flattenEquivalentAddressGroup( List groupList, Attributes attrs) { - List addrs = new ArrayList(); + List addrs = new ArrayList<>(); for (EquivalentAddressGroup group : groupList) { addrs.addAll(group.getAddresses()); } diff --git a/grpclb/src/test/java/io/grpc/grpclb/CachedSubchannelPoolTest.java b/grpclb/src/test/java/io/grpc/grpclb/CachedSubchannelPoolTest.java index 62f8c6c97..9c5151f39 100644 --- a/grpclb/src/test/java/io/grpc/grpclb/CachedSubchannelPoolTest.java +++ b/grpclb/src/test/java/io/grpc/grpclb/CachedSubchannelPoolTest.java @@ -70,7 +70,7 @@ public class CachedSubchannelPoolTest { private final Helper helper = mock(Helper.class); private final FakeClock clock = new FakeClock(); private final CachedSubchannelPool pool = new CachedSubchannelPool(); - private final ArrayList mockSubchannels = new ArrayList(); + private final ArrayList mockSubchannels = new ArrayList<>(); @Before public void setUp() { diff --git a/grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java b/grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java index 60027b9e0..e54052810 100644 --- a/grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java +++ b/grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java @@ -150,9 +150,9 @@ public class GrpclbLoadBalancerTest { new LinkedList>(); private final LinkedList mockSubchannels = new LinkedList(); private final LinkedList fakeOobChannels = new LinkedList(); - private final ArrayList subchannelTracker = new ArrayList(); - private final ArrayList oobChannelTracker = new ArrayList(); - private final ArrayList failingLbAuthorities = new ArrayList(); + private final ArrayList subchannelTracker = new ArrayList<>(); + private final ArrayList oobChannelTracker = new ArrayList<>(); + private final ArrayList failingLbAuthorities = new ArrayList<>(); private final TimeProvider timeProvider = new TimeProvider() { @Override public long currentTimeNanos() { @@ -1305,8 +1305,8 @@ public class GrpclbLoadBalancerTest { private List fallbackTestVerifyUseOfBalancerBackendLists( InOrder inOrder, List servers) { - ArrayList addrs = new ArrayList(); - ArrayList tokens = new ArrayList(); + ArrayList addrs = new ArrayList<>(); + ArrayList tokens = new ArrayList<>(); for (ServerEntry server : servers) { addrs.add(new EquivalentAddressGroup(server.addr, LB_BACKEND_ATTRS)); tokens.add(server.token); @@ -1327,7 +1327,7 @@ public class GrpclbLoadBalancerTest { assertThat(picker.dropList).containsExactlyElementsIn(Collections.nCopies(addrs.size(), null)); assertThat(picker.pickList).containsExactly(GrpclbState.BUFFER_ENTRY); assertEquals(addrs.size(), mockSubchannels.size()); - ArrayList subchannels = new ArrayList(mockSubchannels); + ArrayList subchannels = new ArrayList<>(mockSubchannels); mockSubchannels.clear(); for (Subchannel subchannel : subchannels) { deliverSubchannelState(subchannel, ConnectivityStateInfo.forNonError(CONNECTING)); @@ -1337,7 +1337,7 @@ public class GrpclbLoadBalancerTest { inOrder.verify(helper, never()) .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); - ArrayList pickList = new ArrayList(); + ArrayList pickList = new ArrayList<>(); for (int i = 0; i < addrs.size(); i++) { Subchannel subchannel = subchannels.get(i); BackendEntry backend; @@ -1521,7 +1521,7 @@ public class GrpclbLoadBalancerTest { } private static List createResolvedServerAddresses(boolean ... isLb) { - ArrayList list = new ArrayList(); + ArrayList list = new ArrayList<>(); for (int i = 0; i < isLb.length; i++) { SocketAddress addr = new FakeSocketAddress("fake-address-" + i); EquivalentAddressGroup eag = diff --git a/interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java b/interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java index 544994695..ac724f618 100644 --- a/interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java +++ b/interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java @@ -824,7 +824,7 @@ public abstract class AbstractInteropTest { final int numRequests = 10; List requests = - new ArrayList(numRequests); + new ArrayList<>(numRequests); for (int ix = numRequests; ix > 0; --ix) { requests.add(request); requestStream.onNext(request); @@ -863,7 +863,7 @@ public abstract class AbstractInteropTest { final int numRequests = 10; List requests = - new ArrayList(numRequests); + new ArrayList<>(numRequests); for (int ix = numRequests; ix > 0; --ix) { requests.add(request); requestStream.onNext(request); @@ -1030,7 +1030,7 @@ public abstract class AbstractInteropTest { final int numRequests = 10; List requests = - new ArrayList(numRequests); + new ArrayList<>(numRequests); for (int ix = numRequests; ix > 0; --ix) { requests.add(request); diff --git a/interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java b/interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java index ad7b6aa27..edf6b7ce3 100644 --- a/interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java +++ b/interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java @@ -282,7 +282,7 @@ public final class Http2Client { private class RstStreamObserver implements StreamObserver { private final CountDownLatch latch = new CountDownLatch(1); - private final List responses = new ArrayList(); + private final List responses = new ArrayList<>(); private Throwable error; @Override diff --git a/interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java b/interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java index a213f440a..62f182528 100644 --- a/interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java +++ b/interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java @@ -97,7 +97,7 @@ public class StressTestClient { private List addresses = singletonList(new InetSocketAddress("localhost", 8080)); - private List testCaseWeightPairs = new ArrayList(); + private List testCaseWeightPairs = new ArrayList<>(); private String serverHostOverride; private boolean useTls = false; @@ -118,7 +118,7 @@ public class StressTestClient { */ private final List> workerFutures = new ArrayList>(); - private final List channels = new ArrayList(); + private final List channels = new ArrayList<>(); private ListeningExecutorService threadpool; @VisibleForTesting @@ -291,7 +291,7 @@ public class StressTestClient { } private List parseServerAddresses(String addressesStr) { - List addresses = new ArrayList(); + List addresses = new ArrayList<>(); for (List namePort : parseCommaSeparatedTuples(addressesStr)) { InetAddress address; @@ -313,7 +313,7 @@ public class StressTestClient { } private static List parseTestCases(String testCasesStr) { - List testCaseWeightPairs = new ArrayList(); + List testCaseWeightPairs = new ArrayList<>(); for (List nameWeight : parseCommaSeparatedTuples(testCasesStr)) { TestCases testCase = TestCases.fromString(nameWeight.get(0)); @@ -355,7 +355,7 @@ public class StressTestClient { } private static String serverAddressesToString(List addresses) { - List tmp = new ArrayList(); + List tmp = new ArrayList<>(); for (InetSocketAddress address : addresses) { URI uri; try { @@ -541,7 +541,7 @@ public class StressTestClient { Preconditions.checkNotNull(testCaseWeightPairs, "testCaseWeightPairs"); Preconditions.checkArgument(testCaseWeightPairs.size() > 0); - List testCases = new ArrayList(); + List testCases = new ArrayList<>(); for (TestCaseWeightPair testCaseWeightPair : testCaseWeightPairs) { for (int i = 0; i < testCaseWeightPair.weight; i++) { testCases.add(testCaseWeightPair.testCase); diff --git a/netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java b/netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java index e59c33645..920afca0c 100644 --- a/netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java +++ b/netty/src/main/java/io/grpc/netty/GrpcHttp2HeadersUtils.java @@ -132,7 +132,7 @@ class GrpcHttp2HeadersUtils { @Override public List getAll(CharSequence csName) { AsciiString name = requireAsciiString(csName); - List returnValues = new ArrayList(4); + List returnValues = new ArrayList<>(4); for (int i = 0; i < namesAndValuesIdx; i += 2) { if (equals(name, namesAndValues[i])) { returnValues.add(values[i / 2]); diff --git a/netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java b/netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java index e48715324..682af1b9e 100644 --- a/netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java +++ b/netty/src/test/java/io/grpc/netty/NettyClientTransportTest.java @@ -104,7 +104,7 @@ public class NettyClientTransportTest { @Mock private ManagedClientTransport.Listener clientTransportListener; - private final List transports = new ArrayList(); + private final List transports = new ArrayList<>(); private final NioEventLoopGroup group = new NioEventLoopGroup(1); private final EchoServerListener serverListener = new EchoServerListener(); private final InternalChannelz channelz = new InternalChannelz(); @@ -236,7 +236,7 @@ public class NettyClientTransportTest { } // Send a single RPC on each transport. - final List rpcs = new ArrayList(transports.size()); + final List rpcs = new ArrayList<>(transports.size()); for (NettyClientTransport transport : transports) { rpcs.add(new Rpc(transport).halfClose()); } @@ -750,7 +750,7 @@ public class NettyClientTransportTest { } private static final class EchoServerListener implements ServerListener { - final List transports = new ArrayList(); + final List transports = new ArrayList<>(); final List streamListeners = Collections.synchronizedList(new ArrayList()); diff --git a/okhttp/src/main/java/io/grpc/okhttp/Headers.java b/okhttp/src/main/java/io/grpc/okhttp/Headers.java index 23167914a..cb71846eb 100644 --- a/okhttp/src/main/java/io/grpc/okhttp/Headers.java +++ b/okhttp/src/main/java/io/grpc/okhttp/Headers.java @@ -58,7 +58,7 @@ class Headers { headers.discardAll(GrpcUtil.USER_AGENT_KEY); // 7 is the number of explicit add calls below. - List
okhttpHeaders = new ArrayList
(7 + InternalMetadata.headerCount(headers)); + List
okhttpHeaders = new ArrayList<>(7 + InternalMetadata.headerCount(headers)); // Set GRPC-specific headers. okhttpHeaders.add(SCHEME_HEADER); diff --git a/okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java b/okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java index 5f43ad965..116fc0b07 100644 --- a/okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java +++ b/okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java @@ -1938,7 +1938,7 @@ public class OkHttpClientTransportTest { Metadata trailers; RpcProgress rpcProgress; CountDownLatch closed = new CountDownLatch(1); - ArrayList messages = new ArrayList(); + ArrayList messages = new ArrayList<>(); boolean onReadyCalled; MockStreamListener() { diff --git a/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/OkHostnameVerifier.java b/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/OkHostnameVerifier.java index b7b1d5367..8b108c74a 100644 --- a/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/OkHostnameVerifier.java +++ b/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/OkHostnameVerifier.java @@ -123,14 +123,14 @@ public final class OkHostnameVerifier implements HostnameVerifier { public static List allSubjectAltNames(X509Certificate certificate) { List altIpaNames = getSubjectAltNames(certificate, ALT_IPA_NAME); List altDnsNames = getSubjectAltNames(certificate, ALT_DNS_NAME); - List result = new ArrayList(altIpaNames.size() + altDnsNames.size()); + List result = new ArrayList<>(altIpaNames.size() + altDnsNames.size()); result.addAll(altIpaNames); result.addAll(altDnsNames); return result; } private static List getSubjectAltNames(X509Certificate certificate, int type) { - List result = new ArrayList(); + List result = new ArrayList<>(); try { Collection subjectAltNames = certificate.getSubjectAlternativeNames(); if (subjectAltNames == null) { diff --git a/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Platform.java b/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Platform.java index d6f88ba0e..51244c902 100644 --- a/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Platform.java +++ b/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Platform.java @@ -449,7 +449,7 @@ public class Platform { public void configureTlsExtensions( SSLSocket sslSocket, String hostname, List protocols) { SSLParameters parameters = sslSocket.getSSLParameters(); - List names = new ArrayList(protocols.size()); + List names = new ArrayList<>(protocols.size()); for (Protocol protocol : protocols) { if (protocol == Protocol.HTTP_1_0) continue; // No HTTP/1.0 for ALPN. names.add(protocol.toString()); @@ -505,7 +505,7 @@ public class Platform { @Override public void configureTlsExtensions( SSLSocket sslSocket, String hostname, List protocols) { - List names = new ArrayList(protocols.size()); + List names = new ArrayList<>(protocols.size()); for (int i = 0, size = protocols.size(); i < size; i++) { Protocol protocol = protocols.get(i); if (protocol == Protocol.HTTP_1_0) continue; // No HTTP/1.0 for ALPN. diff --git a/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Util.java b/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Util.java index bee316970..a0e668fd8 100644 --- a/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Util.java +++ b/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Util.java @@ -212,7 +212,7 @@ public final class Util { /** Returns an immutable copy of {@code list}. */ public static List immutableList(List list) { - return Collections.unmodifiableList(new ArrayList(list)); + return Collections.unmodifiableList(new ArrayList<>(list)); } /** Returns an immutable list containing {@code elements}. */ @@ -250,7 +250,7 @@ public final class Util { * {@code second}. The returned elements are in the same order as in {@code first}. */ private static List intersect(T[] first, T[] second) { - List result = new ArrayList(); + List result = new ArrayList<>(); for (T a : first) { for (T b : second) { if (a.equals(b)) { diff --git a/okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java b/okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java index 143ad5fb6..9c919e9fb 100644 --- a/okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java +++ b/okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java @@ -35,7 +35,7 @@ import static org.junit.Assert.fail; public class HpackTest { private static List
headerEntries(String... elements) { - List
result = new ArrayList
(elements.length / 2); + List
result = new ArrayList<>(elements.length / 2); for (int i = 0; i < elements.length; i += 2) { result.add(new Header(elements[i], elements[i + 1])); } diff --git a/services/src/main/java/io/grpc/services/ChannelzProtoUtil.java b/services/src/main/java/io/grpc/services/ChannelzProtoUtil.java index 3ee47e445..a1ada8fe5 100644 --- a/services/src/main/java/io/grpc/services/ChannelzProtoUtil.java +++ b/services/src/main/java/io/grpc/services/ChannelzProtoUtil.java @@ -323,7 +323,7 @@ final class ChannelzProtoUtil { static List toSocketOptionsList(InternalChannelz.SocketOptions options) { Preconditions.checkNotNull(options); - List ret = new ArrayList(); + List ret = new ArrayList<>(); if (options.lingerSeconds != null) { ret.add(toSocketOptionLinger(options.lingerSeconds)); } @@ -379,7 +379,7 @@ final class ChannelzProtoUtil { } private static List toChannelTraceEvents(List events) { - List channelTraceEvents = new ArrayList(); + List channelTraceEvents = new ArrayList<>(); for (Event event : events) { ChannelTraceEvent.Builder builder = ChannelTraceEvent.newBuilder() .setDescription(event.description) diff --git a/services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java b/services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java index 81e384f87..5e608029e 100644 --- a/services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java +++ b/services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java @@ -589,7 +589,7 @@ public class ProtoReflectionServiceTest { private static class FlowControlClientResponseObserver implements ClientResponseObserver { private final List responses = - new ArrayList(); + new ArrayList<>(); private boolean onCompleteCalled = false; @Override diff --git a/services/src/test/java/io/grpc/services/BinaryLogProviderTest.java b/services/src/test/java/io/grpc/services/BinaryLogProviderTest.java index c34519da4..8e8703085 100644 --- a/services/src/test/java/io/grpc/services/BinaryLogProviderTest.java +++ b/services/src/test/java/io/grpc/services/BinaryLogProviderTest.java @@ -146,7 +146,7 @@ public class BinaryLogProviderTest { }; Channel wChannel = binlogProvider.wrapChannel(channel); ClientCall clientCall = wChannel.newCall(method, CallOptions.DEFAULT); - final List observedResponse = new ArrayList(); + final List observedResponse = new ArrayList<>(); clientCall.start( new NoopClientCall.NoopClientCallListener() { @Override @@ -224,7 +224,7 @@ public class BinaryLogProviderTest { @Test public void wrapMethodDefinition_handler() throws Exception { // The request as seen by the user supplied server code - final List observedRequest = new ArrayList(); + final List observedRequest = new ArrayList<>(); final AtomicReference> serverCall = new AtomicReference>(); ServerMethodDefinition methodDef = @@ -244,7 +244,7 @@ public class BinaryLogProviderTest { } }); ServerMethodDefinition wDef = binlogProvider.wrapMethodDefinition(methodDef); - List serializedResp = new ArrayList(); + List serializedResp = new ArrayList<>(); ServerCall.Listener wListener = startServerCallHelper(wDef, serializedResp); String expectedRequest = "hello world"; diff --git a/stub/src/test/java/io/grpc/stub/ClientCallsTest.java b/stub/src/test/java/io/grpc/stub/ClientCallsTest.java index 91076b17f..91ca89a59 100644 --- a/stub/src/test/java/io/grpc/stub/ClientCallsTest.java +++ b/stub/src/test/java/io/grpc/stub/ClientCallsTest.java @@ -244,7 +244,7 @@ public class ClientCallsTest { throws Exception { final AtomicReference> listener = new AtomicReference>(); - final List requests = new ArrayList(); + final List requests = new ArrayList<>(); NoopClientCall call = new NoopClientCall() { @Override public void start(io.grpc.ClientCall.Listener responseListener, Metadata headers) { @@ -305,7 +305,7 @@ public class ClientCallsTest { }; final AtomicReference> listener = new AtomicReference>(); - final List requests = new ArrayList(); + final List requests = new ArrayList<>(); NoopClientCall call = new NoopClientCall() { @Override public void start(io.grpc.ClientCall.Listener responseListener, Metadata headers) { @@ -351,7 +351,7 @@ public class ClientCallsTest { }; final AtomicReference> listener = new AtomicReference>(); - final List requests = new ArrayList(); + final List requests = new ArrayList<>(); NoopClientCall call = new NoopClientCall() { @Override public void start(io.grpc.ClientCall.Listener responseListener, Metadata headers) { @@ -407,7 +407,7 @@ public class ClientCallsTest { final ClientCall clientCall = channel.newCall(STREAMING_METHOD, CallOptions.DEFAULT); final CountDownLatch latch = new CountDownLatch(1); - final List receivedMessages = new ArrayList(6); + final List receivedMessages = new ArrayList<>(6); ClientResponseObserver responseObserver = new ClientResponseObserver() { @@ -449,7 +449,7 @@ public class ClientCallsTest { @Test public void inprocessTransportOutboundFlowControl() throws Exception { final Semaphore semaphore = new Semaphore(0); - final List receivedMessages = new ArrayList(6); + final List receivedMessages = new ArrayList<>(6); final SettableFuture> observerFuture = SettableFuture.create(); ServerServiceDefinition service = ServerServiceDefinition.builder( diff --git a/stub/src/test/java/io/grpc/stub/ServerCallsTest.java b/stub/src/test/java/io/grpc/stub/ServerCallsTest.java index 5101aa87a..a3d12d322 100644 --- a/stub/src/test/java/io/grpc/stub/ServerCallsTest.java +++ b/stub/src/test/java/io/grpc/stub/ServerCallsTest.java @@ -461,8 +461,8 @@ public class ServerCallsTest { private static class ServerCallRecorder extends ServerCall { private final MethodDescriptor methodDescriptor; - private final List requestCalls = new ArrayList(); - private final List responses = new ArrayList(); + private final List requestCalls = new ArrayList<>(); + private final List responses = new ArrayList<>(); private Metadata headers; private Metadata trailers; private Status status; diff --git a/testing/src/main/java/io/grpc/internal/testing/TestUtils.java b/testing/src/main/java/io/grpc/internal/testing/TestUtils.java index e7524671c..9a01b6a88 100644 --- a/testing/src/main/java/io/grpc/internal/testing/TestUtils.java +++ b/testing/src/main/java/io/grpc/internal/testing/TestUtils.java @@ -90,7 +90,7 @@ public class TestUtils { } catch (NoSuchAlgorithmException ex) { throw new RuntimeException(ex); } - List ciphersMinusGcm = new ArrayList(); + List ciphersMinusGcm = new ArrayList<>(); for (String cipher : ciphers) { // The GCM implementation in Java is _very_ slow (~1 MB/s) if (cipher.contains("_GCM_")) { diff --git a/testing/src/main/java/io/grpc/testing/GrpcCleanupRule.java b/testing/src/main/java/io/grpc/testing/GrpcCleanupRule.java index 541bd73dd..82a986f77 100644 --- a/testing/src/main/java/io/grpc/testing/GrpcCleanupRule.java +++ b/testing/src/main/java/io/grpc/testing/GrpcCleanupRule.java @@ -47,7 +47,7 @@ import org.junit.runners.model.Statement; @NotThreadSafe public final class GrpcCleanupRule implements TestRule { - private final List resources = new ArrayList(); + private final List resources = new ArrayList<>(); private long timeoutNanos = TimeUnit.SECONDS.toNanos(10L); private Stopwatch stopwatch = Stopwatch.createUnstarted(); diff --git a/testing/src/main/java/io/grpc/testing/TestUtils.java b/testing/src/main/java/io/grpc/testing/TestUtils.java index 19333bbbd..15de4cfed 100644 --- a/testing/src/main/java/io/grpc/testing/TestUtils.java +++ b/testing/src/main/java/io/grpc/testing/TestUtils.java @@ -78,7 +78,7 @@ public class TestUtils { } catch (NoSuchAlgorithmException ex) { throw new RuntimeException(ex); } - List ciphersMinusGcm = new ArrayList(); + List ciphersMinusGcm = new ArrayList<>(); for (String cipher : ciphers) { // The GCM implementation in Java is _very_ slow (~1 MB/s) if (cipher.contains("_GCM_")) { -- cgit v1.2.3