package g0;

import android.content.Context;
import android.media.MediaCodec;
import android.media.MediaFormat;
import android.os.Handler;
import com.ifpdos.player.resample.AudioResample;
import java.nio.ByteBuffer;
import java.util.concurrent.atomic.AtomicBoolean;
import o0.AbstractC0651c;
import vendor.mediatek.CaptureRecorder;

/* JADX INFO: renamed from: g0.e, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes.dex */
public final class C0481e implements InterfaceC0480d {

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public static final a f4033j = new a(null);

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private C0479c f4034a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private CaptureRecorder f4035b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private int f4036c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private int f4037d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private int f4038e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private final int f4039f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private final AtomicBoolean f4040g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private int f4041h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    private final AudioResample f4042i;

    /* JADX INFO: renamed from: g0.e$a */
    public static final class a {
        public /* synthetic */ a(kotlin.jvm.internal.g gVar) {
            this();
        }

        private a() {
        }
    }

    /* JADX INFO: renamed from: g0.e$b */
    public static final class b extends CaptureRecorder.OutputSink.b {
        b() {
        }

        @Override // vendor.mediatek.CaptureRecorder.OutputSink.b
        public void a(CaptureRecorder.OutputSink outputSink) {
            kotlin.jvm.internal.l.e(outputSink, "outputSink");
            Q0.e.f("MTKAudioCaptureRecorder", "onEndOfStream: ");
            outputSink.i();
        }

        @Override // vendor.mediatek.CaptureRecorder.OutputSink.b
        public void b(CaptureRecorder.OutputSink outputSink, int i2, String s2) {
            kotlin.jvm.internal.l.e(outputSink, "outputSink");
            kotlin.jvm.internal.l.e(s2, "s");
            Q0.e.b("MTKAudioCaptureRecorder", "onError: code(" + i2 + "), msg:" + s2);
        }

        @Override // vendor.mediatek.CaptureRecorder.OutputSink.b
        public void c(CaptureRecorder.OutputSink outputSink, int i2, MediaCodec.BufferInfo bufferInfo) {
            kotlin.jvm.internal.l.e(outputSink, "outputSink");
            kotlin.jvm.internal.l.e(bufferInfo, "bufferInfo");
            ByteBuffer byteBufferC = outputSink.g(i2).c();
            Q0.e.a("MTKAudioCaptureRecorder", "Thread.currentThread().name: " + Thread.currentThread().getName());
            Q0.e.a("MTKAudioCaptureRecorder", "onOutputBufferAvailable: index=" + i2 + ", bufferInfo=" + bufferInfo.size);
            byte[] bArrA = C0484h.f4048a.a(3, C0481e.this.f4038e, bufferInfo.size + 7);
            byteBufferC.position(bufferInfo.offset);
            byteBufferC.limit(bufferInfo.size + bufferInfo.offset);
            byte[] bArr = new byte[bArrA.length + byteBufferC.remaining()];
            int length = bArrA.length;
            for (int i3 = 0; i3 < length; i3++) {
                bArr[i3] = bArrA[i3];
            }
            byteBufferC.get(bArr, bArrA.length, byteBufferC.remaining());
            o0.g gVar = o0.g.I;
            gVar.saveData(bArr, 2);
            byte[] bArrResample = C0481e.this.f4042i.resample(bArr);
            if (bArrResample != null) {
                C0479c c0479c = C0481e.this.f4034a;
                if (c0479c != null) {
                    c0479c.c(bArrResample);
                }
                gVar.saveData(bArrResample, C0481e.this.f4041h);
            }
            outputSink.j(i2, bufferInfo);
        }

        @Override // vendor.mediatek.CaptureRecorder.OutputSink.b
        public void d(CaptureRecorder.OutputSink outputSink, MediaFormat mediaFormat) {
            kotlin.jvm.internal.l.e(outputSink, "outputSink");
            kotlin.jvm.internal.l.e(mediaFormat, "mediaFormat");
            Q0.e.f("MTKAudioCaptureRecorder", "onOutputFormatChanged: " + mediaFormat);
        }
    }

