package kotlinx.coroutines.internal;

import java.util.concurrent.CancellationException;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import kotlin.Result;
import kotlin.coroutines.Continuation;
import kotlinx.coroutines.f0;
import kotlinx.coroutines.q0;
import kotlinx.coroutines.q1;
import tv.danmaku.ijk.media.player.IjkMediaMeta;

/* JADX INFO: loaded from: classes.dex */
public final class g extends f0 implements nd.b, Continuation {

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f29460h = AtomicReferenceFieldUpdater.newUpdater(g.class, Object.class, "_reusableCancellableContinuation$volatile");
    private volatile /* synthetic */ Object _reusableCancellableContinuation$volatile;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final kotlinx.coroutines.t f29461d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final Continuation f29462e;

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

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final Object f29464g;

    public g(kotlinx.coroutines.t tVar, Continuation continuation) {
        super(-1);
        this.f29461d = tVar;
        this.f29462e = continuation;
        this.f29463f = a.f29451c;
        this.f29464g = v.b(continuation.getContext());
    }

    @Override // kotlinx.coroutines.f0
    public final void b(Object obj, CancellationException cancellationException) {
        if (obj instanceof kotlinx.coroutines.r) {
            ((kotlinx.coroutines.r) obj).f29530b.invoke(cancellationException);
        }
    }

    @Override // kotlinx.coroutines.f0
    public final Continuation c() {
        return this;
    }

    @Override // nd.b
    public final nd.b getCallerFrame() {
        Continuation continuation = this.f29462e;
        if (continuation instanceof nd.b) {
            return (nd.b) continuation;
        }
        return null;
    }

    @Override // kotlin.coroutines.Continuation
    public final kotlin.coroutines.h getContext() {
        return this.f29462e.getContext();
    }

    @Override // kotlinx.coroutines.f0
    public final Object j() {
        Object obj = this.f29463f;
        this.f29463f = a.f29451c;
        return obj;
    }

    @Override // kotlin.coroutines.Continuation
    public final void resumeWith(Object obj) {
        Continuation continuation = this.f29462e;
        kotlin.coroutines.h context = continuation.getContext();
        Throwable thA = Result.a(obj);
        Object qVar = thA == null ? obj : new kotlinx.coroutines.q(thA, false);
        kotlinx.coroutines.t tVar = this.f29461d;
        if (tVar.M(context)) {
            this.f29463f = qVar;
            this.f29356c = 0;
            tVar.L(context, this);
            return;
        }
        q0 q0VarA = q1.a();
        if (q0VarA.f29525c >= IjkMediaMeta.AV_CH_WIDE_RIGHT) {
            this.f29463f = qVar;
            this.f29356c = 0;
            kotlin.collections.h hVar = q0VarA.f29527e;
            if (hVar == null) {
                hVar = new kotlin.collections.h();
                q0VarA.f29527e = hVar;
            }
            hVar.addLast(this);
            return;
        }
        q0VarA.Q(true);
        try {
            kotlin.coroutines.h context2 = continuation.getContext();
            Object objC = v.c(context2, this.f29464g);
            try {
                continuation.resumeWith(obj);
                while (q0VarA.S()) {
                }
            } finally {
                v.a(context2, objC);
            }
        } finally {
            try {
            } finally {
            }
        }
    }

    public final String toString() {
        return "DispatchedContinuation[" + this.f29461d + ", " + kotlinx.coroutines.y.e0(this.f29462e) + ']';
    }
}