package g.i.a.c.z;

import android.bluetooth.BluetoothDevice;
import android.content.Context;
import com.cvte.vman.instance.InvokeCmd;
import io.netty.handler.codec.compression.Bzip2Constants;
import io.netty.handler.codec.dns.DnsRecord;
import io.netty.handler.codec.http2.Http2CodecUtil;
import io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.util.Locale;
import java.util.Objects;
import no.nordicsemi.android.dfu.DfuBaseService;

/* JADX INFO: loaded from: classes.dex */
public class k extends g.i.a.c.x.a {
    public g.i.a.a.a.a.d u0;

    public class a extends g.i.a.a.a.a.d {
        public a() {
        }

        /*  JADX ERROR: UnsupportedOperationException in pass: RegionMakerVisitor
            java.lang.UnsupportedOperationException
            	at java.base/java.util.Collections$UnmodifiableCollection.add(Collections.java:1093)
            	at jadx.core.dex.visitors.regions.maker.SwitchRegionMaker$1.leaveRegion(SwitchRegionMaker.java:390)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.traverseInternal(DepthRegionTraversal.java:70)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.lambda$traverseInternal$0(DepthRegionTraversal.java:68)
            	at java.base/java.util.ArrayList.forEach(ArrayList.java:1604)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.traverseInternal(DepthRegionTraversal.java:68)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.traverse(DepthRegionTraversal.java:23)
            	at jadx.core.dex.visitors.regions.maker.SwitchRegionMaker.insertBreaksForCase(SwitchRegionMaker.java:370)
            	at jadx.core.dex.visitors.regions.maker.SwitchRegionMaker.insertBreaks(SwitchRegionMaker.java:85)
            	at jadx.core.dex.visitors.regions.PostProcessRegions.leaveRegion(PostProcessRegions.java:33)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.traverseInternal(DepthRegionTraversal.java:70)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.lambda$traverseInternal$0(DepthRegionTraversal.java:68)
            	at java.base/java.util.ArrayList.forEach(ArrayList.java:1604)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.traverseInternal(DepthRegionTraversal.java:68)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.lambda$traverseInternal$0(DepthRegionTraversal.java:68)
            	at java.base/java.util.ArrayList.forEach(ArrayList.java:1604)
            	at java.base/java.util.Collections$UnmodifiableCollection.forEach(Collections.java:1118)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.traverseInternal(DepthRegionTraversal.java:68)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.lambda$traverseInternal$0(DepthRegionTraversal.java:68)
            	at java.base/java.util.ArrayList.forEach(ArrayList.java:1604)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.traverseInternal(DepthRegionTraversal.java:68)
            	at jadx.core.dex.visitors.regions.DepthRegionTraversal.traverse(DepthRegionTraversal.java:19)
            	at jadx.core.dex.visitors.regions.PostProcessRegions.process(PostProcessRegions.java:23)
            	at jadx.core.dex.visitors.regions.RegionMakerVisitor.visit(RegionMakerVisitor.java:31)
            */
        @Override // g.i.a.a.a.a.d
        public void a(g.i.a.a.a.a.a r6) {
            /*
                r5 = this;
                g.i.a.c.z.k r0 = g.i.a.c.z.k.this
                java.util.Objects.requireNonNull(r0)
                short r1 = r6.a
                byte r2 = r6.f5275b
                java.util.Map<java.lang.Short, g.i.a.a.a.a.a> r3 = r0.s0
                java.lang.Short r4 = java.lang.Short.valueOf(r1)
                boolean r3 = r3.containsKey(r4)
                if (r3 == 0) goto L1e
                java.util.Map<java.lang.Short, g.i.a.a.a.a.a> r3 = r0.s0
                java.lang.Short r4 = java.lang.Short.valueOf(r1)
                r3.put(r4, r6)
            L1e:
                r3 = 1
                r4 = 1536(0x600, float:2.152E-42)
                if (r1 == r4) goto L38
                switch(r1) {
                    case 1538: goto L2a;
                    case 1539: goto L2a;
                    case 1540: goto L2a;
                    case 1541: goto L2a;
                    case 1542: goto L2a;
                    case 1543: goto L2a;
                    case 1544: goto L2a;
                    case 1545: goto L2a;
                    default: goto L26;
                }
            L26:
                switch(r1) {
                    case 1551: goto L2a;
                    case 1552: goto L2a;
                    case 1553: goto L2a;
                    case 1554: goto L2a;
                    default: goto L29;
                }
            L29:
                goto L5a
            L2a:
                byte r6 = r6.f5275b
                if (r6 != 0) goto L32
                r6 = 0
                r0.C = r6
                goto L34
            L32:
                r0.C = r3
            L34:
                r0.q()
                goto L5a
            L38:
                java.lang.String r6 = "ACK-CMD_OTA_GET_DEVICE_INFO"
                g.h.a.i.U3(r6)
                r6 = 2
                if (r2 == r6) goto L42
                if (r2 != r3) goto L5a
            L42:
                java.lang.String r6 = "CMD_OTA_GET_DEVICE_INFO not support"
                g.h.a.i.W3(r6)
                r6 = 281(0x119, float:3.94E-43)
                r0.M = r6
                r6 = 0
                r0.f5608z = r6
                java.util.Set<java.lang.Short> r6 = r0.r0
                java.lang.Short r1 = java.lang.Short.valueOf(r4)
                r6.remove(r1)
                r0.y()
            L5a:
                return
            */
            throw new UnsupportedOperationException("Method not decompiled: g.i.a.c.z.k.a.a(g.i.a.a.a.a.a):void");
        }

