package g.i0.i;

import com.seewo.libmcuservice.constant.IMcuConstants;
import com.seewo.vcommons.constants.Platform;
import g.i0.i.d;
import g.i0.i.g;
import g.i0.i.g.e;
import h.x;
import h.y;
import java.io.Closeable;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.RejectedExecutionException;
import java.util.logging.Level;
import java.util.logging.Logger;

/* JADX INFO: loaded from: classes.dex */
public final class o implements Closeable {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final Logger f6330b = Logger.getLogger(e.class.getName());

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final h.h f6331c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final a f6332d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final boolean f6333e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final d.a f6334f;

    public static final class a implements x {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final h.h f6335b;

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        public int f6336c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        public byte f6337d;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public int f6338e;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public int f6339f;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public short f6340g;

        public a(h.h hVar) {
            this.f6335b = hVar;
        }

        @Override // h.x, java.io.Closeable, java.lang.AutoCloseable
        public void close() {
        }

        @Override // h.x
        public y e() {
            return this.f6335b.e();
        }

        @Override // h.x
        public long v(h.f fVar, long j2) {
            int i2;
            int iC;
            do {
                int i3 = this.f6339f;
                if (i3 != 0) {
                    long jV = this.f6335b.v(fVar, Math.min(j2, i3));
                    if (jV == -1) {
                        return -1L;
                    }
                    this.f6339f = (int) (((long) this.f6339f) - jV);
                    return jV;
                }
                this.f6335b.l(this.f6340g);
                this.f6340g = (short) 0;
                if ((this.f6337d & 4) != 0) {
                    return -1L;
                }
                i2 = this.f6338e;
                int iE = o.E(this.f6335b);
                this.f6339f = iE;
                this.f6336c = iE;
                byte bJ = (byte) (this.f6335b.J() & IMcuConstants.DEFAULT_VALUE);
                this.f6337d = (byte) (this.f6335b.J() & IMcuConstants.DEFAULT_VALUE);
                Logger logger = o.f6330b;
                if (logger.isLoggable(Level.FINE)) {
                    logger.fine(e.a(true, this.f6338e, this.f6336c, bJ, this.f6337d));
                }
                iC = this.f6335b.c() & Platform.UNKNOWN;
                this.f6338e = iC;
                if (bJ != 9) {
                    e.c("%s != TYPE_CONTINUATION", Byte.valueOf(bJ));
                    throw null;
                }
            } while (iC == i2);
            e.c("TYPE_CONTINUATION streamId changed", new Object[0]);
            throw null;
        }
    }

    public interface b {
    }

    public o(h.h hVar, boolean z) {
        this.f6331c = hVar;
        this.f6333e = z;
        a aVar = new a(hVar);
        this.f6332d = aVar;
        this.f6334f = new d.a(4096, aVar);
    }

    public static int E(h.h hVar) {
        return (hVar.J() & IMcuConstants.DEFAULT_VALUE) | ((hVar.J() & IMcuConstants.DEFAULT_VALUE) << 16) | ((hVar.J() & IMcuConstants.DEFAULT_VALUE) << 8);
    }

    public static int a(int i2, byte b2, short s) {
        if ((b2 & 8) != 0) {
            i2--;
        }
        if (s <= i2) {
            return (short) (i2 - s);
        }
        e.c("PROTOCOL_ERROR padding %s > remaining length %s", Short.valueOf(s), Integer.valueOf(i2));
        throw null;
    }

