package defpackage;

import java.io.IOException;
import java.io.InterruptedIOException;
import java.lang.ref.Reference;
import java.net.Socket;
import java.util.ArrayDeque;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.TimeZone;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

/* renamed from: ˌˋˎᵚ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C1588 implements Cloneable {

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public InterfaceC3060 f6292;

    /* renamed from: ˁˑᵰ, reason: contains not printable characters */
    public volatile boolean f6293;

    /* renamed from: ˎˑː, reason: contains not printable characters */
    public C4699 f6294;

    /* renamed from: ˑᵥˁ, reason: contains not printable characters */
    public boolean f6295;

    /* renamed from: ᐧﾞ, reason: contains not printable characters */
    public boolean f6296;

    /* renamed from: ᵙᵢᵨᵳ, reason: contains not printable characters */
    public final CopyOnWriteArrayList f6297;

    /* renamed from: ᵡˎ, reason: contains not printable characters */
    public C0700 f6298;

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

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final C1947 f6300;

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public final AtomicBoolean f6301;

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

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

    /* renamed from: ᵮᵠـˌ, reason: contains not printable characters */
    public boolean f6304;

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

    /* renamed from: ᵺʙ, reason: contains not printable characters */
    public boolean f6306;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public final C4370 f6307;

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

    /* renamed from: ﾞⁱ, reason: contains not printable characters */
    public volatile C4699 f6309;

    public C1588(C3914 c3914, C1947 c1947) {
        this.f6303 = c3914;
        this.f6300 = c1947;
        this.f6308 = (C5557) c3914.f14700.f11366;
        c3914.f14714.getClass();
        C4370 c4370 = new C4370(this);
        c4370.mo8741(0L);
        this.f6307 = c4370;
        this.f6301 = new AtomicBoolean();
        this.f6305 = true;
        this.f6297 = new CopyOnWriteArrayList();
        new AtomicReference(c1947.f7847);
    }

    /* renamed from: ᵴᵳ, reason: contains not printable characters */
    public static final String m4558(C1588 c1588) {
        StringBuilder sb = new StringBuilder();
        sb.append(c1588.f6293 ? "canceled " : "");
        sb.append("call");
        sb.append(" to ");
        sb.append(c1588.f6300.f7850.m4415());
        return sb.toString();
    }

    public final void cancel() {
        if (this.f6293) {
            return;
        }
        this.f6293 = true;
        C4699 c4699 = this.f6309;
        if (c4699 != null) {
            ((InterfaceC4906) c4699.f17374).cancel();
        }
        Iterator it = this.f6297.iterator();
        while (it.hasNext()) {
            ((InterfaceC0041) it.next()).cancel();
        }
    }

    public final Object clone() {
        return new C1588(this.f6303, this.f6300);
    }

    /* renamed from: ˇʼʤˎ, reason: contains not printable characters */
    public final IOException m4559(IOException iOException) {
        Socket socketM4560;
        TimeZone timeZone = AbstractC4061.f15224;
        C0700 c0700 = this.f6298;
        if (c0700 != null) {
            synchronized (c0700) {
                socketM4560 = m4560();
            }
            if (this.f6298 == null) {
                if (socketM4560 != null) {
                    AbstractC4061.m8927(socketM4560);
                }
            } else if (socketM4560 != null) {
                ᵹˉᵞ.ᵳٴᵶ("Check failed.");
                return null;
            }
        }
        if (this.f6295 || !this.f6307.m9834()) {
            return iOException;
        }
        InterruptedIOException interruptedIOException = new InterruptedIOException("timeout");
        if (iOException != null) {
            interruptedIOException.initCause(iOException);
        }
        return interruptedIOException;
    }

    /* renamed from: ˌᵜᵹᵩ, reason: contains not printable characters */
    public final Socket m4560() {
        C0700 c0700 = this.f6298;
        TimeZone timeZone = AbstractC4061.f15224;
        ArrayList arrayList = c0700.f3399;
        int size = arrayList.size();
        int i = 0;
        int i2 = 0;
        while (true) {
            if (i2 >= size) {
                i = -1;
                break;
            }
            Object obj = arrayList.get(i2);
            i2++;
            if (ᵲᵝᵪ.ᵹᵝᵶ(((Reference) obj).get(), this)) {
                break;
            }
            i++;
        }
        if (i == -1) {
            ᵹˉᵞ.ᵳٴᵶ("Check failed.");
            return null;
        }
        arrayList.remove(i);
        this.f6298 = null;
        if (!arrayList.isEmpty()) {
            return null;
        }
        c0700.f3405 = System.nanoTime();
        C5557 c5557 = this.f6308;
        ConcurrentLinkedQueue concurrentLinkedQueue = (ConcurrentLinkedQueue) c5557.f20845;
        C0897 c0897 = (C0897) c5557.f20844;
        TimeZone timeZone2 = AbstractC4061.f15224;
        if (!c0700.f3410) {
            c0897.m3020((C0898) c5557.f20842, 0L);
            return null;
        }
        c0700.f3410 = true;
        concurrentLinkedQueue.remove(c0700);
        if (concurrentLinkedQueue.isEmpty()) {
            c0897.m3018();
        }
        return c0700.f3398;
    }

    /* renamed from: ˎˏʜʾ, reason: contains not printable characters */
    public final C2977 m4561() {
        if (!this.f6301.compareAndSet(false, true)) {
            ᵹˉᵞ.ᵳٴᵶ("Already Executed");
            return null;
        }
        this.f6307.m9835();
        AbstractC0761 abstractC0761 = AbstractC0761.f3627;
        this.f6299 = AbstractC0761.f3627.mo2841();
        try {
            ᵮᵥٴ r2 = this.f6303.f14703;
            synchronized (r2) {
                ((ArrayDeque) r2.ᵤᵙᵷ).add(this);
            }
            return m4563();
        } finally {
            ᵮᵥٴ r3 = this.f6303.f14703;
            r3.getClass();
            ᵮᵥٴ.ᵡᵘˎʽ(r3, (RunnableC4064) null, this, (RunnableC4064) null, 5);
        }
    }

    /* renamed from: ˏˋٴ, reason: contains not printable characters */
    public final void m4562(InterfaceC3314 interfaceC3314) {
        if (!this.f6301.compareAndSet(false, true)) {
            ᵹˉᵞ.ᵳٴᵶ("Already Executed");
            return;
        }
        AbstractC0761 abstractC0761 = AbstractC0761.f3627;
        this.f6299 = AbstractC0761.f3627.mo2841();
        ᵮᵥٴ r0 = this.f6303.f14703;
        RunnableC4064 runnableC4064 = new RunnableC4064(this, interfaceC3314);
        r0.getClass();
        ᵮᵥٴ.ᵡᵘˎʽ(r0, runnableC4064, (C1588) null, (RunnableC4064) null, 6);
    }

    /* JADX WARN: Removed duplicated region for block: B:16:0x0074  */
    /* 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 defpackage.C2977 m4563() throws java.lang.Throwable {
        /*
            r11 = this;
            java.util.ArrayList r2 = new java.util.ArrayList
            r2.<init>()
            ᵪᵹˀ r0 = r11.f6303
            java.util.List r0 = r0.f14709
            defpackage.AbstractC2767.m6826(r0, r2)
            ᵨᵺᵶ r0 = new ᵨᵺᵶ
            ᵪᵹˀ r1 = r11.f6303
            r9 = 1
            r0.<init>(r9, r1)
            r2.add(r0)
            ᵨᵺᵶ r0 = new ᵨᵺᵶ
            ᵪᵹˀ r1 = r11.f6303
            ᵖᵜˑ r1 = r1.f14710
            r10 = 0
            r0.<init>(r10, r1)
            r2.add(r0)
            ᵗᵦ r0 = new ᵗᵦ
            r1 = 2
            r0.<init>(r1)
            r2.add(r0)
            ᵗᵦ r0 = defpackage.C2466.f9635
            r2.add(r0)
            ᵪᵹˀ r0 = r11.f6303
            java.util.List r0 = r0.f14695
            defpackage.AbstractC2767.m6826(r0, r2)
            ᵗᵦ r0 = defpackage.C2466.f9636
            r2.add(r0)
            ᵼˆˏˈ r0 = new ᵼˆˏˈ
            ːˀᵹᵨ r5 = r11.f6300
            ᵪᵹˀ r1 = r11.f6303
            int r6 = r1.f14704
            int r7 = r1.f14701
            int r8 = r1.f14716
            r3 = 0
            r4 = 0
            r1 = r11
            r0.<init>(r1, r2, r3, r4, r5, r6, r7, r8)
            r11 = 0
            ᵞᵞᵞ r0 = r0.m10902(r5)     // Catch: java.lang.Throwable -> L68 java.io.IOException -> L6b
            boolean r2 = r1.f6293     // Catch: java.lang.Throwable -> L68 java.io.IOException -> L6b
            if (r2 != 0) goto L5d
            r1.m4565(r11)
            return r0
        L5d:
            defpackage.AbstractC1348.m4181(r0)     // Catch: java.lang.Throwable -> L68 java.io.IOException -> L6b
            java.io.IOException r0 = new java.io.IOException     // Catch: java.lang.Throwable -> L68 java.io.IOException -> L6b
            java.lang.String r2 = "Canceled"
            r0.<init>(r2)     // Catch: java.lang.Throwable -> L68 java.io.IOException -> L6b
            throw r0     // Catch: java.lang.Throwable -> L68 java.io.IOException -> L6b
        L68:
            r0 = move-exception
            r9 = r10
            goto L72
        L6b:
            r0 = move-exception
            java.io.IOException r0 = r1.m4565(r0)     // Catch: java.lang.Throwable -> L71
            throw r0     // Catch: java.lang.Throwable -> L71
        L71:
            r0 = move-exception
        L72:
            if (r9 != 0) goto L77
            r1.m4565(r11)
        L77:
            throw r0
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C1588.m4563():ᵞᵞᵞ");
    }

    /* renamed from: ᵶᵷᵕ, reason: contains not printable characters */
    public final IOException m4564(C4699 c4699, boolean z, boolean z2, boolean z3, boolean z4, IOException iOException) {
        boolean z5;
        boolean z6;
        if (c4699.equals(this.f6309)) {
            synchronized (this) {
                z5 = false;
                if (z) {
                    try {
                        if (!this.f6304) {
                            if ((z2 || !this.f6302) && ((!z4 || !this.f6306) && (!z3 || !this.f6296))) {
                            }
                        }
                        if (z) {
                            this.f6304 = false;
                        }
                        if (z2) {
                            this.f6302 = false;
                        }
                        if (z4) {
                            this.f6306 = false;
                        }
                        if (z3) {
                            this.f6296 = false;
                        }
                        boolean z7 = (this.f6304 || this.f6302 || this.f6306 || this.f6296) ? false : true;
                        if (z7) {
                            if (!this.f6305) {
                                z5 = true;
                            }
                        }
                        boolean z8 = z7;
                        z6 = z5;
                        z5 = z8;
                    } catch (Throwable th) {
                        throw th;
                    }
                } else {
                    z6 = z2 ? false : false;
                }
            }
            if (z5) {
                this.f6309 = null;
                C0700 c0700 = this.f6298;
                if (c0700 != null) {
                    c0700.m2700();
                }
            }
            if (z6) {
                return m4559(iOException);
            }
        }
        return iOException;
    }

    /* renamed from: ᵸˑ, reason: contains not printable characters */
    public final IOException m4565(IOException iOException) {
        boolean z;
        synchronized (this) {
            z = false;
            if (this.f6305) {
                this.f6305 = false;
                if (!this.f6304 && !this.f6302 && !this.f6306) {
                    if (!this.f6296) {
                        z = true;
                    }
                }
            }
        }
        return z ? m4559(iOException) : iOException;
    }

    /* renamed from: ᵹᵝᵶ, reason: contains not printable characters */
    public final void m4566(boolean z) {
        C4699 c4699;
        synchronized (this) {
            if (!this.f6305) {
                throw new IllegalStateException("released");
            }
        }
        if (z && (c4699 = this.f6309) != null) {
            ((InterfaceC4906) c4699.f17374).cancel();
            ((C1588) c4699.f17372).m4564(c4699, true, true, true, true, null);
        }
        this.f6294 = null;
    }

    /* renamed from: ᵻᵢﹳᵰ, reason: contains not printable characters */
    public final void m4567(C0700 c0700) {
        TimeZone timeZone = AbstractC4061.f15224;
        if (this.f6298 != null) {
            ᵹˉᵞ.ᵳٴᵶ("Check failed.");
        } else {
            this.f6298 = c0700;
            c0700.f3399.add(new C5007(this, this.f6299));
        }
    }
}