aboutsummaryrefslogtreecommitdiff
path: root/testing
diff options
context:
space:
mode:
authorzpencer <spencerfang@google.com>2018-03-30 08:48:37 -0700
committerGitHub <noreply@github.com>2018-03-30 08:48:37 -0700
commit7c37f1d32b9dc11027ff1ba946303f5a11dbfe00 (patch)
tree8323666a75669ee53e6740a78069539e309beda1 /testing
parent2a95e3825753a455810a93890c36348e7815b4f9 (diff)
downloadgrpc-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.java10
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"));
}
/**