    public C0481e(Context context) {
        kotlin.jvm.internal.l.e(context, "context");
        this.f4034a = new C0479c(409600);
        this.f4035b = new CaptureRecorder(context);
        this.f4037d = 48000;
        this.f4038e = 1;
        this.f4039f = 5;
        this.f4040g = new AtomicBoolean(false);
        this.f4041h = 1;
        this.f4042i = new AudioResample();
    }

    @Override // g0.InterfaceC0480d
    public int configure(int i2, int i3, int i4) {
        int i5;
        Q0.e.a("MTKAudioCaptureRecorder", "configure: sampleRateInHz=" + i2 + ", channelCount=" + i3 + ", audioSource=" + i4);
        if ((i4 & 2) == 2) {
            this.f4041h = 2;
            i5 = 1;
        } else {
            i5 = -1;
        }
        if ((i4 & 1) == 1) {
            i5 = i5 == 1 ? 2 : 0;
            this.f4041h = 1;
        }
        Q0.e.a("MTKAudioCaptureRecorder", "configure: testType=" + this.f4041h);
        this.f4036c = i5;
        this.f4035b.setAudioCapturePoint(i5);
        if (this.f4036c != 0) {
            this.f4035b.setMicrophoneSource(1);
            this.f4035b.setMicrophoneChannels(2);
            this.f4035b.setMicrophoneSamplingRate(48000);
        }
        if (i5 == -1) {
            return -11;
        }
        this.f4037d = i2;
        this.f4038e = i3;
        this.f4042i.config(2, 48000, i3, i2);
        return 0;
    }

    @Override // g0.InterfaceC0480d
    public int read(byte[] audioData, int i2, int i3) throws InterruptedException {
        kotlin.jvm.internal.l.e(audioData, "audioData");
        while (this.f4040g.get()) {
            C0479c c0479c = this.f4034a;
            if (i3 <= (c0479c != null ? c0479c.e() : 0)) {
                C0479c c0479c2 = this.f4034a;
                if (c0479c2 != null) {
                    return c0479c2.b(audioData, i2, i3);
                }
                return 0;
            }
            if (this.f4040g.get()) {
                Thread.sleep(10L);
            }
        }
        Q0.e.a("MTKAudioCaptureRecorder", "read: end");
        return -1;
    }

    @Override // g0.InterfaceC0480d
    public int release() {
        return 0;
    }

    @Override // g0.InterfaceC0480d
    public int startRecording() {
        try {
            this.f4040g.set(true);
            Q0.e.a("MTKAudioCaptureRecorder", "startRecording: " + this.f4036c);
            if (this.f4035b.e(2, this.f4039f, new b(), new Handler(AbstractC0651c.b("MTKAudioCaptureRecorder"))) == null) {
                Q0.e.b("MTKAudioCaptureRecorder", "MtkCaptureRecorder: sink is null");
            }
            this.f4035b.setAudioEncoder(3);
            this.f4035b.g();
            this.f4035b.start();
            o0.g gVar = o0.g.I;
            gVar.start(this.f4041h);
            gVar.start(2);
            return 0;
        } catch (Throwable th) {
            Q0.e.b("MTKAudioCaptureRecorder", "MtkCaptureRecorder: " + th.getMessage());
            return -1;
        }
    }

    @Override // g0.InterfaceC0480d
    public int stop() {
        try {
            this.f4040g.set(false);
            o0.g gVar = o0.g.I;
            gVar.stop(this.f4041h);
            gVar.stop(2);
            this.f4035b.stop();
            this.f4035b.h();
            this.f4042i.release();
            return 0;
        } catch (Throwable th) {
            Q0.e.c("MTKAudioCaptureRecorder", "stopRecording: ", th);
            return -1;
        }
    }
}