package com.benq.platform;

import android.content.Context;
import android.os.Binder;
import android.util.Log;
import com.benq.platform.IBenQAudioRecordBinder;
import i0.C0546a;
import java.util.LinkedHashMap;
import java.util.Map;
import kotlin.jvm.internal.g;
import kotlin.jvm.internal.k;
import kotlin.jvm.internal.l;
import n1.l;
import n1.m;

/* JADX INFO: loaded from: classes.dex */
public final class IFPBenQAudioRecordService extends IBenQAudioRecordBinder.Stub {
    private static final int AUDIO_SOURCE_MIC = 2;
    private static final int AUDIO_SOURCE_SYSTEM = 1;
    private static final int AUDIO_SOURCE_SYSTEM_AND_MIC = 3;
    public static final Companion Companion = new Companion(null);
    private static final String TAG = "@IFPBenQAudioRecordService";
    private final Context context;
    private final Object sessionLock;
    private final Map<Integer, C0546a> sessions;

    public static final class Companion {
        public /* synthetic */ Companion(g gVar) {
            this();
        }

        private Companion() {
        }
    }

    public IFPBenQAudioRecordService(Context context) {
        l.e(context, "context");
        this.context = context;
        this.sessionLock = new Object();
        this.sessions = new LinkedHashMap();
    }

    private final Integer convertAudioSource(int i2) {
        if (i2 == 1) {
            return 1;
        }
        if (i2 == 2) {
            return 2;
        }
        if (i2 == 3) {
            return 3;
        }
        Log.e(TAG, "Invalid audio source: " + i2);
        return null;
    }

    private final C0546a getOrCreateSession(int i2) {
        C0546a c0546a;
        synchronized (this.sessionLock) {
            try {
                Map<Integer, C0546a> map = this.sessions;
                Integer numValueOf = Integer.valueOf(i2);
                C0546a c0546a2 = map.get(numValueOf);
                if (c0546a2 == null) {
                    c0546a2 = new C0546a();
                    c0546a2.d(this.context);
                    Log.d(TAG, "create session: pid=" + i2);
                    map.put(numValueOf, c0546a2);
                }
                c0546a = c0546a2;
            } catch (Throwable th) {
                throw th;
            }
        }
        return c0546a;
    }

    private final boolean isSupportedChannelCount(int i2) {
        return i2 == 1 || i2 == 2;
    }

    private final boolean isSupportedSampleRate(int i2) {
        return i2 == 16000 || i2 == 44100 || i2 == 48000;
    }

    private final int withCallingSession(String str, boolean z2, y1.l lVar) {
        C0546a c0546a;
        Object objB;
        int iIntValue;
        int callingPid = Binder.getCallingPid();
        synchronized (this.sessionLock) {
            try {
                c0546a = (C0546a) this.sessions.get(Integer.valueOf(callingPid));
                k.b(1);
            } catch (Throwable th) {
                k.b(1);
                k.a(1);
                throw th;
            }
        }
        k.a(1);
        if (c0546a == null) {
            Log.w(TAG, str + ": no session for pid=" + callingPid);
            return -1;
        }
        try {
            l.a aVar = n1.l.f5861g;
            synchronized (c0546a) {
                try {
                    iIntValue = ((Number) lVar.invoke(c0546a)).intValue();
                    k.b(1);
                } catch (Throwable th2) {
                    k.b(1);
                    k.a(1);
                    throw th2;
                }
            }
            k.a(1);
            objB = n1.l.b(Integer.valueOf(iIntValue));
        } catch (Throwable th3) {
            l.a aVar2 = n1.l.f5861g;
            objB = n1.l.b(m.a(th3));
        }
        if (n1.l.g(objB)) {
            int iIntValue2 = ((Number) objB).intValue();
            if (z2) {
                Log.d(TAG, str + ": pid=" + callingPid + ", result=" + iIntValue2);
            }
        }
        Throwable thD = n1.l.d(objB);
        if (thD != null) {
            Log.e(TAG, str + " failed: pid=" + callingPid, thD);
            objB = -1;
        }
        return ((Number) objB).intValue();
    }

