package I0;

import B0.t0;
import android.media.MediaCodec;
import android.os.Bundle;
import android.os.HandlerThread;
import java.util.ArrayDeque;
import java.util.Arrays;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: loaded from: classes.dex */
public final class g implements o {

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public static final ArrayDeque f3204g = new ArrayDeque();

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public static final Object f3205h = new Object();

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final MediaCodec f3206a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final HandlerThread f3207b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public e f3208c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final AtomicReference f3209d;

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

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

    public g(MediaCodec mediaCodec, HandlerThread handlerThread) {
        t0 t0Var = new t0();
        this.f3206a = mediaCodec;
        this.f3207b = handlerThread;
        this.f3210e = t0Var;
        this.f3209d = new AtomicReference();
    }

    public static f b() {
        ArrayDeque arrayDeque = f3204g;
        synchronized (arrayDeque) {
            try {
                if (arrayDeque.isEmpty()) {
                    return new f();
                }
                return (f) arrayDeque.removeFirst();
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public static void e(f fVar) {
        ArrayDeque arrayDeque = f3204g;
        synchronized (arrayDeque) {
            arrayDeque.add(fVar);
        }
    }

    @Override // I0.o
    public final void a() {
        RuntimeException runtimeException = (RuntimeException) this.f3209d.getAndSet(null);
        if (runtimeException != null) {
            throw runtimeException;
        }
    }

    @Override // I0.o
    public final void c(Bundle bundle) {
        a();
        e eVar = this.f3208c;
        int i = x0.v.f18553a;
        eVar.obtainMessage(4, bundle).sendToTarget();
    }

    @Override // I0.o
    public final void d(int i, A0.d dVar, long j8, int i5) {
        a();
        f fVarB = b();
        fVarB.f3199a = i;
        fVarB.f3200b = 0;
        fVarB.f3202d = j8;
        fVarB.f3203e = i5;
        int i8 = dVar.f12f;
        MediaCodec.CryptoInfo cryptoInfo = fVarB.f3201c;
        cryptoInfo.numSubSamples = i8;
        int[] iArr = dVar.f10d;
        int[] iArrCopyOf = cryptoInfo.numBytesOfClearData;
        if (iArr != null) {
            if (iArrCopyOf == null || iArrCopyOf.length < iArr.length) {
                iArrCopyOf = Arrays.copyOf(iArr, iArr.length);
            } else {
                System.arraycopy(iArr, 0, iArrCopyOf, 0, iArr.length);
            }
        }
        cryptoInfo.numBytesOfClearData = iArrCopyOf;
        int[] iArr2 = dVar.f11e;
        int[] iArrCopyOf2 = cryptoInfo.numBytesOfEncryptedData;
        if (iArr2 != null) {
            if (iArrCopyOf2 == null || iArrCopyOf2.length < iArr2.length) {
                iArrCopyOf2 = Arrays.copyOf(iArr2, iArr2.length);
            } else {
                System.arraycopy(iArr2, 0, iArrCopyOf2, 0, iArr2.length);
            }
        }
        cryptoInfo.numBytesOfEncryptedData = iArrCopyOf2;
        byte[] bArr = dVar.f8b;
        byte[] bArrCopyOf = cryptoInfo.key;
        if (bArr != null) {
            if (bArrCopyOf == null || bArrCopyOf.length < bArr.length) {
                bArrCopyOf = Arrays.copyOf(bArr, bArr.length);
            } else {
                System.arraycopy(bArr, 0, bArrCopyOf, 0, bArr.length);
            }
        }
        bArrCopyOf.getClass();
        cryptoInfo.key = bArrCopyOf;
        byte[] bArr2 = dVar.f7a;
        byte[] bArrCopyOf2 = cryptoInfo.iv;
        if (bArr2 != null) {
            if (bArrCopyOf2 == null || bArrCopyOf2.length < bArr2.length) {
                bArrCopyOf2 = Arrays.copyOf(bArr2, bArr2.length);
            } else {
                System.arraycopy(bArr2, 0, bArrCopyOf2, 0, bArr2.length);
            }
        }
        bArrCopyOf2.getClass();
        cryptoInfo.iv = bArrCopyOf2;
        cryptoInfo.mode = dVar.f9c;
        if (x0.v.f18553a >= 24) {
            A0.c.p();
            cryptoInfo.setPattern(A0.c.f(dVar.f13g, dVar.f14h));
        }
        this.f3208c.obtainMessage(2, fVarB).sendToTarget();
    }

    @Override // I0.o
    public final void f(int i, int i5, long j8, int i8) {
        a();
        f fVarB = b();
        fVarB.f3199a = i;
        fVarB.f3200b = i5;
        fVarB.f3202d = j8;
        fVarB.f3203e = i8;
        e eVar = this.f3208c;
        int i9 = x0.v.f18553a;
        eVar.obtainMessage(1, fVarB).sendToTarget();
    }

    @Override // I0.o
    public final void flush() {
        if (this.f3211f) {
            try {
                e eVar = this.f3208c;
                eVar.getClass();
                eVar.removeCallbacksAndMessages(null);
                t0 t0Var = this.f3210e;
                synchronized (t0Var) {
                    t0Var.f916b = false;
                }
                e eVar2 = this.f3208c;
                eVar2.getClass();
                eVar2.obtainMessage(3).sendToTarget();
                t0Var.c();
            } catch (InterruptedException e8) {
                Thread.currentThread().interrupt();
                throw new IllegalStateException(e8);
            }
        }
    }

    @Override // I0.o
    public final void shutdown() {
        if (this.f3211f) {
            flush();
            this.f3207b.quit();
        }
        this.f3211f = false;
    }

    @Override // I0.o
    public final void start() {
        if (this.f3211f) {
            return;
        }
        HandlerThread handlerThread = this.f3207b;
        handlerThread.start();
        this.f3208c = new e(this, handlerThread.getLooper());
        this.f3211f = true;
    }
}