正在查看： Atlys v4.8.7 应用的 n.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
Atlys v4.8.7 - n.java 源代码
package Ek;
import Bk.AbstractC0041i;
import Bk.C;
import Bk.C0033a;
import Bk.C0034b;
import Bk.C0036d;
import Bk.I;
import Bk.f0;
import Bk.h0;
import Bk.i0;
import Bk.s0;
import Bk.t0;
import D0.P;
import D0.U;
import Dk.AbstractC0099n0;
import Dk.B;
import Dk.C0093l0;
import Dk.C0113s0;
import Dk.C0116t0;
import Dk.H0;
import Dk.I0;
import Dk.InterfaceC0082h1;
import Dk.J;
import Dk.RunnableC0110r0;
import Dk.l2;
import Dk.o2;
import Dk.s2;
import Dk.v2;
import Dk.x2;
import io.grpc.StatusException;
import java.io.EOFException;
import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.URI;
import java.util.Collections;
import java.util.EnumMap;
import java.util.HashMap;
import java.util.IdentityHashMap;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.Locale;
import java.util.Map;
import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executor;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.net.SocketFactory;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLSocketFactory;
public final class n implements J, d, y {
public static final Map S;
public static final Logger T;
public final SocketFactory A;
public final SSLSocketFactory B;
public final HostnameVerifier C;
public int D;
public final LinkedList E;
public final Fk.c F;
public I0 G;
public boolean H;
public long I;
public long J;
public boolean K;
public final Runnable L;
public final int M;
public final boolean N;
public final x2 O;
public final C0116t0 P;
public final C Q;
public final int R;
public final InetSocketAddress a;
public final String b;
public final String c;
public final Random d;
public final Gd.s e;
public final int f;
public final Gk.n g;
public InterfaceC0082h1 h;
public e i;
public e3.r j;
public final Object k;
public final I l;
public int m;
public final HashMap n;
public final Executor o;
public final l2 p;
public final ScheduledExecutorService q;
public final int r;
public int s;
public m t;
public C0034b u;
public s0 v;
public boolean w;
public C0113s0 x;
public boolean y;
public boolean z;
static {
EnumMap enumMap = new EnumMap(Gk.a.class);
Gk.a aVar = Gk.a.NO_ERROR;
s0 s0Var = s0.m;
enumMap.put((EnumMap) aVar, (Gk.a) s0Var.g("No error: A GRPC status of OK should have been sent"));
enumMap.put((EnumMap) Gk.a.PROTOCOL_ERROR, (Gk.a) s0Var.g("Protocol error"));
enumMap.put((EnumMap) Gk.a.INTERNAL_ERROR, (Gk.a) s0Var.g("Internal error"));
enumMap.put((EnumMap) Gk.a.FLOW_CONTROL_ERROR, (Gk.a) s0Var.g("Flow control error"));
enumMap.put((EnumMap) Gk.a.STREAM_CLOSED, (Gk.a) s0Var.g("Stream closed"));
enumMap.put((EnumMap) Gk.a.FRAME_TOO_LARGE, (Gk.a) s0Var.g("Frame too large"));
enumMap.put((EnumMap) Gk.a.REFUSED_STREAM, (Gk.a) s0.n.g("Refused stream"));
enumMap.put((EnumMap) Gk.a.CANCEL, (Gk.a) s0.f.g("Cancelled"));
enumMap.put((EnumMap) Gk.a.COMPRESSION_ERROR, (Gk.a) s0Var.g("Compression error"));
enumMap.put((EnumMap) Gk.a.CONNECT_ERROR, (Gk.a) s0Var.g("Connect error"));
enumMap.put((EnumMap) Gk.a.ENHANCE_YOUR_CALM, (Gk.a) s0.k.g("Enhance your calm"));
enumMap.put((EnumMap) Gk.a.INADEQUATE_SECURITY, (Gk.a) s0.i.g("Inadequate security"));
S = Collections.unmodifiableMap(enumMap);
T = Logger.getLogger(n.class.getName());
}
public n(g gVar, InetSocketAddress inetSocketAddress, String str, String str2, C0034b c0034b, C c, Ak.a aVar) {
C0093l0 c0093l0 = AbstractC0099n0.r;
Gk.k kVar = new Gk.k();
this.d = new Random();
Object obj = new Object();
this.k = obj;
this.n = new HashMap();
this.D = 0;
this.E = new LinkedList();
this.P = new C0116t0(this, 2);
this.R = 30000;
eg.d.O(inetSocketAddress, "address");
this.a = inetSocketAddress;
this.b = str;
this.r = gVar.j;
this.f = gVar.n;
Executor executor = gVar.b;
eg.d.O(executor, "executor");
this.o = executor;
this.p = new l2(gVar.b);
ScheduledExecutorService scheduledExecutorService = gVar.d;
eg.d.O(scheduledExecutorService, "scheduledExecutorService");
this.q = scheduledExecutorService;
this.m = 3;
SocketFactory socketFactory = gVar.f;
this.A = socketFactory == null ? SocketFactory.getDefault() : socketFactory;
this.B = gVar.g;
this.C = gVar.h;
Fk.c cVar = gVar.i;
eg.d.O(cVar, "connectionSpec");
this.F = cVar;
eg.d.O(c0093l0, "stopwatchFactory");
this.e = c0093l0;
this.g = kVar;
StringBuilder sb = new StringBuilder();
if (str2 != null) {
sb.append(str2);
sb.append(' ');
}
sb.append("grpc-java-okhttp/1.62.2");
this.c = sb.toString();
this.Q = c;
this.L = aVar;
this.M = gVar.p;
gVar.e.getClass();
this.O = new x2();
this.l = I.a(n.class, inetSocketAddress.toString());
C0034b c0034b2 = C0034b.b;
C0033a c0033a = o2.b;
IdentityHashMap identityHashMap = new IdentityHashMap(1);
identityHashMap.put(c0033a, c0034b);
for (Map.Entry entry : c0034b2.a.entrySet()) {
if (!identityHashMap.containsKey(entry.getKey())) {
identityHashMap.put((C0033a) entry.getKey(), entry.getValue());
}
}
this.u = new C0034b(identityHashMap);
this.N = gVar.q;
synchronized (obj) {
}
}
public static void h(n nVar, String str) {
Gk.a aVar = Gk.a.PROTOCOL_ERROR;
nVar.getClass();
nVar.u(0, aVar, y(aVar).a(str));
}
public static Socket i(n nVar, InetSocketAddress inetSocketAddress, InetSocketAddress inetSocketAddress2, String str, String str2) {
String str3;
int i;
String str4;
nVar.getClass();
Socket socket = null;
try {
InetAddress address = inetSocketAddress2.getAddress();
SocketFactory socketFactory = nVar.A;
Socket createSocket = address != null ? socketFactory.createSocket(inetSocketAddress2.getAddress(), inetSocketAddress2.getPort()) : socketFactory.createSocket(inetSocketAddress2.getHostName(), inetSocketAddress2.getPort());
try {
createSocket.setTcpNoDelay(true);
createSocket.setSoTimeout(nVar.R);
eo.d n = eo.b.n(createSocket);
eo.u b = eo.b.b(eo.b.j(createSocket));
o0.t j = nVar.j(inetSocketAddress, str, str2);
Fk.f fVar = (Fk.f) j.c;
Hk.b bVar = (Hk.b) j.b;
Locale locale = Locale.US;
b.D("CONNECT " + bVar.a + ":" + bVar.b + " HTTP/1.1");
b.D("\r\n");
int length = fVar.b.length / 2;
for (int i2 = 0; i2 < length; i2++) {
int i3 = i2 * 2;
String[] strArr = fVar.b;
if (i3 >= 0 && i3 < strArr.length) {
str3 = strArr[i3];
b.D(str3);
b.D(": ");
i = i3 + 1;
if (i >= 0 && i < strArr.length) {
str4 = strArr[i];
b.D(str4);
b.D("\r\n");
}
str4 = null;
b.D(str4);
b.D("\r\n");
}
str3 = null;
b.D(str3);
b.D(": ");
i = i3 + 1;
if (i >= 0) {
str4 = strArr[i];
b.D(str4);
b.D("\r\n");
}
str4 = null;
b.D(str4);
b.D("\r\n");
}
b.D("\r\n");
b.flush();
B3.a x = B3.a.x(s(n));
while (!s(n).equals("")) {
}
int i4 = x.b;
if (i4 >= 200 && i4 < 300) {
createSocket.setSoTimeout(0);
return createSocket;
}
eo.h hVar = new eo.h();
try {
createSocket.shutdownOutput();
n.read(hVar, 1024L);
} catch (IOException e) {
hVar.w0("Unable to read body: " + e.toString());
}
try {
createSocket.close();
} catch (IOException unused) {
}
Locale locale2 = Locale.US;
throw new StatusException(s0.n.g("Response returned from proxy was not successful (expected 2xx, got " + i4 + " " + ((String) x.d) + "). Response body:\n" + hVar.N0()));
} catch (IOException e2) {
e = e2;
socket = createSocket;
if (socket != null) {
AbstractC0099n0.b(socket);
}
throw new StatusException(s0.n.g("Failed trying to connect with proxy").f(e));
}
} catch (IOException e3) {
e = e3;
}
}
public static String s(eo.d dVar) {
eo.h hVar = new eo.h();
while (dVar.read(hVar, 1L) != -1) {
if (hVar.f(hVar.b - 1) == 10) {
return hVar.w(Long.MAX_VALUE);
}
}
throw new EOFException("\\n not found: " + hVar.a0(hVar.b).e());
}
public static s0 y(Gk.a aVar) {
s0 s0Var = (s0) S.get(aVar);
if (s0Var != null) {
return s0Var;
}
return s0.g.g("Unknown http2 error code: " + aVar.a);
}
@Override
public final Runnable a(InterfaceC0082h1 interfaceC0082h1) {
this.h = interfaceC0082h1;
if (this.H) {
I0 i0 = new I0(new Cj.a(this, 7), this.q, this.I, this.J, this.K);
this.G = i0;
i0.c();
}
c cVar = new c(this.p, this);
Gk.n nVar = this.g;
eo.u b = eo.b.b(cVar);
((Gk.k) nVar).getClass();
b bVar = new b(cVar, new Gk.j(b));
synchronized (this.k) {
e eVar = new e(this, bVar);
this.i = eVar;
this.j = new e3.r(this, eVar);
}
CountDownLatch countDownLatch = new CountDownLatch(1);
this.p.execute(new t0(this, countDownLatch, cVar, 6));
try {
t();
countDownLatch.countDown();
this.p.execute(new Ak.a(this, 15));
return null;
} catch (Throwable th2) {
countDownLatch.countDown();
throw th2;
}
}
@Override
public final void b(s0 s0Var) {
synchronized (this.k) {
try {
if (this.v != null) {
return;
}
this.v = s0Var;
this.h.i(s0Var);
x();
} catch (Throwable th2) {
throw th2;
}
}
}
@Override
public final I c() {
return this.l;
}
@Override
public final C0034b d() {
return this.u;
}
@Override
public final void e(H0 h0) {
boolean z;
long j;
Ld.c cVar = Ld.c.a;
synchronized (this.k) {
try {
eg.d.V(this.i != null);
if (this.y) {
StatusException n = n();
Logger logger = C0113s0.g;
try {
cVar.execute(new RunnableC0110r0(h0, n));
} catch (Throwable th2) {
C0113s0.g.log(Level.SEVERE, "Failed to execute PingCallback", th2);
}
return;
}
C0113s0 c0113s0 = this.x;
if (c0113s0 != null) {
j = 0;
z = false;
} else {
long nextLong = this.d.nextLong();
Gd.r rVar = (Gd.r) this.e.get();
rVar.b();
C0113s0 c0113s02 = new C0113s0(nextLong, rVar);
this.x = c0113s02;
this.O.getClass();
c0113s0 = c0113s02;
z = true;
j = nextLong;
}
if (z) {
this.i.s0((int) (j >>> 32), (int) j, false);
}
c0113s0.a(h0);
} catch (Throwable th3) {
throw th3;
}
}
}
@Override
public final void f(s0 s0Var) {
b(s0Var);
synchronized (this.k) {
try {
Iterator it = this.n.entrySet().iterator();
while (it.hasNext()) {
Map.Entry entry = (Map.Entry) it.next();
it.remove();
((k) entry.getValue()).n.g(s0Var, false, new f0());
q((k) entry.getValue());
}
for (k kVar : this.E) {
kVar.n.e(s0Var, Dk.C.d, true, new f0());
q(kVar);
}
this.E.clear();
x();
} catch (Throwable th2) {
throw th2;
}
}
}
@Override
public final B g(i0 i0Var, f0 f0Var, C0036d c0036d, AbstractC0041i[] abstractC0041iArr) {
eg.d.O(i0Var, "method");
eg.d.O(f0Var, "headers");
C0034b c0034b = this.u;
s2 s2Var = new s2(abstractC0041iArr);
for (AbstractC0041i abstractC0041i : abstractC0041iArr) {
abstractC0041i.n(c0034b, f0Var);
}
synchronized (this.k) {
try {
try {
return new k(i0Var, f0Var, this.i, this, this.j, this.k, this.r, this.f, this.b, this.c, s2Var, this.O, c0036d, this.N);
} catch (Throwable th2) {
th = th2;
throw th;
}
} catch (Throwable th3) {
th = th3;
}
}
}
public final o0.t j(java.net.InetSocketAddress r20, java.lang.String r21, java.lang.String r22) {
throw new UnsupportedOperationException("Method not decompiled: Ek.n.j(java.net.InetSocketAddress, java.lang.String, java.lang.String):o0.t");
}
public final void k(int i, s0 s0Var, Dk.C c, boolean z, Gk.a aVar, f0 f0Var) {
synchronized (this.k) {
try {
k kVar = (k) this.n.remove(Integer.valueOf(i));
if (kVar != null) {
if (aVar != null) {
this.i.Q(i, Gk.a.CANCEL);
}
if (s0Var != null) {
j jVar = kVar.n;
if (f0Var == null) {
f0Var = new f0();
}
jVar.e(s0Var, c, z, f0Var);
}
if (!v()) {
x();
q(kVar);
}
}
} catch (Throwable th2) {
throw th2;
}
}
}
public final x[] l() {
x[] xVarArr;
synchronized (this.k) {
try {
xVarArr = new x[this.n.size()];
Iterator it = this.n.values().iterator();
int i = 0;
while (it.hasNext()) {
xVarArr[i] = ((k) it.next()).n.p();
i++;
}
} catch (Throwable th2) {
throw th2;
}
}
return xVarArr;
}
public final int m() {
URI a = AbstractC0099n0.a(this.b);
return a.getPort() != -1 ? a.getPort() : this.a.getPort();
}
public final StatusException n() {
synchronized (this.k) {
try {
s0 s0Var = this.v;
if (s0Var != null) {
return new StatusException(s0Var);
}
return new StatusException(s0.n.g("Connection closed"));
} catch (Throwable th2) {
throw th2;
}
}
}
public final k o(int i) {
k kVar;
synchronized (this.k) {
kVar = (k) this.n.get(Integer.valueOf(i));
}
return kVar;
}
public final boolean p(int i) {
boolean z;
synchronized (this.k) {
if (i < this.m) {
z = true;
if ((i & 1) == 1) {
}
}
z = false;
}
return z;
}
public final void q(k kVar) {
if (this.z && this.E.isEmpty() && this.n.isEmpty()) {
this.z = false;
I0 i0 = this.G;
if (i0 != null) {
synchronized (i0) {
if (!i0.d) {
int i = i0.e;
if (i == 2 || i == 3) {
i0.e = 1;
}
if (i0.e == 4) {
i0.e = 5;
}
}
}
}
}
if (kVar.e) {
this.P.r1(kVar, false);
}
}
public final void r(Exception exc) {
u(0, Gk.a.INTERNAL_ERROR, s0.n.f(exc));
}
public final void t() {
synchronized (this.k) {
try {
this.i.q();
P p = new P(1, false);
p.g(7, this.f);
this.i.I0(p);
if (this.f > 65535) {
this.i.z(0, r1 - 65535);
}
} catch (Throwable th2) {
throw th2;
}
}
}
public final String toString() {
U T2 = com.bumptech.glide.d.T(this);
T2.c(this.l.c, "logId");
T2.d(this.a, "address");
return T2.toString();
}
public final void u(int i, Gk.a aVar, s0 s0Var) {
synchronized (this.k) {
try {
if (this.v == null) {
this.v = s0Var;
this.h.i(s0Var);
}
if (aVar != null && !this.w) {
this.w = true;
this.i.e0(aVar, new byte[0]);
}
Iterator it = this.n.entrySet().iterator();
while (it.hasNext()) {
Map.Entry entry = (Map.Entry) it.next();
if (((Integer) entry.getKey()).intValue() > i) {
it.remove();
((k) entry.getValue()).n.e(s0Var, Dk.C.b, false, new f0());
q((k) entry.getValue());
}
}
for (k kVar : this.E) {
kVar.n.e(s0Var, Dk.C.d, true, new f0());
q(kVar);
}
this.E.clear();
x();
} catch (Throwable th2) {
throw th2;
}
}
}
public final boolean v() {
boolean z = false;
while (true) {
LinkedList linkedList = this.E;
if (linkedList.isEmpty() || this.n.size() >= this.D) {
break;
}
w((k) linkedList.poll());
z = true;
}
return z;
}
public final void w(k kVar) {
eg.d.U("StreamId already assigned", kVar.n.M == -1);
this.n.put(Integer.valueOf(this.m), kVar);
if (!this.z) {
this.z = true;
I0 i0 = this.G;
if (i0 != null) {
i0.b();
}
}
if (kVar.e) {
this.P.r1(kVar, true);
}
j jVar = kVar.n;
int i = this.m;
if (!(jVar.M == -1)) {
throw new IllegalStateException(g1.c.c0("the stream has been started with id %s", new Object[]{Integer.valueOf(i)}));
}
jVar.M = i;
e3.r rVar = jVar.G;
jVar.L = new x(rVar, i, rVar.a, jVar);
j jVar2 = jVar.N.n;
eg.d.V(jVar2.j != null);
synchronized (jVar2.b) {
eg.d.U("Already allocated", !jVar2.f);
jVar2.f = true;
}
jVar2.d();
x2 x2Var = jVar2.c;
x2Var.getClass();
((v2) x2Var.b).e();
if (jVar.J) {
jVar.F.E(jVar.M, jVar.y, jVar.N.q);
for (AbstractC0041i abstractC0041i : jVar.N.l.a) {
abstractC0041i.h();
}
jVar.y = null;
eo.h hVar = jVar.z;
if (hVar.b > 0) {
jVar.G.d(jVar.A, jVar.L, hVar, jVar.B);
}
jVar.J = false;
}
h0 h0Var = kVar.j.a;
if ((h0Var != h0.a && h0Var != h0.b) || kVar.q) {
this.i.flush();
}
int i2 = this.m;
if (i2 < 2147483645) {
this.m = i2 + 2;
} else {
this.m = Integer.MAX_VALUE;
u(Integer.MAX_VALUE, Gk.a.NO_ERROR, s0.n.g("Stream ids exhausted"));
}
}
public final void x() {
if (this.v == null || !this.n.isEmpty() || !this.E.isEmpty() || this.y) {
return;
}
this.y = true;
I0 i0 = this.G;
if (i0 != null) {
synchronized (i0) {
try {
if (i0.e != 6) {
i0.e = 6;
ScheduledFuture scheduledFuture = i0.f;
if (scheduledFuture != null) {
scheduledFuture.cancel(false);
}
ScheduledFuture scheduledFuture2 = i0.g;
if (scheduledFuture2 != null) {
scheduledFuture2.cancel(false);
i0.g = null;
}
}
} catch (Throwable th2) {
throw th2;
}
}
}
C0113s0 c0113s0 = this.x;
if (c0113s0 != null) {
c0113s0.c(n());
this.x = null;
}
if (!this.w) {
this.w = true;
this.i.e0(Gk.a.NO_ERROR, new byte[0]);
}
this.i.close();
}
}