    static /* synthetic */ int withCallingSession$default(IFPBenQAudioRecordService iFPBenQAudioRecordService, String str, boolean z2, y1.l lVar, int i2, Object obj) {
        C0546a c0546a;
        Object objB;
        int iIntValue;
        if ((i2 & 2) != 0) {
            z2 = true;
        }
        int callingPid = Binder.getCallingPid();
        synchronized (iFPBenQAudioRecordService.sessionLock) {
            try {
                c0546a = (C0546a) iFPBenQAudioRecordService.sessions.get(Integer.valueOf(callingPid));
                k.b(1);
            } catch (Throwable th) {
                k.b(1);
                k.a(1);
                throw th;
            }
        }
        k.a(1);
        if (c0546a == null) {
            Log.w(TAG, str + ": no session for pid=" + callingPid);
            return -1;
        }
        try {
            l.a aVar = n1.l.f5861g;
            synchronized (c0546a) {
                try {
                    iIntValue = ((Number) lVar.invoke(c0546a)).intValue();
                    k.b(1);
                } catch (Throwable th2) {
                    k.b(1);
                    k.a(1);
                    throw th2;
                }
            }
            k.a(1);
            objB = n1.l.b(Integer.valueOf(iIntValue));
        } catch (Throwable th3) {
            l.a aVar2 = n1.l.f5861g;
            objB = n1.l.b(m.a(th3));
        }
        if (n1.l.g(objB)) {
            int iIntValue2 = ((Number) objB).intValue();
            if (z2) {
                Log.d(TAG, str + ": pid=" + callingPid + ", result=" + iIntValue2);
            }
        }
        Throwable thD = n1.l.d(objB);
        if (thD != null) {
            Log.e(TAG, str + " failed: pid=" + callingPid, thD);
            objB = -1;
        }
        return ((Number) objB).intValue();
    }

    public int configure(int i2, int i3, int i4) {
        Object objB;
        int iB;
        if (!isSupportedSampleRate(i2) || !isSupportedChannelCount(i3)) {
            Log.e(TAG, "configure: unsupported config sampleRate=" + i2 + ", channelCount=" + i3);
            return -11;
        }
        Integer numConvertAudioSource = convertAudioSource(i4);
        if (numConvertAudioSource == null) {
            return -10;
        }
        int iIntValue = numConvertAudioSource.intValue();
        int callingPid = Binder.getCallingPid();
        C0546a orCreateSession = getOrCreateSession(callingPid);
        try {
            l.a aVar = n1.l.f5861g;
            synchronized (orCreateSession) {
                iB = orCreateSession.b(i2, i3, iIntValue);
            }
            objB = n1.l.b(Integer.valueOf(iB));
        } catch (Throwable th) {
            l.a aVar2 = n1.l.f5861g;
            objB = n1.l.b(m.a(th));
        }
        if (n1.l.g(objB)) {
            Log.d(TAG, "configure: pid=" + callingPid + ", result=" + ((Number) objB).intValue());
        }
        Throwable thD = n1.l.d(objB);
        if (thD != null) {
            Log.e(TAG, "configure failed: pid=" + callingPid, thD);
            objB = -1;
        }
        return ((Number) objB).intValue();
    }

    public final void onCreate() {
        Log.d(TAG, "onCreate");
    }

