From 2f155606b8aa2548420ced9bd8033861fdb2562a Mon Sep 17 00:00:00 2001 From: zpencer Date: Wed, 15 Nov 2017 11:49:13 -0800 Subject: core,netty: add ID to NettyServer (#3745) These are already WithLogId: ManagedChannelImpl, InternalSubchannel, ServerTransport --- netty/src/main/java/io/grpc/netty/NettyServer.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) (limited to 'netty') diff --git a/netty/src/main/java/io/grpc/netty/NettyServer.java b/netty/src/main/java/io/grpc/netty/NettyServer.java index 12e7179d2..6fb594ad2 100644 --- a/netty/src/main/java/io/grpc/netty/NettyServer.java +++ b/netty/src/main/java/io/grpc/netty/NettyServer.java @@ -23,10 +23,12 @@ import static io.netty.channel.ChannelOption.SO_KEEPALIVE; import io.grpc.ServerStreamTracer; import io.grpc.internal.InternalServer; +import io.grpc.internal.LogId; import io.grpc.internal.ServerListener; import io.grpc.internal.ServerTransportListener; import io.grpc.internal.SharedResourceHolder; import io.grpc.internal.TransportTracer; +import io.grpc.internal.WithLogId; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.Channel; import io.netty.channel.ChannelFuture; @@ -48,9 +50,10 @@ import javax.annotation.Nullable; /** * Netty-based server implementation. */ -class NettyServer implements InternalServer { +class NettyServer implements InternalServer, WithLogId { private static final Logger log = Logger.getLogger(InternalServer.class.getName()); + private final LogId logId = LogId.allocate(getClass().getName()); private final SocketAddress address; private final Class channelType; private final ProtocolNegotiator protocolNegotiator; @@ -218,6 +221,11 @@ class NettyServer implements InternalServer { } } + @Override + public LogId getLogId() { + return logId; + } + class EventLoopReferenceCounter extends AbstractReferenceCounted { @Override protected void deallocate() { -- cgit v1.2.3