package O0;

import C3.D;
import C3.G;
import C3.W;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.TimeUnit;
import k4.C1099b;
import k4.x;
import m4.RunnableC1180p;
import r4.C1495b;
import u0.T;
import w2.InterfaceC1703f;

/* JADX INFO: loaded from: classes.dex */
public final /* synthetic */ class e implements n, InterfaceC1703f {

    /* JADX INFO: renamed from: q, reason: collision with root package name */
    public final /* synthetic */ boolean f4823q;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    public final /* synthetic */ Object f4824r;

    /* JADX INFO: renamed from: s, reason: collision with root package name */
    public final /* synthetic */ Object f4825s;

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    public final /* synthetic */ Object f4826t;

    public /* synthetic */ e(Object obj, Object obj2, boolean z8, Object obj3) {
        this.f4824r = obj;
        this.f4825s = obj2;
        this.f4823q = z8;
        this.f4826t = obj3;
    }

    @Override // w2.InterfaceC1703f
    public void a(Exception exc) throws Throwable {
        C1495b c1495b = (C1495b) this.f4824r;
        c1495b.getClass();
        g3.h hVar = (g3.h) this.f4825s;
        if (exc != null) {
            hVar.a(exc);
            return;
        }
        if (this.f4823q) {
            boolean z8 = true;
            CountDownLatch countDownLatch = new CountDownLatch(1);
            new Thread(new RunnableC1180p(c1495b, 2, countDownLatch)).start();
            TimeUnit timeUnit = TimeUnit.SECONDS;
            ExecutorService executorService = x.f13942a;
            boolean z9 = false;
            try {
                long nanos = timeUnit.toNanos(2L);
                long jNanoTime = System.nanoTime() + nanos;
                while (true) {
                    try {
                        try {
                            countDownLatch.await(nanos, TimeUnit.NANOSECONDS);
                            break;
                        } catch (Throwable th) {
                            th = th;
                            if (z8) {
                                Thread.currentThread().interrupt();
                            }
                            throw th;
                        }
                    } catch (InterruptedException unused) {
                        nanos = jNanoTime - System.nanoTime();
                        z9 = true;
                    }
                }
                if (z9) {
                    Thread.currentThread().interrupt();
                }
            } catch (Throwable th2) {
                th = th2;
                z8 = z9;
            }
        }
        hVar.b((C1099b) this.f4826t);
    }

    @Override // O0.n
    public W h(int i, T t6, int[] iArr) {
        q qVar = (q) this.f4824r;
        qVar.getClass();
        k kVar = (k) this.f4825s;
        f fVar = new f(qVar, kVar);
        int i5 = ((int[]) this.f4826t)[i];
        D dJ = G.j();
        int i8 = 0;
        while (i8 < t6.f17200a) {
            int i9 = i;
            T t8 = t6;
            dJ.a(new g(i9, t8, i8, kVar, iArr[i8], this.f4823q, fVar, i5));
            i8++;
            i = i9;
            t6 = t8;
        }
        return dJ.g();
    }
}