Merge branch '7.0.x'

This commit is contained in:
Sam Brannen
2026-09-14 18:17:15 +02:00
5 changed files with 9 additions and 9 deletions
@@ -169,7 +169,7 @@ final class SubscriberInputStream extends InputStream implements Subscriber<Data
}
int addWork() {
for (;;) {
while (true) {
int produced = this.workAmount.getPlain();
if (produced == Integer.MIN_VALUE) {
@@ -297,7 +297,7 @@ final class SubscriberInputStream extends InputStream implements Subscriber<Data
this.available = null;
int actualWorkAmount = this.workAmount.getAcquire();
for (;;) {
while (true) {
if (this.closed) {
return CLOSED;
}
@@ -332,7 +332,7 @@ final class SubscriberInputStream extends InputStream implements Subscriber<Data
discard(this.available);
this.available = null;
for (;;) {
while (true) {
int workAmount = this.workAmount.getPlain();
DataBuffer value;
while ((value = this.queue.poll()) != null) {
@@ -202,7 +202,7 @@ public final class ConcurrentLruCache<K, V> {
* current size of the cache, unless the node has already been removed.
*/
private void markAsRemoved(Node<K, V> node) {
for (; ; ) {
while (true) {
CacheEntry<V> current = node.get();
if (current.state == CacheEntryState.REMOVED) {
return;