Tarjeta Transporte v3.0.29 - z31.java 源代码

package com.sgcr;

import com.sgcr.e90;
import com.sgcr.fa0;
import com.sgcr.n61;
import com.sgcr.u51;
import java.io.IOException;
import java.net.ConnectException;
import java.net.Proxy;
import java.net.Socket;
import java.security.cert.Certificate;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.TimeUnit;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLPeerUnverifiedException;
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocket;
import javax.net.ssl.SSLSocketFactory;
import okio.BufferedSink;
import okio.BufferedSource;
import okio.Okio;
import okio.Timeout;

public final class z31 extends fa0.Cnew implements lj {

    public static final Cif f16889return = new Cif(null);

    public fa0 f16890break;

    public Socket f16891case;

    public BufferedSource f16892catch;

    public BufferedSink f16893class;

    public boolean f16894const;

    public Socket f16895else;

    public boolean f16896final;

    public e90 f16897goto;

    public int f16898import;

    public final List f16899native;

    public final a41 f16900new;

    public long f16901public;

    public int f16902super;

    public g01 f16903this;

    public int f16904throw;

    public final r71 f16905try;

    public int f16906while;

    public class Cfor {

        public static final int[] f16907if;

        static {
            int[] iArr = new int[Proxy.Type.values().length];
            try {
                iArr[Proxy.Type.DIRECT.ordinal()] = 1;
            } catch (NoSuchFieldError unused) {
            }
            try {
                iArr[Proxy.Type.HTTP.ordinal()] = 2;
            } catch (NoSuchFieldError unused2) {
            }
            f16907if = iArr;
        }
    }

    public static final class Cif {
        public Cif() {
        }

        public Cif(wp wpVar) {
            this();
        }
    }

    public static final class Cnew extends wg0 implements e60 {

        public final e90 f16908for;

        public final be f16909if;

        public final s0 f16910new;

        public Cnew(be beVar, e90 e90Var, s0 s0Var) {
            super(0);
            this.f16909if = beVar;
            this.f16908for = e90Var;
            this.f16910new = s0Var;
        }

        @Override
        public final List invoke() {
            ae m6017try = this.f16909if.m6017try();
            hd0.m9597new(m6017try);
            return m6017try.mo5448if(this.f16908for.m7596try(), this.f16910new.m15304const().m17092break());
        }
    }

    public static final class Ctry extends wg0 implements e60 {
        public Ctry() {
            super(0);
        }

        @Override
        public final List invoke() {
            e90 e90Var = z31.this.f16897goto;
            hd0.m9597new(e90Var);
            List<Certificate> m7596try = e90Var.m7596try();
            ArrayList arrayList = new ArrayList(sg.m15510native(m7596try, 10));
            for (Certificate certificate : m7596try) {
                hd0.m9602try(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate");
                arrayList.add((X509Certificate) certificate);
            }
            return arrayList;
        }
    }

    public z31(a41 a41Var, r71 r71Var) {
        hd0.m9590else(a41Var, "connectionPool");
        hd0.m9590else(r71Var, "route");
        this.f16900new = a41Var;
        this.f16905try = r71Var;
        this.f16898import = 1;
        this.f16899native = new ArrayList();
        this.f16901public = Long.MAX_VALUE;
    }

    public final void m19004abstract(long j) {
        this.f16901public = j;
    }

    public final void m19005break(int i, int i2, rb rbVar, rx rxVar) {
        Socket createSocket;
        Proxy m14887for = this.f16905try.m14887for();
        s0 m14888if = this.f16905try.m14888if();
        Proxy.Type type = m14887for.type();
        int i3 = type == null ? -1 : Cfor.f16907if[type.ordinal()];
        if (i3 == 1 || i3 == 2) {
            createSocket = m14888if.m15302catch().createSocket();
            hd0.m9597new(createSocket);
        } else {
            createSocket = new Socket(m14887for);
        }
        this.f16891case = createSocket;
        rxVar.m15208break(rbVar, this.f16905try.m14890try(), m14887for);
        createSocket.setSoTimeout(i2);
        try {
            ow0.f12740if.m13875goto().mo13863else(createSocket, this.f16905try.m14890try(), i);
            try {
                this.f16892catch = Okio.buffer(Okio.source(createSocket));
                this.f16893class = Okio.buffer(Okio.sink(createSocket));
            } catch (NullPointerException e) {
                if (hd0.m9594if(e.getMessage(), "throw with null exception")) {
                    throw new IOException(e);
                }
            }
        } catch (ConnectException e2) {
            ConnectException connectException = new ConnectException("Failed to connect to " + this.f16905try.m14890try());
            connectException.initCause(e2);
            throw connectException;
        }
    }