        @Override // g.i.a.a.a.a.d
        public void b(BluetoothDevice bluetoothDevice, boolean z2, int i2) {
            if (i2 == 512) {
                k.this.B(InvokeCmd.CMD_XBUG_SET_XBUG_DUMP_CVTE_LOG);
            } else {
                if (i2 != 0) {
                    return;
                }
                if (k.this.E == 521) {
                    k.this.M = 2048;
                    if (k.this.f5594f) {
                        g.a.a.a.a.m0(g.a.a.a.a.F("disconnect in OTA process, mErrorState: "), k.this.M);
                    }
                }
                k.this.B(0);
                synchronized (k.this.f5606x) {
                    k.this.f5607y = false;
                    k.this.f5606x.notifyAll();
                }
            }
            k.this.w();
            k.this.q();
        }

        @Override // g.i.a.a.a.a.d
        public void c(g.i.a.a.a.a.e eVar) {
            k kVar = k.this;
            Objects.requireNonNull(kVar);
            short s2 = eVar.f5300d;
            byte[] bArr = eVar.f5301e;
            switch (s2) {
                case 1536:
                case InvokeCmd.CMD_EASYTOUCH_GET_LOGINFO /* 1537 */:
                case 1544:
                case 1545:
                case 1549:
                    short s3 = (short) (s2 & 65535);
                    if (!kVar.r0.contains(Short.valueOf(s3))) {
                        g.h.a.i.w0(String.format("not expect event: 0x%04X", Short.valueOf(s3)));
                        return;
                    }
                    kVar.r0.remove(Short.valueOf(s3));
                    kVar.f5608z = bArr;
                    kVar.y();
                    return;
                case 1538:
                case 1540:
                case 1541:
                case 1542:
                case 1543:
                case 1547:
                case 1550:
                case 1551:
                case 1552:
                    synchronized (kVar.V) {
                        kVar.p0 = bArr;
                        kVar.q0 = true;
                        kVar.V.notifyAll();
                        break;
                    }
                    return;
                case 1539:
                case 1546:
                case 1548:
                default:
                    return;
            }
        }
    }

    public k(Context context, g.i.a.c.q.f fVar, g.i.a.c.m.a.b bVar) {
        super(context, fVar, bVar);
        this.u0 = new a();
    }

    @Override // g.i.a.c.x.a, g.i.a.c.m.a.a
    public void A() {
        this.n0 = false;
        g.i.a.b.e.h.a aVar = this.m0;
        if (aVar != null) {
            aVar.j();
        }
        g.i.a.a.a.a.c cVar = this.t0;
        if (cVar != null) {
            cVar.k(this.u0);
        }
    }

    public byte S(int i2, byte[] bArr) {
        if (bArr == null || bArr.length != 32) {
            StringBuilder sbF = g.a.a.a.a.F("invalid sha256:");
            sbF.append(g.h.a.i.y(bArr));
            g.h.a.i.U3(sbF.toString());
            return (byte) 0;
        }
        if (this.f5594f) {
            g.h.a.i.U3(String.format(Locale.US, "checkImage:imageId=0x%04X, sha256=%s", Integer.valueOf(i2), g.h.a.i.y(bArr)));
        }
        byte[] bArr2 = new byte[36];
        bArr2[0] = 1;
        bArr2[1] = 0;
        bArr2[2] = (byte) (i2 & DnsRecord.CLASS_ANY);
        bArr2[3] = (byte) ((i2 >> 8) & DnsRecord.CLASS_ANY);
        System.arraycopy(bArr, 0, bArr2, 4, 32);
        if (this.f5594f) {
            g.h.a.i.U3(String.format("<< CMD_CHECK_IMAGE (0x%04X)", (short) 1552));
        }
        if (!L((short) 1552, bArr2)) {
            throw new g.i.a.c.g.c("checkImage failed", 512);
        }
        g.h.a.i.V3(this.f5594f, "... waiting CMD_CHECK_IMAGE response");
        byte[] bArrP = P(30000L);
        if (bArrP == null || bArrP.length < 2) {
            return (byte) 0;
        }
        ByteBuffer byteBufferWrap = ByteBuffer.wrap(bArrP);
        byteBufferWrap.order(ByteOrder.LITTLE_ENDIAN);
        int i3 = (((short) (byteBufferWrap.get(1) & 255)) << 8) | ((short) (byteBufferWrap.get(0) & 255));
        byte b2 = byteBufferWrap.get(2);
        if (this.f5594f) {
            g.h.a.i.U3(String.format(Locale.US, "image_Id=%d,result=0x%02X ", Integer.valueOf(i3), Byte.valueOf(b2)));
        }
        return b2;
    }

