Atlys v4.8.7 - j.java 源代码

package Sn;

import B0.R2;
import On.C0208a;
import On.C0219l;
import On.C0222o;
import On.C0225s;
import On.C0227u;
import On.E;
import On.F;
import On.S;
import On.w;
import Vn.B;
import Vn.p;
import Vn.q;
import Vn.x;
import Vn.y;
import Xn.n;
import bn.AbstractC0441m;
import com.google.protobuf.Reader;
import eo.AbstractC0622b;
import eo.u;
import eo.v;
import java.io.IOException;
import java.net.ConnectException;
import java.net.InetSocketAddress;
import java.net.Proxy;
import java.net.Socket;
import java.net.SocketTimeoutException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;
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 kotlin.jvm.internal.l;

public final class j extends Vn.g {
    public final S b;
    public Socket c;
    public Socket d;
    public C0227u e;
    public F f;
    public p g;
    public v h;
    public u i;
    public boolean j;
    public boolean k;
    public int l;
    public int m;
    public int n;
    public int o;
    public final ArrayList p;
    public long q;

    public j(k kVar, S s) {
        l.h(kVar, "connectionPool");
        l.h(s, "route");
        this.b = s;
        this.o = 1;
        this.p = new ArrayList();
        this.q = Long.MAX_VALUE;
    }

    public static void d(E e, S s, IOException iOException) {
        l.h(e, "client");
        l.h(s, "failedRoute");
        l.h(iOException, "failure");
        if (s.b.type() != Proxy.Type.DIRECT) {
            C0208a c0208a = s.a;
            c0208a.h.connectFailed(c0208a.i.j(), s.b.address(), iOException);
        }
        I2.a aVar = e.D;
        synchronized (aVar) {
            ((LinkedHashSet) aVar.b).add(s);
        }
    }

    @Override
    public final synchronized void a(p pVar, B b) {
        l.h(pVar, "connection");
        l.h(b, "settings");
        this.o = (b.a & 16) != 0 ? b.b[4] : Reader.READ_DONE;
    }

    @Override
    public final void b(x xVar) {
        l.h(xVar, "stream");
        xVar.c(8, null);
    }

    public final void c(int r16, int r17, int r18, int r19, boolean r20, Sn.h r21, On.C0225s r22) {
        throw new UnsupportedOperationException("Method not decompiled: Sn.j.c(int, int, int, int, boolean, Sn.h, On.s):void");
    }

    public final void e(int i, int i2, h hVar, C0225s c0225s) {
        Socket createSocket;
        S s = this.b;
        Proxy proxy = s.b;
        C0208a c0208a = s.a;
        Proxy.Type type = proxy.type();
        int i3 = type == null ? -1 : i.a[type.ordinal()];
        if (i3 == 1 || i3 == 2) {
            createSocket = c0208a.b.createSocket();
            l.e(createSocket);
        } else {
            createSocket = new Socket(proxy);
        }
        this.c = createSocket;
        InetSocketAddress inetSocketAddress = this.b.c;
        c0225s.getClass();
        l.h(hVar, "call");
        l.h(inetSocketAddress, "inetSocketAddress");
        createSocket.setSoTimeout(i2);
        try {
            n nVar = n.a;
            n.a.e(createSocket, this.b.c, i);
            try {
                this.h = AbstractC0622b.c(AbstractC0622b.n(createSocket));
                this.i = AbstractC0622b.b(AbstractC0622b.j(createSocket));
            } catch (NullPointerException e) {
                if (l.c(e.getMessage(), "throw with null exception")) {
                    throw new IOException(e);
                }
            }
        } catch (ConnectException e2) {
            ConnectException connectException = new ConnectException("Failed to connect to " + this.b.c);
            connectException.initCause(e2);
            throw connectException;
        }
    }

    public final void f(int r22, int r23, int r24, Sn.h r25, On.C0225s r26) {
        throw new UnsupportedOperationException("Method not decompiled: Sn.j.f(int, int, int, Sn.h, On.s):void");
    }

