diff --git a/core/src/test/java/io/grpc/inprocess/InProcessServerTest.java b/core/src/test/java/io/grpc/inprocess/InProcessServerTest.java deleted file mode 100644 index 541c4f69857..00000000000 --- a/core/src/test/java/io/grpc/inprocess/InProcessServerTest.java +++ /dev/null @@ -1,80 +0,0 @@ -/* - * Copyright 2016 The gRPC Authors - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package io.grpc.inprocess; - -import com.google.common.truth.Truth; -import io.grpc.ServerStreamTracer; -import io.grpc.internal.FakeClock; -import io.grpc.internal.ObjectPool; -import io.grpc.internal.ServerListener; -import io.grpc.internal.ServerTransport; -import io.grpc.internal.ServerTransportListener; -import java.util.Collections; -import java.util.concurrent.ScheduledExecutorService; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.junit.runners.JUnit4; - -@RunWith(JUnit4.class) -public class InProcessServerTest { - private InProcessServerBuilder builder = InProcessServerBuilder.forName("name"); - - @Test - public void getPort_notStarted() throws Exception { - InProcessServer s = - new InProcessServer(builder, Collections.emptyList()); - - Truth.assertThat(s.getListenSocketAddress()).isEqualTo(new InProcessSocketAddress("name")); - } - - @Test - public void serverHoldsRefToScheduler() throws Exception { - final ScheduledExecutorService ses = new FakeClock().getScheduledExecutorService(); - class RefCountingObjectPool implements ObjectPool { - private int count; - - @Override - public ScheduledExecutorService getObject() { - count++; - return ses; - } - - @Override - public ScheduledExecutorService returnObject(Object returned) { - count--; - return null; - } - } - - RefCountingObjectPool pool = new RefCountingObjectPool(); - builder.schedulerPool = pool; - InProcessServer s = - new InProcessServer(builder, Collections.emptyList()); - Truth.assertThat(pool.count).isEqualTo(0); - s.start(new ServerListener() { - @Override public ServerTransportListener transportCreated(ServerTransport transport) { - throw new UnsupportedOperationException(); - } - - @Override public void serverShutdown() {} - }); - Truth.assertThat(pool.count).isEqualTo(1); - s.shutdown(); - Truth.assertThat(pool.count).isEqualTo(0); - } -} - diff --git a/testing/src/main/java/io/grpc/testing/FakeNameResolverProvider.java b/testing/src/main/java/io/grpc/testing/FakeNameResolverProvider.java index efad08ebf3f..60ecacc05f1 100644 --- a/testing/src/main/java/io/grpc/testing/FakeNameResolverProvider.java +++ b/testing/src/main/java/io/grpc/testing/FakeNameResolverProvider.java @@ -33,10 +33,6 @@ /** A name resolver to always resolve the given URI into the given address. */ public final class FakeNameResolverProvider extends NameResolverProvider { - private final URI targetUri; - private final SocketAddress address; - - /** * Register a new resolver. * @@ -48,6 +44,9 @@ public static final void register(String targetUri, SocketAddress address) { new FakeNameResolverProvider(URI.create(targetUri), address)); } + private final URI targetUri; + private final SocketAddress address; + private FakeNameResolverProvider(URI targetUri, SocketAddress address) { this.targetUri = targetUri; this.address = address;