package g.i.a.c.p; import android.annotation.TargetApi; import android.bluetooth.BluetoothDevice; import android.bluetooth.BluetoothGatt; import android.bluetooth.BluetoothGattCharacteristic; import android.bluetooth.BluetoothGattDescriptor; import android.content.Context; import android.os.Handler; import android.os.Looper; import com.cvte.vman.instance.InvokeCmd; import g.h.a.i; import io.netty.handler.codec.compression.Bzip2Constants; import io.netty.handler.traffic.AbstractTrafficShapingHandler; import java.util.Locale; import java.util.Objects; /* JADX INFO: loaded from: classes.dex */ public abstract class b extends g.i.a.c.o.b implements f { public g.i.a.b.e.h.c m0; public volatile boolean n0; public C0085b o0; public g.i.a.b.e.c p0; public BluetoothGatt q0; public volatile byte[] r0; public volatile boolean s0; public volatile boolean t0; public volatile boolean u0; public Handler v0; public Runnable w0; public class a implements Runnable { public a() { } @Override // java.lang.Runnable public void run() { BluetoothDevice bluetoothDeviceG; b bVar = b.this; if (bVar.f5605w == 513) { String str = bVar.O; int bondState = 10; if (bVar.i0 != null && (bluetoothDeviceG = bVar.G(str)) != null) { bondState = bluetoothDeviceG.getBondState(); } i.V3(b.this.f5594f, ">> mBondState: " + bondState); b.this.Z(); } } } /* JADX INFO: renamed from: g.i.a.c.p.b$b, reason: collision with other inner class name */ public class C0085b extends g.i.a.b.e.h.d { public C0085b(a aVar) { } @Override // g.i.a.b.e.h.d public void a(g.i.a.b.e.h.b bVar) { if (b.this.n0) { b.this.N(bVar); } else if (b.this.f5594f) { i.w0("is already stop the scan, do nothing"); } } @Override // g.i.a.b.e.h.d public void b(int i2) { Objects.requireNonNull(b.this); } } public b(Context context, g.i.a.c.q.f fVar, g.i.a.c.m.a.b bVar) { super(context, fVar, bVar); this.r0 = null; this.s0 = false; this.t0 = false; this.u0 = false; this.v0 = new Handler(Looper.getMainLooper()); this.w0 = new a(); } @Override // g.i.a.c.m.a.a public void A() { this.n0 = false; g.i.a.b.e.h.c cVar = this.m0; if (cVar != null) { cVar.j(); } } @Override // g.i.a.c.o.b public boolean H(g.i.a.b.e.h.e eVar) { if (this.f5594f) { i.U3("start le scan"); } this.n0 = true; g.i.a.b.e.h.c cVar = this.m0; if (cVar == null) { X(eVar); } else { cVar.f5308c = eVar; } return this.m0.k(); } public void L(BluetoothGatt bluetoothGatt) { if (bluetoothGatt != null) { BluetoothDevice device = bluetoothGatt.getDevice(); boolean zF = r().f(4); if (this.f5594f) { i.U3(String.format("close gatt connection: %s, closeClient=%b", device.getAddress(), Boolean.valueOf(zF))); } g.i.a.b.e.c cVar = this.p0; if (cVar != null) { cVar.c(device.getAddress(), zF); } else if (zF) { bluetoothGatt.close(); } } B(1280); } public void M(BluetoothGatt bluetoothGatt, BluetoothGattCharacteristic bluetoothGattCharacteristic, boolean z2) { StringBuilder sb; String str; String strL; int properties = bluetoothGattCharacteristic.getProperties(); if ((properties & 16) == 0) { strL = g.a.a.a.a.l("check properties failed: ", properties); } else { if (this.f5594f) { sb = g.a.a.a.a.F("setCharacteristicNotification() - uuid: "); sb.append(bluetoothGattCharacteristic.getUuid()); str = " enabled: "; } else { sb = new StringBuilder(); str = "setCharacteristicNotification() enabled: "; } sb.append(str); sb.append(z2); i.U3(sb.toString()); if (!bluetoothGatt.setCharacteristicNotification(bluetoothGattCharacteristic, z2)) { this.M = 266; throw new g.i.a.c.g.c("setCharacteristicNotification failed", this.M); } BluetoothGattDescriptor descriptor = bluetoothGattCharacteristic.getDescriptor(f.f5633b); if (descriptor == null) { this.M = 266; throw new g.i.a.c.g.c("no descriptor exist", this.M); } boolean z3 = descriptor.getValue() != null && descriptor.getValue().length == 2 && descriptor.getValue()[0] > 0 && descriptor.getValue()[1] == 0; g.a.a.a.a.l0("current cccd state: ", z3, this.f5594f); if (z2 && z3) { strL = "cccd already enabled"; } else { if (z2 || z3) { this.M = 0; this.s0 = false; descriptor.setValue(z2 ? BluetoothGattDescriptor.ENABLE_NOTIFICATION_VALUE : BluetoothGattDescriptor.DISABLE_NOTIFICATION_VALUE); if (!bluetoothGatt.writeDescriptor(descriptor)) { this.M = 266; throw new g.i.a.c.g.c("writeDescriptor failed", this.M); } synchronized (this.V) { if (this.M == 0 && !this.s0) { try { this.V.wait(AbstractTrafficShapingHandler.DEFAULT_MAX_TIME); } catch (InterruptedException e2) { i.W3("wait writeDescriptor interrupted: " + e2.toString()); } } } if (this.M == 0 && !this.s0) { StringBuilder sb2 = new StringBuilder(); sb2.append(z2 ? "Enabling " : "Disabling"); sb2.append(" notifications failed"); i.W3(sb2.toString()); this.M = 266; } if (this.M != 0) { throw new g.i.a.c.g.c("Unable to set notifications state", this.M); } if (this.f5594f) { StringBuilder sb3 = new StringBuilder(); sb3.append(z2 ? "Enabe" : "Disable"); sb3.append(" notifications success"); i.U3(sb3.toString()); return; } return; } strL = "cccd already disable"; } } i.W3(strL); } /* JADX WARN: Removed duplicated region for block: B:62:0x011d */ /* JADX WARN: Removed duplicated region for block: B:63:0x011f */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public void N(g.i.a.b.e.h.b r6) { /* Method dump skipped, instruction units count: 363 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: g.i.a.c.p.b.N(g.i.a.b.e.h.b):void"); } public void O(g.i.a.b.e.h.e eVar, long j2) { if (this.f5600r) { throw new g.i.a.c.g.c("user aborted", InvokeCmd.CMD_EXTENDDISPLAY_CTRL_GET_DISPLAY_EDID_INFO); } z(InvokeCmd.CMD_XBUG_GET_LOG_NODE_INFO, true); this.M = 0; this.k0 = false; H(eVar); try { synchronized (this.j0) { if (this.M == 0 && !this.k0) { this.j0.wait(j2); } } } catch (InterruptedException e2) { StringBuilder sbF = g.a.a.a.a.F("scanLeDevice interrupted, e = "); sbF.append(e2.toString()); i.W3(sbF.toString()); this.M = 259; } if (this.M == 0 && !this.k0) { i.W3("didn't find the special device"); this.M = 265; } if (this.M != 0) { throw new g.i.a.c.g.c("Error while scan remote ota device", this.M); } } @TargetApi(23) public boolean P(BluetoothGatt bluetoothGatt, int i2) { this.M = 0; this.u0 = false; if (this.f5594f) { g.a.a.a.a.a0("requestMtu: ", i2); } if (!bluetoothGatt.requestMtu(i2)) { i.W3("requestMtu failed"); return false; } try { synchronized (this.V) { if (!this.u0 && this.M == 0) { if (this.f5594f) { i.U3("wait mtu request callback for 15000ms"); } this.V.wait(AbstractTrafficShapingHandler.DEFAULT_MAX_TIME); } } } catch (InterruptedException e2) { i.W3("requestMtu: Sleeping interrupted, e = " + e2); } if (this.u0 || this.M != 0) { return true; } if (this.f5594f) { i.w0("requestMtu No CallBack"); } return false; } public boolean Q(BluetoothGatt bluetoothGatt, BluetoothGattCharacteristic bluetoothGattCharacteristic, byte[] bArr, int i2, boolean z2) { String str; byte[] bArr2; boolean zWriteCharacteristic; if (!z2 && this.f5600r) { throw new g.i.a.c.g.c("user aborted", InvokeCmd.CMD_EXTENDDISPLAY_CTRL_GET_DISPLAY_EDID_INFO); } if (bluetoothGattCharacteristic == null) { str = "characteristic == null"; } else { if (bArr != null && i2 >= 0) { this.r0 = null; this.C = true; boolean z3 = false; int i3 = 0; while (this.C) { this.B = false; if (i3 > 0) { try { if (this.f5594f) { i.w0("re-send command just wait a while"); } Thread.sleep(1000L); } catch (InterruptedException e2) { i.W3(e2.toString()); } if (!z2 && this.f5600r) { throw new g.i.a.c.g.c("user aborted", InvokeCmd.CMD_EXTENDDISPLAY_CTRL_GET_DISPLAY_EDID_INFO); } } long j2 = AbstractTrafficShapingHandler.DEFAULT_MAX_TIME; if (bluetoothGattCharacteristic.getWriteType() == 2) { j2 = 30000; } if (bluetoothGatt == null) { i.W3("gatt == null"); zWriteCharacteristic = false; } else { if (bArr.length > i2) { bArr2 = new byte[i2]; System.arraycopy(bArr, 0, bArr2, 0, i2); } else { bArr2 = bArr; } if (this.f5594f) { i.U3(String.format(Locale.US, "[TX] WRITE_TYPE_0x%02X, (%d)%s >> (%d)%s", Integer.valueOf(bluetoothGattCharacteristic.getWriteType()), Integer.valueOf(bluetoothGattCharacteristic.getInstanceId()), bluetoothGattCharacteristic.getUuid(), Integer.valueOf(bArr2.length), i.y(bArr2))); } bluetoothGattCharacteristic.setValue(bArr2); zWriteCharacteristic = bluetoothGatt.writeCharacteristic(bluetoothGattCharacteristic); } if (zWriteCharacteristic) { synchronized (this.A) { try { if (!this.B && this.f5605w == 515) { this.A.wait(j2); } } catch (InterruptedException e3) { i.W3("mWriteLock Sleeping interrupted,e:" + e3); if (this.M == 0) { this.M = 259; } } } if (this.M == 0 && !this.B) { i.W3("send command but no callback"); this.M = 261; } z3 = zWriteCharacteristic; } else { i.W3("writePacket failed"); this.M = 267; z3 = false; } if (this.M != 0 || i3 <= 3) { i3++; } else { i.W3("send command reach max try time"); this.M = 268; } if (this.M != 0) { throw new g.i.a.c.g.c("Error while send command", this.M); } } return z3; } str = "value == null || size < 0"; } i.W3(str); return false; } public boolean R(BluetoothGattCharacteristic bluetoothGattCharacteristic, byte[] bArr, boolean z2) { return Q(this.q0, bluetoothGattCharacteristic, bArr, bArr != null ? bArr.length : -1, z2); } /* JADX WARN: Removed duplicated region for block: B:41:0x00a3 */ /* JADX WARN: Removed duplicated region for block: B:43:0x00a6 */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public byte[] S(android.bluetooth.BluetoothGattCharacteristic r8) { /* r7 = this; android.bluetooth.BluetoothGatt r0 = r7.q0 boolean r1 = r7.f5600r if (r1 != 0) goto Lb0 r1 = 0 if (r0 != 0) goto Lc java.lang.String r8 = "gatt == null" goto L1b Lc: if (r8 != 0) goto L11 java.lang.String r8 = "characteristic == null" goto L1b L11: int r2 = r8.getProperties() r3 = 2 r2 = r2 & r3 if (r2 != 0) goto L20 java.lang.String r8 = "characteristic not support PROPERTY_READ" L1b: g.h.a.i.W3(r8) goto La5 L20: java.util.Locale r2 = java.util.Locale.US java.lang.Object[] r3 = new java.lang.Object[r3] int r4 = r8.getInstanceId() java.lang.Integer r4 = java.lang.Integer.valueOf(r4) r5 = 0 r3[r5] = r4 java.util.UUID r4 = r8.getUuid() java.lang.String r4 = r4.toString() r6 = 1 r3[r6] = r4 java.lang.String r4 = "readCharacteristic:(handler=%d) %s" java.lang.String r2 = java.lang.String.format(r2, r4, r3) g.h.a.i.U3(r2) r7.M = r5 r7.f5608z = r1 r7.f5607y = r5 boolean r8 = r0.readCharacteristic(r8) if (r8 == 0) goto L96 java.lang.Object r8 = r7.f5606x monitor-enter(r8) int r0 = r7.M // Catch: java.lang.Throwable -> L68 java.lang.InterruptedException -> L6a if (r0 != 0) goto L83 boolean r0 = r7.f5607y // Catch: java.lang.Throwable -> L68 java.lang.InterruptedException -> L6a if (r0 != 0) goto L83 int r0 = r7.f5605w // Catch: java.lang.Throwable -> L68 java.lang.InterruptedException -> L6a r1 = 515(0x203, float:7.22E-43) if (r0 != r1) goto L83 java.lang.Object r0 = r7.f5606x // Catch: java.lang.Throwable -> L68 java.lang.InterruptedException -> L6a r1 = 15000(0x3a98, double:7.411E-320) r0.wait(r1) // Catch: java.lang.Throwable -> L68 java.lang.InterruptedException -> L6a goto L83 L68: r0 = move-exception goto L94 L6a: r0 = move-exception java.lang.StringBuilder r1 = new java.lang.StringBuilder // Catch: java.lang.Throwable -> L68 r1.() // Catch: java.lang.Throwable -> L68 java.lang.String r2 = "mCharacteristicReadCalledLock Sleeping interrupted,e:" r1.append(r2) // Catch: java.lang.Throwable -> L68 r1.append(r0) // Catch: java.lang.Throwable -> L68 java.lang.String r0 = r1.toString() // Catch: java.lang.Throwable -> L68 g.h.a.i.W3(r0) // Catch: java.lang.Throwable -> L68 r0 = 259(0x103, float:3.63E-43) r7.M = r0 // Catch: java.lang.Throwable -> L68 L83: monitor-exit(r8) // Catch: java.lang.Throwable -> L68 int r8 = r7.M if (r8 != 0) goto L9f boolean r8 = r7.f5607y if (r8 != 0) goto L9f java.lang.String r8 = "read value but no callback" g.h.a.i.W3(r8) r8 = 261(0x105, float:3.66E-43) goto L9d L94: monitor-exit(r8) // Catch: java.lang.Throwable -> L68 throw r0 L96: java.lang.String r8 = "readCharacteristic failed" g.h.a.i.w0(r8) r8 = 279(0x117, float:3.91E-43) L9d: r7.M = r8 L9f: int r8 = r7.M if (r8 != 0) goto La6 byte[] r1 = r7.f5608z La5: return r1 La6: g.i.a.c.g.c r8 = new g.i.a.c.g.c int r0 = r7.M java.lang.String r1 = "Error while send command" r8.(r1, r0) throw r8 Lb0: g.i.a.c.g.c r8 = new g.i.a.c.g.c java.lang.String r0 = "user aborted" r1 = 4128(0x1020, float:5.785E-42) r8.(r0, r1) throw r8 */ throw new UnsupportedOperationException("Method not decompiled: g.i.a.c.p.b.S(android.bluetooth.BluetoothGattCharacteristic):byte[]"); } public void T(int i2) { if (!r().G) { i.w0("not support update buffer check mtu size"); } else { this.f5592c0 = i2 + (-3) > 16 ? 16 * (i2 / 16) : 16; g.a.a.a.a.n0(g.a.a.a.a.F("> mBufferCheckMtuSize="), this.f5592c0); } } public void U(BluetoothGatt bluetoothGatt) { int i2 = this.f5605w; if (i2 == 0 || i2 == 1280) { if (this.f5594f) { i.w0("already disconnect"); } } else if (bluetoothGatt == null) { if (this.f5594f) { i.U3("gatt == null"); } B(0); } else { B(1024); if (this.f5594f) { i.U3("disconnect()"); } bluetoothGatt.disconnect(); D(); } } public byte[] V(long j2) throws g.i.a.c.g.c { this.M = 0; this.t0 = true; try { synchronized (this.V) { if (this.M == 0 && this.r0 == null && this.f5605w == 515) { this.t0 = false; this.V.wait(j2); } if (this.M == 0 && !this.t0) { i.W3("wait for notification, but not come"); this.M = 767; } } } catch (InterruptedException e2) { StringBuilder sbF = g.a.a.a.a.F("readNotificationResponse interrupted, "); sbF.append(e2.toString()); i.W3(sbF.toString()); this.M = 259; } if (this.M == 0) { return this.r0; } throw new g.i.a.c.g.c("Unable to receive notification", this.M); } public void W(int i2) { this.U = i2 + (-3) > 16 ? 16 * (i2 / 16) : 16; g.a.a.a.a.n0(g.a.a.a.a.F("> MAX_PACKET_SIZE="), this.U); } public final void X(g.i.a.b.e.h.e eVar) { if (this.o0 == null) { this.o0 = new C0085b(null); } this.m0 = new g.i.a.b.e.h.c(this.f5595m, eVar, this.o0); } public void Y(int i2) { try { Thread.sleep(1000L); } catch (InterruptedException unused) { } i.w0(String.format("terminateConnection, error = 0x%04X", Integer.valueOf(i2))); BluetoothGatt bluetoothGatt = this.q0; if (bluetoothGatt != null) { U(bluetoothGatt); BluetoothGatt bluetoothGatt2 = this.q0; if (r().f(2) || bluetoothGatt2.getDevice().getBondState() == 10) { g.i.a.b.e.g.a.b(bluetoothGatt2); } L(this.q0); } } public boolean Z() { if (this.q0 == null) { i.W3("mBluetoothGatt == null"); this.M = Bzip2Constants.HUFFMAN_MAX_ALPHABET_SIZE; w(); return false; } if (this.f5600r) { i.W3("task already aborted, ignore"); this.M = InvokeCmd.CMD_EXTENDDISPLAY_CTRL_GET_DISPLAY_EDID_INFO; return false; } if (this.f5594f) { i.w0("Attempting to start service discovery..."); } boolean zDiscoverServices = this.q0.discoverServices(); if (!zDiscoverServices) { this.M = Bzip2Constants.HUFFMAN_MAX_ALPHABET_SIZE; w(); } return zDiscoverServices; } public g.i.a.b.e.h.e a0() { g.i.a.b.e.h.e eVar = new g.i.a.b.e.h.e(17); eVar.f5394s = 31000L; return eVar; } public void b0() { B(InvokeCmd.CMD_XBUG_SET_VMAN_SERVICE_LOG_LEVEL); if (this.v0 == null) { Z(); } else { i.U3(String.format(Locale.US, "delay to discover service for :%d ms ", 1600)); this.v0.postDelayed(this.w0, 1600L); } } public byte[] c0() { return V(r().h0); } /* JADX WARN: Removed duplicated region for block: B:25:0x0059 */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public boolean d0() { /* r6 = this; android.bluetooth.BluetoothGatt r0 = r6.q0 r1 = 0 if (r0 != 0) goto L8 java.lang.String r0 = "mBluetoothGatt == null" goto Le L8: boolean r0 = r6.f5600r if (r0 == 0) goto L12 java.lang.String r0 = "task already aborted, ignore" Le: g.h.a.i.W3(r0) return r1 L12: g.i.a.c.q.f r0 = r6.r() int r0 = r0.f5694d0 r2 = 1 if (r0 != 0) goto L23 boolean r0 = r6.f5594f java.lang.String r1 = "no need to set phy" g.h.a.i.V3(r0, r1) return r2 L23: boolean r0 = r6.f5594f java.lang.String r3 = "setPreferredPhy:" java.lang.StringBuilder r3 = g.a.a.a.a.F(r3) g.i.a.c.q.f r4 = r6.r() int r4 = r4.f5694d0 r3.append(r4) java.lang.String r3 = r3.toString() g.h.a.i.V3(r0, r3) g.i.a.c.q.f r0 = r6.r() int r0 = r0.f5694d0 if (r0 == 0) goto L5f r3 = 2 if (r0 == r2) goto L59 r4 = 4 if (r0 == r3) goto L53 r5 = 3 if (r0 == r5) goto L4d goto L59 L4d: android.bluetooth.BluetoothGatt r0 = r6.q0 r0.setPreferredPhy(r4, r4, r3) goto L64 L53: android.bluetooth.BluetoothGatt r0 = r6.q0 r0.setPreferredPhy(r4, r4, r2) goto L64 L59: android.bluetooth.BluetoothGatt r0 = r6.q0 r0.setPreferredPhy(r3, r3, r1) goto L64 L5f: android.bluetooth.BluetoothGatt r0 = r6.q0 r0.setPreferredPhy(r2, r2, r1) L64: return r2 */ throw new UnsupportedOperationException("Method not decompiled: g.i.a.c.p.b.d0():boolean"); } @Override // g.i.a.c.m.a.a public boolean e() { Handler handler = this.v0; if (handler != null) { handler.removeCallbacks(this.w0); } super.e(); return true; } public boolean e0() { this.n0 = false; g.i.a.b.e.h.c cVar = this.m0; if (cVar != null) { return cVar.l(); } return true; } @Override // g.i.a.c.o.b, g.i.a.c.m.a.a public void u() { super.u(); this.p0 = g.i.a.b.e.c.f5337b; X(null); } }