fix: use all known headers to detect connectivity errors (googleapis#2841)

Change-Id: I4c3edfc2548a2115576f0aea997781929baeb9cf

Author: igorbernstein2

java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/csm/tracers/BuiltinMetricsTracer.java

@@ -20,6 +20,7 @@
 
 import com.google.api.core.ObsoleteApi;
 import com.google.api.gax.retrying.ServerStreamingAttemptException;
+import com.google.bigtable.v2.ResponseParams;
 import com.google.cloud.bigtable.data.v2.internal.csm.MetricRegistry;
 import com.google.cloud.bigtable.data.v2.internal.csm.attributes.ClientInfo;
 import com.google.cloud.bigtable.data.v2.internal.csm.attributes.MethodInfo;
@@ -33,6 +34,7 @@
 import io.grpc.Deadline;
 import io.grpc.Status;
 import java.time.Duration;
+import java.util.Optional;
 import java.util.concurrent.CancellationException;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -398,6 +400,22 @@ private void recordAttemptCompletion(@Nullable Throwable throwable) {
           sidebandData.getResponseParams(),
           code,
           sidebandData.getGfeTiming());
+    }
+
+    boolean seenServer =
+        Optional.ofNullable(sidebandData.getPeerInfo())
+            .map(pe -> pe.getApplicationFrontendId() != 0)
+            .orElse(false);
+
+    seenServer =
+        seenServer
+            || Optional.ofNullable(sidebandData.getResponseParams())
+                .map(rp -> !ResponseParams.getDefaultInstance().equals(rp))
+                .orElse(false);
+
+    seenServer = seenServer || (sidebandData.getGfeTiming() != null);
+
+    if (seenServer) {
       recorder.connectivityErrorCount.record(
           clientInfo, tableId, methodInfo, sidebandData.getResponseParams(), code, 0);
     } else {