导航菜单

页面标题

页面副标题

All File Recovery v1.0.2 - f.java 源代码

正在查看: All File Recovery v1.0.2 应用的 f.java JAVA 源代码文件

本页面展示 JAVA 反编译生成的源代码文件,支持语法高亮显示。 仅供安全研究与技术分析使用,严禁用于任何非法用途。请遵守相关法律法规。


package Zd;

import Dc.K;
import Rd.C0390b;
import Td.C;
import Td.C0414a;
import Td.C0420g;
import Td.C0425l;
import Td.D;
import Td.E;
import Td.G;
import Td.I;
import Td.InterfaceC0418e;
import Td.InterfaceC0423j;
import Td.r;
import Td.t;
import Td.w;
import ae.C0513g;
import ae.InterfaceC0510d;
import bd.InterfaceC0517a;
import be.C0523b;
import ce.C0526a;
import ce.EnumC0527b;
import ce.f;
import ce.n;
import ef.l;
import ef.m;
import he.AbstractC0628c;
import he.C0629d;
import ie.e;
import java.io.IOException;
import java.lang.ref.Reference;
import java.net.ConnectException;
import java.net.Proxy;
import java.net.Socket;
import java.net.SocketException;
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 ke.InterfaceC0714m;
import ke.InterfaceC0715n;
import ke.c0;
import ke.d0;
import ke.s0;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import kotlin.jvm.internal.Lambda;
import kotlin.jvm.internal.SourceDebugExtension;
import nd.C0750D;

@SourceDebugExtension({"SMAP\nRealConnection.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealConnection.kt\nokhttp3/internal/connection/RealConnection\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 3 Util.kt\nokhttp3/internal/Util\n+ 4 _Collections.kt\nkotlin/collections/CollectionsKt___CollectionsKt\n*L\n1#1,765:1\n1#2:766\n608#3,4:767\n608#3,4:774\n615#3,4:778\n1747#4,3:771\n*S KotlinDebug\n*F\n+ 1 RealConnection.kt\nokhttp3/internal/connection/RealConnection\n*L\n529#1:767,4\n582#1:774,4\n648#1:778,4\n574#1:771,3\n*E\n"})
public final class f extends f.c implements InterfaceC0423j {

    @l
    public static final a t = new a();

    @l
    public static final String u = "throw with null exception";
    public static final int v = 21;
    public static final long w = 10000000000L;

    @l
    public final g c;

    @l
    public final I d;

    @m
    public Socket e;

    @m
    public Socket f;

    @m
    public t g;

    @m
    public D h;

    @m
    public ce.f i;

    @m
    public InterfaceC0715n j;

    @m
    public InterfaceC0714m k;
    public boolean l;
    public boolean m;
    public int n;
    public int o;
    public int p;
    public int q;

    @l
    public final List<Reference<Zd.e>> r;
    public long s;

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

        @l
        public final f a(@l g connectionPool, @l I route, @l Socket socket, long j) {
            Intrinsics.checkNotNullParameter(connectionPool, "connectionPool");
            Intrinsics.checkNotNullParameter(route, "route");
            Intrinsics.checkNotNullParameter(socket, "socket");
            f fVar = new f(connectionPool, route);
            fVar.f = socket;
            fVar.s = j;
            return fVar;
        }