    public final List<c> B(int i2, short s, byte b2, int i3) throws IOException {
        a aVar = this.f6332d;
        aVar.f6339f = i2;
        aVar.f6336c = i2;
        aVar.f6340g = s;
        aVar.f6337d = b2;
        aVar.f6338e = i3;
        d.a aVar2 = this.f6334f;
        while (!aVar2.f6253b.q()) {
            int iJ = aVar2.f6253b.J() & IMcuConstants.DEFAULT_VALUE;
            if (iJ == 128) {
                throw new IOException("index == 0");
            }
            if ((iJ & 128) == 128) {
                int iG = aVar2.g(iJ, 127) - 1;
                if (!(iG >= 0 && iG <= d.f6250a.length - 1)) {
                    int iB = aVar2.b(iG - d.f6250a.length);
                    if (iB >= 0) {
                        c[] cVarArr = aVar2.f6256e;
                        if (iB < cVarArr.length) {
                            aVar2.f6252a.add(cVarArr[iB]);
                        }
                    }
                    StringBuilder sbC = a.b.c.a.a.C("Header index too large ");
                    sbC.append(iG + 1);
                    throw new IOException(sbC.toString());
                }
                aVar2.f6252a.add(d.f6250a[iG]);
            } else if (iJ == 64) {
                h.i iVarF = aVar2.f();
                d.a(iVarF);
                aVar2.e(-1, new c(iVarF, aVar2.f()));
            } else if ((iJ & 64) == 64) {
                aVar2.e(-1, new c(aVar2.d(aVar2.g(iJ, 63) - 1), aVar2.f()));
            } else if ((iJ & 32) == 32) {
                int iG2 = aVar2.g(iJ, 31);
                aVar2.f6255d = iG2;
                if (iG2 < 0 || iG2 > aVar2.f6254c) {
                    StringBuilder sbC2 = a.b.c.a.a.C("Invalid dynamic table size update ");
                    sbC2.append(aVar2.f6255d);
                    throw new IOException(sbC2.toString());
                }
                int i4 = aVar2.f6259h;
                if (iG2 < i4) {
                    if (iG2 == 0) {
                        aVar2.a();
                    } else {
                        aVar2.c(i4 - iG2);
                    }
                }
            } else if (iJ == 16 || iJ == 0) {
                h.i iVarF2 = aVar2.f();
                d.a(iVarF2);
                aVar2.f6252a.add(new c(iVarF2, aVar2.f()));
            } else {
                aVar2.f6252a.add(new c(aVar2.d(aVar2.g(iJ, 15) - 1), aVar2.f()));
            }
        }
        d.a aVar3 = this.f6334f;
        Objects.requireNonNull(aVar3);
        ArrayList arrayList = new ArrayList(aVar3.f6252a);
        aVar3.f6252a.clear();
        return arrayList;
    }

    public final void K(b bVar, int i2, byte b2, int i3) {
        if (i2 != 8) {
            e.c("TYPE_PING length != 8: %s", Integer.valueOf(i2));
            throw null;
        }
        if (i3 != 0) {
            e.c("TYPE_PING streamId != 0", new Object[0]);
            throw null;
        }
        int iC = this.f6331c.c();
        int iC2 = this.f6331c.c();
        boolean z = (b2 & 1) != 0;
        g.f fVar = (g.f) bVar;
        Objects.requireNonNull(fVar);
        if (!z) {
            try {
                g gVar = g.this;
                gVar.f6290j.execute(gVar.new e(true, iC, iC2));
            } catch (RejectedExecutionException unused) {
            }
        } else {
            synchronized (g.this) {
                g gVar2 = g.this;
                gVar2.m = false;
                gVar2.notifyAll();
            }
        }
    }

    public final void L(b bVar, int i2, byte b2, int i3) throws IOException {
        if (i3 == 0) {
            e.c("PROTOCOL_ERROR: TYPE_PUSH_PROMISE streamId == 0", new Object[0]);
            throw null;
        }
        short sJ = (b2 & 8) != 0 ? (short) (this.f6331c.J() & IMcuConstants.DEFAULT_VALUE) : (short) 0;
        int iC = this.f6331c.c() & Platform.UNKNOWN;
        List<c> listB = B(a(i2 - 4, b2, sJ), sJ, b2, i3);
        g gVar = g.this;
        synchronized (gVar) {
            if (gVar.v.contains(Integer.valueOf(iC))) {
                gVar.O(iC, g.i0.i.b.PROTOCOL_ERROR);
                return;
            }
            gVar.v.add(Integer.valueOf(iC));
            try {
                gVar.B(new h(gVar, "OkHttp %s Push Request[%s]", new Object[]{gVar.f6286f, Integer.valueOf(iC)}, iC, listB));
            } catch (RejectedExecutionException unused) {
            }
        }
    }