    public final void m19006case() {
        Socket socket = this.f16891case;
        if (socket != null) {
            cs1.m6677super(socket);
        }
    }

    public final void m19007catch(qj qjVar) {
        s0 m14888if = this.f16905try.m14888if();
        SSLSocketFactory m15303class = m14888if.m15303class();
        SSLSocket sSLSocket = null;
        try {
            hd0.m9597new(m15303class);
            Socket createSocket = m15303class.createSocket(this.f16891case, m14888if.m15304const().m17092break(), m14888if.m15304const().m17106super(), true);
            hd0.m9602try(createSocket, "null cannot be cast to non-null type javax.net.ssl.SSLSocket");
            SSLSocket sSLSocket2 = (SSLSocket) createSocket;
            try {
                pj m14538if = qjVar.m14538if(sSLSocket2);
                if (m14538if.m14161this()) {
                    ow0.f12740if.m13875goto().mo5681case(sSLSocket2, m14888if.m15304const().m17092break(), m14888if.m15305else());
                }
                sSLSocket2.startHandshake();
                SSLSession session = sSLSocket2.getSession();
                e90.Cif cif = e90.f7920case;
                hd0.m9586case(session, "sslSocketSession");
                e90 m7598if = cif.m7598if(session);
                HostnameVerifier m15301case = m14888if.m15301case();
                hd0.m9597new(m15301case);
                if (m15301case.verify(m14888if.m15304const().m17092break(), session)) {
                    be m15308if = m14888if.m15308if();
                    hd0.m9597new(m15308if);
                    this.f16897goto = new e90(m7598if.m7592case(), m7598if.m7594if(), m7598if.m7595new(), new Cnew(m15308if, m7598if, m14888if));
                    m15308if.m6014for(m14888if.m15304const().m17092break(), new Ctry());
                    String mo5683goto = m14538if.m14161this() ? ow0.f12740if.m13875goto().mo5683goto(sSLSocket2) : null;
                    this.f16895else = sSLSocket2;
                    this.f16892catch = Okio.buffer(Okio.source(sSLSocket2));
                    this.f16893class = Okio.buffer(Okio.sink(sSLSocket2));
                    this.f16903this = mo5683goto != null ? g01.f8727for.m8586if(mo5683goto) : g01.HTTP_1_1;
                    ow0.f12740if.m13875goto().mo13864for(sSLSocket2);
                    return;
                }
                List m7596try = m7598if.m7596try();
                if (!(!m7596try.isEmpty())) {
                    throw new SSLPeerUnverifiedException("Hostname " + m14888if.m15304const().m17092break() + " not verified (no certificates)");
                }
                Object obj = m7596try.get(0);
                hd0.m9602try(obj, "null cannot be cast to non-null type java.security.cert.X509Certificate");
                X509Certificate x509Certificate = (X509Certificate) obj;
                throw new SSLPeerUnverifiedException(ni1.m13172this("\n              |Hostname " + m14888if.m15304const().m17092break() + " not verified:\n              |    certificate: " + be.f6747new.m6019if(x509Certificate) + "\n              |    DN: " + x509Certificate.getSubjectDN().getName() + "\n              |    subjectAltNames: " + at0.f6505if.m5673if(x509Certificate) + "\n              ", null, 1, null));
            } catch (Throwable th) {
                th = th;
                sSLSocket = sSLSocket2;
                if (sSLSocket != null) {
                    ow0.f12740if.m13875goto().mo13864for(sSLSocket);
                }
                if (sSLSocket != null) {
                    cs1.m6677super(sSLSocket);
                }
                throw th;
            }
        } catch (Throwable th2) {
            th = th2;
        }
    }

    public final void m19008class(int i, int i2, int i3, rb rbVar, rx rxVar) {
        u51 m19014final = m19014final();
        va0 m16481catch = m19014final.m16481catch();
        for (int i4 = 0; i4 < 21; i4++) {
            m19005break(i, i2, rbVar, rxVar);
            m19014final = m19009const(i2, i3, m19014final, m16481catch);
            if (m19014final == null) {
                return;
            }
            Socket socket = this.f16891case;
            if (socket != null) {
                cs1.m6677super(socket);
            }
            this.f16891case = null;
            this.f16893class = null;
            this.f16892catch = null;
            rxVar.m15219goto(rbVar, this.f16905try.m14890try(), this.f16905try.m14887for(), null);
        }
    }