    public int T(String str, int i2) {
        BluetoothDevice remoteDevice;
        int i3;
        int i4;
        int i5 = 0;
        while (!this.f5600r) {
            B(256);
            this.M = 0;
            this.f5603u = false;
            try {
                remoteDevice = this.i0.getRemoteDevice(str);
            } catch (Exception e2) {
                g.h.a.i.W3(e2.toString());
                remoteDevice = null;
            }
            if (remoteDevice == null) {
                i3 = InvokeCmd.CMD_EXTENDDISPLAY_CTRL_GET_HDMI_IN_OUT;
            } else {
                g.h.a.i.V3(this.f5594f, "connecting to " + str);
                n0().h(this.u0);
                n0().b(remoteDevice, null);
                try {
                    synchronized (this.f5604v) {
                        if (!this.f5603u && this.M == 0) {
                            g.h.a.i.x0(this.f5594f, "wait for connect for 32000 ms");
                            this.f5604v.wait(32000L);
                        }
                    }
                } catch (InterruptedException e3) {
                    StringBuilder sbF = g.a.a.a.a.F("Sleeping interrupted : ");
                    sbF.append(e3.toString());
                    g.h.a.i.W3(sbF.toString());
                    this.M = 259;
                }
                if (this.M == 0) {
                    if (!this.f5603u) {
                        g.h.a.i.W3("wait for connect, but can not connect with no callback");
                        i4 = 260;
                    } else if (this.f5605w != 515) {
                        StringBuilder sbF2 = g.a.a.a.a.F("connect with some error, please check. mConnectionState");
                        sbF2.append(this.f5605w);
                        g.h.a.i.W3(sbF2.toString());
                        i4 = 264;
                    }
                    this.M = i4;
                }
                if (this.M == 0) {
                    g.h.a.i.V3(false, "connected the device which going to upgrade");
                } else if (this.f5605w == 256) {
                    B(0);
                }
                i3 = this.M;
            }
            if (i3 == 0) {
                return 0;
            }
            if ((i3 & (-2049)) != 133) {
                l0();
            } else {
                g.h.a.i.X3(this.f5594f, "connect fail with GATT_ERROR, do not need disconnect");
            }
            B(1280);
            try {
                Thread.sleep(1600L);
            } catch (InterruptedException e4) {
                e4.printStackTrace();
            }
            i5++;
            if (i5 > i2) {
                return i3;
            }
        }
        return InvokeCmd.CMD_EXTENDDISPLAY_CTRL_GET_DISPLAY_EDID_INFO;
    }

    public void U(byte b2) {
        p pVar = new p(this.G.G, b2, null);
        g.h.a.i.V3(this.f5594f, pVar.toString());
        if (t().f5681q) {
            L((short) 1538, this.L.a(pVar.a(), 0, 16));
        } else {
            L((short) 1538, pVar.a());
        }
        g.h.a.i.V3(false, "... Reading CMD_OTA_START notification");
        byte b3 = R()[0];
        if (b3 != 1) {
            throw g.a.a.a.a.c("start dfu failed, status=0x%02X", new Object[]{Byte.valueOf(b3)}, "start dfu failed", 766);
        }
    }

    public void V(byte b2, boolean z2) {
        if (a0(new byte[]{b2})) {
            if (z2) {
                if (m()) {
                    D();
                } else {
                    g.h.a.i.w0("device already disconnected");
                }
                k0(0);
            }
            k(this.G);
        }
    }

    public void W(int i2, byte b2) {
        byte[] bArr = {(byte) (i2 & DnsRecord.CLASS_ANY), (byte) ((i2 >> 8) & DnsRecord.CLASS_ANY), b2};
        g.h.a.i.V3(this.f5594f, String.format("<< CMD_OTA_VALID (0x%04X)", (short) 1540));
        if (!L((short) 1540, bArr)) {
            throw new g.i.a.c.g.c("Validate FW failed", 512);
        }
        g.h.a.i.V3(false, "... waiting CMD_OTA_VALID response");
        byte b3 = P(30000L)[0];
        if (b3 == 1) {
            g.h.a.i.V3(false, "validate success");
        } else {
            if (b3 != 5) {
                throw g.a.a.a.a.c("Validate FW failed, status=0x%02X", new Object[]{Byte.valueOf(b3)}, "Validate FW failed", 766);
            }
            throw g.a.a.a.a.c("0x%02X, Validate FW failed", new Object[]{Byte.valueOf(b3)}, "Validate FW failed", InvokeCmd.CMD_XBUG_VMAN_FUNTION_CHECK_TIMEOUT_BASE_GET);
        }
    }

    public void X(int i2, boolean z2) {
        if (this.f5600r) {
            i2 = 4128;
        }
        if (this.f5594f) {
            g.h.a.i.U3(String.format("error = 0x%04X, needReset=%b", Integer.valueOf(i2), Boolean.valueOf(z2)));
        }
        if (i2 != 4128) {
            z(260, true);
        }
        if (z2) {
            s0();
        }
        g.i.a.b.e.h.a aVar = this.m0;
        if (aVar != null) {
            aVar.l();
        }
        if (r().f(1)) {
            k0(i2);
        }
        k(this.G);
        g.i.a.c.m.a.b bVar = this.f5598p;
        if (bVar != null) {
            bVar.a(i2);
        }
        this.f5600r = true;
    }

