YourPorn v1.2.4版本的 MD5 值为:25af0cc492747d0d721ef41054943bde
以下内容为反编译后的 Ccase.java 源代码,内容仅作参考
package w2;
import android.net.Uri;
import android.text.TextUtils;
import android.util.Log;
import java.io.File;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.InetAddress;
import java.net.Proxy;
import java.net.ProxySelector;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.URLEncoder;
import java.util.Iterator;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import k8.Cpackage;
import w2.Ccatch;
import x2.Ctry;
public class Ccase {
public final Thread f9657case;
public final w2.Cfor f9659else;
public final Ccatch f9661goto;
public final ServerSocket f9663new;
public final int f9664try;
public final Object f9658do = new Object();
public final ExecutorService f9662if = Executors.newFixedThreadPool(8);
public final Map<String, Celse> f9660for = new ConcurrentHashMap();
public final class Cfor implements Runnable {
public final CountDownLatch f9665else;
public Cfor(CountDownLatch countDownLatch) {
this.f9665else = countDownLatch;
}
@Override
public void run() {
this.f9665else.countDown();
Ccase ccase = Ccase.this;
Objects.requireNonNull(ccase);
while (!Thread.currentThread().isInterrupted()) {
try {
ccase.f9662if.submit(new Cif(ccase.f9663new.accept()));
} catch (IOException e10) {
ccase.m4085try(new Cconst("Error during waiting connection", e10));
return;
}
}
}
}
public final class Cif implements Runnable {
public final Socket f9667else;
public Cif(Socket socket) {
this.f9667else = socket;
}
@Override
public void run() {
StringBuilder sb;
Ccase ccase = Ccase.this;
Socket socket = this.f9667else;
Objects.requireNonNull(ccase);
try {
try {
Cnew m4103do = Cnew.m4103do(socket.getInputStream());
String m2993return = Cpackage.m2993return(m4103do.f9706do);
Objects.requireNonNull(ccase.f9661goto);
if ("ping".equals(m2993return)) {
ccase.f9661goto.m4087if(socket);
} else {
ccase.m4080do(m2993return).m4098for(m4103do, socket);
}
ccase.m4079case(socket);
sb = new StringBuilder();
} catch (Throwable th) {
ccase.m4079case(socket);
b.Cdo.m581throws("Opened connections: " + ccase.m4083if());
throw th;
}
} catch (SocketException unused) {
ccase.m4079case(socket);
sb = new StringBuilder();
} catch (IOException e10) {
e = e10;
ccase.m4085try(new Cconst("Error processing request", e));
ccase.m4079case(socket);
sb = new StringBuilder();
} catch (Cconst e11) {
e = e11;
ccase.m4085try(new Cconst("Error processing request", e));
ccase.m4079case(socket);
sb = new StringBuilder();
}
sb.append("Opened connections: ");
sb.append(ccase.m4083if());
b.Cdo.m581throws(sb.toString());
}
}
public Ccase(w2.Cfor cfor, Cdo cdo) {
this.f9659else = cfor;
try {
ServerSocket serverSocket = new ServerSocket(0, 8, InetAddress.getByName("127.0.0.1"));
this.f9663new = serverSocket;
int localPort = serverSocket.getLocalPort();
this.f9664try = localPort;
List<Proxy> list = Cthis.f9712new;
ProxySelector.setDefault(new Cthis(ProxySelector.getDefault(), "127.0.0.1", localPort));
CountDownLatch countDownLatch = new CountDownLatch(1);
Thread thread = new Thread(new Cfor(countDownLatch));
this.f9657case = thread;
thread.start();
countDownLatch.await();
this.f9661goto = new Ccatch("127.0.0.1", localPort);
b.Cdo.m581throws("Proxy cache server started. Is it alive? " + m4084new());
} catch (IOException | InterruptedException e10) {
this.f9662if.shutdown();
throw new IllegalStateException("Error starting local proxy server", e10);
}
}
public final void m4079case(Socket socket) {
try {
if (!socket.isInputShutdown()) {
socket.shutdownInput();
}
} catch (SocketException | IOException unused) {
}
try {
if (!socket.isOutputShutdown()) {
socket.shutdownOutput();
}
} catch (IOException e10) {
b.Cdo.m575default("Failed to close socket on proxy side: {}. It seems client have already closed connection.", e10.getMessage());
}
try {
if (socket.isClosed()) {
return;
}
socket.close();
} catch (IOException unused2) {
}
}
public final Celse m4080do(String str) {
Celse celse;
synchronized (this.f9658do) {
celse = this.f9660for.get(str);
if (celse == null) {
celse = new Celse(str, this.f9659else);
this.f9660for.put(str, celse);
}
}
return celse;
}
public void m4081else(w2.Cif cif) {
synchronized (this.f9658do) {
Iterator<Celse> it = this.f9660for.values().iterator();
while (it.hasNext()) {
it.next().f9684for.remove(cif);
}
}
}
public String m4082for(String str) {
Objects.requireNonNull(str, "Url can't be null!");
w2.Cfor cfor = this.f9659else;
if (new File(cfor.f9691do, cfor.f9694if.mo2692new(str)).exists()) {
w2.Cfor cfor2 = this.f9659else;
File file = new File(cfor2.f9691do, cfor2.f9694if.mo2692new(str));
try {
Ctry ctry = (Ctry) this.f9659else.f9693for;
ctry.f9777do.submit(new Ctry.Cdo(file));
} catch (IOException e10) {
b.Cdo.m579switch("Error touching file " + file, e10);
}
return Uri.fromFile(file).toString();
}
if (!m4084new()) {
return str;
}
Locale locale = Locale.US;
Object[] objArr = new Object[3];
objArr[0] = "127.0.0.1";
objArr[1] = Integer.valueOf(this.f9664try);
try {
objArr[2] = URLEncoder.encode(str, "utf-8");
return String.format(locale, "http://%s:%d/%s", objArr);
} catch (UnsupportedEncodingException e11) {
throw new RuntimeException("Error encoding url", e11);
}
}
public final int m4083if() {
int i10;
synchronized (this.f9658do) {
i10 = 0;
Iterator<Celse> it = this.f9660for.values().iterator();
while (it.hasNext()) {
i10 += it.next().f9683do.get();
}
}
return i10;
}
public final boolean m4084new() {
Ccatch ccatch = this.f9661goto;
Objects.requireNonNull(ccatch);
int i10 = 70;
int i11 = 0;
while (i11 < 3) {
try {
} catch (InterruptedException e10) {
e = e10;
b.Cdo.m579switch("Error pinging server due to unexpected error", e);
} catch (ExecutionException e11) {
e = e11;
b.Cdo.m579switch("Error pinging server due to unexpected error", e);
} catch (TimeoutException unused) {
b.Cdo.m575default("HttpProxyCacheDebuger", "Error pinging server (attempt: " + i11 + ", timeout: " + i10 + "). ");
}
if (((Boolean) ccatch.f9669do.submit(new Ccatch.Cif(null)).get(i10, TimeUnit.MILLISECONDS)).booleanValue()) {
return true;
}
i11++;
i10 *= 2;
}
Locale locale = Locale.US;
Object[] objArr = new Object[3];
objArr[0] = Integer.valueOf(i11);
objArr[1] = Integer.valueOf(i10 / 2);
try {
objArr[2] = ProxySelector.getDefault().select(new URI(ccatch.m4086do()));
String format = String.format(locale, "Error pinging server (attempts: %d, max timeout: %d). If you see this message, please, report at https://github.com/danikula/AndroidVideoCache/issues/134. Default proxies are: %s", objArr);
b.Cdo.m579switch(format, new Cconst(format));
return false;
} catch (URISyntaxException e12) {
throw new IllegalStateException(e12);
}
}
public final void m4085try(Throwable th) {
String message = th.getMessage();
if (TextUtils.isEmpty(message)) {
return;
}
Log.e("HttpProxyCacheServer error", message);
}
}