This repository was archived by the owner on May 8, 2026. It is now read-only.
File tree Expand file tree Collapse file tree
google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc Expand file tree Collapse file tree Original file line number Diff line number Diff line change 5151import java .util .logging .Logger ;
5252import javax .annotation .Nullable ;
5353
54- import static com .google .bigtable .v2 .PeerInfo .TransportType .TRANSPORT_TYPE_UNKNOWN ;
55-
5654/**
5755 * A {@link ManagedChannel} that will send requests round-robin via a set of channels.
5856 *
@@ -560,8 +558,8 @@ static class Entry implements BigtableChannelObserver {
560558 /** this contains the PeerInfo field of the most recent rpc on this channel entry. */
561559 @ VisibleForTesting
562560 volatile PeerInfo .TransportType transportType =
563- TRANSPORT_TYPE_UNKNOWN ;
564-
561+ PeerInfo . TransportType . TRANSPORT_TYPE_UNKNOWN ;
562+
565563 /** Queue storing the last 5 minutes of probe results */
566564 @ VisibleForTesting
567565 final ConcurrentLinkedQueue <ProbeResult > probeHistory = new ConcurrentLinkedQueue <>();
@@ -594,7 +592,7 @@ void setTransportType(CallOptions callOptions) {
594592 transportType = Optional .ofNullable (sidebandData )
595593 .map (MetadataExtractorInterceptor .SidebandData ::getPeerInfo )
596594 .map (PeerInfo ::getTransportType )
597- .orElse (TRANSPORT_TYPE_UNKNOWN );
595+ .orElse (PeerInfo . TransportType . TRANSPORT_TYPE_UNKNOWN );
598596 }
599597
600598 ManagedChannel getManagedChannel () {
You can’t perform that action at this time.
0 commit comments