package b7;

import Z6.B0;
import Z6.F;
import java.lang.reflect.InvocationTargetException;

/* JADX INFO: loaded from: classes.dex */
public final class q extends C0556f {

    /* JADX INFO: renamed from: A, reason: collision with root package name */
    public final EnumC0551a f9268A;

    public q(int i, EnumC0551a enumC0551a) {
        super(i);
        this.f9268A = enumC0551a;
        if (enumC0551a != EnumC0551a.f9221q) {
            if (i < 1) {
                throw new IllegalArgumentException(I1.a.k(i, "Buffered channel capacity must be at least 1, but ", " was specified").toString());
            }
        } else {
            throw new IllegalArgumentException(("This implementation does not support suspension for senders, use " + P6.n.a(C0556f.class).c() + " instead").toString());
        }
    }

    /* JADX WARN: Code restructure failed: missing block: B:51:0x00b6, code lost:
    
        return r8;
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object F(Object obj, boolean z8) throws IllegalAccessException, F, InvocationTargetException {
        EnumC0551a enumC0551a = EnumC0551a.f9223s;
        A6.n nVar = A6.n.f457a;
        if (this.f9268A == enumC0551a) {
            Object objE = super.e(obj);
            return (!(objE instanceof C0562l) || (objE instanceof C0561k)) ? objE : nVar;
        }
        Object obj2 = AbstractC0558h.f9244d;
        n nVar2 = (n) C0556f.f9234v.get(this);
        while (true) {
            long andIncrement = C0556f.f9230r.getAndIncrement(this);
            long j8 = 1152921504606846975L & andIncrement;
            boolean zS = s(andIncrement, false);
            int i = AbstractC0558h.f9242b;
            long j9 = i;
            long j10 = j8 / j9;
            int i5 = (int) (j8 % j9);
            if (nVar2.f12574s != j10) {
                n nVarA = C0556f.a(this, j10, nVar2);
                if (nVarA != null) {
                    nVar2 = nVarA;
                } else if (zS) {
                    return new C0561k(p());
                }
            }
            int iD = C0556f.d(this, nVar2, i5, obj, j8, obj2, zS);
            if (iD == 0) {
                nVar2.a();
                return nVar;
            }
            if (iD == 1) {
                break;
            }
            if (iD != 2) {
                if (iD == 3) {
                    throw new IllegalStateException("unexpected");
                }
                if (iD == 4) {
                    if (j8 < C0556f.f9231s.get(this)) {
                        nVar2.a();
                    }
                    return new C0561k(p());
                }
                if (iD == 5) {
                    nVar2.a();
                }
            } else {
                if (zS) {
                    nVar2.i();
                    return new C0561k(p());
                }
                B0 b02 = obj2 instanceof B0 ? (B0) obj2 : null;
                if (b02 != null) {
                    b02.a(nVar2, i5 + i);
                }
                i((nVar2.f12574s * j9) + ((long) i5));
            }
        }
    }

    @Override // b7.C0556f, b7.w
    public final Object e(Object obj) {
        return F(obj, false);
    }

    @Override // b7.C0556f, b7.w
    public final Object k(E6.d dVar, Object obj) throws Throwable {
        if (F(obj, true) instanceof C0561k) {
            throw p();
        }
        return A6.n.f457a;
    }

    @Override // b7.C0556f
    public final boolean v() {
        return this.f9268A == EnumC0551a.f9222r;
    }
}