package h.a;

import h.a.r0;
import java.util.concurrent.CancellationException;

/* JADX INFO: compiled from: DispatchedTask.kt */
/* JADX INFO: loaded from: classes.dex */
@g.i
public abstract class a0<T> extends h.a.l1.h {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public int f4206f;

    public a0(int i2) {
        this.f4206f = i2;
    }

    public void a(Object obj, Throwable th) {
    }

    public abstract g.e0.d<T> b();

    public Throwable d(Object obj) {
        l lVar = obj instanceof l ? (l) obj : null;
        if (lVar == null) {
            return null;
        }
        return lVar.f4276b;
    }

    /* JADX WARN: Multi-variable type inference failed */
    public <T> T g(Object obj) {
        return obj;
    }

    public final void h(Throwable th, Throwable th2) {
        if (th == null && th2 == null) {
            return;
        }
        if (th != null && th2 != null) {
            f.a.y.a.m(th, th2);
        }
        if (th == null) {
            th = th2;
        }
        g.h0.c.l.c(th);
        f.a.y.a.j0(b().e(), new t("Fatal exception in coroutines machinery for " + this + ". Please read KDoc to 'handleFatalException' method and report this incident to maintainers", th));
    }

    public abstract Object i();

    @Override // java.lang.Runnable
    public final void run() {
        Object objL;
        r0 r0Var;
        h.a.l1.i iVar = this.f4304e;
        try {
            h.a.k1.d dVar = (h.a.k1.d) b();
            g.e0.d<T> dVar2 = dVar.f4245i;
            Object obj = dVar.f4247k;
            g.e0.f fVarE = dVar2.e();
            Object objB = h.a.k1.t.b(fVarE, obj);
            f1<?> f1VarP1 = objB != h.a.k1.t.a ? f.a.y.a.p1(dVar2, fVarE, objB) : null;
            try {
                g.e0.f fVarE2 = dVar2.e();
                Object objI = i();
                Throwable thD = d(objI);
                if (thD == null && b0.a(this.f4206f)) {
                    int i2 = r0.f4326d;
                    r0Var = (r0) fVarE2.get(r0.a.f4327b);
                } else {
                    r0Var = null;
                }
                if (r0Var != null && !r0Var.a()) {
                    CancellationException cancellationExceptionI = r0Var.i();
                    a(objI, cancellationExceptionI);
                    dVar2.f(f.a.y.a.L(cancellationExceptionI));
                } else if (thD != null) {
                    dVar2.f(f.a.y.a.L(thD));
                } else {
                    dVar2.f(g(objI));
                }
                Object objL2 = g.a0.a;
                if (f1VarP1 != null) {
                    throw null;
                }
                h.a.k1.t.a(fVarE, objB);
                try {
                    iVar.a();
                } catch (Throwable th) {
                    objL2 = f.a.y.a.L(th);
                }
                h(null, g.l.a(objL2));
            } catch (Throwable th2) {
                if (f1VarP1 != null) {
                    throw null;
                }
                h.a.k1.t.a(fVarE, objB);
                throw th2;
            }
        } catch (Throwable th3) {
            try {
                iVar.a();
                objL = g.a0.a;
            } catch (Throwable th4) {
                objL = f.a.y.a.L(th4);
            }
            h(th3, g.l.a(objL));
        }
    }
}