aboutsummaryrefslogtreecommitdiff
path: root/core/src/main/java/io/grpc/internal/AbstractServerStream.java
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/main/java/io/grpc/internal/AbstractServerStream.java')
-rw-r--r--core/src/main/java/io/grpc/internal/AbstractServerStream.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/java/io/grpc/internal/AbstractServerStream.java b/core/src/main/java/io/grpc/internal/AbstractServerStream.java
index 7cdb69e97..ec4a8e696 100644
--- a/core/src/main/java/io/grpc/internal/AbstractServerStream.java
+++ b/core/src/main/java/io/grpc/internal/AbstractServerStream.java
@@ -128,7 +128,6 @@ public abstract class AbstractServerStream extends AbstractStream
Preconditions.checkNotNull(trailers, "trailers");
if (!outboundClosed) {
outboundClosed = true;
- statsTraceCtx.streamClosed(status);
endOfMessages();
addStatusToTrailers(trailers, status);
// Safe to set without synchronization because access is tightly controlled.
@@ -336,6 +335,7 @@ public abstract class AbstractServerStream extends AbstractStream
statsTraceCtx.streamClosed(newStatus);
getTransportTracer().reportStreamClosed(false);
} else {
+ statsTraceCtx.streamClosed(closedStatus);
getTransportTracer().reportStreamClosed(closedStatus.isOk());
}
listenerClosed = true;