MT Manager v2.13.3 - C2930.java 源代码

package l;

import java.io.IOException;
import java.net.ConnectException;
import java.net.Proxy;
import java.net.Socket;
import java.net.SocketTimeoutException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;
import javax.net.ssl.SSLPeerUnverifiedException;
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocket;
import javax.net.ssl.SSLSocketFactory;

public final class C2930 extends AbstractC1768 {

    public final ۬ۥ۟ۗ f9357;

    public C1959 f9358;

    public InterfaceC4939 f9359;

    public int f9360;

    public Socket f9362;

    public C8728 f9363;

    public boolean f9364;

    public final ۦۦ۟ۗ f9365;

    public Socket f9366;

    public InterfaceC2855 f9367;

    public EnumC1225 f9369;

    public int f9368 = 1;

    public final ArrayList f9361 = new ArrayList();

    public long f9370 = Long.MAX_VALUE;

    public C2930(۬ۥ۟ۗ r3, ۦۦ۟ۗ r4) {
        this.f9357 = r3;
        this.f9365 = r4;
    }

    public final void m7667(int r6, int r7, int r8, int r9, boolean r10, l.ۨۧ۟ۗ r11) {
        throw new UnsupportedOperationException("Method not decompiled: l.C2930.m7667(int, int, int, int, boolean, l.ۨۧ۟ۗ):void");
    }

    private void m7662(int i, int i2, ۨۧ۟ۗ r8) {
        Socket createSocket;
        ۦۦ۟ۗ r0 = this.f9365;
        Proxy proxy = r0.ۨ();
        ۧ۠۟ۗ r2 = r0.ۗ();
        if (proxy.type() == Proxy.Type.DIRECT || proxy.type() == Proxy.Type.HTTP) {
            createSocket = r2.۫().createSocket();
        } else {
            createSocket = new Socket(proxy);
        }
        this.f9362 = createSocket;
        r8.getClass();
        this.f9362.setSoTimeout(i2);
        try {
            C0758.m2348().m2353(this.f9362, r0.ۖ(), i);
            try {
                this.f9359 = ۫ۨۡۗ.ۗ(۫ۨۡۗ.ۨ(this.f9362));
                this.f9367 = ۫ۨۡۗ.ۗ(۫ۨۡۗ.ۗ(this.f9362));
            } catch (NullPointerException e) {
                if ("throw with null exception".equals(e.getMessage())) {
                    throw new IOException(e);
                }
            }
        } catch (ConnectException e2) {
            ConnectException connectException = new ConnectException("Failed to connect to " + r0.ۖ());
            connectException.initCause(e2);
            throw connectException;
        }
    }

    private void m7663(C2228 c2228, int i, ۨۧ۟ۗ r11) {
        SSLSocket sSLSocket;
        ۦۦ۟ۗ r0 = this.f9365;
        SSLSocketFactory sSLSocketFactory = r0.ۗ().۠();
        EnumC1225 enumC1225 = EnumC1225.HTTP_1_1;
        if (sSLSocketFactory == null) {
            List list = r0.ۗ().ۘ();
            EnumC1225 enumC12252 = EnumC1225.H2_PRIOR_KNOWLEDGE;
            if (list.contains(enumC12252)) {
                this.f9366 = this.f9362;
                this.f9369 = enumC12252;
                m7660(i);
                return;
            } else {
                this.f9366 = this.f9362;
                this.f9369 = enumC1225;
                return;
            }
        }
        r11.getClass();
        ۧ۠۟ۗ r02 = r0.ۗ();
        try {
            try {
                sSLSocket = (SSLSocket) r02.۠().createSocket(this.f9362, r02.ۥ().ۢ(), r02.ۥ().ۤ(), true);
            } catch (AssertionError e) {
                e = e;
            }
        } catch (Throwable th) {
            th = th;
            sSLSocket = null;
        }
        try {
            ۫ۥ۟ۗ m6023 = c2228.m6023(sSLSocket);
            if (m6023.ۗ()) {
                C0758.m2348().mo2355(sSLSocket, r02.ۥ().ۢ(), r02.ۘ());
            }
            sSLSocket.startHandshake();
            SSLSession session = sSLSocket.getSession();
            C1959 m5280 = C1959.m5280(session);
            if (!r02.ۖ().verify(r02.ۥ().ۢ(), session)) {
                X509Certificate x509Certificate = (X509Certificate) m5280.m5282().get(0);
                throw new SSLPeerUnverifiedException("Hostname " + r02.ۥ().ۢ() + " not verified:\n    certificate: " + C3971.m10015(x509Certificate) + "\n    DN: " + x509Certificate.getSubjectDN().getName() + "\n    subjectAltNames: " + C7030.m17262(x509Certificate));
            }
            r02.ۗ().m10017(r02.ۥ().ۢ(), m5280.m5282());
            String mo2359 = m6023.ۗ() ? C0758.m2348().mo2359(sSLSocket) : null;
            this.f9366 = sSLSocket;
            this.f9359 = ۫ۨۡۗ.ۗ(۫ۨۡۗ.ۨ(sSLSocket));
            this.f9367 = ۫ۨۡۗ.ۗ(۫ۨۡۗ.ۗ(this.f9366));
            this.f9358 = m5280;
            if (mo2359 != null) {
                enumC1225 = EnumC1225.m3597(mo2359);
            }
            this.f9369 = enumC1225;
            C0758.m2348().mo2354(sSLSocket);
            if (this.f9369 == EnumC1225.HTTP_2) {
                m7660(i);
            }
        } catch (AssertionError e2) {
            e = e2;
            if (!C0834.m2588(e)) {
                throw e;
            }
            throw new IOException(e);
        } catch (Throwable th2) {
            th = th2;
            if (sSLSocket != null) {
                C0758.m2348().mo2354(sSLSocket);
            }
            C0834.m2587((Socket) sSLSocket);
            throw th;
        }
    }

