77 lines
1.8 KiB
Java
77 lines
1.8 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
/* renamed from: o.gfq, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes.dex */
|
||
|
|
public abstract class AbstractC15057gfq extends AbstractC15004geU {
|
||
|
|
private boolean a;
|
||
|
|
public long b;
|
||
|
|
public ggE<AbstractC15050gfj<?>> e;
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
public static long d() {
|
||
|
|
return 4294967296L;
|
||
|
|
}
|
||
|
|
|
||
|
|
public void e() {
|
||
|
|
}
|
||
|
|
|
||
|
|
public long j() {
|
||
|
|
AbstractC15050gfj<?> c;
|
||
|
|
ggE<AbstractC15050gfj<?>> gge = this.e;
|
||
|
|
if (gge == null || (c = gge.c()) == null) {
|
||
|
|
return Long.MAX_VALUE;
|
||
|
|
}
|
||
|
|
c.run();
|
||
|
|
return 0L;
|
||
|
|
}
|
||
|
|
|
||
|
|
protected boolean i() {
|
||
|
|
ggE<AbstractC15050gfj<?>> gge = this.e;
|
||
|
|
return gge == null || gge.a == gge.e;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final boolean h() {
|
||
|
|
AbstractC15050gfj<?> c;
|
||
|
|
ggE<AbstractC15050gfj<?>> gge = this.e;
|
||
|
|
if (gge == null || (c = gge.c()) == null) {
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
c.run();
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void c(boolean z) {
|
||
|
|
this.b += z ? 4294967296L : 1L;
|
||
|
|
if (z) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.a = true;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void a() {
|
||
|
|
long j = this.b - 4294967296L;
|
||
|
|
this.b = j;
|
||
|
|
if (j > 0) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
C15045gfe.b();
|
||
|
|
if (this.a) {
|
||
|
|
e();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.AbstractC15004geU
|
||
|
|
public final AbstractC15004geU c(int i) {
|
||
|
|
if (i > 0) {
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
throw new IllegalArgumentException("Expected positive parallelism level, but got ".concat(String.valueOf(i)).toString());
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: protected */
|
||
|
|
public long f() {
|
||
|
|
ggE<AbstractC15050gfj<?>> gge = this.e;
|
||
|
|
return (gge == null || gge.a == gge.e) ? Long.MAX_VALUE : 0L;
|
||
|
|
}
|
||
|
|
}
|