diff options
Diffstat (limited to 'core/src/main/java/io/grpc/internal/AbstractServerStream.java')
-rw-r--r-- | core/src/main/java/io/grpc/internal/AbstractServerStream.java | 2 |
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; |