    public final void g(Cn.E e, int i, h hVar, C0225s c0225s) {
        SSLSocket sSLSocket;
        C0208a c0208a = this.b.a;
        SSLSocketFactory sSLSocketFactory = c0208a.c;
        F f = F.HTTP_1_1;
        if (sSLSocketFactory == null) {
            List list = c0208a.j;
            F f2 = F.H2_PRIOR_KNOWLEDGE;
            if (!list.contains(f2)) {
                this.d = this.c;
                this.f = f;
                return;
            } else {
                this.d = this.c;
                this.f = f2;
                m(i);
                return;
            }
        }
        c0225s.getClass();
        l.h(hVar, "call");
        C0208a c0208a2 = this.b.a;
        SSLSocketFactory sSLSocketFactory2 = c0208a2.c;
        SSLSocket sSLSocket2 = null;
        String str = null;
        try {
            l.e(sSLSocketFactory2);
            Socket socket = this.c;
            w wVar = c0208a2.i;
            Socket createSocket = sSLSocketFactory2.createSocket(socket, wVar.d, wVar.e, true);
            l.f(createSocket, "null cannot be cast to non-null type javax.net.ssl.SSLSocket");
            sSLSocket = (SSLSocket) createSocket;
        } catch (Throwable th) {
            th = th;
        }
        try {
            C0222o b = e.b(sSLSocket);
            if (b.b) {
                n nVar = n.a;
                n.a.d(sSLSocket, c0208a2.i.d, c0208a2.j);
            }
            sSLSocket.startHandshake();
            SSLSession session = sSLSocket.getSession();
            l.g(session, "sslSocketSession");
            C0227u y = Ag.g.y(session);
            HostnameVerifier hostnameVerifier = c0208a2.d;
            l.e(hostnameVerifier);
            if (hostnameVerifier.verify(c0208a2.i.d, session)) {
                C0219l c0219l = c0208a2.e;
                l.e(c0219l);
                this.e = new C0227u(y.a, y.b, y.c, new R2(c0219l, y, c0208a2, 16));
                c0219l.a(c0208a2.i.d, new M5.a(this, 24));
                if (b.b) {
                    n nVar2 = n.a;
                    str = n.a.f(sSLSocket);
                }
                this.d = sSLSocket;
                this.h = AbstractC0622b.c(AbstractC0622b.n(sSLSocket));
                this.i = AbstractC0622b.b(AbstractC0622b.j(sSLSocket));
                if (str != null) {
                    f = Ld.a.S(str);
                }
                this.f = f;
                n nVar3 = n.a;
                n.a.a(sSLSocket);
                if (this.f == F.HTTP_2) {
                    m(i);
                    return;
                }
                return;
            }
            List a = y.a();
            if (!(!a.isEmpty())) {
                throw new SSLPeerUnverifiedException("Hostname " + c0208a2.i.d + " not verified (no certificates)");
            }
            Object obj = a.get(0);
            l.f(obj, "null cannot be cast to non-null type java.security.cert.X509Certificate");
            X509Certificate x509Certificate = (X509Certificate) obj;
            StringBuilder sb = new StringBuilder("\n              |Hostname ");
            sb.append(c0208a2.i.d);
            sb.append(" not verified:\n              |    certificate: ");
            C0219l c0219l2 = C0219l.c;
            StringBuilder sb2 = new StringBuilder("sha256/");
            eo.k kVar = eo.k.d;
            byte[] encoded = x509Certificate.getPublicKey().getEncoded();
            l.g(encoded, "publicKey.encoded");
            sb2.append(Yl.e.t(0, -1234567890, encoded).b("SHA-256").a());
            sb.append(sb2.toString());
            sb.append("\n              |    DN: ");
            sb.append(x509Certificate.getSubjectDN().getName());
            sb.append("\n              |    subjectAltNames: ");
            sb.append(xl.n.r1(bo.c.a(x509Certificate, 7), bo.c.a(x509Certificate, 2)));
            sb.append("\n              ");
            throw new SSLPeerUnverifiedException(AbstractC0441m.V(sb.toString()));
        } catch (Throwable th2) {
            th = th2;
            sSLSocket2 = sSLSocket;
            if (sSLSocket2 != null) {
                n nVar4 = n.a;
                n.a.a(sSLSocket2);
            }
            if (sSLSocket2 != null) {
                Pn.b.d(sSLSocket2);
            }
            throw th;
        }
    }

    public final synchronized void h() {
        this.m++;
    }