    public final u51 m19009const(int i, int i2, u51 u51Var, va0 va0Var) {
        String str = "CONNECT " + cs1.e(va0Var, true) + " HTTP/1.1";
        while (true) {
            BufferedSource bufferedSource = this.f16892catch;
            hd0.m9597new(bufferedSource);
            BufferedSink bufferedSink = this.f16893class;
            hd0.m9597new(bufferedSink);
            da0 da0Var = new da0(null, this, bufferedSource, bufferedSink);
            TimeUnit timeUnit = TimeUnit.MILLISECONDS;
            bufferedSource.timeout().timeout(i, timeUnit);
            bufferedSink.timeout().timeout(i2, timeUnit);
            da0Var.m7129package(u51Var.m16480case(), str);
            da0Var.mo7124for();
            n61.Cif mo7125goto = da0Var.mo7125goto(false);
            hd0.m9597new(mo7125goto);
            n61 m12956new = mo7125goto.m12955native(u51Var).m12956new();
            da0Var.m7123finally(m12956new);
            int m12926case = m12956new.m12926case();
            if (m12926case == 200) {
                if (bufferedSource.getBuffer().exhausted() && bufferedSink.getBuffer().exhausted()) {
                    return null;
                }
                throw new IOException("TLS tunnel buffered too many bytes!");
            }
            if (m12926case != 407) {
                throw new IOException("Unexpected response code for CONNECT: " + m12956new.m12926case());
            }
            u51 mo11764if = this.f16905try.m14888if().m15310this().mo11764if(this.f16905try, m12956new);
            if (mo11764if == null) {
                throw new IOException("Failed to authenticate with proxy");
            }
            if (ui1.m16659native("close", n61.m12925break(m12956new, "Connection", null, 2, null), true)) {
                return mo11764if;
            }
            u51Var = mo11764if;
        }
    }

    public final void m19010continue(boolean z) {
        this.f16894const = z;
    }

    public final jy m19011default(ct0 ct0Var, b41 b41Var) {
        hd0.m9590else(ct0Var, "client");
        hd0.m9590else(b41Var, "chain");
        Socket socket = this.f16895else;
        hd0.m9597new(socket);
        BufferedSource bufferedSource = this.f16892catch;
        hd0.m9597new(bufferedSource);
        BufferedSink bufferedSink = this.f16893class;
        hd0.m9597new(bufferedSink);
        fa0 fa0Var = this.f16890break;
        if (fa0Var != null) {
            return new ga0(ct0Var, this, b41Var, fa0Var);
        }
        socket.setSoTimeout(b41Var.m5849const());
        Timeout timeout = bufferedSource.timeout();
        long m5845break = b41Var.m5845break();
        TimeUnit timeUnit = TimeUnit.MILLISECONDS;
        timeout.timeout(m5845break, timeUnit);
        bufferedSink.timeout().timeout(b41Var.m5848class(), timeUnit);
        return new da0(ct0Var, this, bufferedSource, bufferedSink);
    }

    public final boolean m19012else(va0 va0Var, e90 e90Var) {
        List m7596try = e90Var.m7596try();
        if (!m7596try.isEmpty()) {
            at0 at0Var = at0.f6505if;
            String m17092break = va0Var.m17092break();
            Object obj = m7596try.get(0);
            hd0.m9602try(obj, "null cannot be cast to non-null type java.security.cert.X509Certificate");
            if (at0Var.m5669case(m17092break, (X509Certificate) obj)) {
                return true;
            }
        }
        return false;
    }

    public final synchronized void m19013extends() {
        this.f16896final = true;
    }

    public final u51 m19014final() {
        u51 m16493if = new u51.Cif().m16492goto(this.f16905try.m14888if().m15304const()).m16495try("CONNECT", null).m16491for("Host", cs1.e(this.f16905try.m14888if().m15304const(), true)).m16491for("Proxy-Connection", "Keep-Alive").m16491for("User-Agent", "okhttp/4.12.0").m16493if();
        u51 mo11764if = this.f16905try.m14888if().m15310this().mo11764if(this.f16905try, new n61.Cif().m12955native(m16493if).m12962while(g01.HTTP_1_1).m12952goto(407).m12950final("Preemptive Authenticate").m12951for(cs1.f7310new).m12957public(-1L).m12954import(-1L).m12946catch("Proxy-Authenticate", "OkHttp-Preemptive").m12956new());
        return mo11764if == null ? m16493if : mo11764if;
    }

