package com.google.android.gms.internal.ads;

import android.media.MediaCodec;
import android.os.HandlerThread;
import androidx.annotation.Nullable;
import java.util.ArrayDeque;
import java.util.Arrays;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: loaded from: classes2.dex */
public final class hn2 implements sn2 {

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

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

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

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public a3.u f12202c;

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

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

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

    public hn2(MediaCodec mediaCodec, HandlerThread handlerThread) {
        nn0 nn0Var = new nn0();
        this.f12200a = mediaCodec;
        this.f12201b = handlerThread;
        this.f12204e = nn0Var;
        this.f12203d = new AtomicReference();
    }

    public static gn2 d() {
        ArrayDeque arrayDeque = f12198g;
        synchronized (arrayDeque) {
            try {
                if (arrayDeque.isEmpty()) {
                    return new gn2();
                }
                return (gn2) arrayDeque.removeFirst();
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    @Nullable
    private static int[] zzj(@Nullable int[] iArr, @Nullable int[] iArr2) {
        int length;
        if (iArr == null) {
            return iArr2;
        }
        if (iArr2 == null || iArr2.length < (length = iArr.length)) {
            return Arrays.copyOf(iArr, iArr.length);
        }
        System.arraycopy(iArr, 0, iArr2, 0, length);
        return iArr2;
    }

    @Nullable
    private static byte[] zzk(@Nullable byte[] bArr, @Nullable byte[] bArr2) {
        int length;
        if (bArr == null) {
            return bArr2;
        }
        if (bArr2 == null || bArr2.length < (length = bArr.length)) {
            return Arrays.copyOf(bArr, bArr.length);
        }
        System.arraycopy(bArr, 0, bArr2, 0, length);
        return bArr2;
    }

    public final void a(int i10, mc2 mc2Var, long j10, int i11) {
        c();
        gn2 gn2VarD = d();
        gn2VarD.f11804a = i10;
        gn2VarD.f11805b = 0;
        gn2VarD.f11807d = j10;
        gn2VarD.f11808e = i11;
        int i12 = mc2Var.f14073b;
        MediaCodec.CryptoInfo cryptoInfo = gn2VarD.f11806c;
        cryptoInfo.numSubSamples = i12;
        cryptoInfo.numBytesOfClearData = zzj(mc2Var.zzd, cryptoInfo.numBytesOfClearData);
        cryptoInfo.numBytesOfEncryptedData = zzj(mc2Var.zze, cryptoInfo.numBytesOfEncryptedData);
        byte[] bArrZzk = zzk(mc2Var.zzb, cryptoInfo.key);
        bArrZzk.getClass();
        cryptoInfo.key = bArrZzk;
        byte[] bArrZzk2 = zzk(mc2Var.zza, cryptoInfo.iv);
        bArrZzk2.getClass();
        cryptoInfo.iv = bArrZzk2;
        cryptoInfo.mode = mc2Var.f14072a;
        cryptoInfo.setPattern(new MediaCodec.CryptoInfo.Pattern(mc2Var.f14074c, mc2Var.f14075d));
        a3.u uVar = this.f12202c;
        String str = bb1.f9474a;
        uVar.obtainMessage(2, gn2VarD).sendToTarget();
    }

    public final void b() {
        if (this.f12205f) {
            try {
                a3.u uVar = this.f12202c;
                uVar.getClass();
                uVar.removeCallbacksAndMessages(null);
                nn0 nn0Var = this.f12204e;
                synchronized (nn0Var) {
                    nn0Var.f14669a = false;
                }
                a3.u uVar2 = this.f12202c;
                uVar2.getClass();
                uVar2.obtainMessage(3).sendToTarget();
                synchronized (nn0Var) {
                    while (!nn0Var.f14669a) {
                        nn0Var.wait();
                    }
                }
            } catch (InterruptedException e10) {
                Thread.currentThread().interrupt();
                throw new IllegalStateException(e10);
            }
        }
    }

    public final void c() {
        RuntimeException runtimeException = (RuntimeException) this.f12203d.getAndSet(null);
        if (runtimeException != null) {
            throw runtimeException;
        }
    }
}