    public final boolean i(On.C0208a r9, java.util.List r10) {
        throw new UnsupportedOperationException("Method not decompiled: Sn.j.i(On.a, java.util.List):boolean");
    }

    public final boolean j(boolean z) {
        long j;
        byte[] bArr = Pn.b.a;
        long nanoTime = System.nanoTime();
        Socket socket = this.c;
        l.e(socket);
        Socket socket2 = this.d;
        l.e(socket2);
        v vVar = this.h;
        l.e(vVar);
        if (socket.isClosed() || socket2.isClosed() || socket2.isInputShutdown() || socket2.isOutputShutdown()) {
            return false;
        }
        p pVar = this.g;
        if (pVar != null) {
            return pVar.d(nanoTime);
        }
        synchronized (this) {
            j = nanoTime - this.q;
        }
        if (j < 10000000000L || !z) {
            return true;
        }
        try {
            int soTimeout = socket2.getSoTimeout();
            try {
                socket2.setSoTimeout(1);
                boolean z2 = !vVar.i0();
                socket2.setSoTimeout(soTimeout);
                return z2;
            } catch (Throwable th) {
                socket2.setSoTimeout(soTimeout);
                throw th;
            }
        } catch (SocketTimeoutException unused) {
            return true;
        } catch (IOException unused2) {
            return false;
        }
    }

    public final Tn.c k(E e, Tn.e eVar) {
        Socket socket = this.d;
        l.e(socket);
        v vVar = this.h;
        l.e(vVar);
        u uVar = this.i;
        l.e(uVar);
        p pVar = this.g;
        if (pVar != null) {
            return new q(e, this, eVar, pVar);
        }
        int i = eVar.g;
        socket.setSoTimeout(i);
        TimeUnit timeUnit = TimeUnit.MILLISECONDS;
        vVar.a.timeout().g(i, timeUnit);
        uVar.a.timeout().g(eVar.h, timeUnit);
        return new Un.g(e, this, vVar, uVar);
    }

    public final synchronized void l() {
        this.j = true;
    }

    public final void m(int i) {
        Socket socket = this.d;
        l.e(socket);
        v vVar = this.h;
        l.e(vVar);
        u uVar = this.i;
        l.e(uVar);
        socket.setSoTimeout(0);
        Rn.c cVar = Rn.c.i;
        Un.g gVar = new Un.g(cVar);
        String str = this.b.a.i.d;
        l.h(str, "peerName");
        gVar.f = socket;
        String str2 = Pn.b.g + ' ' + str;
        l.h(str2, "<set-?>");
        gVar.g = str2;
        gVar.b = vVar;
        gVar.c = uVar;
        gVar.h = this;
        gVar.d = i;
        p pVar = new p(gVar);
        this.g = pVar;
        B b = p.B;
        this.o = (b.a & 16) != 0 ? b.b[4] : Reader.READ_DONE;
        y yVar = pVar.y;
        synchronized (yVar) {
            try {
                if (yVar.e) {
                    throw new IOException("closed");
                }
                if (yVar.b) {
                    Logger logger = y.g;
                    if (logger.isLoggable(Level.FINE)) {
                        logger.fine(Pn.b.i(">> CONNECTION " + Vn.e.a.e(), new Object[0]));
                    }
                    yVar.a.T0(Vn.e.a);
                    yVar.a.flush();
                }
            } catch (Throwable th) {
                throw th;
            }
        }
        pVar.y.g(pVar.r);
        if (pVar.r.a() != 65535) {
            pVar.y.z(0, r0 - 65535);
        }
        cVar.f().c(new Qn.f(pVar.d, pVar.z, 1), 0L);
    }

    public final String toString() {
        Object obj;
        StringBuilder sb = new StringBuilder("Connection{");
        S s = this.b;
        sb.append(s.a.i.d);
        sb.append(':');
        sb.append(s.a.i.e);
        sb.append(", proxy=");
        sb.append(s.b);
        sb.append(" hostAddress=");
        sb.append(s.c);
        sb.append(" cipherSuite=");
        C0227u c0227u = this.e;
        if (c0227u == null || (obj = c0227u.b) == null) {
            obj = "none";
        }
        sb.append(obj);
        sb.append(" protocol=");
        sb.append(this.f);
        sb.append('}');
        return sb.toString();
    }
}