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

all: add toString() to Server to improve debug info

This commit is contained in:
ZHANG Dapeng 2018-04-13 09:41:09 -07:00 committed by GitHub
parent 0eafb8e9ca
commit a6811d5bb1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 30 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
alts/src/main/java/io/grpc/alts/AltsServerBuilder.java
View File

@ -16,6 +16,7 @@
package io.grpc.alts; package io.grpc.alts;
import com.google.common.base.MoreObjects;
import io.grpc.BindableService; import io.grpc.BindableService;
import io.grpc.CompressorRegistry; import io.grpc.CompressorRegistry;
import io.grpc.DecompressorRegistry; import io.grpc.DecompressorRegistry;
@ -248,5 +249,10 @@ public final class AltsServerBuilder extends ServerBuilder<AltsServerBuilder> {
public void awaitTermination() throws InterruptedException { public void awaitTermination() throws InterruptedException {
delegate.awaitTermination(); delegate.awaitTermination();
} }
@Override
public String toString() {
return MoreObjects.toStringHelper(this).add("delegate", delegate).toString();
}
} }
} }

6
core/src/main/java/io/grpc/inprocess/InProcessServer.java
View File

@ -18,6 +18,7 @@ package io.grpc.inprocess;
import static com.google.common.base.Preconditions.checkNotNull; import static com.google.common.base.Preconditions.checkNotNull;
import com.google.common.base.MoreObjects;
import io.grpc.ServerStreamTracer; import io.grpc.ServerStreamTracer;
import io.grpc.internal.Channelz.SocketStats; import io.grpc.internal.Channelz.SocketStats;
import io.grpc.internal.Instrumented; import io.grpc.internal.Instrumented;
@ -95,6 +96,11 @@ final class InProcessServer implements InternalServer {
} }
} }
@Override
public String toString() {
return MoreObjects.toStringHelper(this).add("name", name).toString();
}
synchronized ServerTransportListener register(InProcessTransport transport) { synchronized ServerTransportListener register(InProcessTransport transport) {
if (shutdown) { if (shutdown) {
return null; return null;

9
core/src/main/java/io/grpc/internal/ServerImpl.java
View File

@ -25,6 +25,7 @@ import static io.grpc.internal.GrpcUtil.TIMEOUT_KEY;
import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.NANOSECONDS;
import com.google.common.annotations.VisibleForTesting; import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.MoreObjects;
import com.google.common.base.Preconditions; import com.google.common.base.Preconditions;
import com.google.common.util.concurrent.ListenableFuture; import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.SettableFuture; import com.google.common.util.concurrent.SettableFuture;
@ -580,6 +581,14 @@ public final class ServerImpl extends io.grpc.Server implements Instrumented<Ser
return ret; return ret;
} }
@Override
public String toString() {
return MoreObjects.toStringHelper(this)
.add("logId", logId)
.add("transportServer", transportServer)
.toString();
}
private static final class NoopListener implements ServerStreamListener { private static final class NoopListener implements ServerStreamListener {
@Override @Override
public void messagesAvailable(MessageProducer producer) { public void messagesAvailable(MessageProducer producer) {

9
netty/src/main/java/io/grpc/netty/NettyServer.java
View File

@ -21,6 +21,7 @@ import static io.grpc.netty.NettyServerBuilder.MAX_CONNECTION_AGE_NANOS_DISABLED
import static io.netty.channel.ChannelOption.SO_BACKLOG; import static io.netty.channel.ChannelOption.SO_BACKLOG;
import static io.netty.channel.ChannelOption.SO_KEEPALIVE; import static io.netty.channel.ChannelOption.SO_KEEPALIVE;
import com.google.common.base.MoreObjects;
import com.google.common.base.Preconditions; import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableList;
import com.google.common.util.concurrent.ListenableFuture; import com.google.common.util.concurrent.ListenableFuture;
@ -304,6 +305,14 @@ class NettyServer implements InternalServer, WithLogId {
return logId; return logId;
} }
@Override
public String toString() {
return MoreObjects.toStringHelper(this)
.add("logId", logId)
.add("address", address)
.toString();
}
class EventLoopReferenceCounter extends AbstractReferenceCounted { class EventLoopReferenceCounter extends AbstractReferenceCounted {
@Override @Override
protected void deallocate() { protected void deallocate() {