package defpackage;

import java.io.Closeable;
import java.io.EOFException;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.TimeZone;
import java.util.logging.Level;
import java.util.logging.Logger;

/* JADX INFO: renamed from: ᵖʢːᵧ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C2384 implements Closeable {

    /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
    public static final Logger f9317 = Logger.getLogger(AbstractC3401.class.getName());

    /* JADX INFO: renamed from: ˌᴵ, reason: contains not printable characters */
    public final InterfaceC2322 f9318;

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public final C4889 f9319;

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public final C4617 f9320;

    public C2384(InterfaceC2322 interfaceC2322) {
        this.f9318 = interfaceC2322;
        C4617 c4617 = new C4617(interfaceC2322);
        this.f9320 = c4617;
        this.f9319 = new C4889(c4617);
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() throws IOException {
        this.f9318.close();
    }

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public final void m6105(C2486 c2486, int i, int i2, int i3) throws IOException {
        int i4;
        if (i3 == 0) {
            C1685.m4568("PROTOCOL_ERROR: TYPE_PUSH_PROMISE streamId == 0");
            return;
        }
        if ((i2 & 8) != 0) {
            byte b = this.f9318.readByte();
            byte[] bArr = AbstractC1701.f6716;
            i4 = b & 255;
        } else {
            i4 = 0;
        }
        int i5 = this.f9318.readInt() & Integer.MAX_VALUE;
        List listM6110 = m6110(ᵿᵽᵤ.ᵮᵣᵗˈ(i - 4, i2, i4), i4, i2, i3);
        C4901 c4901 = c2486.f9663;
        synchronized (c4901) {
            if (c4901.f18652.contains(Integer.valueOf(i5))) {
                c4901.m10190(i5, 2);
                return;
            }
            c4901.f18652.add(Integer.valueOf(i5));
            C5380.m10968(c4901.f18669, c4901.f18659 + '[' + i5 + "] onRequest", new C2660(c4901, i5, listM6110));
        }
    }

    /* JADX INFO: renamed from: ˏːˆ, reason: contains not printable characters */
    public final void m6106(C2486 c2486, int i, int i2, int i3) throws IOException {
        int i4;
        if (i3 == 0) {
            C1685.m4568("PROTOCOL_ERROR: TYPE_HEADERS streamId == 0");
            return;
        }
        boolean z = false;
        boolean z2 = (i2 & 1) != 0;
        if ((i2 & 8) != 0) {
            byte b = this.f9318.readByte();
            byte[] bArr = AbstractC1701.f6716;
            i4 = b & 255;
        } else {
            i4 = 0;
        }
        if ((i2 & 32) != 0) {
            InterfaceC2322 interfaceC2322 = this.f9318;
            interfaceC2322.readInt();
            interfaceC2322.readByte();
            byte[] bArr2 = AbstractC1701.f6716;
            i -= 5;
        }
        List listM6110 = m6110(ᵿᵽᵤ.ᵮᵣᵗˈ(i, i2, i4), i4, i2, i3);
        C4901 c4901 = c2486.f9663;
        if (i3 != 0 && (i3 & 1) == 0) {
            z = true;
        }
        if (z) {
            C5380.m10968(c4901.f18669, c4901.f18659 + '[' + i3 + "] onHeaders", new C2660(c4901, i3, listM6110, z2));
            return;
        }
        synchronized (c4901) {
            C0217 c0217M10184 = c4901.m10184(i3);
            if (c0217M10184 != null) {
                c0217M10184.m1387(AbstractC1190.m3670(listM6110), z2);
                return;
            }
            if (c4901.f18668) {
                return;
            }
            if (i3 <= c4901.f18665) {
                return;
            }
            if (i3 % 2 == c4901.f18666 % 2) {
                return;
            }
            C0217 c0217 = new C0217(i3, c4901, false, z2, AbstractC1190.m3670(listM6110));
            c4901.f18665 = i3;
            c4901.f18661.put(Integer.valueOf(i3), c0217);
            C5380.m10968(c4901.f18649.m10966(), c4901.f18659 + '[' + i3 + "] onStream", new C2520(c4901, 4, c0217));
        }
    }

    /* JADX WARN: Code restructure failed: missing block: B:66:0x010f, code lost:
    
        if (r6 == false) goto L68;
     */
    /* JADX WARN: Code restructure failed: missing block: B:67:0x0111, code lost:
    
        r9.m1387(defpackage.C0661.f3101, true);
     */
    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final void m6107(C2486 c2486, int i, int i2, final int i3) throws IOException {
        boolean z;
        int i4;
        boolean z2;
        boolean z3;
        if (i3 == 0) {
            C1685.m4568("PROTOCOL_ERROR: TYPE_DATA streamId == 0");
            return;
        }
        final boolean z4 = true;
        if ((i2 & 1) != 0) {
            z = true;
        } else {
            z = true;
            z4 = false;
        }
        if ((i2 & 32) != 0) {
            C1685.m4568("PROTOCOL_ERROR: FLAG_COMPRESSED without SETTINGS_COMPRESS_DATA");
            return;
        }
        if ((i2 & 8) != 0) {
            byte b = this.f9318.readByte();
            byte[] bArr = AbstractC1701.f6716;
            i4 = b & 255;
        } else {
            i4 = 0;
        }
        final int i5 = ᵿᵽᵤ.ᵮᵣᵗˈ(i, i2, i4);
        InterfaceC2322 interfaceC2322 = this.f9318;
        final C4901 c4901 = c2486.f9663;
        if (!((i3 == 0 || (i3 & 1) != 0) ? false : z)) {
            C0217 c0217M10184 = c4901.m10184(i3);
            if (c0217M10184 != null) {
                TimeZone timeZone = AbstractC1190.f5068;
                C3439 c3439 = c0217M10184.f1703;
                long j = i5;
                c3439.getClass();
                long j2 = j;
                while (true) {
                    C0217 c0217 = c3439.f13272;
                    if (j2 <= 0) {
                        TimeZone timeZone2 = AbstractC1190.f5068;
                        c0217.f1706.m10186(j);
                        c3439.f13272.f1706.f18654.getClass();
                        break;
                    }
                    synchronized (c0217) {
                        z2 = c3439.f13269;
                        z3 = c3439.f13270.f18672 + j2 > c3439.f13267;
                    }
                    if (z3) {
                        interfaceC2322.skip(j2);
                        c3439.f13272.m1393(4);
                        break;
                    }
                    if (z2) {
                        interfaceC2322.skip(j2);
                        break;
                    }
                    long jMo1490 = interfaceC2322.mo1490(c3439.f13268, j2);
                    if (jMo1490 == -1) {
                        throw new EOFException();
                    }
                    j2 -= jMo1490;
                    C0217 c02172 = c3439.f13272;
                    synchronized (c02172) {
                        try {
                            if (c3439.f13271) {
                                c3439.f13268.m10199();
                            } else {
                                C4903 c4903 = c3439.f13270;
                                boolean z5 = c4903.f18672 == 0;
                                c4903.m10212(c3439.f13268);
                                if (z5) {
                                    c02172.notifyAll();
                                }
                            }
                        } catch (Throwable th) {
                            throw th;
                        }
                    }
                }
            } else {
                c2486.f9663.m10190(i3, 2);
                long j3 = i5;
                c2486.f9663.m10186(j3);
                interfaceC2322.skip(j3);
            }
        } else {
            final C4903 c49032 = new C4903();
            long j4 = i5;
            interfaceC2322.mo5353(j4);
            interfaceC2322.mo1490(c49032, j4);
            C5380.m10968(c4901.f18669, c4901.f18659 + '[' + i3 + "] onData", new InterfaceC1841(i3, c49032, i5, z4) { // from class: ᵬᵢᵽᵽ

                /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
                public final /* synthetic */ C4903 f15635;

                /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
                public final /* synthetic */ int f15636;

                /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
                public final /* synthetic */ int f15637;

                @Override // defpackage.InterfaceC1841
                /* JADX INFO: renamed from: ᵲᵶᵳˈ */
                public final Object mo1021() {
                    C4901 c49012 = this.f15634;
                    int i6 = this.f15636;
                    C4903 c49033 = this.f15635;
                    int i7 = this.f15637;
                    try {
                        c49012.f18646.getClass();
                        c49033.skip(i7);
                        c49012.f18664.m5767(i6, 9);
                        synchronized (c49012) {
                            c49012.f18652.remove(Integer.valueOf(i6));
                        }
                    } catch (IOException unused) {
                    }
                    return C5063.f19112;
                }
            });
        }
        this.f9318.skip(i4);
    }

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public final void m6108(C2486 c2486, int i, int i2, int i3) throws IOException {
        if (i != 8) {
            C1685.m4568(AbstractC2704.m6517(i, "TYPE_PING length != 8: "));
            return;
        }
        if (i3 != 0) {
            C1685.m4568("TYPE_PING streamId != 0");
            return;
        }
        int i4 = this.f9318.readInt();
        int i5 = this.f9318.readInt();
        boolean z = (i2 & 1) != 0;
        C4901 c4901 = c2486.f9663;
        if (!z) {
            C5380.m10968(c4901.f18656, AbstractC3653.m8231(new StringBuilder(), c2486.f9663.f18659, " ping"), new C0033(c2486.f9663, i4, i5, 1));
            return;
        }
        synchronized (c4901) {
            try {
                if (i4 == 1) {
                    c4901.f18663++;
                } else if (i4 == 2) {
                    c4901.f18648++;
                } else if (i4 == 3) {
                    c4901.notifyAll();
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    /* JADX INFO: renamed from: ᵟᵹᵙ, reason: contains not printable characters */
    public final void m6109(C2486 c2486, int i, int i2) throws IOException {
        int i3;
        Object[] array;
        if (i < 8) {
            C1685.m4568(AbstractC2704.m6517(i, "TYPE_GOAWAY length < 8: "));
            return;
        }
        if (i2 != 0) {
            C1685.m4568("TYPE_GOAWAY streamId != 0");
            return;
        }
        int i4 = this.f9318.readInt();
        int i5 = this.f9318.readInt();
        int i6 = i - 8;
        int[] iArrM8225 = AbstractC3653.m8225(14);
        int length = iArrM8225.length;
        int i7 = 0;
        while (true) {
            if (i7 >= length) {
                i3 = 0;
                break;
            }
            i3 = iArrM8225[i7];
            if (AbstractC3653.m8218(i3) == i5) {
                break;
            } else {
                i7++;
            }
        }
        if (i3 == 0) {
            C1685.m4568(AbstractC2704.m6517(i5, "TYPE_GOAWAY unexpected error code: "));
            return;
        }
        C1054 c1054Mo5343 = C1054.f4543;
        if (i6 > 0) {
            c1054Mo5343 = this.f9318.mo5343(i6);
        }
        c1054Mo5343.mo3458();
        C4901 c4901 = c2486.f9663;
        synchronized (c4901) {
            array = c4901.f18661.values().toArray(new C0217[0]);
            c4901.f18668 = true;
        }
        for (C0217 c0217 : (C0217[]) array) {
            if (c0217.f1702 > i4 && c0217.m1383()) {
                c0217.m1386(8);
                c2486.f9663.m10188(c0217.f1702);
            }
        }
    }

    /* JADX INFO: renamed from: ᵱʡˏ, reason: contains not printable characters */
    public final List m6110(int i, int i2, int i3, int i4) throws IOException {
        C4617 c4617 = this.f9320;
        c4617.f17562 = i;
        c4617.f17563 = i2;
        c4617.f17561 = i3;
        c4617.f17560 = i4;
        C4889 c4889 = this.f9319;
        C1978 c1978 = c4889.f18614;
        while (!c1978.mo5344()) {
            byte b = c1978.readByte();
            byte[] bArr = AbstractC1701.f6716;
            int i5 = b & 255;
            if (i5 == 128) {
                C1685.m4568("index == 0");
                return null;
            }
            if ((b & 128) == 128) {
                int iM10159 = c4889.m10159(i5, 127);
                int i6 = iM10159 - 1;
                if (i6 >= 0) {
                    C5511[] c5511Arr = AbstractC4640.f17639;
                    if (i6 <= c5511Arr.length - 1) {
                        c4889.m10157(c5511Arr[i6]);
                    }
                }
                int length = c4889.f18615 + 1 + (i6 - AbstractC4640.f17639.length);
                if (length >= 0) {
                    C5511[] c5511Arr2 = c4889.f18611;
                    if (length < c5511Arr2.length) {
                        c4889.m10157(c5511Arr2[length]);
                    }
                }
                C1685.m4568(AbstractC2704.m6517(iM10159, "Header index too large "));
                return null;
            }
            if (i5 == 64) {
                C5511[] c5511Arr3 = AbstractC4640.f17639;
                C1054 c1054M10156 = c4889.m10156();
                AbstractC4640.m9771(c1054M10156);
                c4889.m10158(new C5511(c1054M10156, c4889.m10156()));
            } else if ((b & 64) == 64) {
                c4889.m10158(new C5511(c4889.m10155(c4889.m10159(i5, 63) - 1), c4889.m10156()));
            } else if ((b & 32) == 32) {
                int iM101592 = c4889.m10159(i5, 31);
                c4889.f18612 = iM101592;
                if (iM101592 < 0 || iM101592 > 4096) {
                    throw new IOException("Invalid dynamic table size update " + c4889.f18612);
                }
                int i7 = c4889.f18609;
                if (iM101592 < i7) {
                    if (iM101592 == 0) {
                        AbstractC3761.m8429(c4889.f18611, null);
                        c4889.f18615 = c4889.f18611.length - 1;
                        c4889.f18613 = 0;
                        c4889.f18609 = 0;
                    } else {
                        c4889.m10154(i7 - iM101592);
                    }
                }
            } else if (i5 == 16 || i5 == 0) {
                C5511[] c5511Arr4 = AbstractC4640.f17639;
                C1054 c1054M101562 = c4889.m10156();
                AbstractC4640.m9771(c1054M101562);
                c4889.m10157(new C5511(c1054M101562, c4889.m10156()));
            } else {
                c4889.m10157(new C5511(c4889.m10155(c4889.m10159(i5, 15) - 1), c4889.m10156()));
            }
        }
        ArrayList arrayList = c4889.f18608;
        List listM8998 = AbstractC4126.m8998(arrayList);
        arrayList.clear();
        c4889.f18610 = 0L;
        return listM8998;
    }

    /* JADX WARN: Code restructure failed: missing block: B:87:0x012d, code lost:
    
        defpackage.C1685.m4568(defpackage.AbstractC2704.m6517(r7, "PROTOCOL_ERROR SETTINGS_MAX_FRAME_SIZE: "));
     */
    /* JADX WARN: Code restructure failed: missing block: B:88:0x0136, code lost:
    
        return false;
     */
    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final boolean m6111(boolean z, C2486 c2486) throws Exception {
        int iM4659;
        int i;
        try {
            this.f9318.mo5353(9L);
            iM4659 = AbstractC1701.m4659(this.f9318);
        } catch (EOFException unused) {
        }
        if (iM4659 > 16384) {
            C1685.m4568(AbstractC2704.m6517(iM4659, "FRAME_SIZE_ERROR: "));
            return false;
        }
        int i2 = this.f9318.readByte() & 255;
        byte b = this.f9318.readByte();
        int i3 = b & 255;
        int i4 = this.f9318.readInt();
        int i5 = Integer.MAX_VALUE & i4;
        if (i2 != 8) {
            Logger logger = f9317;
            if (logger.isLoggable(Level.FINE)) {
                logger.fine(AbstractC3401.m7801(true, i5, iM4659, i2, i3));
            }
        }
        if (z && i2 != 4) {
            ᵷᵝˎ.ᵶᵥᵝ(AbstractC3401.m7803(i2), "Expected a SETTINGS frame but was ");
            return false;
        }
        int i6 = 5;
        switch (i2) {
            case 0:
                m6107(c2486, iM4659, i3, i5);
                return true;
            case 1:
                m6106(c2486, iM4659, i3, i5);
                return true;
            case 2:
                if (iM4659 != 5) {
                    C1685.m4568(AbstractC0793.m2876(iM4659, "TYPE_PRIORITY length: ", " != 5"));
                    return false;
                }
                if (i5 == 0) {
                    C1685.m4568("TYPE_PRIORITY streamId == 0");
                    return false;
                }
                InterfaceC2322 interfaceC2322 = this.f9318;
                interfaceC2322.readInt();
                interfaceC2322.readByte();
                return true;
            case 3:
                if (iM4659 != 4) {
                    C1685.m4568(AbstractC0793.m2876(iM4659, "TYPE_RST_STREAM length: ", " != 4"));
                    return false;
                }
                if (i5 == 0) {
                    C1685.m4568("TYPE_RST_STREAM streamId == 0");
                    return false;
                }
                int i7 = this.f9318.readInt();
                int[] iArrM8225 = AbstractC3653.m8225(14);
                int length = iArrM8225.length;
                int i8 = 0;
                while (true) {
                    if (i8 < length) {
                        i = iArrM8225[i8];
                        if (AbstractC3653.m8218(i) != i7) {
                            i8++;
                        }
                    } else {
                        i = 0;
                    }
                }
                if (i == 0) {
                    C1685.m4568(AbstractC2704.m6517(i7, "TYPE_RST_STREAM unexpected error code: "));
                    return false;
                }
                C4901 c4901 = c2486.f9663;
                if (i5 == 0 || (i4 & 1) != 0) {
                    C0217 c0217M10188 = c4901.m10188(i5);
                    if (c0217M10188 != null) {
                        c0217M10188.m1386(i);
                    }
                    return true;
                }
                C5380.m10968(c4901.f18669, c4901.f18659 + '[' + i5 + "] onReset", new C2660(c4901, i5, i));
                return true;
            case 4:
                InterfaceC2322 interfaceC23222 = this.f9318;
                if (i5 != 0) {
                    C1685.m4568("TYPE_SETTINGS streamId != 0");
                    return false;
                }
                if ((b & 1) != 0) {
                    if (iM4659 != 0) {
                        C1685.m4568("FRAME_SIZE_ERROR ack frame should be empty!");
                        return false;
                    }
                    return true;
                }
                if (iM4659 % 6 != 0) {
                    C1685.m4568(AbstractC2704.m6517(iM4659, "TYPE_SETTINGS length % 6 != 0: "));
                    return false;
                }
                C2753 c2753 = new C2753();
                C5485 c5485 = ᵗʓ.ˑˊᵲ(ᵗʓ.ᵠˏˏ(0, iM4659), 6);
                int i9 = c5485.f20741;
                int i10 = c5485.f20743;
                int i11 = c5485.f20742;
                if ((i11 > 0 && i9 <= i10) || (i11 < 0 && i10 <= i9)) {
                    while (true) {
                        short s = interfaceC23222.readShort();
                        byte[] bArr = AbstractC1701.f6716;
                        int i12 = s & 65535;
                        int i13 = interfaceC23222.readInt();
                        if (i12 != 2) {
                            if (i12 != 4) {
                                if (i12 == 5 && (i13 < 16384 || i13 > 16777215)) {
                                }
                            } else if (i13 < 0) {
                                C1685.m4568("PROTOCOL_ERROR SETTINGS_INITIAL_WINDOW_SIZE > 2^31 - 1");
                                return false;
                            }
                        } else if (i13 != 0 && i13 != 1) {
                            C1685.m4568("PROTOCOL_ERROR SETTINGS_ENABLE_PUSH != 0 or 1");
                            return false;
                        }
                        c2753.m6659(i12, i13);
                        if (i9 != i10) {
                            i9 += i11;
                        }
                        break;
                    }
                }
                C4901 c49012 = c2486.f9663;
                C5380.m10968(c49012.f18656, AbstractC3653.m8231(new StringBuilder(), c49012.f18659, " applyAndAckSettings"), new C2520(c2486, i6, c2753));
                return true;
            case 5:
                m6105(c2486, iM4659, i3, i5);
                return true;
            case C5224.STRING_SET_FIELD_NUMBER /* 6 */:
                m6108(c2486, iM4659, i3, i5);
                return true;
            case C5224.DOUBLE_FIELD_NUMBER /* 7 */:
                m6109(c2486, iM4659, i5);
                return true;
            case C5224.BYTES_FIELD_NUMBER /* 8 */:
                try {
                    if (iM4659 != 4) {
                        throw new IOException("TYPE_WINDOW_UPDATE length !=4: " + iM4659);
                    }
                    long j = ((long) this.f9318.readInt()) & 2147483647L;
                    if (j == 0) {
                        throw new IOException("windowSizeIncrement was 0");
                    }
                    Logger logger2 = f9317;
                    if (logger2.isLoggable(Level.FINE)) {
                        logger2.fine(AbstractC3401.m7802(i5, iM4659, j, true));
                    }
                    C4901 c49013 = c2486.f9663;
                    if (i5 == 0) {
                        synchronized (c49013) {
                            c49013.f18645 += j;
                            c49013.notifyAll();
                        }
                        return true;
                    }
                    C0217 c0217M10184 = c49013.m10184(i5);
                    if (c0217M10184 != null) {
                        synchronized (c0217M10184) {
                            c0217M10184.f1709 += j;
                            if (j > 0) {
                                c0217M10184.notifyAll();
                            }
                            break;
                        }
                        return true;
                    }
                    return true;
                } catch (Exception e) {
                    f9317.fine(AbstractC3401.m7801(true, i5, iM4659, 8, i3));
                    throw e;
                }
            default:
                this.f9318.skip(iM4659);
                return true;
        }
    }
}