    /* JADX WARN: Removed duplicated region for block: B:27:0x0071 A[Catch: all -> 0x0051, TryCatch #1 {, blocks: (B:15:0x0043, B:17:0x0049, B:25:0x006b, B:27:0x0071, B:28:0x0078, B:24:0x0061, B:14:0x0039, B:21:0x0053, B:11:0x0029), top: B:40:0x0049, inners: #0, #2 }] */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final void onDestroy() {
        /*
            r6 = this;
            java.lang.Object r0 = r6.sessionLock
            monitor-enter(r0)
            java.util.Map<java.lang.Integer, i0.a> r1 = r6.sessions     // Catch: java.lang.Throwable -> L9e
            java.util.Collection r1 = r1.values()     // Catch: java.lang.Throwable -> L9e
            java.lang.Iterable r1 = (java.lang.Iterable) r1     // Catch: java.lang.Throwable -> L9e
            java.util.List r1 = o1.AbstractC0676l.P(r1)     // Catch: java.lang.Throwable -> L9e
            java.util.Map<java.lang.Integer, i0.a> r2 = r6.sessions     // Catch: java.lang.Throwable -> L9e
            r2.clear()     // Catch: java.lang.Throwable -> L9e
            monitor-exit(r0)
            r0 = r1
            java.lang.Iterable r0 = (java.lang.Iterable) r0
            java.util.Iterator r0 = r0.iterator()
        L1c:
            boolean r2 = r0.hasNext()
            if (r2 == 0) goto L7e
            java.lang.Object r2 = r0.next()
            i0.a r2 = (i0.C0546a) r2
            monitor-enter(r2)
            n1.l$a r3 = n1.l.f5861g     // Catch: java.lang.Throwable -> L38
            int r3 = r2.i()     // Catch: java.lang.Throwable -> L38
            java.lang.Integer r3 = java.lang.Integer.valueOf(r3)     // Catch: java.lang.Throwable -> L38
            java.lang.Object r3 = n1.l.b(r3)     // Catch: java.lang.Throwable -> L38
            goto L43
        L38:
            r3 = move-exception
            n1.l$a r4 = n1.l.f5861g     // Catch: java.lang.Throwable -> L51
            java.lang.Object r3 = n1.m.a(r3)     // Catch: java.lang.Throwable -> L51
            java.lang.Object r3 = n1.l.b(r3)     // Catch: java.lang.Throwable -> L51
        L43:
            java.lang.Throwable r3 = n1.l.d(r3)     // Catch: java.lang.Throwable -> L51
            if (r3 == 0) goto L53
            java.lang.String r4 = "@IFPBenQAudioRecordService"
            java.lang.String r5 = "onDestroy stop failed"
            android.util.Log.w(r4, r5, r3)     // Catch: java.lang.Throwable -> L51
            goto L53
        L51:
            r0 = move-exception
            goto L7c
        L53:
            int r3 = r2.g()     // Catch: java.lang.Throwable -> L60
            java.lang.Integer r3 = java.lang.Integer.valueOf(r3)     // Catch: java.lang.Throwable -> L60
            java.lang.Object r3 = n1.l.b(r3)     // Catch: java.lang.Throwable -> L60
            goto L6b
        L60:
            r3 = move-exception
            n1.l$a r4 = n1.l.f5861g     // Catch: java.lang.Throwable -> L51
            java.lang.Object r3 = n1.m.a(r3)     // Catch: java.lang.Throwable -> L51
            java.lang.Object r3 = n1.l.b(r3)     // Catch: java.lang.Throwable -> L51
        L6b:
            java.lang.Throwable r3 = n1.l.d(r3)     // Catch: java.lang.Throwable -> L51
            if (r3 == 0) goto L78
            java.lang.String r4 = "@IFPBenQAudioRecordService"
            java.lang.String r5 = "onDestroy release failed"
            android.util.Log.w(r4, r5, r3)     // Catch: java.lang.Throwable -> L51
        L78:
            n1.s r3 = n1.s.f5871a     // Catch: java.lang.Throwable -> L51
            monitor-exit(r2)
            goto L1c
        L7c:
            monitor-exit(r2)
            throw r0
        L7e:
            java.lang.String r0 = "@IFPBenQAudioRecordService"
            int r1 = r1.size()
            java.lang.StringBuilder r2 = new java.lang.StringBuilder
            r2.<init>()
            java.lang.String r3 = "onDestroy: released "
            r2.append(r3)
            r2.append(r1)
            java.lang.String r1 = " sessions"
            r2.append(r1)
            java.lang.String r1 = r2.toString()
            android.util.Log.d(r0, r1)
            return
        L9e:
            r1 = move-exception
            monitor-exit(r0)
            throw r1
        */
        throw new UnsupportedOperationException("Method not decompiled: com.benq.platform.IFPBenQAudioRecordService.onDestroy():void");
    }

