package qbsg.top.ble;
final class BleManager$startDeviceInfoRead$1 extends kotlin.coroutines.jvm.internal.SuspendLambda implements a7.e {
    final synthetic String $address;
    final synthetic android.bluetooth.BluetoothGatt $gatt;
    int label;
    final synthetic qbsg.top.ble.BleManager this$0;

    public BleManager$startDeviceInfoRead$1(qbsg.top.ble.BleManager p1, String p2, android.bluetooth.BluetoothGatt p3, kotlin.coroutines.Continuation p4)
    {
        this.this$0 = p1;
        this.$address = p2;
        this.$gatt = p3;
        super(2, p4);
        return;
    }

    public final kotlin.coroutines.Continuation create(Object p4, kotlin.coroutines.Continuation p5)
    {
        return new qbsg.top.ble.BleManager$startDeviceInfoRead$1(this.this$0, this.$address, this.$gatt, p5);
    }

    public bridge synthetic Object invoke(Object p1, Object p2)
    {
        return this.invoke(((kotlinx.coroutines.CoroutineScope) p1), ((kotlin.coroutines.Continuation) p2));
    }

    public final Object invoke(kotlinx.coroutines.CoroutineScope p1, kotlin.coroutines.Continuation p2)
    {
        return ((qbsg.top.ble.BleManager$startDeviceInfoRead$1) this.create(p1, p2)).invokeSuspend(p6.a0.a);
    }

    public final Object invokeSuspend(Object p8)
    {
        int v0_0 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED();
        String v1_1 = this.label;
        if (v1_1 == null) {
            q6.y.Y(p8);
            p6.a0 v8_10 = qbsg.top.ble.BleManager.access$getReadChannels$p(this.this$0);
            String v1_0 = this.$address;
            if (v8_10.get(v1_0) == null) {
                v8_10.putIfAbsent(v1_0, kotlinx.coroutines.channels.ChannelKt.Channel$default(2147483647, 0, 0, 6, 0));
            }
            p6.a0 v8_1 = this.this$0;
            String v1_2 = this.$gatt;
            java.util.UUID v4_3 = this.$address;
            kotlin.jvm.internal.s.c(v4_3);
            String v5_1 = qbsg.top.ble.BleManagerKt.access$getMODEL_NUMBER_UUID$p();
            kotlin.jvm.internal.s.e(v5_1, "access$getMODEL_NUMBER_UUID$p(...)");
            this.label = 1;
            if (qbsg.top.ble.BleManager.access$readDeviceInfoString(v8_1, v1_2, v4_3, v5_1, this) != v0_0) {
                p6.a0 v8_3 = this.this$0;
                String v1_3 = this.$gatt;
                String v3_0 = this.$address;
                kotlin.jvm.internal.s.c(v3_0);
                java.util.UUID v4_4 = qbsg.top.ble.BleManagerKt.access$getFIRMWARE_REVISION_UUID$p();
                kotlin.jvm.internal.s.e(v4_4, "access$getFIRMWARE_REVISION_UUID$p(...)");
                this.label = 2;
                p8 = qbsg.top.ble.BleManager.access$readDeviceInfoString(v8_3, v1_3, v3_0, v4_4, this);
                if (p8 == v0_0) {
                    return v0_0;
                }
            }
        } else {
            if (v1_1 == 1) {
                q6.y.Y(p8);
            } else {
                if (v1_1 != 2) {
                    throw new IllegalStateException("call to \'resume\' before \'invoke\' with coroutine");
                } else {
                    q6.y.Y(p8);
                }
            }
        }
        p6.a0 v8_6 = ((String) p8);
        java.util.concurrent.ConcurrentHashMap vtmp10 = qbsg.top.ble.BleManager.access$getPendingFirmware$p(this.this$0);
        if (((String) p8) == null) {
            v8_6 = "";
        }
        vtmp10.put(this.$address, v8_6);
        this.$gatt.requestMtu(512);
        return p6.a0.a;
    }
}