        public a(DefaultConstructorMarker defaultConstructorMarker) {
        }
    }

    public class b {
        public static final int[] a;

        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) {
            }
            a = iArr;
        }
    }

    public static final class c extends Lambda implements InterfaceC0517a<List<? extends Certificate>> {
        public final C0420g a;
        public final t b;
        public final C0414a c;

        public c(C0420g c0420g, t tVar, C0414a c0414a) {
            super(0);
            this.a = c0420g;
            this.b = tVar;
            this.c = c0414a;
        }

        @Override
        @l
        public final List<? extends Certificate> invoke() {
            AbstractC0628c abstractC0628c = this.a.b;
            Intrinsics.checkNotNull(abstractC0628c);
            return abstractC0628c.a(this.b.m(), this.c.i.d);
        }
    }

    @SourceDebugExtension({"SMAP\nRealConnection.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealConnection.kt\nokhttp3/internal/connection/RealConnection$connectTls$2\n+ 2 _Collections.kt\nkotlin/collections/CollectionsKt___CollectionsKt\n*L\n1#1,765:1\n1549#2:766\n1620#2,3:767\n*S KotlinDebug\n*F\n+ 1 RealConnection.kt\nokhttp3/internal/connection/RealConnection$connectTls$2\n*L\n411#1:766\n411#1:767,3\n*E\n"})
    public static final class d extends Lambda implements InterfaceC0517a<List<? extends X509Certificate>> {
        public d() {
            super(0);
        }

        @Override
        @l
        public final List<? extends X509Certificate> invoke() {
            t tVar = f.this.g;
            Intrinsics.checkNotNull(tVar);
            List<Certificate> m = tVar.m();
            ArrayList arrayList = new ArrayList(K.b0(m, 10));
            for (Certificate certificate : m) {
                Intrinsics.checkNotNull(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate");
                arrayList.add((X509Certificate) certificate);
            }
            return arrayList;
        }
    }

    public static final class e extends e.d {
        public final Zd.c d;

        public e(InterfaceC0715n interfaceC0715n, InterfaceC0714m interfaceC0714m, Zd.c cVar) {
            super(true, interfaceC0715n, interfaceC0714m);
            this.d = cVar;
        }

        @Override
        public void close() {
            this.d.a(-1L, true, true, null);
        }
    }

    public f(@l g connectionPool, @l I route) {
        Intrinsics.checkNotNullParameter(connectionPool, "connectionPool");
        Intrinsics.checkNotNullParameter(route, "route");
        this.c = connectionPool;
        this.d = route;
        this.q = 1;
        this.r = new ArrayList();
        this.s = Long.MAX_VALUE;
    }

    public final boolean A() {
        return this.i != null;
    }

    @l
    public final InterfaceC0510d B(@l C client, @l C0513g chain) throws SocketException {
        Intrinsics.checkNotNullParameter(client, "client");
        Intrinsics.checkNotNullParameter(chain, "chain");
        Socket socket = this.f;
        Intrinsics.checkNotNull(socket);
        InterfaceC0715n interfaceC0715n = this.j;
        Intrinsics.checkNotNull(interfaceC0715n);
        InterfaceC0714m interfaceC0714m = this.k;
        Intrinsics.checkNotNull(interfaceC0714m);
        ce.f fVar = this.i;
        if (fVar != null) {
            return new ce.g(client, this, chain, fVar);
        }
        socket.setSoTimeout(chain.g);
        s0 timeout = interfaceC0715n.timeout();
        long j = chain.g;
        TimeUnit timeUnit = TimeUnit.MILLISECONDS;
        timeout.j(j, timeUnit);
        interfaceC0714m.timeout().j(chain.h, timeUnit);
        return new C0523b(client, this, interfaceC0715n, interfaceC0714m);
    }

    @l
    public final e.d C(@l Zd.c exchange) throws SocketException {
        Intrinsics.checkNotNullParameter(exchange, "exchange");
        Socket socket = this.f;
        Intrinsics.checkNotNull(socket);
        InterfaceC0715n interfaceC0715n = this.j;
        Intrinsics.checkNotNull(interfaceC0715n);
        InterfaceC0714m interfaceC0714m = this.k;
        Intrinsics.checkNotNull(interfaceC0714m);
        socket.setSoTimeout(0);
        E();
        return new e(interfaceC0715n, interfaceC0714m, exchange);
    }

    public final synchronized void D() {
        this.m = true;
    }

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

    public final boolean F(List<I> list) {
        List<I> list2 = list;
        if ((list2 instanceof Collection) && list2.isEmpty()) {
            return false;
        }
        for (I i : list2) {
            Proxy.Type type = i.b.type();
            Proxy.Type type2 = Proxy.Type.DIRECT;
            if (type == type2 && this.d.b.type() == type2 && Intrinsics.areEqual(this.d.c, i.c)) {
                return true;
            }
        }
        return false;
    }

    public final void G(long j) {
        this.s = j;
    }

    public final void H(boolean z) {
        this.l = z;
    }

    public final void I(int i) {
        this.n = i;
    }

    public final void J(int i) throws IOException {
        Socket socket = this.f;
        Intrinsics.checkNotNull(socket);
        InterfaceC0715n interfaceC0715n = this.j;
        Intrinsics.checkNotNull(interfaceC0715n);
        InterfaceC0714m interfaceC0714m = this.k;
        Intrinsics.checkNotNull(interfaceC0714m);
        socket.setSoTimeout(0);
        f.a aVar = new f.a(true, Yd.d.i);
        aVar.y(socket, this.d.a.i.d, interfaceC0715n, interfaceC0714m);
        Intrinsics.checkNotNullParameter(this, "listener");
        aVar.g = this;
        aVar.i = i;
        ce.f fVar = new ce.f(aVar);
        this.i = fVar;
        ce.f.D.getClass();
        this.q = ce.f.F.f();
        ce.f.o2(fVar, false, null, 3, null);
    }

    public final boolean K(w wVar) {
        t tVar;
        if (Ud.f.h && !Thread.holdsLock(this)) {
            throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + this);
        }
        w wVar2 = this.d.a.i;
        if (wVar.e != wVar2.e) {
            return false;
        }
        if (Intrinsics.areEqual(wVar.d, wVar2.d)) {
            return true;
        }
        if (!this.m && (tVar = this.g) != null) {
            Intrinsics.checkNotNull(tVar);
            if (j(wVar, tVar)) {
                return true;
            }
        }
        return false;
    }

    public final synchronized void L(@l Zd.e call, @m IOException iOException) {
        try {
            Intrinsics.checkNotNullParameter(call, "call");
            if (iOException instanceof n) {
                if (((n) iOException).a == EnumC0527b.REFUSED_STREAM) {
                    int i = this.p + 1;
                    this.p = i;
                    if (i > 1) {
                        this.l = true;
                        this.n++;
                    }
                } else if (((n) iOException).a != EnumC0527b.CANCEL || !call.p) {
                    this.l = true;
                    this.n++;
                }
            } else if (!A() || (iOException instanceof C0526a)) {
                this.l = true;
                if (this.o == 0) {
                    if (iOException != null) {
                        l(call.a, this.d, iOException);
                    }
                    this.n++;
                }
            }
        } catch (Throwable th) {
            throw th;
        }
    }

    @Override
    @l
    public D a() {
        D d2 = this.h;
        Intrinsics.checkNotNull(d2);
        return d2;
    }

    @Override
    @l
    public I b() {
        return this.d;
    }

    @Override
    @m
    public t c() {
        return this.g;
    }

    @Override
    @l
    public Socket d() {
        Socket socket = this.f;
        Intrinsics.checkNotNull(socket);
        return socket;
    }

    @Override
    public synchronized void e(@l ce.f connection, @l ce.m settings) {
        Intrinsics.checkNotNullParameter(connection, "connection");
        Intrinsics.checkNotNullParameter(settings, "settings");
        this.q = settings.f();
    }

    @Override
    public void f(@l ce.i stream) throws IOException {
        Intrinsics.checkNotNullParameter(stream, "stream");
        stream.d(EnumC0527b.REFUSED_STREAM, null);
    }

    public final void i() {
        Socket socket = this.e;
        if (socket != null) {
            Ud.f.q(socket);
        }
    }

    public final boolean j(w wVar, t tVar) {
        List<Certificate> m = tVar.m();
        if (!m.isEmpty()) {
            C0629d c0629d = C0629d.a;
            String str = wVar.d;
            Certificate certificate = m.get(0);
            Intrinsics.checkNotNull(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate");
            if (c0629d.e(str, (X509Certificate) certificate)) {
                return true;
            }
        }
        return false;
    }

    public final void k(int r13, int r14, int r15, int r16, boolean r17, @ef.l Td.InterfaceC0418e r18, @ef.l Td.r r19) {
        throw new UnsupportedOperationException("Method not decompiled: Zd.f.k(int, int, int, int, boolean, Td.e, Td.r):void");
    }

    public final void l(@l C client, @l I failedRoute, @l IOException failure) {
        Intrinsics.checkNotNullParameter(client, "client");
        Intrinsics.checkNotNullParameter(failedRoute, "failedRoute");
        Intrinsics.checkNotNullParameter(failure, "failure");
        if (failedRoute.b.type() != Proxy.Type.DIRECT) {
            C0414a c0414a = failedRoute.a;
            c0414a.h.connectFailed(c0414a.i.Z(), failedRoute.b.address(), failure);
        }
        client.D.b(failedRoute);
    }

    public final void m(int i, int i2, InterfaceC0418e interfaceC0418e, r rVar) throws IOException {
        Socket createSocket;
        I i3 = this.d;
        Proxy proxy = i3.b;
        C0414a c0414a = i3.a;
        Proxy.Type type = proxy.type();
        int i4 = type == null ? -1 : b.a[type.ordinal()];
        if (i4 == 1 || i4 == 2) {
            createSocket = c0414a.b.createSocket();
            Intrinsics.checkNotNull(createSocket);
        } else {
            createSocket = new Socket(proxy);
        }
        this.e = createSocket;
        rVar.j(interfaceC0418e, this.d.c, proxy);
        createSocket.setSoTimeout(i2);
        try {
            ee.h.a.getClass();
            ee.h.b.g(createSocket, this.d.c, i);
            try {
                this.j = d0.c(c0.t(createSocket));
                this.k = d0.b(c0.o(createSocket));
            } catch (NullPointerException e2) {
                if (Intrinsics.areEqual(e2.getMessage(), u)) {
                    throw new IOException(e2);
                }
            }
        } catch (ConnectException e3) {
            ConnectException connectException = new ConnectException("Failed to connect to " + this.d.c);
            connectException.initCause(e3);
            throw connectException;
        }
    }

    public final void n(Zd.b bVar) throws IOException {
        C0414a c0414a = this.d.a;
        SSLSocketFactory sSLSocketFactory = c0414a.c;
        SSLSocket sSLSocket = null;
        String str = null;
        try {
            Intrinsics.checkNotNull(sSLSocketFactory);
            Socket socket = this.e;
            w wVar = c0414a.i;
            Socket createSocket = sSLSocketFactory.createSocket(socket, wVar.d, wVar.e, true);
            Intrinsics.checkNotNull(createSocket, "null cannot be cast to non-null type javax.net.ssl.SSLSocket");
            SSLSocket sSLSocket2 = (SSLSocket) createSocket;
            try {
                C0425l a2 = bVar.a(sSLSocket2);
                if (a2.b) {
                    ee.h.a.getClass();
                    ee.h.b.f(sSLSocket2, c0414a.i.d, c0414a.j);
                }
                sSLSocket2.startHandshake();
                SSLSession sslSocketSession = sSLSocket2.getSession();
                t.a aVar = t.e;
                Intrinsics.checkNotNullExpressionValue(sslSocketSession, "sslSocketSession");
                t c2 = aVar.c(sslSocketSession);
                HostnameVerifier hostnameVerifier = c0414a.d;
                Intrinsics.checkNotNull(hostnameVerifier);
                if (hostnameVerifier.verify(c0414a.i.d, sslSocketSession)) {
                    C0420g c0420g = c0414a.e;
                    Intrinsics.checkNotNull(c0420g);
                    this.g = new t(c2.a, c2.b, c2.c, new c(c0420g, c2, c0414a));
                    c0420g.c(c0414a.i.d, new d());
                    if (a2.b) {
                        ee.h.a.getClass();
                        str = ee.h.b.j(sSLSocket2);
                    }
                    this.f = sSLSocket2;
                    this.j = d0.c(c0.t(sSLSocket2));
                    this.k = d0.b(c0.o(sSLSocket2));
                    this.h = str != null ? D.b.a(str) : D.HTTP_1_1;
                    ee.h.a.getClass();
                    ee.h.b.c(sSLSocket2);
                    return;
                }
                List<Certificate> m = c2.m();
                if (m.isEmpty()) {
                    throw new SSLPeerUnverifiedException("Hostname " + c0414a.i.d + " not verified (no certificates)");
                }
                Certificate certificate = m.get(0);
                Intrinsics.checkNotNull(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate");
                X509Certificate x509Certificate = (X509Certificate) certificate;
                throw new SSLPeerUnverifiedException(C0750D.x("\n              |Hostname " + c0414a.i.d + " not verified:\n              |    certificate: " + C0420g.c.a(x509Certificate) + "\n              |    DN: " + x509Certificate.getSubjectDN().getName() + "\n              |    subjectAltNames: " + C0629d.a.a(x509Certificate) + "\n              ", null, 1, null));
            } catch (Throwable th) {
                th = th;
                sSLSocket = sSLSocket2;
                if (sSLSocket != null) {
                    ee.h.a.getClass();
                    ee.h.b.c(sSLSocket);
                }
                if (sSLSocket != null) {
                    Ud.f.q(sSLSocket);
                }
                throw th;
            }
        } catch (Throwable th2) {
            th = th2;
        }
    }

    public final void o(int i, int i2, int i3, InterfaceC0418e interfaceC0418e, r rVar) throws IOException {
        E q = q();
        w wVar = q.a;
        for (int i4 = 0; i4 < 21; i4++) {
            m(i, i2, interfaceC0418e, rVar);
            q = p(i2, i3, q, wVar);
            if (q == null) {
                return;
            }
            Socket socket = this.e;
            if (socket != null) {
                Ud.f.q(socket);
            }
            this.e = null;
            this.k = null;
            this.j = null;
            I i5 = this.d;
            rVar.h(interfaceC0418e, i5.c, i5.b, null);
        }
    }

    public final E p(int i, int i2, E request, w wVar) throws IOException {
        String str = "CONNECT " + Ud.f.f0(wVar, true) + " HTTP/1.1";
        while (true) {
            InterfaceC0715n interfaceC0715n = this.j;
            Intrinsics.checkNotNull(interfaceC0715n);
            InterfaceC0714m interfaceC0714m = this.k;
            Intrinsics.checkNotNull(interfaceC0714m);
            C0523b c0523b = new C0523b(null, this, interfaceC0715n, interfaceC0714m);
            TimeUnit timeUnit = TimeUnit.MILLISECONDS;
            interfaceC0715n.timeout().j(i, timeUnit);
            interfaceC0714m.timeout().j(i2, timeUnit);
            c0523b.C(request.c, str);
            c0523b.b();
            G.a g = c0523b.g(false);
            Intrinsics.checkNotNull(g);
            g.getClass();
            Intrinsics.checkNotNullParameter(request, "request");
            g.a = request;
            G c2 = g.c();
            c0523b.B(c2);
            int i3 = c2.d;
            if (i3 == 200) {
                if (interfaceC0715n.B().g1() && interfaceC0714m.B().g1()) {
                    return null;
                }
                throw new IOException("TLS tunnel buffered too many bytes!");
            }
            if (i3 != 407) {
                throw new IOException("Unexpected response code for CONNECT: " + c2.d);
            }
            I i4 = this.d;
            E a2 = i4.a.f.a(i4, c2);
            if (a2 == null) {
                throw new IOException("Failed to authenticate with proxy");
            }
            if (com.vungle.ads.internal.presenter.i.CLOSE.equalsIgnoreCase(c2.D0("Connection", null))) {
                return a2;
            }
            request = a2;
        }
    }

    public final E q() throws IOException {
        E.a aVar = new E.a();
        aVar.B(this.d.a.i);
        aVar.p("CONNECT", null);
        aVar.n("Host", Ud.f.f0(this.d.a.i, true));
        aVar.n("Proxy-Connection", "Keep-Alive");
        aVar.n("User-Agent", Ud.f.j);
        E request = aVar.b();
        G.a aVar2 = new G.a();
        Intrinsics.checkNotNullParameter(request, "request");
        aVar2.a = request;
        aVar2.B(D.HTTP_1_1);
        aVar2.c = 407;
        Intrinsics.checkNotNullParameter("Preemptive Authenticate", "message");
        aVar2.d = "Preemptive Authenticate";
        aVar2.g = Ud.f.c;
        aVar2.k = -1L;
        aVar2.l = -1L;
        aVar2.v("Proxy-Authenticate", "OkHttp-Preemptive");
        G c2 = aVar2.c();
        I i = this.d;
        E a2 = i.a.f.a(i, c2);
        return a2 == null ? request : a2;
    }

    public final void r(Zd.b bVar, int i, InterfaceC0418e interfaceC0418e, r rVar) throws IOException {
        C0414a c0414a = this.d.a;
        if (c0414a.c != null) {
            rVar.C(interfaceC0418e);
            n(bVar);
            rVar.B(interfaceC0418e, this.g);
            if (this.h == D.HTTP_2) {
                J(i);
                return;
            }
            return;
        }
        List<D> list = c0414a.j;
        D d2 = D.H2_PRIOR_KNOWLEDGE;
        if (!list.contains(d2)) {
            this.f = this.e;
            this.h = D.HTTP_1_1;
        } else {
            this.f = this.e;
            this.h = d2;
            J(i);
        }
    }

    @l
    public final List<Reference<Zd.e>> s() {
        return this.r;
    }

    @l
    public final g t() {
        return this.c;
    }

    @l
    public String toString() {
        Object obj;
        StringBuilder sb = new StringBuilder("Connection{");
        sb.append(this.d.a.i.d);
        sb.append(C0390b.h);
        sb.append(this.d.a.i.e);
        sb.append(", proxy=");
        sb.append(this.d.b);
        sb.append(" hostAddress=");
        sb.append(this.d.c);
        sb.append(" cipherSuite=");
        t tVar = this.g;
        if (tVar == null || (obj = tVar.b) == null) {
            obj = "none";
        }
        sb.append(obj);
        sb.append(" protocol=");
        sb.append(this.h);
        sb.append(C0390b.j);
        return sb.toString();
    }

    public final long u() {
        return this.s;
    }

    public final boolean v() {
        return this.l;
    }

    public final int w() {
        return this.n;
    }

    public final synchronized void x() {
        this.o++;
    }

    public final boolean y(@l C0414a address, @m List<I> list) {
        Intrinsics.checkNotNullParameter(address, "address");
        if (Ud.f.h && !Thread.holdsLock(this)) {
            throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + this);
        }
        if (this.r.size() >= this.q || this.l || !this.d.a.o(address)) {
            return false;
        }
        if (Intrinsics.areEqual(address.i.d, this.d.a.i.d)) {
            return true;
        }
        if (this.i == null || list == null || !F(list) || address.d != C0629d.a || !K(address.i)) {
            return false;
        }
        try {
            C0420g c0420g = address.e;
            Intrinsics.checkNotNull(c0420g);
            String str = address.i.d;
            t tVar = this.g;
            Intrinsics.checkNotNull(tVar);
            c0420g.a(str, tVar.m());
            return true;
        } catch (SSLPeerUnverifiedException unused) {
            return false;
        }
    }

    public final boolean z(boolean z) {
        long j;
        if (Ud.f.h && Thread.holdsLock(this)) {
            throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this);
        }
        long nanoTime = System.nanoTime();
        Socket socket = this.e;
        Intrinsics.checkNotNull(socket);
        Socket socket2 = this.f;
        Intrinsics.checkNotNull(socket2);
        InterfaceC0715n interfaceC0715n = this.j;
        Intrinsics.checkNotNull(interfaceC0715n);
        if (socket.isClosed() || socket2.isClosed() || socket2.isInputShutdown() || socket2.isOutputShutdown()) {
            return false;
        }
        ce.f fVar = this.i;
        if (fVar != null) {
            return fVar.k1(nanoTime);
        }
        synchronized (this) {
            j = nanoTime - this.s;
        }
        if (j < w || !z) {
            return true;
        }
        return Ud.f.N(socket2, interfaceC0715n);
    }
}