    public int read(byte[] bArr, int i2, int i3) {
        C0546a c0546a;
        Object objB;
        int iF;
        if (bArr == null) {
            Log.e(TAG, "read: audioData is null");
            return -1;
        }
        int callingPid = Binder.getCallingPid();
        synchronized (this.sessionLock) {
            c0546a = (C0546a) this.sessions.get(Integer.valueOf(callingPid));
        }
        if (c0546a == null) {
            Log.w(TAG, "read: no session for pid=" + callingPid);
            return -1;
        }
        try {
            l.a aVar = n1.l.f5861g;
            synchronized (c0546a) {
                iF = c0546a.f(bArr, i2, i3);
            }
            objB = n1.l.b(Integer.valueOf(iF));
        } catch (Throwable th) {
            l.a aVar2 = n1.l.f5861g;
            objB = n1.l.b(m.a(th));
        }
        if (n1.l.g(objB)) {
            ((Number) objB).intValue();
        }
        Throwable thD = n1.l.d(objB);
        if (thD != null) {
            Log.e(TAG, "read failed: pid=" + callingPid, thD);
            objB = -1;
        }
        return ((Number) objB).intValue();
    }

    public int release() {
        C0546a c0546aRemove;
        Object objB;
        int iG;
        int callingPid = Binder.getCallingPid();
        synchronized (this.sessionLock) {
            c0546aRemove = this.sessions.remove(Integer.valueOf(callingPid));
        }
        if (c0546aRemove == null) {
            Log.w(TAG, "release: no session for pid=" + callingPid);
            return -1;
        }
        try {
            l.a aVar = n1.l.f5861g;
            synchronized (c0546aRemove) {
                iG = c0546aRemove.g();
            }
            objB = n1.l.b(Integer.valueOf(iG));
        } catch (Throwable th) {
            l.a aVar2 = n1.l.f5861g;
            objB = n1.l.b(m.a(th));
        }
        if (n1.l.g(objB)) {
            Log.d(TAG, "release: pid=" + callingPid + ", result=" + ((Number) objB).intValue());
        }
        Throwable thD = n1.l.d(objB);
        if (thD != null) {
            Log.e(TAG, "release failed: pid=" + callingPid, thD);
            objB = -1;
        }
        return ((Number) objB).intValue();
    }

    public int startRecording() {
        C0546a c0546a;
        Object objB;
        int iH;
        int callingPid = Binder.getCallingPid();
        synchronized (this.sessionLock) {
            c0546a = (C0546a) this.sessions.get(Integer.valueOf(callingPid));
        }
        if (c0546a == null) {
            Log.w(TAG, "startRecording: no session for pid=" + callingPid);
            return -1;
        }
        try {
            l.a aVar = n1.l.f5861g;
            synchronized (c0546a) {
                iH = c0546a.h();
            }
            objB = n1.l.b(Integer.valueOf(iH));
        } catch (Throwable th) {
            l.a aVar2 = n1.l.f5861g;
            objB = n1.l.b(m.a(th));
        }
        if (n1.l.g(objB)) {
            Log.d(TAG, "startRecording: pid=" + callingPid + ", result=" + ((Number) objB).intValue());
        }
        Throwable thD = n1.l.d(objB);
        if (thD != null) {
            Log.e(TAG, "startRecording failed: pid=" + callingPid, thD);
            objB = -1;
        }
        return ((Number) objB).intValue();
    }

    public int stop() {
        C0546a c0546a;
        Object objB;
        int i2;
        int callingPid = Binder.getCallingPid();
        synchronized (this.sessionLock) {
            c0546a = (C0546a) this.sessions.get(Integer.valueOf(callingPid));
        }
        if (c0546a == null) {
            Log.w(TAG, "stop: no session for pid=" + callingPid);
            return -1;
        }
        try {
            l.a aVar = n1.l.f5861g;
            synchronized (c0546a) {
                i2 = c0546a.i();
            }
            objB = n1.l.b(Integer.valueOf(i2));
        } catch (Throwable th) {
            l.a aVar2 = n1.l.f5861g;
            objB = n1.l.b(m.a(th));
        }
        if (n1.l.g(objB)) {
            Log.d(TAG, "stop: pid=" + callingPid + ", result=" + ((Number) objB).intValue());
        }
        Throwable thD = n1.l.d(objB);
        if (thD != null) {
            Log.e(TAG, "stop failed: pid=" + callingPid, thD);
            objB = -1;
        }
        return ((Number) objB).intValue();
    }
}