package defpackage;

import java.io.Closeable;
import java.io.IOException;
import java.net.Socket;
import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.TimeZone;

/* renamed from: ᵳˋᵢ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C4560 implements Closeable {

    /* renamed from: ᵳᵹᵺˋ, reason: contains not printable characters */
    public static final C2985 f16955;

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public final C3246 f16956;

    /* renamed from: ˀᵗᵩ, reason: contains not printable characters */
    public final ᵧˉʙ f16957;

    /* renamed from: ˁˑᵰ, reason: contains not printable characters */
    public final C3276 f16958;

    /* renamed from: ˆᵼᵷˊ, reason: contains not printable characters */
    public final C4537 f16959;

    /* renamed from: ˊᵸˊ, reason: contains not printable characters */
    public long f16960;

    /* renamed from: ˌᵪ, reason: contains not printable characters */
    public final LinkedHashSet f16961;

    /* renamed from: ˎˑː, reason: contains not printable characters */
    public final C0897 f16962;

    /* renamed from: ˑᵝﹳᵜ, reason: contains not printable characters */
    public long f16963;

    /* renamed from: ˑᵥˁ, reason: contains not printable characters */
    public final C0897 f16964;

    /* renamed from: ᐧﾞ, reason: contains not printable characters */
    public long f16965;

    /* renamed from: ᵙᵢᵨᵳ, reason: contains not printable characters */
    public C2985 f16966;

    /* renamed from: ᵛˈᵤ, reason: contains not printable characters */
    public final C1487 f16967;

    /* renamed from: ᵡˎ, reason: contains not printable characters */
    public final C0897 f16968;

    /* renamed from: ᵡᵘˎʽ, reason: contains not printable characters */
    public final C5257 f16969;

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public boolean f16970;

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final LinkedHashMap f16971 = new LinkedHashMap();

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public int f16972;

    /* renamed from: ᵧـˌᵎ, reason: contains not printable characters */
    public long f16973;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public final AbstractC2371 f16974;

    /* renamed from: ᵮᵠـˌ, reason: contains not printable characters */
    public final ᵼᵫᵧˀ f16975;

    /* renamed from: ᵶʔᵢˊ, reason: contains not printable characters */
    public long f16976;

    /* renamed from: ᵺʙ, reason: contains not printable characters */
    public long f16977;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public int f16978;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public final String f16979;

    /* renamed from: ﾞⁱ, reason: contains not printable characters */
    public final C2985 f16980;

    static {
        C2985 c2985 = new C2985();
        c2985.m7296(4, 65535);
        c2985.m7296(5, 16384);
        f16955 = c2985;
    }

    public C4560(ʽˋːᵜ r5) {
        this.f16974 = (AbstractC2371) r5.ᵤᵙᵷ;
        String str = (String) r5.ᵾᵬ;
        this.f16979 = str == null ? null : str;
        this.f16972 = 3;
        C3246 c3246 = (C3246) r5.ᵢˇᵭ;
        this.f16956 = c3246;
        this.f16968 = c3246.m7606();
        this.f16964 = c3246.m7606();
        this.f16962 = c3246.m7606();
        this.f16975 = ᵼᵫᵧˀ.ˑᵥˁ;
        this.f16958 = (C3276) r5.ᵡⁱᵥ;
        C2985 c2985 = new C2985();
        c2985.m7296(4, 16777216);
        this.f16980 = c2985;
        this.f16966 = f16955;
        this.f16969 = new C5257(0);
        this.f16960 = r0.m7295();
        ᵧˉʙ r52 = (ᵧˉʙ) r5.ᵿʗᵝʽ;
        ᵧˉʙ r1 = r52 != null ? r52 : null;
        this.f16957 = r1;
        this.f16959 = new C4537((C2567) r1.ᵾᵬ);
        this.f16967 = new C1487(this, new C4221((C2753) r1.ᵿʗᵝʽ));
        this.f16961 = new LinkedHashSet();
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        m9719(1, 9, null);
    }

    public final void flush() {
        this.f16959.flush();
    }

    /* renamed from: ˊᵸˊ, reason: contains not printable characters */
    public final void m9711(final long j, final int i) {
        C0897.m3015(this.f16968, this.f16979 + '[' + i + "] windowUpdate", new InterfaceC4622() { // from class: ᵨᵢᵚ
            @Override // defpackage.InterfaceC4622
            /* renamed from: ᵥᵯˎ */
            public final Object mo1401() {
                C4560 c4560 = this.f13984;
                int i2 = i;
                try {
                    c4560.f16959.m9639(j, i2);
                } catch (IOException e) {
                    c4560.m9719(2, 2, e);
                }
                return C3637.f13536;
            }
        });
    }

    /* renamed from: ˌʾˀ, reason: contains not printable characters */
    public final boolean m9712(long j) {
        synchronized (this) {
            if (this.f16970) {
                return false;
            }
            if (this.f16965 < this.f16977) {
                if (j >= this.f16976) {
                    return false;
                }
            }
            return true;
        }
    }

    /* renamed from: ˏᵙ, reason: contains not printable characters */
    public final C4498 m9713(int i) {
        C4498 c4498;
        synchronized (this) {
            c4498 = (C4498) this.f16971.get(Integer.valueOf(i));
        }
        return c4498;
    }

    /* renamed from: ˑᵥˁ, reason: contains not printable characters */
    public final void m9714(int i, int i2) {
        C0897.m3015(this.f16968, this.f16979 + '[' + i + "] writeSynReset", new C1961(this, i, i2, 0));
    }

    /* renamed from: ᵞʡ, reason: contains not printable characters */
    public final C4498 m9715(int i) {
        C4498 c4498;
        synchronized (this) {
            c4498 = (C4498) this.f16971.remove(Integer.valueOf(i));
            notifyAll();
        }
        return c4498;
    }

    /* JADX WARN: Code restructure failed: missing block: B:19:0x0035, code lost:
    
        r2 = java.lang.Math.min((int) java.lang.Math.min(r12, r6 - r4), r8.f16959.f16876);
        r6 = r2;
        r8.f16963 += r6;
     */
    /* renamed from: ᵡˎ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final void m9716(int r9, boolean r10, defpackage.C0963 r11, long r12) {
        /*
            r8 = this;
            r0 = 0
            int r2 = (r12 > r0 ? 1 : (r12 == r0 ? 0 : -1))
            r3 = 0
            if (r2 != 0) goto Ld
            ᵲⁱ r8 = r8.f16959
            r8.m9641(r10, r9, r11, r3)
            return
        Ld:
            int r2 = (r12 > r0 ? 1 : (r12 == r0 ? 0 : -1))
            if (r2 <= 0) goto L68
            monitor-enter(r8)
        L12:
            long r4 = r8.f16963     // Catch: java.lang.Throwable -> L2a java.lang.InterruptedException -> L59
            long r6 = r8.f16960     // Catch: java.lang.Throwable -> L2a java.lang.InterruptedException -> L59
            int r2 = (r4 > r6 ? 1 : (r4 == r6 ? 0 : -1))
            if (r2 < 0) goto L34
            java.util.LinkedHashMap r2 = r8.f16971     // Catch: java.lang.Throwable -> L2a java.lang.InterruptedException -> L59
            java.lang.Integer r4 = java.lang.Integer.valueOf(r9)     // Catch: java.lang.Throwable -> L2a java.lang.InterruptedException -> L59
            boolean r2 = r2.containsKey(r4)     // Catch: java.lang.Throwable -> L2a java.lang.InterruptedException -> L59
            if (r2 == 0) goto L2c
            r8.wait()     // Catch: java.lang.Throwable -> L2a java.lang.InterruptedException -> L59
            goto L12
        L2a:
            r9 = move-exception
            goto L66
        L2c:
            java.io.IOException r9 = new java.io.IOException     // Catch: java.lang.Throwable -> L2a java.lang.InterruptedException -> L59
            java.lang.String r10 = "stream closed"
            r9.<init>(r10)     // Catch: java.lang.Throwable -> L2a java.lang.InterruptedException -> L59
            throw r9     // Catch: java.lang.Throwable -> L2a java.lang.InterruptedException -> L59
        L34:
            long r6 = r6 - r4
            long r4 = java.lang.Math.min(r12, r6)     // Catch: java.lang.Throwable -> L2a
            int r2 = (int) r4     // Catch: java.lang.Throwable -> L2a
            ᵲⁱ r4 = r8.f16959     // Catch: java.lang.Throwable -> L2a
            int r4 = r4.f16876     // Catch: java.lang.Throwable -> L2a
            int r2 = java.lang.Math.min(r2, r4)     // Catch: java.lang.Throwable -> L2a
            long r4 = r8.f16963     // Catch: java.lang.Throwable -> L2a
            long r6 = (long) r2     // Catch: java.lang.Throwable -> L2a
            long r4 = r4 + r6
            r8.f16963 = r4     // Catch: java.lang.Throwable -> L2a
            monitor-exit(r8)
            long r12 = r12 - r6
            ᵲⁱ r4 = r8.f16959
            if (r10 == 0) goto L54
            int r5 = (r12 > r0 ? 1 : (r12 == r0 ? 0 : -1))
            if (r5 != 0) goto L54
            r5 = 1
            goto L55
        L54:
            r5 = r3
        L55:
            r4.m9641(r5, r9, r11, r2)
            goto Ld
        L59:
            java.lang.Thread r9 = java.lang.Thread.currentThread()     // Catch: java.lang.Throwable -> L2a
            r9.interrupt()     // Catch: java.lang.Throwable -> L2a
            java.io.InterruptedIOException r9 = new java.io.InterruptedIOException     // Catch: java.lang.Throwable -> L2a
            r9.<init>()     // Catch: java.lang.Throwable -> L2a
            throw r9     // Catch: java.lang.Throwable -> L2a
        L66:
            monitor-exit(r8)
            throw r9
        L68:
            return
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C4560.m9716(int, boolean, ˇᵠᵦ, long):void");
    }

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public final void m9717(long j) {
        synchronized (this) {
            try {
                C5257.m10905(this.f16969, j, 0L, 2);
                long jM10907 = this.f16969.m10907();
                if (jM10907 >= this.f16980.m7295() / 2) {
                    m9711(jM10907, 0);
                    C5257.m10905(this.f16969, 0L, jM10907, 1);
                }
                this.f16958.getClass();
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final void m9718(int i) {
        synchronized (this.f16959) {
            synchronized (this) {
                if (this.f16970) {
                    return;
                }
                this.f16970 = true;
                this.f16959.m9643(AbstractC1348.f5567, this.f16978, i);
            }
        }
    }

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public final void m9719(int i, int i2, IOException iOException) {
        int i3;
        Object[] array;
        TimeZone timeZone = AbstractC4061.f15224;
        try {
            m9718(i);
        } catch (IOException unused) {
        }
        synchronized (this) {
            if (this.f16971.isEmpty()) {
                array = null;
            } else {
                array = this.f16971.values().toArray(new C4498[0]);
                this.f16971.clear();
            }
        }
        C4498[] c4498Arr = (C4498[]) array;
        if (c4498Arr != null) {
            for (C4498 c4498 : c4498Arr) {
                try {
                    c4498.m9588(i2, iOException);
                } catch (IOException unused2) {
                }
            }
        }
        try {
            this.f16959.close();
        } catch (IOException unused3) {
        }
        try {
            ((Socket) ((ᵮᵥٴ) this.f16957.ᵢˇᵭ).ᵢˇᵭ).close();
        } catch (IOException unused4) {
        }
        this.f16968.m3017();
        this.f16964.m3017();
        this.f16962.m3017();
    }
}