@@ -547,6 +547,7 @@ static class Entry implements BigtableChannelObserver {
547547 * start.
548548 */
549549 @ VisibleForTesting final AtomicInteger errorCount = new AtomicInteger (0 );
550+
550551 @ VisibleForTesting final AtomicInteger successCount = new AtomicInteger (0 );
551552 @ VisibleForTesting final AtomicInteger outstandingUnaryRpcs = new AtomicInteger (0 );
552553
@@ -557,8 +558,7 @@ static class Entry implements BigtableChannelObserver {
557558
558559 /** this contains the PeerInfo field of the most recent rpc on this channel entry. */
559560 @ VisibleForTesting
560- volatile PeerInfo .TransportType transportType =
561- PeerInfo .TransportType .TRANSPORT_TYPE_UNKNOWN ;
561+ volatile PeerInfo .TransportType transportType = PeerInfo .TransportType .TRANSPORT_TYPE_UNKNOWN ;
562562
563563 /** Queue storing the last 5 minutes of probe results */
564564 @ VisibleForTesting
@@ -589,7 +589,8 @@ void setTransportType(CallOptions callOptions) {
589589 // Set to the specific transport type if present, otherwise default to UNKNOWN
590590 // we could check the Status and set it to unknown, but we might have PeerInfo with some non
591591 // OK Status
592- transportType = Optional .ofNullable (sidebandData )
592+ transportType =
593+ Optional .ofNullable (sidebandData )
593594 .map (MetadataExtractorInterceptor .SidebandData ::getPeerInfo )
594595 .map (PeerInfo ::getTransportType )
595596 .orElse (PeerInfo .TransportType .TRANSPORT_TYPE_UNKNOWN );
@@ -766,6 +767,7 @@ public void onHeaders(Metadata headers) {
766767 entry .setTransportType (callOptions );
767768 super .onHeaders (headers );
768769 }
770+
769771 @ Override
770772 public void onClose (Status status , Metadata trailers ) {
771773 if (!wasClosed .compareAndSet (false , true )) {
0 commit comments