From d0d946ec9f0176a6971f4ffec5f206eb2dd7b5eb Mon Sep 17 00:00:00 2001 From: Carl Mastrangelo Date: Mon, 18 Apr 2016 16:21:53 -0700 Subject: [PATCH] new name --- core/src/main/java/io/grpc/inprocess/InProcessServer.java | 4 ++-- .../java/io/grpc/internal/AbstractServerImplBuilder.java | 4 ++-- .../{TransportServer.java => InternalServer.java} | 2 +- core/src/main/java/io/grpc/internal/ServerImpl.java | 4 ++-- core/src/main/java/io/grpc/internal/ServerListener.java | 2 +- .../java/io/grpc/inprocess/InProcessTransportTest.java | 4 ++-- core/src/test/java/io/grpc/internal/ServerImplTest.java | 2 +- netty/src/main/java/io/grpc/netty/NettyServer.java | 6 +++--- netty/src/test/java/io/grpc/netty/NettyTransportTest.java | 4 ++-- .../io/grpc/internal/testing/AbstractTransportTest.java | 8 ++++---- 10 files changed, 20 insertions(+), 20 deletions(-) rename core/src/main/java/io/grpc/internal/{TransportServer.java => InternalServer.java} (98%) diff --git a/core/src/main/java/io/grpc/inprocess/InProcessServer.java b/core/src/main/java/io/grpc/inprocess/InProcessServer.java index 98a99516d1..0dabae7148 100644 --- a/core/src/main/java/io/grpc/inprocess/InProcessServer.java +++ b/core/src/main/java/io/grpc/inprocess/InProcessServer.java @@ -31,9 +31,9 @@ package io.grpc.inprocess; +import io.grpc.internal.InternalServer; import io.grpc.internal.ServerListener; import io.grpc.internal.ServerTransportListener; -import io.grpc.internal.TransportServer; import java.io.IOException; import java.util.concurrent.ConcurrentHashMap; @@ -42,7 +42,7 @@ import java.util.concurrent.ConcurrentMap; import javax.annotation.concurrent.ThreadSafe; @ThreadSafe -class InProcessServer implements TransportServer { +class InProcessServer implements InternalServer { private static final ConcurrentMap registry = new ConcurrentHashMap(); diff --git a/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java b/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java index c700e452f7..0f528abd37 100644 --- a/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java +++ b/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java @@ -138,7 +138,7 @@ public abstract class AbstractServerImplBuilder channelType; diff --git a/netty/src/test/java/io/grpc/netty/NettyTransportTest.java b/netty/src/test/java/io/grpc/netty/NettyTransportTest.java index 7b23ec70fa..b50cab77a7 100644 --- a/netty/src/test/java/io/grpc/netty/NettyTransportTest.java +++ b/netty/src/test/java/io/grpc/netty/NettyTransportTest.java @@ -32,8 +32,8 @@ package io.grpc.netty; import io.grpc.internal.ClientTransportFactory; +import io.grpc.internal.InternalServer; import io.grpc.internal.ManagedClientTransport; -import io.grpc.internal.TransportServer; import io.grpc.internal.testing.AbstractTransportTest; import io.grpc.testing.TestUtils; @@ -65,7 +65,7 @@ public class NettyTransportTest extends AbstractTransportTest { } @Override - protected TransportServer newServer() { + protected InternalServer newServer() { return NettyServerBuilder .forPort(SERVER_PORT) .flowControlWindow(65 * 1024) diff --git a/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java b/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java index e1a5488434..a011254c22 100644 --- a/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java +++ b/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java @@ -58,13 +58,13 @@ import io.grpc.Status; import io.grpc.internal.ClientStream; import io.grpc.internal.ClientStreamListener; import io.grpc.internal.ClientTransport; +import io.grpc.internal.InternalServer; import io.grpc.internal.ManagedClientTransport; import io.grpc.internal.ServerListener; import io.grpc.internal.ServerStream; import io.grpc.internal.ServerStreamListener; import io.grpc.internal.ServerTransport; import io.grpc.internal.ServerTransportListener; -import io.grpc.internal.TransportServer; import org.junit.After; import org.junit.Before; @@ -99,7 +99,7 @@ public abstract class AbstractTransportTest { * returned instance should be new and yet be accessible by new client transports. This * effectively means that each instance should listen on the same port, or similar. */ - protected abstract TransportServer newServer(); + protected abstract InternalServer newServer(); /** * Returns a new transport that when started will be able to connect to the server. @@ -111,7 +111,7 @@ public abstract class AbstractTransportTest { * {@code serverListener}, otherwise tearDown() can't wait for shutdown which can put following * tests in an indeterminate state. */ - private TransportServer server; + private InternalServer server; private ServerTransport serverTransport; private ManagedClientTransport client; private MethodDescriptor methodDescriptor = MethodDescriptor.create( @@ -215,7 +215,7 @@ public abstract class AbstractTransportTest { public void serverAlreadyListening() throws Exception { client = null; server.start(serverListener); - TransportServer server2 = newServer(); + InternalServer server2 = newServer(); thrown.expect(IOException.class); server2.start(new MockServerListener()); }