NetMirror.apk
Download file
package b3;
import java.io.IOException;
import java.io.InterruptedIOException;
import java.util.concurrent.TimeUnit;
import kotlin.jvm.internal.DefaultConstructorMarker;
/* JADX INFO: renamed from: b3.g, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes.dex */
public class C0324g extends G {
/* JADX INFO: renamed from: i, reason: collision with root package name */
private static final long f5616i;
/* JADX INFO: renamed from: j, reason: collision with root package name */
private static final long f5617j;
/* JADX INFO: renamed from: k, reason: collision with root package name */
private static C0324g f5618k;
/* JADX INFO: renamed from: l, reason: collision with root package name */
public static final a f5619l = new a(null);
/* JADX INFO: renamed from: f, reason: collision with root package name */
private boolean f5620f;
/* JADX INFO: renamed from: g, reason: collision with root package name */
private C0324g f5621g;
/* JADX INFO: renamed from: h, reason: collision with root package name */
private long f5622h;
/* JADX INFO: renamed from: b3.g$a */
public static final class a {
private a() {
}
/* JADX INFO: Access modifiers changed from: private */
public final boolean d(C0324g c0324g) {
synchronized (C0324g.class) {
for (C0324g c0324g2 = C0324g.f5618k; c0324g2 != null; c0324g2 = c0324g2.f5621g) {
if (c0324g2.f5621g == c0324g) {
c0324g2.f5621g = c0324g.f5621g;
c0324g.f5621g = null;
return false;
}
}
return true;
}
}
/* JADX INFO: Access modifiers changed from: private */
public final void e(C0324g c0324g, long j3, boolean z3) {
synchronized (C0324g.class) {
try {
if (C0324g.f5618k == null) {
C0324g.f5618k = new C0324g();
new b().start();
}
long jNanoTime = System.nanoTime();
if (j3 != 0 && z3) {
c0324g.f5622h = Math.min(j3, c0324g.c() - jNanoTime) + jNanoTime;
} else if (j3 != 0) {
c0324g.f5622h = j3 + jNanoTime;
} else {
if (!z3) {
throw new AssertionError();
}
c0324g.f5622h = c0324g.c();
}
long jU = c0324g.u(jNanoTime);
C0324g c0324g2 = C0324g.f5618k;
D2.h.c(c0324g2);
while (c0324g2.f5621g != null) {
C0324g c0324g3 = c0324g2.f5621g;
D2.h.c(c0324g3);
if (jU < c0324g3.u(jNanoTime)) {
break;
}
c0324g2 = c0324g2.f5621g;
D2.h.c(c0324g2);
}
c0324g.f5621g = c0324g2.f5621g;
c0324g2.f5621g = c0324g;
if (c0324g2 == C0324g.f5618k) {
C0324g.class.notify();
}
r2.r rVar = r2.r.f10584a;
} catch (Throwable th) {
throw th;
}
}
}
public final C0324g c() throws InterruptedException {
C0324g c0324g = C0324g.f5618k;
D2.h.c(c0324g);
C0324g c0324g2 = c0324g.f5621g;
if (c0324g2 == null) {
long jNanoTime = System.nanoTime();
C0324g.class.wait(C0324g.f5616i);
C0324g c0324g3 = C0324g.f5618k;
D2.h.c(c0324g3);
if (c0324g3.f5621g != null || System.nanoTime() - jNanoTime < C0324g.f5617j) {
return null;
}
return C0324g.f5618k;
}
long jU = c0324g2.u(System.nanoTime());
if (jU > 0) {
long j3 = jU / 1000000;
C0324g.class.wait(j3, (int) (jU - (1000000 * j3)));
return null;
}
C0324g c0324g4 = C0324g.f5618k;
D2.h.c(c0324g4);
c0324g4.f5621g = c0324g2.f5621g;
c0324g2.f5621g = null;
return c0324g2;
}
public /* synthetic */ a(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
}
/* JADX INFO: renamed from: b3.g$b */
private static final class b extends Thread {
public b() {
super("Okio Watchdog");
setDaemon(true);
}
@Override // java.lang.Thread, java.lang.Runnable
public void run() {
C0324g c0324gC;
while (true) {
try {
synchronized (C0324g.class) {
c0324gC = C0324g.f5619l.c();
if (c0324gC == C0324g.f5618k) {
C0324g.f5618k = null;
return;
}
r2.r rVar = r2.r.f10584a;
}
if (c0324gC != null) {
c0324gC.x();
}
} catch (InterruptedException unused) {
continue;
}
}
}
}
/* JADX INFO: renamed from: b3.g$c */
public static final class c implements D {
/* JADX INFO: renamed from: c, reason: collision with root package name */
final /* synthetic */ D f5624c;
c(D d4) {
this.f5624c = d4;
}
@Override // b3.D
public void Q(i iVar, long j3) throws IOException {
D2.h.f(iVar, "source");
AbstractC0323f.b(iVar.F0(), 0L, j3);
while (true) {
long j4 = 0;
if (j3 <= 0) {
return;
}
A a4 = iVar.f5627b;
D2.h.c(a4);
while (true) {
if (j4 >= 65536) {
break;
}
j4 += (long) (a4.f5592c - a4.f5591b);
if (j4 >= j3) {
j4 = j3;
break;
} else {
a4 = a4.f5595f;
D2.h.c(a4);
}
}
C0324g c0324g = C0324g.this;
c0324g.r();
try {
this.f5624c.Q(iVar, j4);
r2.r rVar = r2.r.f10584a;
if (c0324g.s()) {
throw c0324g.m(null);
}
j3 -= j4;
} catch (IOException e4) {
if (!c0324g.s()) {
throw e4;
}
throw c0324g.m(e4);
} finally {
c0324g.s();
}
}
}
@Override // b3.D
/* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */
public C0324g f() {
return C0324g.this;
}
@Override // b3.D, java.io.Closeable, java.lang.AutoCloseable
public void close() throws IOException {
C0324g c0324g = C0324g.this;
c0324g.r();
try {
this.f5624c.close();
r2.r rVar = r2.r.f10584a;
if (c0324g.s()) {
throw c0324g.m(null);
}
} catch (IOException e4) {
if (!c0324g.s()) {
throw e4;
}
throw c0324g.m(e4);
} finally {
c0324g.s();
}
}
@Override // b3.D, java.io.Flushable
public void flush() throws IOException {
C0324g c0324g = C0324g.this;
c0324g.r();
try {
this.f5624c.flush();
r2.r rVar = r2.r.f10584a;
if (c0324g.s()) {
throw c0324g.m(null);
}
} catch (IOException e4) {
if (!c0324g.s()) {
throw e4;
}
throw c0324g.m(e4);
} finally {
c0324g.s();
}
}
public String toString() {
return "AsyncTimeout.sink(" + this.f5624c + ')';
}
}
/* JADX INFO: renamed from: b3.g$d */
public static final class d implements F {
/* JADX INFO: renamed from: c, reason: collision with root package name */
final /* synthetic */ F f5626c;
d(F f3) {
this.f5626c = f3;
}
@Override // b3.F
/* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */
public C0324g f() {
return C0324g.this;
}
@Override // b3.F, java.io.Closeable, java.lang.AutoCloseable
public void close() throws IOException {
C0324g c0324g = C0324g.this;
c0324g.r();
try {
this.f5626c.close();
r2.r rVar = r2.r.f10584a;
if (c0324g.s()) {
throw c0324g.m(null);
}
} catch (IOException e4) {
if (!c0324g.s()) {
throw e4;
}
throw c0324g.m(e4);
} finally {
c0324g.s();
}
}
public String toString() {
return "AsyncTimeout.source(" + this.f5626c + ')';
}
@Override // b3.F
public long x(i iVar, long j3) throws IOException {
D2.h.f(iVar, "sink");
C0324g c0324g = C0324g.this;
c0324g.r();
try {
long jX = this.f5626c.x(iVar, j3);
if (c0324g.s()) {
throw c0324g.m(null);
}
return jX;
} catch (IOException e4) {
if (c0324g.s()) {
throw c0324g.m(e4);
}
throw e4;
} finally {
c0324g.s();
}
}
}
static {
long millis = TimeUnit.SECONDS.toMillis(60L);
f5616i = millis;
f5617j = TimeUnit.MILLISECONDS.toNanos(millis);
}
/* JADX INFO: Access modifiers changed from: private */
public final long u(long j3) {
return this.f5622h - j3;
}
public final IOException m(IOException iOException) {
return t(iOException);
}
public final void r() {
if (this.f5620f) {
throw new IllegalStateException("Unbalanced enter/exit");
}
long jH = h();
boolean zE = e();
if (jH != 0 || zE) {
this.f5620f = true;
f5619l.e(this, jH, zE);
}
}
public final boolean s() {
if (!this.f5620f) {
return false;
}
this.f5620f = false;
return f5619l.d(this);
}
protected IOException t(IOException iOException) {
InterruptedIOException interruptedIOException = new InterruptedIOException("timeout");
if (iOException != null) {
interruptedIOException.initCause(iOException);
}
return interruptedIOException;
}
public final D v(D d4) {
D2.h.f(d4, "sink");
return new c(d4);
}
public final F w(F f3) {
D2.h.f(f3, "source");
return new d(f3);
}
protected void x() {
}
}
⚠️ This content was hidden by an advertisement filtering extension in your browser. Please disable it and reload the page to access the decompiled content.
We only display one small text ad to keep this service free. Here's what it looks like:
Read the Docs for Business: You write the docs. We do the rest.
Try it today!Ad by EthicalAds