aboutsummaryrefslogtreecommitdiff
path: root/testing
diff options
context:
space:
mode:
authorzpencer <spencerfang@google.com>2018-03-08 16:57:12 -0800
committerGitHub <noreply@github.com>2018-03-08 16:57:12 -0800
commit921b668ad5a0ad08471630921c3b45f77fcf8ecc (patch)
tree9af6171c1ae62b2912ba2f265d4510ec6b7b8b77 /testing
parentf0eb6d2102c5d09e887c1eefd563985c1d702273 (diff)
downloadgrpc-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.java18
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;