84 lines
3.4 KiB
Java
84 lines
3.4 KiB
Java
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;
|
|
}
|
|
}
|