package p138.p329.p362.p370; import java.io.IOException; import java.io.OutputStream; import p138.p139.p143.p144.C2803; import p138.p329.p346.C6228; import p138.p329.p346.p347.C6272; import p138.p329.p346.p347.C6273; import p138.p329.p362.InterfaceC6338; import p138.p329.p362.p367.AbstractC6372; import p463.p481.C7162; import p463.p481.InterfaceC7161; /* JADX INFO: renamed from: ދ.ށ.މ.މ.ރ, reason: contains not printable characters */ /* JADX INFO: loaded from: classes.dex */ public class C6399 extends OutputStream { /* JADX INFO: renamed from: އ, reason: contains not printable characters */ public static final InterfaceC7161 f17866 = C7162.m10575((Class) C6399.class); /* JADX INFO: renamed from: ރ, reason: contains not printable characters */ public C6405 f17867; /* JADX INFO: renamed from: ބ, reason: contains not printable characters */ public InterfaceC6338 f17868; /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */ public boolean f17869 = false; /* JADX INFO: renamed from: ކ, reason: contains not printable characters */ public C6401 f17870; /* JADX INFO: renamed from: ދ.ށ.މ.މ.ރ$ؠ, reason: contains not printable characters */ public static class C6401 extends AbstractC6372 { /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */ public C6404 f17871; public /* synthetic */ C6401(int i, long j, C6400 c6400) { this.f17871 = new C6404(i); this.f17790 = j; } @Override // p138.p329.p362.p367.AbstractC6372 /* JADX INFO: renamed from: ֏ */ public int mo9589() { return this.f17871.f17875; } @Override // p138.p329.p362.p367.AbstractC6372 /* JADX INFO: renamed from: ֏ */ public int mo9590(byte[] bArr) { C6404 c6404 = this.f17871; int length = c6404.f17875; if (length >= bArr.length) { length = bArr.length; } int i = c6404.f17874; int i2 = i + length; byte[] bArr2 = c6404.f17872; if (i2 <= bArr2.length) { System.arraycopy(bArr2, i, bArr, 0, length); } else { int length2 = bArr2.length - i; System.arraycopy(bArr2, i, bArr, 0, length2); System.arraycopy(c6404.f17872, 0, bArr, length2, length - length2); } c6404.f17874 = (c6404.f17874 + length) % c6404.f17872.length; c6404.f17875 -= length; return length; } @Override // p138.p329.p362.p367.AbstractC6372 /* JADX INFO: renamed from: ؠ */ public boolean mo9591() { C6404 c6404 = this.f17871; if (c6404 != null) { if (!(c6404.f17875 <= 0)) { return true; } } return false; } /* JADX INFO: renamed from: ހ, reason: contains not printable characters */ public boolean m9630() { C6404 c6404 = this.f17871; return c6404.f17875 == c6404.f17872.length; } } public C6399(C6405 c6405, int i, long j, InterfaceC6338 interfaceC6338) { this.f17867 = c6405; this.f17868 = interfaceC6338; this.f17870 = new C6401(i, j, null); } @Override // java.io.OutputStream, java.io.Closeable, java.lang.AutoCloseable public void close() { while (this.f17870.mo9591()) { m9628(); } C6401 c6401 = this.f17870; c6401.f17871 = null; this.f17869 = true; this.f17867 = null; f17866.mo10573("EOF, {} bytes written", Long.valueOf(c6401.f17790)); } @Override // java.io.OutputStream, java.io.Flushable public void flush() throws IOException { m9629(); if (this.f17870.mo9591()) { m9628(); } } @Override // java.io.OutputStream public void write(int i) throws IOException { m9629(); if (this.f17870.m9630()) { flush(); } if (this.f17870.m9630()) { return; } C6404 c6404 = this.f17870.f17871; if (c6404 == null) { throw null; } c6404.m9632(new byte[]{(byte) i}, 0, 1); } @Override // java.io.OutputStream public void write(byte[] bArr) throws IOException { write(bArr, 0, bArr.length); } /* JADX WARN: Code restructure failed: missing block: B:13:0x002c, code lost: if (r4.f17870.m9630() != false) goto L15; */ /* JADX WARN: Code restructure failed: missing block: B:14:0x002e, code lost: r4.f17870.f17871.m9632(r5, r6, r0); */ /* JADX WARN: Code restructure failed: missing block: B:15:0x0035, code lost: r6 = r6 + r0; r7 = r7 - r0; */ @Override // java.io.OutputStream /* Code decompiled incorrectly, please refer to instructions dump. */ public void write(byte[] bArr, int i, int i2) throws IOException { m9629(); do { int iMin = Math.min(i2, this.f17870.f17871.f17872.length); while (true) { C6404 c6404 = this.f17870.f17871; byte[] bArr2 = c6404.f17872; if (iMin > bArr2.length) { StringBuilder sbM4889 = C2803.m4889("RingBuffer of length "); sbM4889.append(c6404.f17872.length); sbM4889.append(" cannot accomodate "); sbM4889.append(iMin); sbM4889.append(" bytes."); throw new IllegalArgumentException(sbM4889.toString()); } if (!(c6404.f17875 + iMin > bArr2.length)) { break; } else { flush(); } } } while (i2 > 0); } /* JADX WARN: Type inference fix 'apply assigned field type' failed java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$PrimitiveArg at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593) at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35) at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94) */ /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public final void m9628() { C6405 c6405 = this.f17867; C6401 c6401 = this.f17870; InterfaceC6338 interfaceC6338 = this.f17868; if (c6405 == null) { throw null; } while (c6401.mo9591()) { C6405.f17876.mo10556("Writing to {} from offset {}", c6405.f17879, Long.valueOf(c6401.f17790)); C6406 c6406 = c6405.f17877; C6228 c6228 = c6405.f17878; long j = ((C6273) c6406.m9634(new C6272(c6406.f17889, c6228, c6406.f17896, c6406.f17887, c6401, c6406.f17892), "Write", c6228, InterfaceC6411.f17898, c6406.f17893)).f17544; if (interfaceC6338 != null) { interfaceC6338.m9557(j, c6401.f17790); } } } /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */ public final void m9629() throws IOException { if (this.f17869) { throw new IOException("Stream is closed"); } } }