    public final void M(b bVar, int i2, int i3) {
        if (i2 != 4) {
            e.c("TYPE_RST_STREAM length: %d != 4", Integer.valueOf(i2));
            throw null;
        }
        if (i3 == 0) {
            e.c("TYPE_RST_STREAM streamId == 0", new Object[0]);
            throw null;
        }
        int iC = this.f6331c.c();
        g.i0.i.b bVarFromHttp2 = g.i0.i.b.fromHttp2(iC);
        if (bVarFromHttp2 == null) {
            e.c("TYPE_RST_STREAM unexpected error code: %d", Integer.valueOf(iC));
            throw null;
        }
        g.f fVar = (g.f) bVar;
        boolean zE = g.this.E(i3);
        g gVar = g.this;
        if (zE) {
            gVar.B(new k(gVar, "OkHttp %s Push Reset[%s]", new Object[]{gVar.f6286f, Integer.valueOf(i3)}, i3, bVarFromHttp2));
            return;
        }
        p pVarK = gVar.K(i3);
        if (pVarK != null) {
            synchronized (pVarK) {
                if (pVarK.k == null) {
                    pVarK.k = bVarFromHttp2;
                    pVarK.notifyAll();
                }
            }
        }
    }

    public final void N(b bVar, int i2, byte b2, int i3) {
        long j2;
        p[] pVarArr = null;
        if (i3 != 0) {
            e.c("TYPE_SETTINGS streamId != 0", new Object[0]);
            throw null;
        }
        if ((b2 & 1) != 0) {
            if (i2 == 0) {
                Objects.requireNonNull((g.f) bVar);
                return;
            } else {
                e.c("FRAME_SIZE_ERROR ack frame should be empty!", new Object[0]);
                throw null;
            }
        }
        if (i2 % 6 != 0) {
            e.c("TYPE_SETTINGS length %% 6 != 0: %s", Integer.valueOf(i2));
            throw null;
        }
        t tVar = new t();
        for (int i4 = 0; i4 < i2; i4 += 6) {
            int iY = this.f6331c.y() & 65535;
            int iC = this.f6331c.c();
            if (iY == 2) {
                if (iC != 0 && iC != 1) {
                    e.c("PROTOCOL_ERROR SETTINGS_ENABLE_PUSH != 0 or 1", new Object[0]);
                    throw null;
                }
            } else if (iY == 3) {
                iY = 4;
            } else if (iY == 4) {
                iY = 7;
                if (iC < 0) {
                    e.c("PROTOCOL_ERROR SETTINGS_INITIAL_WINDOW_SIZE > 2^31 - 1", new Object[0]);
                    throw null;
                }
            } else if (iY == 5 && (iC < 16384 || iC > 16777215)) {
                e.c("PROTOCOL_ERROR SETTINGS_MAX_FRAME_SIZE: %s", Integer.valueOf(iC));
                throw null;
            }
            tVar.b(iY, iC);
        }
        g.f fVar = (g.f) bVar;
        synchronized (g.this) {
            int iA = g.this.q.a();
            t tVar2 = g.this.q;
            Objects.requireNonNull(tVar2);
            for (int i5 = 0; i5 < 10; i5++) {
                if (((1 << i5) & tVar.f6376a) != 0) {
                    tVar2.b(i5, tVar.f6377b[i5]);
                }
            }
            try {
                g gVar = g.this;
                gVar.f6290j.execute(new n(fVar, "OkHttp %s ACK Settings", new Object[]{gVar.f6286f}, tVar));
            } catch (RejectedExecutionException unused) {
            }
            int iA2 = g.this.q.a();
            if (iA2 == -1 || iA2 == iA) {
                j2 = 0;
            } else {
                j2 = iA2 - iA;
                g gVar2 = g.this;
                if (!gVar2.r) {
                    gVar2.r = true;
                }
                if (!gVar2.f6285e.isEmpty()) {
                    pVarArr = (p[]) g.this.f6285e.values().toArray(new p[g.this.f6285e.size()]);
                }
            }
            g.f6282b.execute(new m(fVar, "OkHttp %s settings", g.this.f6286f));
        }
        if (pVarArr == null || j2 == 0) {
            return;
        }
        for (p pVar : pVarArr) {
            synchronized (pVar) {
                pVar.f6342b += j2;
                if (j2 > 0) {
                    pVar.notifyAll();
                }
            }
        }
    }

