fix: fix client blocking latency

googleapis · Sep 19, 2024 · f2f6277 · f2f6277
1 parent 377437f
commit f2f6277
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/...rc/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableGrpcStreamTracer.java b/...rc/main/java/com/google/cloud/bigtable/data/v2/stub/metrics/BigtableGrpcStreamTracer.java
@@ -16,7 +16,6 @@
 package com.google.cloud.bigtable.data.v2.stub.metrics;
 
 import com.google.common.base.Stopwatch;
-import io.grpc.Attributes;
 import io.grpc.ClientStreamTracer;
 import io.grpc.Metadata;
 import java.util.concurrent.TimeUnit;
@@ -28,18 +27,13 @@
  */
 class BigtableGrpcStreamTracer extends ClientStreamTracer {
 
-  private final Stopwatch stopwatch = Stopwatch.createUnstarted();
+  private final Stopwatch stopwatch = Stopwatch.createStarted();
   private final BigtableTracer tracer;
 
   public BigtableGrpcStreamTracer(BigtableTracer tracer) {
     this.tracer = tracer;
   }
 
-  @Override
-  public void streamCreated(Attributes transportAttrs, Metadata headers) {
-    stopwatch.start();
-  }
-
   @Override
   public void outboundMessageSent(int seqNo, long optionalWireSize, long optionalUncompressedSize) {
     tracer.grpcChannelQueuedLatencies(stopwatch.elapsed(TimeUnit.NANOSECONDS));