导航菜单
登录 注册

页面标题

页面副标题

Fancy Optimizer v4.6.3 - b.java 源代码

正在查看： Fancy Optimizer v4.6.3 应用的 b.java JAVA 源代码文件

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


package q9;

import android.annotation.SuppressLint;
import android.os.Handler;
import android.os.Looper;
import android.os.SystemClock;
import androidx.annotation.NonNull;
import com.applovin.exoplayer2.ui.n;
import com.facebook.internal.p;
import com.facebook.stetho.server.http.HttpHeaders;
import com.fancyclean.boost.networkspeed.ui.presenter.NetworkSpeedTestPresenter;
import com.google.firebase.perf.network.FirebasePerfOkHttpClient;
import com.mbridge.msdk.playercommon.exoplayer2.DefaultLoadControl;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.Locale;
import java.util.Objects;
import no.e;
import no.f;
import no.u;
import no.w;
import no.x;
import no.y;
import no.z;
import vj.h;

public final class b {
    public static final h s = h.f(b.class);

    @SuppressLint({"StaticFieldLeak"})
    public static volatile b t;
    public q9.a b;
    public w c;
    public w d;
    public w e;
    public d q;
    public q9.c r;
    public final Handler a = new Handler(Looper.getMainLooper());
    public long f = 0;
    public int g = 0;
    public int h = 0;
    public int i = 0;
    public long j = 0;
    public long k = 0;
    public long l = 0;
    public long m = 0;
    public long n = 0;
    public int o = DefaultLoadControl.DEFAULT_MIN_BUFFER_MS;
    public boolean p = false;

    public class a implements f {
        public final u a;
        public final x b;

        public a(u uVar, x xVar) {
            this.a = uVar;
            this.b = xVar;
        }

        public final void onFailure(@NonNull e eVar, @NonNull IOException iOException) {
            b bVar = b.this;
            int i = bVar.i;
            if (i < 4) {
                bVar.i = i + 1;
                bVar.c(this.a, this.b);
                return;
            }
            if (bVar.q != null) {
                bVar.a.post(new androidx.core.widget.a(this, 21));
            }
            b.s.d("trace==>onFailure " + iOException, (Throwable) null);
        }

