package defpackage;

import j$.util.Objects;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;
import java.util.logging.Level;

/* renamed from: ᵲᵰˆ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C4523 extends AbstractC5219 implements InterfaceFutureC2302 {

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

    /* renamed from: ᵡˎ, reason: contains not printable characters */
    public InterfaceFutureC2302 f16844;

    /* renamed from: ˇʼʤˎ, reason: contains not printable characters */
    public static Object m9610(Object obj) throws ExecutionException {
        if (obj instanceof C2740) {
            CancellationException cancellationException = new CancellationException("Task was cancelled.");
            cancellationException.initCause(((C2740) obj).f10613);
            throw cancellationException;
        }
        if (obj instanceof C3719) {
            throw new ExecutionException(((C3719) obj).f13885);
        }
        if (obj == AbstractC5219.f19490) {
            return null;
        }
        return obj;
    }

    /* renamed from: ˎˏʜʾ, reason: contains not printable characters */
    public static boolean m9611(Object obj) {
        return !(obj instanceof RunnableC1381);
    }

    /* renamed from: ᵶᵷᵕ, reason: contains not printable characters */
    public static void m9612(C4523 c4523) {
        C4575 c4575;
        C4575 c45752 = null;
        while (true) {
            c4523.getClass();
            for (C1406 c1406 = AbstractC5219.f19487.ˁˑᵰ(c4523); c1406 != null; c1406 = c1406.f5762) {
                Thread thread = c1406.f5761;
                if (thread != null) {
                    c1406.f5761 = null;
                    LockSupport.unpark(thread);
                }
            }
            InterfaceFutureC2302 interfaceFutureC2302 = c4523.f16844;
            if ((c4523.f19492 instanceof C2740) & (interfaceFutureC2302 != null)) {
                Object obj = c4523.f19492;
                interfaceFutureC2302.cancel((obj instanceof C2740) && ((C2740) obj).f10612);
            }
            ScheduledFuture scheduledFuture = c4523.f16843;
            if (scheduledFuture != null) {
                scheduledFuture.cancel(false);
            }
            c4523.f16844 = null;
            c4523.f16843 = null;
            C4575 c45753 = c45752;
            C4575 c45754 = AbstractC5219.f19487.ᐧﾞ(c4523);
            C4575 c45755 = c45753;
            while (c45754 != null) {
                C4575 c45756 = c45754.f17009;
                c45754.f17009 = c45755;
                c45755 = c45754;
                c45754 = c45756;
            }
            while (c45755 != null) {
                Runnable runnable = c45755.f17010;
                c4575 = c45755.f17009;
                Objects.requireNonNull(runnable);
                if (runnable instanceof RunnableC1381) {
                    RunnableC1381 runnableC1381 = (RunnableC1381) runnable;
                    c4523 = runnableC1381.f5684;
                    if (c4523.f19492 == runnableC1381) {
                        if (AbstractC5219.f19487.ˑᵝﹳᵜ(c4523, runnableC1381, m9614(runnableC1381.f5683))) {
                            break;
                        }
                    } else {
                        continue;
                    }
                } else {
                    Executor executor = c45755.f17011;
                    Objects.requireNonNull(executor);
                    m9613(runnable, executor);
                }
                c45755 = c4575;
            }
            return;
            c45752 = c4575;
        }
    }

    /* renamed from: ᵸˑ, reason: contains not printable characters */
    public static void m9613(Runnable runnable, Executor executor) {
        try {
            executor.execute(runnable);
        } catch (Exception e) {
            AbstractC5219.f19489.m10553().logp(Level.SEVERE, "com.google.common.util.concurrent.AbstractFuture", "executeListener", AbstractC3915.m8580("RuntimeException while executing runnable ", String.valueOf(runnable), " with executor ", String.valueOf(executor)), (Throwable) e);
        }
    }

    /* renamed from: ᵹᵝᵶ, reason: contains not printable characters */
    public static Object m9614(InterfaceFutureC2302 interfaceFutureC2302) {
        Object obj;
        Throwable thMo9617;
        if (interfaceFutureC2302 instanceof C4523) {
            Object c2740 = ((C4523) interfaceFutureC2302).f19492;
            if (c2740 instanceof C2740) {
                C2740 c27402 = (C2740) c2740;
                if (c27402.f10612) {
                    Throwable th = c27402.f10613;
                    c2740 = th != null ? new C2740(th, false) : C2740.f10611;
                }
            }
            Objects.requireNonNull(c2740);
            return c2740;
        }
        if ((interfaceFutureC2302 instanceof AbstractC5219) && (thMo9617 = ((AbstractC5219) interfaceFutureC2302).mo9617()) != null) {
            return new C3719(thMo9617);
        }
        boolean zIsCancelled = interfaceFutureC2302.isCancelled();
        boolean z = true;
        if ((!AbstractC5219.f19488) && zIsCancelled) {
            C2740 c27403 = C2740.f10611;
            Objects.requireNonNull(c27403);
            return c27403;
        }
        boolean z2 = false;
        while (true) {
            try {
                try {
                    try {
                        obj = interfaceFutureC2302.get();
                        break;
                    } catch (Error e) {
                        e = e;
                        return new C3719(e);
                    }
                } catch (InterruptedException unused) {
                    z2 = z;
                } catch (Throwable th2) {
                    if (z2) {
                        Thread.currentThread().interrupt();
                    }
                    throw th2;
                }
            } catch (Error | Exception e2) {
                e = e2;
                return new C3719(e);
            } catch (CancellationException e3) {
                return !zIsCancelled ? new C3719(new IllegalArgumentException("get() threw CancellationException, despite reporting isCancelled() == false: ".concat(String.valueOf(interfaceFutureC2302)), e3)) : new C2740(e3, false);
            } catch (ExecutionException e4) {
                return zIsCancelled ? new C2740(new IllegalArgumentException("get() did not throw CancellationException, despite reporting isCancelled() == true: ".concat(String.valueOf(interfaceFutureC2302)), e4), false) : new C3719(e4.getCause());
            }
        }
        if (z2) {
            Thread.currentThread().interrupt();
        }
        return zIsCancelled ? new C2740(new IllegalArgumentException("get() did not throw CancellationException, despite reporting isCancelled() == true: ".concat(String.valueOf(interfaceFutureC2302))), false) : obj == null ? AbstractC5219.f19490 : obj;
    }

    @Override // java.util.concurrent.Future
    public final boolean cancel(boolean z) {
        C2740 c2740;
        Object obj = this.f19492;
        if (!(obj instanceof RunnableC1381) && !(obj == null)) {
            return false;
        }
        if (AbstractC5219.f19488) {
            c2740 = new C2740(new CancellationException("Future.cancel() was called."), z);
        } else {
            c2740 = z ? C2740.f10610 : C2740.f10611;
            Objects.requireNonNull(c2740);
        }
        boolean z2 = false;
        while (true) {
            if (AbstractC5219.f19487.ˑᵝﹳᵜ(this, obj, c2740)) {
                m9612(this);
                if (!(obj instanceof RunnableC1381)) {
                    break;
                }
                InterfaceFutureC2302 interfaceFutureC2302 = ((RunnableC1381) obj).f5683;
                if (!(interfaceFutureC2302 instanceof C4523)) {
                    interfaceFutureC2302.cancel(z);
                    break;
                }
                this = (C4523) interfaceFutureC2302;
                obj = this.f19492;
                if (!(obj == null) && !(obj instanceof RunnableC1381)) {
                    break;
                }
                z2 = true;
            } else {
                obj = this.f19492;
                if (m9611(obj)) {
                    return z2;
                }
            }
        }
        return true;
    }

    @Override // java.util.concurrent.Future
    public final Object get() throws InterruptedException {
        Object obj;
        C1406 c1406 = C1406.f5760;
        if (Thread.interrupted()) {
            throw new InterruptedException();
        }
        Object obj2 = this.f19492;
        if ((obj2 != null) && m9611(obj2)) {
            return m9610(obj2);
        }
        C1406 c14062 = this.f19493;
        if (c14062 != c1406) {
            C1406 c14063 = new C1406();
            do {
                ᵺᵣᵬ r5 = AbstractC5219.f19487;
                r5.ﾞⁱ(c14063, c14062);
                if (r5.ˊᵸˊ(this, c14062, c14063)) {
                    do {
                        LockSupport.park(this);
                        if (Thread.interrupted()) {
                            m10835(c14063);
                            throw new InterruptedException();
                        }
                        obj = this.f19492;
                    } while (!((obj != null) & m9611(obj)));
                    return m9610(obj);
                }
                c14062 = this.f19493;
            } while (c14062 != c1406);
        }
        Object obj3 = this.f19492;
        Objects.requireNonNull(obj3);
        return m9610(obj3);
    }

    /* JADX WARN: Removed duplicated region for block: B:50:0x00a7  */
    /* JADX WARN: Removed duplicated region for block: B:63:0x00cd  */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:60:0x00c0 -> B:37:0x0080). Please report as a decompilation issue!!! */
    @Override // java.util.concurrent.Future
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final java.lang.Object get(long r20, java.util.concurrent.TimeUnit r22) throws java.lang.InterruptedException, java.util.concurrent.TimeoutException {
        /*
            Method dump skipped, instructions count: 385
            To view this dump add '--comments-level debug' option
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C4523.get(long, java.util.concurrent.TimeUnit):java.lang.Object");
    }

    @Override // java.util.concurrent.Future
    public final boolean isCancelled() {
        return this.f19492 instanceof C2740;
    }

    @Override // java.util.concurrent.Future
    public final boolean isDone() {
        Object obj = this.f19492;
        return (obj != null) & m9611(obj);
    }

    /* JADX WARN: Removed duplicated region for block: B:38:0x00ae  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final java.lang.String toString() {
        /*
            r6 = this;
            java.lang.StringBuilder r0 = new java.lang.StringBuilder
            r0.<init>()
            java.lang.Class r1 = r6.getClass()
            java.lang.String r1 = r1.getName()
            java.lang.String r2 = "com.google.common.util.concurrent."
            boolean r1 = r1.startsWith(r2)
            if (r1 == 0) goto L21
            java.lang.Class r1 = r6.getClass()
            java.lang.String r1 = r1.getSimpleName()
            r0.append(r1)
            goto L2c
        L21:
            java.lang.Class r1 = r6.getClass()
            java.lang.String r1 = r1.getName()
            r0.append(r1)
        L2c:
            r1 = 64
            r0.append(r1)
            int r1 = java.lang.System.identityHashCode(r6)
            java.lang.String r1 = java.lang.Integer.toHexString(r1)
            r0.append(r1)
            java.lang.String r1 = "[status="
            r0.append(r1)
            java.lang.Object r1 = r6.f19492
            boolean r1 = r1 instanceof defpackage.C2740
            java.lang.String r2 = "]"
            if (r1 == 0) goto L50
            java.lang.String r6 = "CANCELLED"
            r0.append(r6)
            goto Le8
        L50:
            boolean r1 = r6.isDone()
            if (r1 == 0) goto L5b
            r6.m9616(r0)
            goto Le8
        L5b:
            int r1 = r0.length()
            java.lang.String r3 = "PENDING"
            r0.append(r3)
            java.lang.Object r3 = r6.f19492
            boolean r4 = r3 instanceof defpackage.RunnableC1381
            java.lang.String r5 = "Exception thrown from implementation: "
            if (r4 == 0) goto L9d
            java.lang.String r4 = ", setFuture=["
            r0.append(r4)
            ˊᵬˋʦ r3 = (defpackage.RunnableC1381) r3
            ᵕᵟʤʼ r3 = r3.f5683
            if (r3 != r6) goto L7f
            java.lang.String r3 = "this future"
            r0.append(r3)     // Catch: java.lang.Throwable -> L7d
            goto L99
        L7d:
            r3 = move-exception
            goto L83
        L7f:
            r0.append(r3)     // Catch: java.lang.Throwable -> L7d
            goto L99
        L83:
            boolean r4 = r3 instanceof java.lang.Error
            if (r4 == 0) goto L8f
            boolean r4 = r3 instanceof java.lang.StackOverflowError
            if (r4 == 0) goto L8c
            goto L8f
        L8c:
            java.lang.Error r3 = (java.lang.Error) r3
            throw r3
        L8f:
            r0.append(r5)
            java.lang.Class r3 = r3.getClass()
            r0.append(r3)
        L99:
            r0.append(r2)
            goto Ld8
        L9d:
            java.lang.String r3 = r6.m9615()     // Catch: java.lang.Throwable -> Lac
            if (r3 == 0) goto Lae
            boolean r4 = r3.isEmpty()     // Catch: java.lang.Throwable -> Lac
            if (r4 == 0) goto Laa
            goto Lae
        Laa:
            r4 = 0
            goto Laf
        Lac:
            r3 = move-exception
            goto Lb3
        Lae:
            r4 = 1
        Laf:
            if (r4 == 0) goto Lcb
            r3 = 0
            goto Lcb
        Lb3:
            boolean r4 = r3 instanceof java.lang.Error
            if (r4 == 0) goto Lbf
            boolean r4 = r3 instanceof java.lang.StackOverflowError
            if (r4 == 0) goto Lbc
            goto Lbf
        Lbc:
            java.lang.Error r3 = (java.lang.Error) r3
            throw r3
        Lbf:
            java.lang.Class r3 = r3.getClass()
            java.lang.String r3 = java.lang.String.valueOf(r3)
            java.lang.String r3 = r5.concat(r3)
        Lcb:
            if (r3 == 0) goto Ld8
            java.lang.String r4 = ", info=["
            r0.append(r4)
            r0.append(r3)
            r0.append(r2)
        Ld8:
            boolean r3 = r6.isDone()
            if (r3 == 0) goto Le8
            int r3 = r0.length()
            r0.delete(r1, r3)
            r6.m9616(r0)
        Le8:
            r0.append(r2)
            java.lang.String r6 = r0.toString()
            return r6
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C4523.toString():java.lang.String");
    }

    /* renamed from: ˏˋٴ, reason: contains not printable characters */
    public final String m9615() {
        InterfaceFutureC2302 interfaceFutureC2302 = this.f16844;
        ScheduledFuture scheduledFuture = this.f16843;
        if (interfaceFutureC2302 == null) {
            return null;
        }
        String strM9550 = AbstractC4486.m9550("inputFuture=[", interfaceFutureC2302.toString(), "]");
        if (scheduledFuture != null) {
            long delay = scheduledFuture.getDelay(TimeUnit.MILLISECONDS);
            if (delay > 0) {
                return strM9550 + ", remaining delay=[" + delay + " ms]";
            }
        }
        return strM9550;
    }

    /* renamed from: ᵝᵵᵺ, reason: contains not printable characters */
    public final void m9616(StringBuilder sb) {
        Object obj;
        boolean z = false;
        while (true) {
            try {
                try {
                    obj = get();
                    break;
                } catch (InterruptedException unused) {
                    z = true;
                } catch (Throwable th) {
                    if (z) {
                        Thread.currentThread().interrupt();
                    }
                    throw th;
                }
            } catch (CancellationException unused2) {
                sb.append("CANCELLED");
                return;
            } catch (ExecutionException e) {
                sb.append("FAILURE, cause=[");
                sb.append(e.getCause());
                sb.append("]");
                return;
            } catch (Exception e2) {
                sb.append("UNKNOWN, cause=[");
                sb.append(e2.getClass());
                sb.append(" thrown from get()]");
                return;
            }
        }
        if (z) {
            Thread.currentThread().interrupt();
        }
        sb.append("SUCCESS, result=[");
        if (obj == null) {
            sb.append("null");
        } else if (obj == this) {
            sb.append("this future");
        } else {
            sb.append(obj.getClass().getName());
            sb.append("@");
            sb.append(Integer.toHexString(System.identityHashCode(obj)));
        }
        sb.append("]");
    }

    @Override // defpackage.InterfaceFutureC2302
    /* renamed from: ᵴᵳ */
    public final void mo5509(Runnable runnable, Executor executor) {
        C4575 c4575;
        C4575 c45752 = C4575.f17008;
        if (executor == null) {
            C1260.m3813("Executor was null.");
            return;
        }
        if (!isDone() && (c4575 = this.f19491) != c45752) {
            C4575 c45753 = new C4575(runnable, executor);
            do {
                c45753.f17009 = c4575;
                if (AbstractC5219.f19487.ᵡᵘˎʽ(this, c4575, c45753)) {
                    return;
                } else {
                    c4575 = this.f19491;
                }
            } while (c4575 != c45752);
        }
        m9613(runnable, executor);
    }

    @Override // defpackage.AbstractC5219
    /* renamed from: ᵻᵢﹳᵰ, reason: contains not printable characters */
    public final Throwable mo9617() {
        if (!(this instanceof C4523)) {
            return null;
        }
        Object obj = this.f19492;
        if (obj instanceof C3719) {
            return ((C3719) obj).f13885;
        }
        return null;
    }
}