134 lines
3.9 KiB
Java
134 lines
3.9 KiB
Java
package l3;
|
|
|
|
import kotlin.Unit;
|
|
import kotlin.jvm.internal.Intrinsics;
|
|
import r3.C0576h;
|
|
import r3.G;
|
|
import r3.K;
|
|
|
|
/* loaded from: classes3.dex */
|
|
public final class v implements G {
|
|
|
|
/* renamed from: a, reason: collision with root package name */
|
|
public final boolean f7468a;
|
|
|
|
/* renamed from: b, reason: collision with root package name */
|
|
public final C0576h f7469b = new Object();
|
|
|
|
/* renamed from: c, reason: collision with root package name */
|
|
public boolean f7470c;
|
|
|
|
/* renamed from: d, reason: collision with root package name */
|
|
public final /* synthetic */ y f7471d;
|
|
|
|
/* JADX WARN: Type inference failed for: r1v1, types: [java.lang.Object, r3.h] */
|
|
public v(y yVar, boolean z3) {
|
|
this.f7471d = yVar;
|
|
this.f7468a = z3;
|
|
}
|
|
|
|
@Override // r3.G, java.io.Closeable, java.lang.AutoCloseable
|
|
public final void close() {
|
|
boolean z3;
|
|
y yVar = this.f7471d;
|
|
byte[] bArr = f3.c.f6469a;
|
|
synchronized (yVar) {
|
|
if (this.f7470c) {
|
|
return;
|
|
}
|
|
synchronized (yVar) {
|
|
z3 = yVar.f7489m == null;
|
|
Unit unit = Unit.INSTANCE;
|
|
}
|
|
y yVar2 = this.f7471d;
|
|
if (!yVar2.f7486j.f7468a) {
|
|
if (this.f7469b.f8284b > 0) {
|
|
while (this.f7469b.f8284b > 0) {
|
|
d(true);
|
|
}
|
|
} else if (z3) {
|
|
yVar2.f7480b.Z(yVar2.f7479a, true, null, 0L);
|
|
}
|
|
}
|
|
synchronized (this.f7471d) {
|
|
this.f7470c = true;
|
|
Unit unit2 = Unit.INSTANCE;
|
|
}
|
|
this.f7471d.f7480b.flush();
|
|
this.f7471d.a();
|
|
}
|
|
}
|
|
|
|
/* JADX WARN: Finally extract failed */
|
|
public final void d(boolean z3) {
|
|
long min;
|
|
boolean z4;
|
|
y yVar = this.f7471d;
|
|
synchronized (yVar) {
|
|
try {
|
|
yVar.f7488l.h();
|
|
while (yVar.f7483e >= yVar.f7484f && !this.f7468a && !this.f7470c) {
|
|
try {
|
|
synchronized (yVar) {
|
|
EnumC0439b enumC0439b = yVar.f7489m;
|
|
if (enumC0439b != null) {
|
|
break;
|
|
} else {
|
|
yVar.k();
|
|
}
|
|
}
|
|
} catch (Throwable th) {
|
|
yVar.f7488l.k();
|
|
throw th;
|
|
}
|
|
}
|
|
yVar.f7488l.k();
|
|
yVar.b();
|
|
min = Math.min(yVar.f7484f - yVar.f7483e, this.f7469b.f8284b);
|
|
yVar.f7483e += min;
|
|
z4 = z3 && min == this.f7469b.f8284b;
|
|
Unit unit = Unit.INSTANCE;
|
|
} catch (Throwable th2) {
|
|
throw th2;
|
|
}
|
|
}
|
|
this.f7471d.f7488l.h();
|
|
try {
|
|
y yVar2 = this.f7471d;
|
|
yVar2.f7480b.Z(yVar2.f7479a, z4, this.f7469b, min);
|
|
} finally {
|
|
this.f7471d.f7488l.k();
|
|
}
|
|
}
|
|
|
|
@Override // r3.G, java.io.Flushable
|
|
public final void flush() {
|
|
y yVar = this.f7471d;
|
|
byte[] bArr = f3.c.f6469a;
|
|
synchronized (yVar) {
|
|
yVar.b();
|
|
Unit unit = Unit.INSTANCE;
|
|
}
|
|
while (this.f7469b.f8284b > 0) {
|
|
d(false);
|
|
this.f7471d.f7480b.flush();
|
|
}
|
|
}
|
|
|
|
@Override // r3.G
|
|
public final K timeout() {
|
|
return this.f7471d.f7488l;
|
|
}
|
|
|
|
@Override // r3.G
|
|
public final void z(C0576h source, long j4) {
|
|
Intrinsics.checkNotNullParameter(source, "source");
|
|
byte[] bArr = f3.c.f6469a;
|
|
C0576h c0576h = this.f7469b;
|
|
c0576h.z(source, j4);
|
|
while (c0576h.f8284b >= 16384) {
|
|
d(false);
|
|
}
|
|
}
|
|
}
|