Skip to content

Commit 429d30f

Browse files
committed
fix: fix session budget penality logic
1 parent fac78d6 commit 429d30f

1 file changed

Lines changed: 2 additions & 5 deletions

File tree

‎java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionCreationBudget.java‎

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import java.time.Duration;
2323
import java.time.Instant;
2424
import java.util.ArrayList;
25+
import java.util.Collections;
2526
import java.util.Iterator;
2627
import java.util.List;
2728
import java.util.logging.Level;
@@ -63,7 +64,7 @@ Instant getNextAvailableBudget() {
6364
return Instant.now();
6465
}
6566

66-
return delayedCreationTokens.get(0);
67+
return Collections.min(delayedCreationTokens);
6768
}
6869

6970
boolean tryReserveSession() {
@@ -96,10 +97,6 @@ private void drainCreationFailures() {
9697
if (iter.next().isBefore(now)) {
9798
concurrentRequests--;
9899
iter.remove();
99-
} else {
100-
// The list should be roughly sorted. Exit early when we encounter
101-
// something expires later.
102-
break;
103100
}
104101
}
105102
}

0 commit comments

Comments
 (0)