package defpackage;

import java.io.IOException;
import java.io.InterruptedIOException;
import java.net.ProtocolException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Locale;
import okhttp3.internal.http2.ConnectionShutdownException;
import okhttp3.internal.http2.StreamResetException;

/* JADX INFO: renamed from: ʿᵩˑ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C0458 implements InterfaceC0340 {

    /* JADX INFO: renamed from: ʽˈˋ, reason: contains not printable characters */
    public final C2729 f2510;

    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    public final C4901 f2511;

    /* JADX INFO: renamed from: ᵨᵣ, reason: contains not printable characters */
    public final EnumC0876 f2512;

    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    public final C4013 f2513;

    /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */
    public volatile C0217 f2514;

    /* JADX INFO: renamed from: ᵻˈᵦʼ, reason: contains not printable characters */
    public volatile boolean f2515;

    /* JADX INFO: renamed from: ᵵᵽ, reason: contains not printable characters */
    public static final List f2509 = AbstractC1190.m3668(new String[]{"connection", "host", "keep-alive", "proxy-connection", "te", "transfer-encoding", "encoding", "upgrade", ":method", ":path", ":scheme", ":authority"});

    /* JADX INFO: renamed from: ˊᵫᵗ, reason: contains not printable characters */
    public static final List f2508 = AbstractC1190.m3668(new String[]{"connection", "host", "keep-alive", "proxy-connection", "te", "transfer-encoding", "encoding", "upgrade"});

    public C0458(C3423 c3423, C4013 c4013, C2729 c2729, C4901 c4901) {
        this.f2513 = c4013;
        this.f2510 = c2729;
        this.f2511 = c4901;
        List list = c3423.f13185;
        EnumC0876 enumC0876 = EnumC0876.f3880;
        this.f2512 = list.contains(enumC0876) ? enumC0876 : EnumC0876.f3879;
    }

    @Override // defpackage.InterfaceC0340
    public final void cancel() {
        this.f2515 = true;
        C0217 c0217 = this.f2514;
        if (c0217 != null) {
            c0217.m1393(9);
        }
    }

    @Override // defpackage.InterfaceC0340
    /* JADX INFO: renamed from: ʽˈˋ */
    public final InterfaceC3906 mo1596(C1120 c1120) {
        return this.f2514.f1703;
    }

    @Override // defpackage.InterfaceC0340
    /* JADX INFO: renamed from: ˊᵫᵗ */
    public final InterfaceC2210 mo1597() {
        return this.f2514;
    }

    @Override // defpackage.InterfaceC0340
    /* JADX INFO: renamed from: ːˏᵟᵯ */
    public final void mo1598() throws IOException {
        this.f2514.f1711.close();
    }

    /* JADX WARN: Removed duplicated region for block: B:19:0x002d  */
    @Override // defpackage.InterfaceC0340
    /* JADX INFO: renamed from: ᵨᵣ */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final C2651 mo1599(boolean z) throws IOException {
        C0661 c0661;
        C0217 c0217 = this.f2514;
        if (c0217 == null) {
            C1685.m4568("stream wasn't created");
            return null;
        }
        synchronized (c0217) {
            while (true) {
                if (!c0217.f1710.isEmpty() || c0217.m1389() != 0) {
                    break;
                }
                if (!z) {
                    c0217.f1706.getClass();
                    C5198 c5198 = c0217.f1711;
                    boolean z2 = c5198.f19583 || c5198.f19582;
                    if (z2) {
                        c0217.f1704.m10664();
                    }
                    try {
                        try {
                            c0217.wait();
                            if (z2) {
                                c0217.f1704.m5675();
                            }
                        } catch (InterruptedException unused) {
                            Thread.currentThread().interrupt();
                            throw new InterruptedIOException();
                        }
                    } catch (Throwable th) {
                        if (z2) {
                            c0217.f1704.m5675();
                        }
                        throw th;
                    }
                }
            }
            if (c0217.f1710.isEmpty()) {
                IOException iOException = c0217.f1701;
                if (iOException != null) {
                    throw iOException;
                }
                throw new StreamResetException(c0217.m1389());
            }
            c0661 = (C0661) c0217.f1710.removeFirst();
        }
        EnumC0876 enumC0876 = this.f2512;
        ArrayList arrayList = new ArrayList(20);
        int size = c0661.size();
        C1404 c1404 = null;
        for (int i = 0; i < size; i++) {
            String strM2426 = c0661.m2426(i);
            String strM2429 = c0661.m2429(i);
            if (strM2426.equals(":status")) {
                c1404 = ᵲᵧˇ.ˏːˆ("HTTP/1.1 ".concat(strM2429));
            } else if (!f2508.contains(strM2426)) {
                arrayList.add(strM2426);
                arrayList.add(AbstractC3801.m8464(strM2429).toString());
            }
        }
        if (c1404 == null) {
            throw new ProtocolException("Expected ':status' header not present");
        }
        C2651 c2651 = new C2651();
        c2651.f10269 = enumC0876;
        c2651.f10272 = c1404.f5808;
        c2651.f10281 = (String) c1404.f5809;
        String[] strArr = (String[]) arrayList.toArray(new String[0]);
        C4759 c4759 = new C4759();
        c4759.f18134.addAll(Arrays.asList(strArr));
        c2651.f10283 = c4759;
        if (z && c2651.f10272 == 100) {
            return null;
        }
        return c2651;
    }

    @Override // defpackage.InterfaceC0340
    /* JADX INFO: renamed from: ᵱᵽʡᵚ */
    public final void mo1600(C4402 c4402) {
        int i;
        C0217 c0217;
        boolean z;
        if (this.f2514 != null) {
            return;
        }
        boolean z2 = c4402.f16709 != null;
        C0661 c0661 = c4402.f16706;
        ArrayList arrayList = new ArrayList(c0661.size() + 4);
        arrayList.add(new C5511(C5511.f20814, c4402.f16705));
        C1054 c1054 = C5511.f20811;
        C1695 c1695 = c4402.f16708;
        String strM4635 = c1695.m4635();
        String strM4641 = c1695.m4641();
        if (strM4641 != null) {
            strM4635 = strM4635 + '?' + strM4641;
        }
        arrayList.add(new C5511(c1054, strM4635));
        String strM2425 = c0661.m2425("Host");
        if (strM2425 != null) {
            arrayList.add(new C5511(C5511.f20813, strM2425));
        }
        arrayList.add(new C5511(C5511.f20809, c1695.f6698));
        int size = c0661.size();
        for (int i2 = 0; i2 < size; i2++) {
            String lowerCase = c0661.m2426(i2).toLowerCase(Locale.US);
            if (!f2509.contains(lowerCase) || (lowerCase.equals("te") && c0661.m2429(i2).equals("trailers"))) {
                arrayList.add(new C5511(lowerCase, c0661.m2429(i2)));
            }
        }
        C4901 c4901 = this.f2511;
        boolean z3 = !z2;
        synchronized (c4901.f18664) {
            synchronized (c4901) {
                try {
                    if (c4901.f18666 > 1073741823) {
                        c4901.m10183(8);
                    }
                    if (c4901.f18668) {
                        throw new ConnectionShutdownException();
                    }
                    i = c4901.f18666;
                    c4901.f18666 = i + 2;
                    c0217 = new C0217(i, c4901, z3, false, null);
                    z = !z2 || c4901.f18657 >= c4901.f18645 || c0217.f1708 >= c0217.f1709;
                    if (c0217.m1392()) {
                        c4901.f18661.put(Integer.valueOf(i), c0217);
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
            c4901.f18664.m5768(z3, i, arrayList);
        }
        if (z) {
            c4901.f18664.flush();
        }
        this.f2514 = c0217;
        boolean z4 = this.f2515;
        C0217 c02172 = this.f2514;
        if (z4) {
            c02172.m1393(9);
            C1685.m4568("Canceled");
        } else {
            c02172.f1704.mo3055(this.f2510.f10494);
            this.f2514.f1699.mo3055(this.f2510.f10481);
        }
    }

    @Override // defpackage.InterfaceC0340
    /* JADX INFO: renamed from: ᵲᵶᵳˈ */
    public final InterfaceC1636 mo1601(C4402 c4402, long j) {
        return this.f2514.f1711;
    }

    @Override // defpackage.InterfaceC0340
    /* JADX INFO: renamed from: ᵵᵽ */
    public final void mo1602() {
        this.f2511.flush();
    }

    /* JADX WARN: Removed duplicated region for block: B:12:0x0019  */
    @Override // defpackage.InterfaceC0340
    /* JADX INFO: renamed from: ᵷᵺʾᵖ */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final boolean mo1603() {
        boolean z;
        C0217 c0217 = this.f2514;
        if (c0217 != null) {
            synchronized (c0217) {
                C3439 c3439 = c0217.f1703;
                if (c3439.f13269) {
                    z = c3439.f13270.mo5344();
                }
            }
            if (z) {
                return true;
            }
        }
        return false;
    }

    @Override // defpackage.InterfaceC0340
    /* JADX INFO: renamed from: ᵻʽᵯ */
    public final InterfaceC4678 mo1604() {
        return this.f2513;
    }

    @Override // defpackage.InterfaceC0340
    /* JADX INFO: renamed from: ᵻˈᵦʼ */
    public final long mo1605(C1120 c1120) {
        if (AbstractC1384.m3961(c1120)) {
            return AbstractC1190.m3671(c1120);
        }
        return 0L;
    }
}