    public void Y(boolean z2) {
        if (a0(null)) {
            if (z2) {
                if (m()) {
                    D();
                } else {
                    g.h.a.i.w0("device already disconnected");
                }
                k0(0);
            }
            k(this.G);
        }
    }

    public boolean Z(g.i.a.c.l.e.a aVar, int i2, int i3) {
        g.h.a.i.V3(this.f5594f, String.format(Locale.US, "nextBinSize=%d, mBytesSentBuffer=%d, bufferSize=%d", Integer.valueOf(aVar.h()), Integer.valueOf(i2), Integer.valueOf(i3)));
        return aVar.h() + i2 > i3;
    }

    /* JADX WARN: Removed duplicated region for block: B:27:0x007e  */
    /* JADX WARN: Removed duplicated region for block: B:29:0x0081  */
    /* JADX WARN: Removed duplicated region for block: B:31:0x0087  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public boolean a0(byte[] r10) throws g.i.a.c.g.c {
        /*
            r9 = this;
            r0 = 524(0x20c, float:7.34E-43)
            r1 = 1
            r9.z(r0, r1)
            r0 = 4
            r2 = 4128(0x1020, float:5.785E-42)
            r3 = 0
            boolean r4 = r9.f5594f     // Catch: g.i.a.c.a -> L24
            java.lang.String r5 = "<< CMD_OTA_ACTIVE_RESET(0x%04X)"
            java.lang.Object[] r6 = new java.lang.Object[r1]     // Catch: g.i.a.c.a -> L24
            r7 = 1542(0x606, float:2.161E-42)
            java.lang.Short r8 = java.lang.Short.valueOf(r7)     // Catch: g.i.a.c.a -> L24
            r6[r3] = r8     // Catch: g.i.a.c.a -> L24
            java.lang.String r5 = java.lang.String.format(r5, r6)     // Catch: g.i.a.c.a -> L24
            g.h.a.i.x0(r4, r5)     // Catch: g.i.a.c.a -> L24
            boolean r1 = r9.L(r7, r10)     // Catch: g.i.a.c.a -> L24
            goto L40
        L24:
            r10 = move-exception
            int r4 = r10.f5446m
            if (r4 != r2) goto L2b
        L29:
            r1 = r3
            goto L5e
        L2b:
            g.i.a.c.q.i r2 = r9.t()
            int r2 = r2.f5675k
            if (r2 >= r0) goto L4a
            g.i.a.c.q.f r2 = r9.r()
            boolean r2 = r2.f5709z
            if (r2 != 0) goto L42
            java.lang.String r10 = "active cmd has no response, ignore"
            g.h.a.i.w0(r10)
        L40:
            r2 = r3
            goto L5e
        L42:
            java.lang.String r1 = "active cmd has no response, notify error"
            g.h.a.i.W3(r1)
        L47:
            int r2 = r10.f5446m
            goto L29
        L4a:
            java.lang.Object[] r1 = new java.lang.Object[r1]
            int r2 = r10.f5446m
            java.lang.Integer r2 = java.lang.Integer.valueOf(r2)
            r1[r3] = r2
            java.lang.String r2 = "Send CMD_OTA_ACTIVE_RESET failed, errorcode= 0x%04X"
            java.lang.String r1 = java.lang.String.format(r2, r1)
            g.h.a.i.w0(r1)
            goto L47
        L5e:
            if (r1 == 0) goto L7e
            g.i.a.c.q.i r10 = r9.t()
            int r10 = r10.f5675k
            if (r10 < r0) goto L7e
            boolean r10 = r9.f5594f     // Catch: g.i.a.c.a -> L75
            java.lang.String r0 = "... Reading CMD_OTA_ACTIVE_RESET notification"
            g.h.a.i.x0(r10, r0)     // Catch: g.i.a.c.a -> L75
            r4 = 1600(0x640, double:7.905E-321)
            r9.P(r4)     // Catch: g.i.a.c.a -> L75
            goto L7e
        L75:
            r10 = move-exception
            java.lang.String r0 = "Read CMD_OTA_ACTIVE_RESET notification failed"
            g.h.a.i.W3(r0)
            int r2 = r10.f5446m
            goto L7f
        L7e:
            r3 = r1
        L7f:
            if (r3 == 0) goto L87
            java.lang.String r10 = "image active success"
            g.h.a.i.w0(r10)
            return r3
        L87:
            g.i.a.c.g.c r10 = new g.i.a.c.g.c
            r10.<init>(r2)
            throw r10
        */
        throw new UnsupportedOperationException("Method not decompiled: g.i.a.c.z.k.a0(byte[]):boolean");
    }

    public byte[] b0(short s2) {
        return e0(s2, null);
    }

    public boolean c0(g.i.a.c.l.e.a aVar) {
        if (aVar.f5569t == 11 && aVar.f5575z == 520) {
            return true;
        }
        g.i.a.c.l.e.a aVar2 = this.G;
        return aVar2.K == 0 || aVar2.L == 0;
    }

    public boolean d0(byte[] bArr, int i2) {
        short s2 = 0;
        for (int i3 = 0; i3 < i2; i3 += 2) {
            s2 = (short) (s2 ^ ((short) ((bArr[i3 + 1] << 8) | (bArr[i3] & Http2CodecUtil.MAX_UNSIGNED_BYTE))));
        }
        short s3 = (short) (((s2 & Http2CodecUtil.MAX_UNSIGNED_BYTE) << 8) | ((65280 & s2) >> 8));
        g.i.a.c.z.a aVar = null;
        b bVar = new b(i2, s3, null);
        g.h.a.i.V3(this.f5594f, bVar.toString());
        int i4 = bVar.a;
        int i5 = bVar.f5765b;
        L((short) 1544, new byte[]{(byte) (i4 & DnsRecord.CLASS_ANY), (byte) (i4 >> 8), (byte) (i5 & DnsRecord.CLASS_ANY), (byte) ((i5 >> 8) & DnsRecord.CLASS_ANY)});
        g.h.a.i.V3(this.f5594f, String.format("... waiting EVENT_OTA_BUFFER_CHECK(0x%04X)response", (short) 1542));
        byte[] bArrR = R();
        if (bArrR != null && bArrR.length > 0) {
            int length = bArrR.length;
            ByteBuffer byteBufferWrap = ByteBuffer.wrap(bArrR);
            byteBufferWrap.order(ByteOrder.LITTLE_ENDIAN);
            aVar = new g.i.a.c.z.a(bArrR[0], length >= 5 ? byteBufferWrap.getInt(1) : 0);
        }
        byte b2 = aVar.a;
        if (b2 == 1) {
            int i6 = aVar.f5764b;
            this.Z = i6;
            g.h.a.i.x0(this.f5594f, String.format(Locale.US, "mImageUpdateOffset=0x%08X(%d)", Integer.valueOf(i6), Integer.valueOf(this.Z)));
            return true;
        }
        if (b2 == 5 || b2 == 6 || b2 == 7) {
            g.h.a.i.W3(String.format("buffer check failed, status=0x%02X ", Byte.valueOf(b2)));
            return false;
        }
        if (b2 != 8) {
            throw new g.i.a.c.g.c("ERROR_OPCODE_RESPONSE_NOT_SUPPORTED", 766);
        }
        throw new g.i.a.c.g.c("DFU_STATUS_FLASH_ERASE_ERROR", aVar.a | 512);
    }

    /* JADX WARN: Removed duplicated region for block: B:17:0x0031 A[PHI: r2
      0x0031: PHI (r2v1 short) = (r2v0 short), (r2v5 short) binds: [B:3:0x0008, B:5:0x000c] A[DONT_GENERATE, DONT_INLINE]] */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public byte[] e0(short r5, byte[] r6) {
        /*
            r4 = this;
            r0 = 0
            r4.M = r0
            r1 = 0
            r4.f5608z = r1
            r2 = 1536(0x600, float:2.152E-42)
            if (r5 == r2) goto L31
            r2 = 1537(0x601, float:2.154E-42)
            if (r5 == r2) goto L31
            r2 = 1546(0x60a, float:2.166E-42)
            if (r5 == r2) goto L25
            r2 = 1547(0x60b, float:2.168E-42)
            if (r5 == r2) goto L20
            r2 = 1550(0x60e, float:2.172E-42)
            if (r5 == r2) goto L1b
            goto L3a
        L1b:
            java.util.Set<java.lang.Short> r2 = r4.r0
            r3 = 1549(0x60d, float:2.17E-42)
            goto L29
        L20:
            java.util.Set<java.lang.Short> r2 = r4.r0
            r3 = 1545(0x609, float:2.165E-42)
            goto L29
        L25:
            java.util.Set<java.lang.Short> r2 = r4.r0
            r3 = 1544(0x608, float:2.164E-42)
        L29:
            java.lang.Short r3 = java.lang.Short.valueOf(r3)
            r2.add(r3)
            goto L3a
        L31:
            java.util.Set<java.lang.Short> r3 = r4.r0
            java.lang.Short r2 = java.lang.Short.valueOf(r2)
            r3.add(r2)
        L3a:
            r4.f5607y = r0
            g.i.a.a.a.a.c r2 = r4.n0()
            boolean r5 = r2.j(r5, r6)
            if (r5 != 0) goto L47
            return r1
        L47:
            java.lang.Object r5 = r4.f5606x
            monitor-enter(r5)
            int r6 = r4.M     // Catch: java.lang.Throwable -> L60 java.lang.InterruptedException -> L62
            if (r6 != 0) goto L7b
            boolean r6 = r4.f5607y     // Catch: java.lang.Throwable -> L60 java.lang.InterruptedException -> L62
            if (r6 != 0) goto L7b
            int r6 = r4.f5605w     // Catch: java.lang.Throwable -> L60 java.lang.InterruptedException -> L62
            r1 = 515(0x203, float:7.22E-43)
            if (r6 != r1) goto L7b
            java.lang.Object r6 = r4.f5606x     // Catch: java.lang.Throwable -> L60 java.lang.InterruptedException -> L62
            r1 = 15000(0x3a98, double:7.411E-320)
            r6.wait(r1)     // Catch: java.lang.Throwable -> L60 java.lang.InterruptedException -> L62
            goto L7b
        L60:
            r6 = move-exception
            goto L9e
        L62:
            r6 = move-exception
            java.lang.StringBuilder r1 = new java.lang.StringBuilder     // Catch: java.lang.Throwable -> L60
            r1.<init>()     // Catch: java.lang.Throwable -> L60
            java.lang.String r2 = "mCharacteristicReadCalledLock Sleeping interrupted,e:"
            r1.append(r2)     // Catch: java.lang.Throwable -> L60
            r1.append(r6)     // Catch: java.lang.Throwable -> L60
            java.lang.String r6 = r1.toString()     // Catch: java.lang.Throwable -> L60
            g.h.a.i.W3(r6)     // Catch: java.lang.Throwable -> L60
            r6 = 259(0x103, float:3.63E-43)
            r4.M = r6     // Catch: java.lang.Throwable -> L60
        L7b:
            monitor-exit(r5)     // Catch: java.lang.Throwable -> L60
            int r5 = r4.M
            if (r5 != 0) goto L8d
            boolean r5 = r4.f5607y
            if (r5 != 0) goto L8d
            java.lang.String r5 = "read value but no callback"
            g.h.a.i.x0(r0, r5)
            r5 = 261(0x105, float:3.66E-43)
            r4.M = r5
        L8d:
            int r5 = r4.M
            if (r5 != 0) goto L94
            byte[] r5 = r4.f5608z
            return r5
        L94:
            g.i.a.c.g.c r5 = new g.i.a.c.g.c
            int r6 = r4.M
            java.lang.String r0 = "Error while send command"
            r5.<init>(r0, r6)
            throw r5
        L9e:
            monitor-exit(r5)     // Catch: java.lang.Throwable -> L60
            throw r6
        */
        throw new UnsupportedOperationException("Method not decompiled: g.i.a.c.z.k.e0(short, byte[]):byte[]");
    }

    @Override // g.i.a.c.m.a.a
    public boolean f(boolean z2) {
        if (!super.f(z2)) {
            return false;
        }
        if (this.f5605w != 515) {
            boolean z3 = this.f5594f;
            StringBuilder sbF = g.a.a.a.a.F("start to re-connect the RCU which going to active image, current state is: ");
            sbF.append(this.f5605w);
            g.h.a.i.j(z3, 3, g.h.a.i.f5271c, sbF.toString());
            int iT = T(this.O, r().M);
            if (iT != 0) {
                StringBuilder sbG = g.a.a.a.a.G("Something error in OTA process, errorCode: ", iT, "mProcessState");
                sbG.append(this.E);
                g.h.a.i.W3(sbG.toString());
                X(iT, true);
                return false;
            }
        }
        if (z2) {
            try {
                Y(true);
                if (r().d(1)) {
                    g.i.a.b.e.b.a.c(this.i0.getRemoteDevice(this.O));
                    g.i.a.b.e.b.a.d(this.O);
                }
                z(Bzip2Constants.HUFFMAN_MAX_ALPHABET_SIZE, true);
            } catch (g.i.a.c.a e2) {
                e2.printStackTrace();
                X(e2.f5446m, false);
            }
        } else {
            s0();
            X(274, true);
        }
        return true;
    }

    public boolean f0(int i2) {
        byte[] bArr = {(byte) (i2 & DnsRecord.CLASS_ANY), (byte) ((i2 >> 8) & DnsRecord.CLASS_ANY)};
        g.h.a.i.V3(this.f5594f, String.format("<< CMD_COPY_IMAGE (0x%04X)", (short) 1551));
        if (!L((short) 1551, bArr)) {
            throw new g.i.a.c.g.c("copyImage failed", 512);
        }
        g.h.a.i.V3(false, "... waiting CMD_COPY_IMAGE response");
        byte b2 = P(30000L)[0];
        if (b2 == 1) {
            return true;
        }
        throw g.a.a.a.a.c("copyImage failed, status=0x%02X", new Object[]{Byte.valueOf(b2)}, "copyImage failed", 766);
    }

    public void g0(String str) {
        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_VMAN_FUNTION_CHECK_TIMEOUT_BASE_SET, true);
        int iT = T(str, r().M);
        if (iT == 0) {
            return;
        }
        if (iT == 4128) {
            throw new g.i.a.c.g.c("aborted, connectRemoteDevice failed", iT);
        }
        g.h.a.i.w0("connect failed:" + iT);
        g.i.a.b.e.h.e eVar = new g.i.a.b.e.h.e(32);
        eVar.f5394s = 31000L;
        F(eVar);
        int iT2 = T(str, r().M);
        if (iT2 == 0) {
            return;
        }
        if (iT2 != 4128) {
            throw new g.i.a.c.g.c("connectRemoteDevice failed", iT2);
        }
        throw new g.i.a.c.g.c("aborted, connectRemoteDevice failed", iT2);
    }

    public boolean h0(int i2) {
        return i2 == 1024 || i2 == 1040 || i2 == 1280 || i2 == 1538 || i2 == 2304;
    }

    public void i0(int i2) {
        h hVar = new h(i2, null);
        g.h.a.i.V3(this.f5594f, hVar.toString());
        int i3 = hVar.a;
        L((short) 1545, new byte[]{(byte) (i3 & DnsRecord.CLASS_ANY), (byte) ((i3 >> 8) & DnsRecord.CLASS_ANY)});
        g.h.a.i.V3(false, "... Reading CMD_OTA_IMAGE_INFO notification");
        i iVarA = i.a(R());
        if (iVarA == null || iVarA.a != 1) {
            throw g.a.a.a.a.c("0x%02X, Get target image info failed", new Object[]{766}, "Get target image info failed", 766);
        }
        if (this.f5594f) {
            g.h.a.i.U3(iVarA.toString());
        }
        this.Z = iVarA.f5769c;
        this.f5590a0 = iVarA.f5770d;
    }

    public boolean j0(int i2) {
        byte[] bArr = {(byte) (i2 & DnsRecord.CLASS_ANY)};
        g.h.a.i.V3(this.f5594f, String.format("<< CMD_OTA_ROLE_SWAP (0x%04X)", (short) 1553));
        if (!L((short) 1553, bArr)) {
            throw new g.i.a.c.g.c("roleSwap failed", 512);
        }
        g.h.a.i.V3(false, "... waiting CMD_OTA_ROLW_SWAP response");
        byte b2 = P(30000L)[0];
        if (b2 == 1) {
            g.h.a.i.x0(this.f5594f, "role swap operation done");
            return true;
        }
        g.h.a.i.W3(String.format("role swap failed, maybe b2b disconnect, status=0x%02X", Byte.valueOf(b2)));
        throw new g.i.a.c.g.c(String.format("roleSwap failed, status=0x%02X", Byte.valueOf(b2)), DfuBaseService.NOTIFICATION_ID);
    }

    public void k0(int i2) {
        int i3 = this.f5605w;
        if (i3 != 0 && i3 != 1280) {
            l0();
        }
        n0().d();
        n0().k(this.u0);
        B(1280);
        g.h.a.i.x0(this.f5594f, String.format("terminateConnection, error = 0x%04X", Integer.valueOf(i2)));
    }

    public void l0() {
        int i2 = this.f5605w;
        if (i2 == 0 || i2 == 1280) {
            g.h.a.i.x0(this.f5594f, "already disconnect");
        } else {
            n0().d();
            D();
        }
    }

    public boolean m0() throws g.i.a.c.g.c {
        d dVar;
        g.h.a.i.V3(this.f5594f, String.format("<< CMD_OTA_BUFFER_CHECK_ENABLE (0x%04X)", (short) 1543));
        if (!L((short) 1543, null)) {
            g.h.a.i.w0("enableBufferCheck failed");
            return false;
        }
        try {
            g.h.a.i.V3(this.f5594f, "... Reading OPCODE_DFU_ENABLE_BUFFER_CHECK_MODE response");
            byte[] bArrP = P(3000L);
            if (bArrP == null || bArrP.length < 1) {
                dVar = new d((byte) 2, 0, 0);
            } else {
                int length = bArrP.length;
                ByteBuffer byteBufferWrap = ByteBuffer.wrap(bArrP);
                byteBufferWrap.order(ByteOrder.LITTLE_ENDIAN);
                dVar = new d(bArrP[0], length >= 3 ? (((short) (byteBufferWrap.get(2) & 255)) << 8) | ((short) (byteBufferWrap.get(1) & 255)) : 0, length >= 4 ? (((short) (byteBufferWrap.get(4) & 255)) << 8) | ((short) (byteBufferWrap.get(3) & 255)) : 0);
            }
            g.h.a.i.V3(this.f5594f, dVar.toString());
            if (dVar.a != 1) {
                g.h.a.i.w0("enableBufferCheck failed");
                return false;
            }
            int i2 = t().f5675k >= 6 ? t().V : dVar.f5767c;
            b(dVar.f5766b);
            O(i2);
            return true;
        } catch (g.i.a.c.a unused) {
            g.h.a.i.W3("wait EnableBufferCheckRsp timeout");
            this.M = 284;
            throw new g.i.a.c.g.c("Unable to receive notification", 284);
        }
    }

    public g.i.a.a.a.a.c n0() {
        if (this.t0 == null) {
            g.i.a.a.a.a.c cVarF = g.i.a.a.a.a.c.f();
            this.t0 = cVarF;
            cVarF.h(this.u0);
        }
        return this.t0;
    }

    public void o0() {
        byte[] bArrE0;
        if (t().f5675k <= 5) {
            g.h.a.i.V3(this.f5594f, String.format("<< CMD_OTA_GET_IMAGE_INFO (0x%04X)", (short) 1537));
            bArrE0 = b0((short) 1537);
        } else {
            g.h.a.i.V3(this.f5594f, String.format("<< CMD_OTA_GET_IMAGE_INFO (0x%04X), bank=0x00", (short) 1537));
            bArrE0 = e0((short) 1537, new byte[]{0});
        }
        t().w(bArrE0);
    }

    public void p0() {
        g.h.a.i.V3(this.f5594f, String.format("<< CMD_OTA_IMAGE_SECTION_SIZE_INFO (0x%04X)", (short) 1546));
        t().v(b0((short) 1546));
    }

    public void q0() {
        if (t().f5675k > 5) {
            g.h.a.i.V3(this.f5594f, String.format("<< CMD_OTA_GET_IMAGE_INFO (0x%04X), bank=0x01", (short) 1537));
            t().w(e0((short) 1537, new byte[]{1}));
            return;
        }
        g.h.a.i.V3(this.f5594f, String.format("<< CMD_GET_INACTIVE_BANK_IMAGE_INFO (0x%04X)", (short) 1550));
        byte[] bArrB0 = b0((short) 1550);
        g.i.a.c.q.i iVarT = t();
        iVarT.R = bArrB0;
        iVarT.k();
    }

    public boolean r0() {
        g.h.a.i.x0(this.f5594f, String.format("<< CMD_GET_TARGET_INFO (0x%04X)", (short) 1536));
        byte[] bArrB0 = b0((short) 1536);
        if (bArrB0 == null) {
            g.h.a.i.W3("Get dev info failed");
            throw new g.i.a.c.g.c("get remote dev info failed", 270);
        }
        g.i.a.c.q.i iVarT = t();
        Objects.requireNonNull(iVarT);
        ByteBuffer byteBufferWrap = ByteBuffer.wrap(bArrB0);
        byteBufferWrap.order(ByteOrder.LITTLE_ENDIAN);
        int iRemaining = byteBufferWrap.remaining();
        if (iRemaining <= 0) {
            g.h.a.i.U3(String.format(Locale.US, "invalid offset:%d, len is %d", 0, Integer.valueOf(iRemaining)));
        } else {
            int i2 = iRemaining - 0;
            if (i2 >= 1) {
                iVarT.f5674j = byteBufferWrap.get(0) & 255;
            }
            if (i2 >= 2) {
                iVarT.f5675k = (byte) (byteBufferWrap.get(1) & BinaryMemcacheOpcodes.PREPEND);
            }
            if (iVarT.f5675k <= 5) {
                if (i2 >= 3) {
                    iVarT.f5676l = byteBufferWrap.get(2);
                }
                if (i2 >= 4) {
                    int i3 = byteBufferWrap.get(3) & 255;
                    iVarT.f5679o = i3;
                    iVarT.f5680p = (i3 & 1) != 0;
                    iVarT.f5681q = ((i3 & 2) >> 1) != 0;
                    iVarT.f5682r = (i3 & 4) >> 2;
                    iVarT.f5683s = ((i3 & 8) >> 3) != 0;
                    iVarT.f5684t = (i3 & 16) >> 4;
                    iVarT.f5686v = ((i3 & 32) >> 5) != 0;
                    iVarT.f5687w = (i3 & 64) >> 6;
                }
                if (i2 >= 5) {
                    iVarT.f5689y = byteBufferWrap.get(4) & 255 & 1;
                }
                if (i2 >= 7) {
                    iVarT.C = byteBufferWrap.get(6) & 255;
                }
                if (i2 >= 12) {
                    iVarT.L = byteBufferWrap.getInt(8);
                }
                if (iVarT.L == 0) {
                    iVarT.N = false;
                } else {
                    iVarT.g();
                }
            } else {
                if (i2 >= 3) {
                    int i4 = byteBufferWrap.get(2) & 255;
                    iVarT.f5679o = i4;
                    iVarT.f5680p = (i4 & 1) != 0;
                    iVarT.f5681q = ((i4 & 2) >> 1) != 0;
                    iVarT.f5682r = (i4 & 4) >> 2;
                    iVarT.f5684t = (i4 & 8) >> 3;
                    iVarT.f5690z = ((i4 & 16) >> 4) != 0;
                }
                if (i2 >= 4) {
                    int i5 = byteBufferWrap.get(3) & 255;
                    int i6 = i5 & 3;
                    iVarT.f5689y = i6;
                    iVarT.f5687w = (i5 & 12) >> 2;
                    iVarT.f5686v = i6 == 2;
                }
                if (i2 >= 5) {
                    iVarT.C = byteBufferWrap.get(4) & 255;
                }
                if (i2 >= 6) {
                    int i7 = byteBufferWrap.get(5) & 255;
                    if (i7 == 0) {
                        iVarT.N = false;
                        iVarT.O = 0;
                        iVarT.L = 3;
                    } else if (i7 == 1) {
                        iVarT.N = true;
                        iVarT.O = 2;
                        iVarT.L = 1;
                    } else if (i7 == 2) {
                        iVarT.N = true;
                        iVarT.O = 1;
                        iVarT.L = 2;
                    }
                }
                if (i2 >= 7) {
                    iVarT.V = byteBufferWrap.getShort(6) & 65535;
                }
            }
            iVarT.a();
        }
        return true;
    }

    public boolean s0() {
        try {
            if (this.f5594f) {
                g.h.a.i.U3(String.format("<< CMD_OTA_RESET (0x%04X)", (short) 1541));
            }
            return N((short) 1541, null, -1, true);
        } catch (g.i.a.c.a e2) {
            g.h.a.i.W3(String.format("Send OPCODE_DFU_RESET_SYSTEM failed, ignore it, errorcode= 0x%04X", Integer.valueOf(e2.f5446m)));
            this.M = 0;
            return false;
        }
    }
}