diff options
author | zpencer <spencerfang@google.com> | 2018-03-08 16:57:12 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-03-08 16:57:12 -0800 |
commit | 921b668ad5a0ad08471630921c3b45f77fcf8ecc (patch) | |
tree | 9af6171c1ae62b2912ba2f265d4510ec6b7b8b77 /testing | |
parent | f0eb6d2102c5d09e887c1eefd563985c1d702273 (diff) | |
download | grpc-grpc-java-921b668ad5a0ad08471630921c3b45f77fcf8ecc.tar.gz |
core,netty,okhttp,testing: separate local vs remote stream start times for channelz (#4194)
The channelz spec states that the two must be separate.
Diffstat (limited to 'testing')
-rw-r--r-- | testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java | 18 |
1 files changed, 9 insertions, 9 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 487df35cb..e165a4694 100644 --- a/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java +++ b/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java @@ -1409,10 +1409,10 @@ public abstract class AbstractTransportTest { { TransportStats serverBefore = getTransportStats(serverTransportListener.transport); assertEquals(0, serverBefore.streamsStarted); - assertEquals(0, serverBefore.lastStreamCreatedTimeNanos); + assertEquals(0, serverBefore.lastRemoteStreamCreatedTimeNanos); TransportStats clientBefore = getTransportStats(client); assertEquals(0, clientBefore.streamsStarted); - assertEquals(0, clientBefore.lastStreamCreatedTimeNanos); + assertEquals(0, clientBefore.lastRemoteStreamCreatedTimeNanos); ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); ClientStreamListenerBase clientStreamListener = new ClientStreamListenerBase(); @@ -1422,14 +1422,14 @@ public abstract class AbstractTransportTest { TransportStats serverAfter = getTransportStats(serverTransportListener.transport); assertEquals(1, serverAfter.streamsStarted); - serverFirstTimestampNanos = serverAfter.lastStreamCreatedTimeNanos; + serverFirstTimestampNanos = serverAfter.lastRemoteStreamCreatedTimeNanos; assertEquals( currentTimeMillis(), - TimeUnit.NANOSECONDS.toMillis(serverAfter.lastStreamCreatedTimeNanos)); + TimeUnit.NANOSECONDS.toMillis(serverAfter.lastRemoteStreamCreatedTimeNanos)); TransportStats clientAfter = getTransportStats(client); assertEquals(1, clientAfter.streamsStarted); - clientFirstTimestampNanos = clientAfter.lastStreamCreatedTimeNanos; + clientFirstTimestampNanos = clientAfter.lastLocalStreamCreatedTimeNanos; assertEquals( currentTimeMillis(), TimeUnit.NANOSECONDS.toMillis(clientFirstTimestampNanos)); @@ -1458,18 +1458,18 @@ public abstract class AbstractTransportTest { assertEquals(2, serverAfter.streamsStarted); assertEquals( TimeUnit.MILLISECONDS.toNanos(elapsedMillis), - serverAfter.lastStreamCreatedTimeNanos - serverFirstTimestampNanos); + serverAfter.lastRemoteStreamCreatedTimeNanos - serverFirstTimestampNanos); long serverSecondTimestamp = - TimeUnit.NANOSECONDS.toMillis(serverAfter.lastStreamCreatedTimeNanos); + TimeUnit.NANOSECONDS.toMillis(serverAfter.lastRemoteStreamCreatedTimeNanos); assertEquals(currentTimeMillis(), serverSecondTimestamp); TransportStats clientAfter = getTransportStats(client); assertEquals(2, clientAfter.streamsStarted); assertEquals( TimeUnit.MILLISECONDS.toNanos(elapsedMillis), - clientAfter.lastStreamCreatedTimeNanos - clientFirstTimestampNanos); + clientAfter.lastLocalStreamCreatedTimeNanos - clientFirstTimestampNanos); long clientSecondTimestamp = - TimeUnit.NANOSECONDS.toMillis(clientAfter.lastStreamCreatedTimeNanos); + TimeUnit.NANOSECONDS.toMillis(clientAfter.lastLocalStreamCreatedTimeNanos); assertEquals(currentTimeMillis(), clientSecondTimestamp); ServerStream serverStream = serverStreamCreation.stream; |