    public final synchronized void m19015finally() {
        this.f16894const = true;
    }

    @Override
    public synchronized void mo8132for(fa0 fa0Var, wd1 wd1Var) {
        hd0.m9590else(fa0Var, "connection");
        hd0.m9590else(wd1Var, "settings");
        this.f16898import = wd1Var.m17653try();
    }

    public final void m19016goto(int r17, int r18, int r19, int r20, boolean r21, com.sgcr.rb r22, com.sgcr.rx r23) {
        throw new UnsupportedOperationException("Method not decompiled: com.sgcr.z31.m19016goto(int, int, int, int, boolean, com.sgcr.rb, com.sgcr.rx):void");
    }

    @Override
    public g01 mo12067if() {
        g01 g01Var = this.f16903this;
        hd0.m9597new(g01Var);
        return g01Var;
    }

    public final boolean m19017import() {
        return this.f16894const;
    }

    public final boolean m19018interface(va0 va0Var) {
        e90 e90Var;
        if (cs1.f7311this && !Thread.holdsLock(this)) {
            throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + this);
        }
        va0 m15304const = this.f16905try.m14888if().m15304const();
        if (va0Var.m17106super() != m15304const.m17106super()) {
            return false;
        }
        if (hd0.m9594if(va0Var.m17092break(), m15304const.m17092break())) {
            return true;
        }
        if (this.f16896final || (e90Var = this.f16897goto) == null) {
            return false;
        }
        hd0.m9597new(e90Var);
        return m19012else(va0Var, e90Var);
    }

    public final int m19019native() {
        return this.f16902super;
    }

    @Override
    public void mo8133new(ia0 ia0Var) {
        hd0.m9590else(ia0Var, "stream");
        ia0Var.m10139try(gx.REFUSED_STREAM, null);
    }

    public r71 m19020package() {
        return this.f16905try;
    }

    public final boolean m19021private(List list) {
        List<r71> list2 = list;
        if ((list2 instanceof Collection) && list2.isEmpty()) {
            return false;
        }
        for (r71 r71Var : list2) {
            if (r71Var.m14887for().type() == Proxy.Type.DIRECT && this.f16905try.m14887for().type() == Proxy.Type.DIRECT && hd0.m9594if(this.f16905try.m14890try(), r71Var.m14890try())) {
                return true;
            }
        }
        return false;
    }

    public final synchronized void m19022protected(y31 y31Var, IOException iOException) {
        int i;
        hd0.m9590else(y31Var, "call");
        if (iOException instanceof di1) {
            if (((di1) iOException).f7689if == gx.REFUSED_STREAM) {
                int i2 = this.f16906while + 1;
                this.f16906while = i2;
                if (i2 > 1) {
                    this.f16894const = true;
                    i = this.f16902super;
                    this.f16902super = i + 1;
                }
            } else if (((di1) iOException).f7689if != gx.CANCEL || !y31Var.mo14951this()) {
                this.f16894const = true;
                i = this.f16902super;
                this.f16902super = i + 1;
            }
        } else if (!m19031throws() || (iOException instanceof oj)) {
            this.f16894const = true;
            if (this.f16904throw == 0) {
                if (iOException != null) {
                    m19029this(y31Var.m18610while(), this.f16905try, iOException);
                }
                i = this.f16902super;
                this.f16902super = i + 1;
            }
        }
    }

    public e90 m19023public() {
        return this.f16897goto;
    }

    public final synchronized void m19024return() {
        this.f16904throw++;
    }