    private void m7660(int i) {
        this.f9366.setSoTimeout(0);
        C3853 c3853 = new C3853();
        c3853.m9781(this.f9366, this.f9365.ۗ().ۥ().ۢ(), this.f9359, this.f9367);
        c3853.m9782(this);
        c3853.m9780(i);
        C8728 m9779 = c3853.m9779();
        this.f9363 = m9779;
        m9779.m21016();
    }

    private void m7661(int r20, int r21, int r22, l.ۨۧ۟ۗ r23) {
        throw new UnsupportedOperationException("Method not decompiled: l.C2930.m7661(int, int, int, l.ۨۧ۟ۗ):void");
    }

    public final boolean m7668(ۧ۠۟ۗ r6, ۦۦ۟ۗ r7) {
        if (this.f9361.size() < this.f9368 && !this.f9364) {
            AbstractC3308 abstractC3308 = AbstractC3308.f11872;
            ۦۦ۟ۗ r1 = this.f9365;
            if (!abstractC3308.mo8511(r1.ۗ(), r6)) {
                return false;
            }
            if (r6.ۥ().ۢ().equals(r1.ۗ().ۥ().ۢ())) {
                return true;
            }
            if (this.f9363 == null || r7 == null || r7.ۨ().type() != Proxy.Type.DIRECT || r1.ۨ().type() != Proxy.Type.DIRECT || !r1.ۖ().equals(r7.ۖ()) || r7.ۗ().ۖ() != C7030.f22445 || !m7669(r6.ۥ())) {
                return false;
            }
            try {
                r6.ۗ().m10017(r6.ۥ().ۢ(), this.f9358.m5282());
                return true;
            } catch (SSLPeerUnverifiedException unused) {
            }
        }
        return false;
    }

    public final boolean m7669(۫ۧ۟ۗ r5) {
        int i = r5.ۤ();
        ۦۦ۟ۗ r1 = this.f9365;
        if (i != r1.ۗ().ۥ().ۤ()) {
            return false;
        }
        if (r5.ۢ().equals(r1.ۗ().ۥ().ۢ())) {
            return true;
        }
        return this.f9358 != null && C7030.m17264(r5.ۢ(), (X509Certificate) this.f9358.m5282().get(0));
    }

    public final ۬ۚ۟ۗ m7665(ۜۧ۟ۗ r5, C8534 c8534, C3658 c3658) {
        if (this.f9363 != null) {
            return new C2381(r5, c8534, c3658, this.f9363);
        }
        this.f9366.setSoTimeout(c8534.m20708());
        C1620 mo1855 = this.f9359.mo1855();
        long m20708 = c8534.m20708();
        TimeUnit timeUnit = TimeUnit.MILLISECONDS;
        mo1855.mo822(m20708, timeUnit);
        this.f9367.ۢ().mo822(c8534.m20711(), timeUnit);
        return new C1691(r5, c3658, this.f9359, this.f9367);
    }

    public final ۦۦ۟ۗ m7664() {
        return this.f9365;
    }

    public final void m7666() {
        C0834.m2587(this.f9362);
    }

    public final Socket m7671() {
        return this.f9366;
    }

    public final boolean m7670(boolean z) {
        if (this.f9366.isClosed() || this.f9366.isInputShutdown() || this.f9366.isOutputShutdown()) {
            return false;
        }
        if (this.f9363 != null) {
            return !r0.m21015();
        }
        if (z) {
            try {
                int soTimeout = this.f9366.getSoTimeout();
                try {
                    this.f9366.setSoTimeout(1);
                    return !this.f9359.mo5682();
                } finally {
                    this.f9366.setSoTimeout(soTimeout);
                }
            } catch (SocketTimeoutException unused) {
            } catch (IOException unused2) {
                return false;
            }
        }
        return true;
    }

    @Override
    public final void mo1263(C4550 c4550) {
        c4550.m11352(5);
    }

    @Override
    public final void mo4829(C8728 c8728) {
        synchronized (this.f9357) {
            this.f9368 = c8728.m21017();
        }
    }

    public final C1959 m7673() {
        return this.f9358;
    }

    public final boolean m7672() {
        return this.f9363 != null;
    }

    public final String toString() {
        StringBuilder sb = new StringBuilder("Connection{");
        ۦۦ۟ۗ r1 = this.f9365;
        sb.append(r1.ۗ().ۥ().ۢ());
        sb.append(":");
        sb.append(r1.ۗ().ۥ().ۤ());
        sb.append(", proxy=");
        sb.append(r1.ۨ());
        sb.append(" hostAddress=");
        sb.append(r1.ۖ());
        sb.append(" cipherSuite=");
        C1959 c1959 = this.f9358;
        sb.append(c1959 != null ? c1959.m5281() : "none");
        sb.append(" protocol=");
        sb.append(this.f9369);
        sb.append('}');
        return sb.toString();
    }
}