        public final void onResponse(@NonNull e eVar, @NonNull y yVar) {
            Exception e;
            String str;
            String str2;
            z zVar;
            x xVar = this.b;
            u uVar = this.a;
            b bVar = b.this;
            int i = 2;
            try {
                h hVar = b.s;
                Boolean valueOf = Boolean.valueOf(yVar.w());
                hVar.getClass();
                h.b(valueOf);
                zVar = yVar.i;
            } catch (Exception e10) {
                e = e10;
                str = null;
                str2 = null;
            }
            if (zVar == null) {
                int i10 = bVar.i;
                if (i10 >= 4) {
                    bVar.a.post(new androidx.activity.d(this, 15));
                    return;
                } else {
                    bVar.i = i10 + 1;
                    bVar.c(uVar, xVar);
                    return;
                }
            }
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(zVar.byteStream()));
            str = null;
            str2 = null;
            while (true) {
                try {
                    String readLine = bufferedReader.readLine();
                    if (readLine == null) {
                        break;
                    }
                    String[] split = readLine.split("=");
                    if (split.length == 2) {
                        if (Objects.equals(split[0], "ip")) {
                            str2 = split[1];
                        }
                        if (Objects.equals(split[0], "loc")) {
                            str = split[1];
                        }
                    }
                } catch (Exception e11) {
                    e = e11;
                    int i11 = bVar.i;
                    if (i11 < 4) {
                        bVar.i = i11 + 1;
                        bVar.c(uVar, xVar);
                        return;
                    }
                    if (bVar.q != null) {
                        bVar.a.post(new n(this, 12));
                    }
                    b.s.d("trace==>onResponse " + e, (Throwable) null);
                    bVar.a.post(new p(this, str2, str, i));
                }
            }
            bufferedReader.close();
            bVar.a.post(new p(this, str2, str, i));
        }
    }

    public class C0248b implements f {
        public final u a;
        public final long b;

        public C0248b(u uVar, long j) {
            this.a = uVar;
            this.b = j;
        }

        public final void onFailure(@NonNull e eVar, @NonNull IOException iOException) {
            h hVar = b.s;
            hVar.d("downloadTest==>onFailure " + iOException, (Throwable) null);
            b bVar = b.this;
            if (bVar.g < 4) {
                hVar.c("uploadTest==>DownloadTestRetryCount == " + bVar.g);
                bVar.g = bVar.g + 1;
                b.b(bVar, this.a);
                return;
            }
            bVar.p = false;
            q9.c cVar = bVar.r;
            if (cVar != null) {
                NetworkSpeedTestPresenter.a aVar = (NetworkSpeedTestPresenter.a) cVar;
                NetworkSpeedTestPresenter.this.d.post(new androidx.activity.a(aVar, 15));
            }
        }

        public final void onResponse(@NonNull e eVar, @NonNull y yVar) {
            u uVar = this.a;
            b bVar = b.this;
            z zVar = yVar.i;
            if (zVar == null) {
                return;
            }
            b.s.c("downloadTest==>onResponse " + yVar.w());
            Objects.requireNonNull(zVar);
            InputStream byteStream = zVar.byteStream();
            try {
                byte[] bArr = new byte[8192];
                while (true) {
                    int read = byteStream.read(bArr);
                    if (read == -1) {
                        bVar.p = false;
                        b.b(bVar, uVar);
                        return;
                    }
                    bVar.n += read;
                    long elapsedRealtime = SystemClock.elapsedRealtime() - bVar.f;
                    if (elapsedRealtime > 0) {
                        bVar.l = ((bVar.n * 1000) * 8) / elapsedRealtime;
                        if (elapsedRealtime >= this.b) {
                            bVar.p = false;
                            return;
                        }
                    }
                }
            } catch (Exception e) {
                b.s.d("downloadTest==>onResponse " + e, (Throwable) null);
                int i = bVar.g;
                if (i < 4) {
                    bVar.g = i + 1;
                    b.b(bVar, uVar);
                    return;
                }
                bVar.p = false;
                q9.c cVar = bVar.r;
                if (cVar != null) {
                    NetworkSpeedTestPresenter.a aVar = (NetworkSpeedTestPresenter.a) cVar;
                    NetworkSpeedTestPresenter.this.d.post(new androidx.activity.a(aVar, 15));
                }
            }
        }
    }

    public class c implements f {
        public final u a;
        public final long b;

        public c(u uVar, long j) {
            this.a = uVar;
            this.b = j;
        }

        public final void onFailure(@NonNull e eVar, @NonNull IOException iOException) {
            h hVar = b.s;
            hVar.d("uploadTest==>onFailure " + iOException, (Throwable) null);
            b bVar = b.this;
            if (bVar.h < 4) {
                hVar.c("uploadTest==>UploadTestRetryCount == " + bVar.h);
                bVar.h = bVar.h + 1;
                b.a(bVar, this.a);
                return;
            }
            bVar.p = false;
            q9.c cVar = bVar.r;
            if (cVar != null) {
                NetworkSpeedTestPresenter.a aVar = (NetworkSpeedTestPresenter.a) cVar;
                NetworkSpeedTestPresenter.this.d.post(new androidx.appcompat.widget.b(aVar, 15));
            }
        }

        public final void onResponse(@NonNull e eVar, @NonNull y yVar) {
            b bVar = b.this;
            bVar.k += 1048576;
            b.s.c("uploadTest==>onResponse " + yVar.w());
            if (SystemClock.elapsedRealtime() - bVar.j >= 0) {
                bVar.m = ((bVar.k * 1000) * 8) / (SystemClock.elapsedRealtime() - bVar.j);
                if (SystemClock.elapsedRealtime() - bVar.j > this.b) {
                    bVar.p = false;
                    bVar.c.cancel();
                }
            }
            b.a(bVar, this.a);
        }
    }

    public static void a(b bVar, u uVar) {
        bVar.getClass();
        if (SystemClock.elapsedRealtime() - bVar.j <= bVar.o) {
            bVar.d(uVar);
        } else {
            bVar.p = false;
            bVar.c.cancel();
        }
    }

    public static void b(b bVar, u uVar) {
        bVar.getClass();
        if (SystemClock.elapsedRealtime() - bVar.f >= bVar.o) {
            return;
        }
        bVar.d.cancel();
        bVar.e(uVar);
    }

    public final void c(u uVar, x xVar) {
        uVar.getClass();
        w c10 = w.c(uVar, xVar, false);
        this.e = c10;
        FirebasePerfOkHttpClient.enqueue(c10, new a(uVar, xVar));
    }

    public final void d(u uVar) {
        this.p = true;
        long j = this.o;
        x.a aVar = new x.a();
        aVar.d("https://speed.cloudflare.com/__up?measId=0");
        aVar.b("POST", this.b);
        x a10 = aVar.a();
        uVar.getClass();
        w c10 = w.c(uVar, a10, false);
        this.c = c10;
        FirebasePerfOkHttpClient.enqueue(c10, new c(uVar, j));
    }

    public final void e(u uVar) {
        this.p = true;
        long j = this.o;
        x.a aVar = new x.a();
        aVar.d(String.format(Locale.US, "https://speed.cloudflare.com/__down?measId=0&bytes=%d", 209715200));
        x a10 = aVar.a();
        uVar.getClass();
        w c10 = w.c(uVar, a10, false);
        this.d = c10;
        FirebasePerfOkHttpClient.enqueue(c10, new C0248b(uVar, j));
    }

    public final void f() {
        this.i = 0;
        u a10 = x9.a.a();
        x.a aVar = new x.a();
        aVar.d("https://cloudflare.com/cdn-cgi/trace");
        aVar.c.a("accept", "*/*");
        aVar.c.a(HttpHeaders.CONTENT_TYPE, "application/json");
        c(a10, aVar.a());
    }
}