package defpackage;

import com.google.common.util.concurrent.ListenableFuture;
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.atomic.AtomicReferenceFieldUpdater;
import java.util.concurrent.locks.LockSupport;
import java.util.logging.Level;
import java.util.logging.Logger;

/* renamed from: ᵦᵳˎ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public abstract class AbstractC3606 implements ListenableFuture {

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public static final Object f13445;

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public static final ᵛᵾˏ f13446;

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public static final C5081 f13447;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public static final boolean f13448;

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public volatile C3736 f13449;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public volatile Object f13450;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public volatile C3897 f13451;

    static {
        boolean z;
        Throwable th;
        ᵛᵾˏ c0430;
        try {
            z = Boolean.parseBoolean(System.getProperty("guava.concurrent.generate_cancellation_cause", "false"));
        } catch (SecurityException unused) {
            z = false;
        }
        f13448 = z;
        f13447 = new C5081(0, AbstractC3606.class);
        Throwable th2 = null;
        try {
            c0430 = new C4676();
            th = null;
        } catch (Error | Exception e) {
            th = e;
            try {
                c0430 = new C0148(AtomicReferenceFieldUpdater.newUpdater(C3897.class, Thread.class, "ᵥᵯˎ"), AtomicReferenceFieldUpdater.newUpdater(C3897.class, C3897.class, "ᵴᵳ"), AtomicReferenceFieldUpdater.newUpdater(AbstractC3606.class, C3897.class, "ᵿʗᵝʽ"), AtomicReferenceFieldUpdater.newUpdater(AbstractC3606.class, C3736.class, "ᵢˇᵭ"), AtomicReferenceFieldUpdater.newUpdater(AbstractC3606.class, Object.class, "ᵧᵾˀˈ"));
            } catch (Error | Exception e2) {
                th2 = e2;
                c0430 = new C0430();
            }
        }
        f13446 = c0430;
        if (th2 != null) {
            C5081 c5081 = f13447;
            Logger loggerM10552 = c5081.m10552();
            Level level = Level.SEVERE;
            loggerM10552.log(level, "UnsafeAtomicHelper is broken!", th);
            c5081.m10552().log(level, "SafeAtomicHelper is broken!", th2);
        }
        f13445 = new Object();
    }

    /* renamed from: ˎˏʜʾ, reason: contains not printable characters */
    public static void m8208(Runnable runnable, Executor executor) {
        try {
            executor.execute(runnable);
        } catch (Exception e) {
            f13447.m10552().log(Level.SEVERE, "RuntimeException while executing runnable " + runnable + " with executor " + executor, (Throwable) e);
        }
    }

    /* renamed from: ˏˋٴ, reason: contains not printable characters */
    public static void m8209(AbstractC3606 abstractC3606, boolean z) {
        C3736 c3736 = null;
        while (true) {
            for (C3897 c3897 = f13446.ˎˑː(abstractC3606); c3897 != null; c3897 = c3897.f14531) {
                Thread thread = c3897.f14530;
                if (thread != null) {
                    c3897.f14530 = null;
                    LockSupport.unpark(thread);
                }
            }
            if (z) {
                abstractC3606.mo8220();
                z = false;
            }
            abstractC3606.mo1033();
            C3736 c37362 = c3736;
            C3736 c37363 = f13446.ˑᵥˁ(abstractC3606);
            C3736 c37364 = c37362;
            while (c37363 != null) {
                C3736 c37365 = c37363.f13949;
                c37363.f13949 = c37364;
                c37364 = c37363;
                c37363 = c37365;
            }
            while (c37364 != null) {
                c3736 = c37364.f13949;
                Runnable runnable = c37364.f13950;
                Objects.requireNonNull(runnable);
                if (runnable instanceof RunnableC3146) {
                    RunnableC3146 runnableC3146 = (RunnableC3146) runnable;
                    abstractC3606 = runnableC3146.f11958;
                    if (abstractC3606.f13450 == runnableC3146) {
                        if (f13446.ˎˏʜʾ(abstractC3606, runnableC3146, m8210(runnableC3146.f11957))) {
                            break;
                        }
                    } else {
                        continue;
                    }
                } else {
                    Executor executor = c37364.f13951;
                    Objects.requireNonNull(executor);
                    m8208(runnable, executor);
                }
                c37364 = c3736;
            }
            return;
        }
    }

    /* renamed from: ᵝᵵᵺ, reason: contains not printable characters */
    public static Object m8210(ListenableFuture listenableFuture) {
        Object obj;
        Throwable thM8213;
        if (listenableFuture instanceof InterfaceC4319) {
            Object c3361 = ((AbstractC3606) listenableFuture).f13450;
            if (c3361 instanceof C3361) {
                C3361 c33612 = (C3361) c3361;
                if (c33612.f12571) {
                    c3361 = c33612.f12572 != null ? new C3361(c33612.f12572, false) : C3361.f12570;
                }
            }
            Objects.requireNonNull(c3361);
            return c3361;
        }
        if ((listenableFuture instanceof AbstractC3606) && (thM8213 = ((AbstractC3606) listenableFuture).m8213()) != null) {
            return new C4503(thM8213);
        }
        boolean zIsCancelled = listenableFuture.isCancelled();
        boolean z = true;
        if ((!f13448) && zIsCancelled) {
            C3361 c33613 = C3361.f12570;
            Objects.requireNonNull(c33613);
            return c33613;
        }
        boolean z2 = false;
        while (true) {
            try {
                try {
                    try {
                        obj = listenableFuture.get();
                        break;
                    } catch (Error e) {
                        e = e;
                        return new C4503(e);
                    }
                } catch (InterruptedException unused) {
                    z2 = z;
                } catch (Throwable th) {
                    if (z2) {
                        Thread.currentThread().interrupt();
                    }
                    throw th;
                }
            } catch (Error | Exception e2) {
                e = e2;
                return new C4503(e);
            } catch (CancellationException e3) {
                if (zIsCancelled) {
                    return new C3361(e3, false);
                }
                return new C4503(new IllegalArgumentException("get() threw CancellationException, despite reporting isCancelled() == false: " + listenableFuture, e3));
            } catch (ExecutionException e4) {
                if (!zIsCancelled) {
                    return new C4503(e4.getCause());
                }
                return new C3361(new IllegalArgumentException("get() did not throw CancellationException, despite reporting isCancelled() == true: " + listenableFuture, e4), false);
            }
        }
        if (z2) {
            Thread.currentThread().interrupt();
        }
        if (!zIsCancelled) {
            return obj == null ? f13445 : obj;
        }
        return new C3361(new IllegalArgumentException("get() did not throw CancellationException, despite reporting isCancelled() == true: " + listenableFuture), false);
    }

    /* renamed from: ᵹᵝᵶ, reason: contains not printable characters */
    public static Object m8211(Object obj) throws ExecutionException {
        if (obj instanceof C3361) {
            Throwable th = ((C3361) obj).f12572;
            CancellationException cancellationException = new CancellationException("Task was cancelled.");
            cancellationException.initCause(th);
            throw cancellationException;
        }
        if (obj instanceof C4503) {
            throw new ExecutionException(((C4503) obj).f16783);
        }
        if (obj == f13445) {
            return null;
        }
        return obj;
    }

    @Override // java.util.concurrent.Future
    public boolean cancel(boolean z) {
        C3361 c3361;
        Object obj = this.f13450;
        if (!(obj == null) && !(obj instanceof RunnableC3146)) {
            return false;
        }
        if (f13448) {
            c3361 = new C3361(new CancellationException("Future.cancel() was called."), z);
        } else {
            c3361 = z ? C3361.f12569 : C3361.f12570;
            Objects.requireNonNull(c3361);
        }
        boolean z2 = false;
        while (true) {
            if (f13446.ˎˏʜʾ(this, obj, c3361)) {
                m8209(this, z);
                if (!(obj instanceof RunnableC3146)) {
                    break;
                }
                ListenableFuture listenableFuture = ((RunnableC3146) obj).f11957;
                if (!(listenableFuture instanceof InterfaceC4319)) {
                    listenableFuture.cancel(z);
                    break;
                }
                this = (AbstractC3606) listenableFuture;
                obj = this.f13450;
                if (!(obj == null) && !(obj instanceof RunnableC3146)) {
                    break;
                }
                z2 = true;
            } else {
                obj = this.f13450;
                if (!(obj instanceof RunnableC3146)) {
                    return z2;
                }
            }
        }
        return true;
    }

    @Override // java.util.concurrent.Future
    public Object get() throws InterruptedException {
        Object obj;
        C3897 c3897 = C3897.f14529;
        if (Thread.interrupted()) {
            throw new InterruptedException();
        }
        Object obj2 = this.f13450;
        if ((obj2 != null) && (!(obj2 instanceof RunnableC3146))) {
            return m8211(obj2);
        }
        C3897 c38972 = this.f13451;
        if (c38972 != c3897) {
            C3897 c38973 = new C3897();
            do {
                ᵛᵾˏ r5 = f13446;
                r5.ˊᵸˊ(c38973, c38972);
                if (r5.ᵹᵝᵶ(this, c38972, c38973)) {
                    do {
                        LockSupport.park(this);
                        if (Thread.interrupted()) {
                            m8214(c38973);
                            throw new InterruptedException();
                        }
                        obj = this.f13450;
                    } while (!((obj != null) & (!(obj instanceof RunnableC3146))));
                    return m8211(obj);
                }
                c38972 = this.f13451;
            } while (c38972 != c3897);
        }
        Object obj3 = this.f13450;
        Objects.requireNonNull(obj3);
        return m8211(obj3);
    }

    /* JADX WARN: Removed duplicated region for block: B:50:0x00ac  */
    /* JADX WARN: Removed duplicated region for block: B:63:0x00d3  */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:60:0x00c6 -> B:37:0x0083). 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 java.lang.Object get(long r21, java.util.concurrent.TimeUnit r23) 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.AbstractC3606.get(long, java.util.concurrent.TimeUnit):java.lang.Object");
    }

    @Override // java.util.concurrent.Future
    public boolean isCancelled() {
        return this.f13450 instanceof C3361;
    }

    @Override // java.util.concurrent.Future
    public boolean isDone() {
        return (!(r2 instanceof RunnableC3146)) & (this.f13450 != null);
    }

    /* JADX WARN: Removed duplicated region for block: B:36:0x00c5  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public 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)
            boolean r1 = r6.isCancelled()
            java.lang.String r2 = "]"
            if (r1 == 0) goto L50
            java.lang.String r6 = "CANCELLED"
            r0.append(r6)
            goto Lcf
        L50:
            boolean r1 = r6.isDone()
            if (r1 == 0) goto L5b
            r6.m8215(r0)
            goto Lcf
        L5b:
            int r1 = r0.length()
            java.lang.String r3 = "PENDING"
            r0.append(r3)
            java.lang.Object r3 = r6.f13450
            boolean r4 = r3 instanceof defpackage.RunnableC3146
            java.lang.String r5 = "Exception thrown from implementation: "
            if (r4 == 0) goto L93
            java.lang.String r4 = ", setFuture=["
            r0.append(r4)
            ᵠᵪˀᵻ r3 = (defpackage.RunnableC3146) r3
            com.google.common.util.concurrent.ListenableFuture r3 = r3.f11957
            if (r3 != r6) goto L81
            java.lang.String r3 = "this future"
            r0.append(r3)     // Catch: java.lang.StackOverflowError -> L7d java.lang.Exception -> L7f
            goto L8f
        L7d:
            r3 = move-exception
            goto L85
        L7f:
            r3 = move-exception
            goto L85
        L81:
            r0.append(r3)     // Catch: java.lang.StackOverflowError -> L7d java.lang.Exception -> L7f
            goto L8f
        L85:
            r0.append(r5)
            java.lang.Class r3 = r3.getClass()
            r0.append(r3)
        L8f:
            r0.append(r2)
            goto Lbf
        L93:
            java.lang.String r3 = r6.mo1032()     // Catch: java.lang.StackOverflowError -> L9f java.lang.Exception -> La1
            boolean r4 = ˆᴵ.ˑᵥˁ(r3)     // Catch: java.lang.StackOverflowError -> L9f java.lang.Exception -> La1
            if (r4 == 0) goto Lb2
            r3 = 0
            goto Lb2
        L9f:
            r3 = move-exception
            goto La2
        La1:
            r3 = move-exception
        La2:
            java.lang.StringBuilder r4 = new java.lang.StringBuilder
            r4.<init>(r5)
            java.lang.Class r3 = r3.getClass()
            r4.append(r3)
            java.lang.String r3 = r4.toString()
        Lb2:
            if (r3 == 0) goto Lbf
            java.lang.String r4 = ", info=["
            r0.append(r4)
            r0.append(r3)
            r0.append(r2)
        Lbf:
            boolean r3 = r6.isDone()
            if (r3 == 0) goto Lcf
            int r3 = r0.length()
            r0.delete(r1, r3)
            r6.m8215(r0)
        Lcf:
            r0.append(r2)
            java.lang.String r6 = r0.toString()
            return r6
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.AbstractC3606.toString():java.lang.String");
    }

    /* renamed from: ˇʼʤˎ, reason: contains not printable characters */
    public final void m8212(StringBuilder sb, Object obj) {
        if (obj == null) {
            sb.append("null");
        } else {
            if (obj == this) {
                sb.append("this future");
                return;
            }
            sb.append(obj.getClass().getName());
            sb.append("@");
            sb.append(Integer.toHexString(System.identityHashCode(obj)));
        }
    }

    /* renamed from: ˌʾˀ, reason: contains not printable characters */
    public final Throwable m8213() {
        if (!(this instanceof InterfaceC4319)) {
            return null;
        }
        Object obj = this.f13450;
        if (obj instanceof C4503) {
            return ((C4503) obj).f16783;
        }
        return null;
    }

    /* renamed from: ˌᵜᵹᵩ, reason: contains not printable characters */
    public final void m8214(C3897 c3897) {
        c3897.f14530 = null;
        while (true) {
            C3897 c38972 = this.f13451;
            if (c38972 == C3897.f14529) {
                return;
            }
            C3897 c38973 = null;
            while (c38972 != null) {
                C3897 c38974 = c38972.f14531;
                if (c38972.f14530 != null) {
                    c38973 = c38972;
                } else if (c38973 != null) {
                    c38973.f14531 = c38974;
                    if (c38973.f14530 == null) {
                        break;
                    }
                } else if (!f13446.ᵹᵝᵶ(this, c38972, c38974)) {
                    break;
                }
                c38972 = c38974;
            }
            return;
        }
    }

    /* renamed from: ˏᵙ, reason: contains not printable characters */
    public final void m8215(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=[");
        m8212(sb, obj);
        sb.append("]");
    }

    /* renamed from: ᵡʠ, reason: contains not printable characters */
    public final boolean m8216() {
        Object obj = this.f13450;
        return (obj instanceof C3361) && ((C3361) obj).f12571;
    }

    @Override // com.google.common.util.concurrent.ListenableFuture
    /* renamed from: ᵥᵯˎ */
    public void mo833(Runnable runnable, Executor executor) {
        C3736 c3736;
        C3736 c37362 = C3736.f13948;
        ᵛᵾˏ.ᵨᵳʝ(executor, "Executor was null.");
        if (!isDone() && (c3736 = this.f13449) != c37362) {
            C3736 c37363 = new C3736(runnable, executor);
            do {
                c37363.f13949 = c3736;
                if (f13446.ˏˋٴ(this, c3736, c37363)) {
                    return;
                } else {
                    c3736 = this.f13449;
                }
            } while (c3736 != c37362);
        }
        m8208(runnable, executor);
    }

    /* renamed from: ᵪʩ, reason: contains not printable characters */
    public boolean m8217(Throwable th) {
        th.getClass();
        if (!f13446.ˎˏʜʾ(this, (Object) null, new C4503(th))) {
            return false;
        }
        m8209(this, false);
        return true;
    }

    /* renamed from: ᵯٴᵦ, reason: contains not printable characters */
    public boolean m8218(Object obj) {
        if (obj == null) {
            obj = f13445;
        }
        if (!f13446.ˎˏʜʾ(this, (Object) null, obj)) {
            return false;
        }
        m8209(this, false);
        return true;
    }

    /* JADX WARN: Removed duplicated region for block: B:23:0x0048  */
    /* 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 boolean m8219(com.google.common.util.concurrent.ListenableFuture r6) {
        /*
            r5 = this;
            r6.getClass()
            java.lang.Object r0 = r5.f13450
            r1 = 0
            if (r0 != 0) goto L44
            boolean r0 = r6.isDone()
            r2 = 1
            r3 = 0
            if (r0 == 0) goto L20
            java.lang.Object r6 = m8210(r6)
            ᵛᵾˏ r0 = defpackage.AbstractC3606.f13446
            boolean r6 = r0.ˎˏʜʾ(r5, r3, r6)
            if (r6 == 0) goto L4f
            m8209(r5, r1)
            return r2
        L20:
            ᵠᵪˀᵻ r0 = new ᵠᵪˀᵻ
            r0.<init>(r5, r6)
            ᵛᵾˏ r4 = defpackage.AbstractC3606.f13446
            boolean r3 = r4.ˎˏʜʾ(r5, r3, r0)
            if (r3 == 0) goto L42
            ᵘᵝᵽˀ r1 = defpackage.EnumC2524.f9848     // Catch: java.lang.Throwable -> L33
            r6.mo833(r0, r1)     // Catch: java.lang.Throwable -> L33
            return r2
        L33:
            r6 = move-exception
            ᵲᵟ r1 = new ᵲᵟ     // Catch: java.lang.Throwable -> L3a
            r1.<init>(r6)     // Catch: java.lang.Throwable -> L3a
            goto L3c
        L3a:
            ᵲᵟ r1 = defpackage.C4503.f16782
        L3c:
            ᵛᵾˏ r6 = defpackage.AbstractC3606.f13446
            r6.ˎˏʜʾ(r5, r0, r1)
            return r2
        L42:
            java.lang.Object r0 = r5.f13450
        L44:
            boolean r5 = r0 instanceof defpackage.C3361
            if (r5 == 0) goto L4f
            ᵣᵟᵔ r0 = (defpackage.C3361) r0
            boolean r5 = r0.f12571
            r6.cancel(r5)
        L4f:
            return r1
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.AbstractC3606.m8219(com.google.common.util.concurrent.ListenableFuture):boolean");
    }

    /* renamed from: ᵶᵷᵕ, reason: contains not printable characters */
    public void mo8220() {
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* renamed from: ᵸˑ */
    public String mo1032() {
        if (!(this instanceof ScheduledFuture)) {
            return null;
        }
        return "remaining delay=[" + ((ScheduledFuture) this).getDelay(TimeUnit.MILLISECONDS) + " ms]";
    }

    /* renamed from: ᵻᵢﹳᵰ */
    public void mo1033() {
    }
}