diff options
author | zpencer <spencerfang@google.com> | 2018-03-30 08:48:37 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-03-30 08:48:37 -0700 |
commit | 7c37f1d32b9dc11027ff1ba946303f5a11dbfe00 (patch) | |
tree | 8323666a75669ee53e6740a78069539e309beda1 /testing | |
parent | 2a95e3825753a455810a93890c36348e7815b4f9 (diff) | |
download | grpc-grpc-java-7c37f1d32b9dc11027ff1ba946303f5a11dbfe00.tar.gz |
core,netty,okhttp,services: expose socket options to channelz (#4228)
For okhttp, expose the standard options from the Socket object.
For netty, expose all the `io.netty.channel.ChannelOption`s of the
`channel.config()`.
Diffstat (limited to 'testing')
-rw-r--r-- | testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java | 10 |
1 files changed, 7 insertions, 3 deletions
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 778475ac2..d69d2d527 100644 --- a/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java +++ b/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java @@ -80,7 +80,6 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import org.junit.After; import org.junit.Before; -import org.junit.Ignore; import org.junit.Rule; import org.junit.Test; import org.junit.rules.ExpectedException; @@ -1693,9 +1692,8 @@ public abstract class AbstractTransportTest { serverStream.close(Status.OK, new Metadata()); } - @Ignore("hardcoding 127.0.0.1 fails in ipv6") @Test - public void socketStats_addresses() throws Exception { + public void socketStats() throws Exception { server.start(serverListener); ManagedClientTransport client = newClientTransport(server); startTransport(client, mockClientTransportListener); @@ -1715,10 +1713,16 @@ public abstract class AbstractTransportTest { SocketStats clientSocketStats = client.getStats().get(); assertEquals(clientAddress, clientSocketStats.local); assertEquals(serverAddress, clientSocketStats.remote); + // very basic sanity check that socket options are populated + assertNotNull(clientSocketStats.socketOptions.lingerSeconds); + assertTrue(clientSocketStats.socketOptions.others.containsKey("SO_SNDBUF")); SocketStats serverSocketStats = serverTransportListener.transport.getStats().get(); assertEquals(serverAddress, serverSocketStats.local); assertEquals(clientAddress, serverSocketStats.remote); + // very basic sanity check that socket options are populated + assertNotNull(serverSocketStats.socketOptions.lingerSeconds); + assertTrue(serverSocketStats.socketOptions.others.containsKey("SO_SNDBUF")); } /** |