Skip to content

Commit 0fcfdee

Browse files
chore: generate libraries at Mon Mar 2 19:46:43 UTC 2026
1 parent 91548d8 commit 0fcfdee

1 file changed

Lines changed: 5 additions & 3 deletions

File tree

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPool.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -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

Comments
 (0)