    public final boolean m19025static(s0 s0Var, List list) {
        hd0.m9590else(s0Var, "address");
        if (cs1.f7311this && !Thread.holdsLock(this)) {
            throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + this);
        }
        if (this.f16899native.size() >= this.f16898import || this.f16894const || !this.f16905try.m14888if().m15311try(s0Var)) {
            return false;
        }
        if (hd0.m9594if(s0Var.m15304const().m17092break(), m19020package().m14888if().m15304const().m17092break())) {
            return true;
        }
        if (this.f16890break == null || list == null || !m19021private(list) || s0Var.m15301case() != at0.f6505if || !m19018interface(s0Var.m15304const())) {
            return false;
        }
        try {
            be m15308if = s0Var.m15308if();
            hd0.m9597new(m15308if);
            String m17092break = s0Var.m15304const().m17092break();
            e90 m19023public = m19023public();
            hd0.m9597new(m19023public);
            m15308if.m6015if(m17092break, m19023public.m7596try());
            return true;
        } catch (SSLPeerUnverifiedException unused) {
            return false;
        }
    }

    public Socket m19026strictfp() {
        Socket socket = this.f16895else;
        hd0.m9597new(socket);
        return socket;
    }

    public final void m19027super(qj qjVar, int i, rb rbVar, rx rxVar) {
        if (this.f16905try.m14888if().m15303class() != null) {
            rxVar.m15225private(rbVar);
            m19007catch(qjVar);
            rxVar.m15224package(rbVar, this.f16897goto);
            if (this.f16903this == g01.HTTP_2) {
                m19032volatile(i);
                return;
            }
            return;
        }
        List m15305else = this.f16905try.m14888if().m15305else();
        g01 g01Var = g01.H2_PRIOR_KNOWLEDGE;
        if (!m15305else.contains(g01Var)) {
            this.f16895else = this.f16891case;
            this.f16903this = g01.HTTP_1_1;
        } else {
            this.f16895else = this.f16891case;
            this.f16903this = g01Var;
            m19032volatile(i);
        }
    }

    public final boolean m19028switch(boolean z) {
        long j;
        if (cs1.f7311this && Thread.holdsLock(this)) {
            throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this);
        }
        long nanoTime = System.nanoTime();
        Socket socket = this.f16891case;
        hd0.m9597new(socket);
        Socket socket2 = this.f16895else;
        hd0.m9597new(socket2);
        BufferedSource bufferedSource = this.f16892catch;
        hd0.m9597new(bufferedSource);
        if (socket.isClosed() || socket2.isClosed() || socket2.isInputShutdown() || socket2.isOutputShutdown()) {
            return false;
        }
        fa0 fa0Var = this.f16890break;
        if (fa0Var != null) {
            return fa0Var.m8103implements(nanoTime);
        }
        synchronized (this) {
            j = nanoTime - this.f16901public;
        }
        if (j < 10000000000L || !z) {
            return true;
        }
        return cs1.m6685volatile(socket2, bufferedSource);
    }

    public final void m19029this(ct0 ct0Var, r71 r71Var, IOException iOException) {
        hd0.m9590else(ct0Var, "client");
        hd0.m9590else(r71Var, "failedRoute");
        hd0.m9590else(iOException, "failure");
        if (r71Var.m14887for().type() != Proxy.Type.DIRECT) {
            s0 m14888if = r71Var.m14888if();
            m14888if.m15300break().connectFailed(m14888if.m15304const().m17104public(), r71Var.m14887for().address(), iOException);
        }
        ct0Var.m6721throws().m15412for(r71Var);
    }

    public final List m19030throw() {
        return this.f16899native;
    }

    public final boolean m19031throws() {
        return this.f16890break != null;
    }

    public String toString() {
        Object obj;
        StringBuilder sb = new StringBuilder();
        sb.append("Connection{");
        sb.append(this.f16905try.m14888if().m15304const().m17092break());
        sb.append(':');
        sb.append(this.f16905try.m14888if().m15304const().m17106super());
        sb.append(", proxy=");
        sb.append(this.f16905try.m14887for());
        sb.append(" hostAddress=");
        sb.append(this.f16905try.m14890try());
        sb.append(" cipherSuite=");
        e90 e90Var = this.f16897goto;
        if (e90Var == null || (obj = e90Var.m7594if()) == null) {
            obj = "none";
        }
        sb.append(obj);
        sb.append(" protocol=");
        sb.append(this.f16903this);
        sb.append('}');
        return sb.toString();
    }

    public final void m19032volatile(int i) {
        Socket socket = this.f16895else;
        hd0.m9597new(socket);
        BufferedSource bufferedSource = this.f16892catch;
        hd0.m9597new(bufferedSource);
        BufferedSink bufferedSink = this.f16893class;
        hd0.m9597new(bufferedSink);
        socket.setSoTimeout(0);
        fa0 m8124if = new fa0.Cif(true, yk1.f16672break).m8125import(socket, this.f16905try.m14888if().m15304const().m17092break(), bufferedSource, bufferedSink).m8118class(this).m8119const(i).m8124if();
        this.f16890break = m8124if;
        this.f16898import = fa0.b.m8114if().m17653try();
        fa0.q(m8124if, false, null, 3, null);
    }

    public final long m19033while() {
        return this.f16901public;
    }
}