    public final void O(b bVar, int i2, int i3) {
        if (i2 != 4) {
            e.c("TYPE_WINDOW_UPDATE length !=4: %s", Integer.valueOf(i2));
            throw null;
        }
        long jC = ((long) this.f6331c.c()) & 2147483647L;
        if (jC == 0) {
            e.c("windowSizeIncrement was 0", Long.valueOf(jC));
            throw null;
        }
        g.f fVar = (g.f) bVar;
        g gVar = g.this;
        if (i3 == 0) {
            synchronized (gVar) {
                g gVar2 = g.this;
                gVar2.o += jC;
                gVar2.notifyAll();
            }
            return;
        }
        p pVarO = gVar.o(i3);
        if (pVarO != null) {
            synchronized (pVarO) {
                pVarO.f6342b += jC;
                if (jC > 0) {
                    pVarO.notifyAll();
                }
            }
        }
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public void close() {
        this.f6331c.close();
    }

    /* JADX WARN: Code restructure failed: missing block: B:151:0x02bc, code lost:
    
        if (r17 == false) goto L153;
     */
    /* JADX WARN: Code restructure failed: missing block: B:152:0x02be, code lost:
    
        r7.i();
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public boolean i(boolean r21, g.i0.i.o.b r22) throws java.io.IOException {
        /*
            Method dump skipped, instruction units count: 768
            To view this dump add '--comments-level debug' option
        */
        throw new UnsupportedOperationException("Method not decompiled: g.i0.i.o.i(boolean, g.i0.i.o$b):boolean");
    }

    public void o(b bVar) {
        if (this.f6333e) {
            if (i(true, bVar)) {
                return;
            }
            e.c("Required SETTINGS preface not received", new Object[0]);
            throw null;
        }
        h.h hVar = this.f6331c;
        h.i iVar = e.f6268a;
        h.i iVarK = hVar.k(iVar.k());
        Logger logger = f6330b;
        if (logger.isLoggable(Level.FINE)) {
            logger.fine(g.i0.c.l("<< CONNECTION %s", iVarK.g()));
        }
        if (iVar.equals(iVarK)) {
            return;
        }
        e.c("Expected a connection header but was %s", iVarK.o());
        throw null;
    }

    public final void z(b bVar, int i2, int i3) {
        p[] pVarArr;
        if (i2 < 8) {
            e.c("TYPE_GOAWAY length < 8: %s", Integer.valueOf(i2));
            throw null;
        }
        if (i3 != 0) {
            e.c("TYPE_GOAWAY streamId != 0", new Object[0]);
            throw null;
        }
        int iC = this.f6331c.c();
        int iC2 = this.f6331c.c();
        int i4 = i2 - 8;
        if (g.i0.i.b.fromHttp2(iC2) == null) {
            e.c("TYPE_GOAWAY unexpected error code: %d", Integer.valueOf(iC2));
            throw null;
        }
        h.i iVarK = h.i.f6532c;
        if (i4 > 0) {
            iVarK = this.f6331c.k(i4);
        }
        g.f fVar = (g.f) bVar;
        Objects.requireNonNull(fVar);
        iVarK.k();
        synchronized (g.this) {
            pVarArr = (p[]) g.this.f6285e.values().toArray(new p[g.this.f6285e.size()]);
            g.this.f6289i = true;
        }
        for (p pVar : pVarArr) {
            if (pVar.f6343c > iC && pVar.g()) {
                g.i0.i.b bVar2 = g.i0.i.b.REFUSED_STREAM;
                synchronized (pVar) {
                    if (pVar.k == null) {
                        pVar.k = bVar2;
                        pVar.notifyAll();
                    }
                }
                g.this.K(pVar.f6343c);
            }
        }
    }
}