package d2;

/* JADX INFO: compiled from: CoroutineContext.kt */
/* JADX INFO: loaded from: classes.dex */
public final class p1<T> extends kotlinx.coroutines.internal.z<T> {

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private ThreadLocal<k1.h<n1.f, Object>> f4524h;

    @Override // kotlinx.coroutines.internal.z, d2.a
    protected void k0(Object obj) {
        k1.h<n1.f, Object> hVar = this.f4524h.get();
        if (hVar != null) {
            kotlinx.coroutines.internal.f0.a(hVar.a(), hVar.b());
            this.f4524h.set(null);
        }
        Object objA = r.a(obj, this.f5241g);
        n1.d<T> dVar = this.f5241g;
        n1.f fVarD = dVar.d();
        Object objC = kotlinx.coroutines.internal.f0.c(fVarD, null);
        p1<?> p1VarC = objC != kotlinx.coroutines.internal.f0.f5187a ? t.c(dVar, fVarD, objC) : null;
        try {
            this.f5241g.j(objA);
            k1.o oVar = k1.o.f5171a;
        } finally {
            if (p1VarC == null || p1VarC.n0()) {
                kotlinx.coroutines.internal.f0.a(fVarD, objC);
            }
        }
    }

    public final boolean n0() {
        if (this.f4524h.get() == null) {
            return false;
        }
        this.f4524h.set(null);
        return true;
    }

    public final void o0(n1.f fVar, Object obj) {
        this.f4524h.set(k1.l.a(fVar, obj));
    }
}