龙将斩千 v5.5.5.39856版本的 MD5 值为:5c05b1d6f8d872ca3fe0343d6ff07caf

以下内容为反编译后的 k.java 源代码,内容仅作参考


package com.qiyukf.nimlib.q;

import android.os.AsyncTask;
import android.text.TextUtils;
import androidx.core.os.EnvironmentCompat;
import com.qiyukf.module.zip4j.util.InternalZipConstants;
import com.qiyukf.nimlib.sdk.ServerAddresses;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;
import org.json.JSONArray;
import org.json.JSONObject;

public final class k {
    private static AtomicBoolean a = new AtomicBoolean(false);
    private a b = null;

    static String e() {
        return g();
    }

    private k() {
    }

    public static k a() {
        return new k();
    }

    public final void b() {
        if (!l.b(com.qiyukf.nimlib.c.d())) {
            com.qiyukf.nimlib.j.b.c("NetPing", "unable to start ping, as network is unavailable");
            return;
        }
        if (a.get()) {
            com.qiyukf.nimlib.j.b.c("NetPing", "cancel start ping, as net ping is running...");
        } else {
            if (this.b != null) {
                return;
            }
            this.b = new a((byte) 0);
            this.b.execute(new Void[0]);
            a.set(true);
        }
    }

    public static void c() {
        try {
            StringBuilder sb = new StringBuilder("network info: ");
            sb.append("net_type=" + g() + ", net_available=" + l.b(com.qiyukf.nimlib.c.d()) + ", net_connected=" + l.c(com.qiyukf.nimlib.c.d()));
            com.qiyukf.nimlib.j.b.c("NetPing", sb.toString());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static class a extends AsyncTask<Void, Void, Void> {
        private a() {
        }

        a(byte b) {
            this();
        }

        @Override
        protected final Void doInBackground(Void[] voidArr) {
            return a();
        }

        @Override
        protected final void onPostExecute(Void r1) {
            super.onPostExecute(r1);
        }

        private static Void a() {
            List<String> d = k.d();
            if (d.size() == 0) {
                return null;
            }
            com.qiyukf.nimlib.j.b.c("NetPing", "***** Net ping start, host list size=" + d.size() + " *****");
            JSONObject jSONObject = new JSONObject();
            JSONArray jSONArray = new JSONArray();
            for (String str : d) {
                com.qiyukf.nimlib.j.b.c("NetPing", "ping host ".concat(String.valueOf(str)));
                JSONObject f = k.f(k.d(str));
                if (f != null) {
                    try {
                        f.put("ip", str);
                        jSONArray.put(f);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
                com.qiyukf.nimlib.j.b.c("NetPing", "ping host result=".concat(String.valueOf(f)));
            }
            try {
                jSONObject.put("net_type", k.e());
                jSONObject.put("net_available", l.b(com.qiyukf.nimlib.c.d()) ? "true" : "false");
                jSONObject.put("net_connected", l.c(com.qiyukf.nimlib.c.d()) ? "true" : "false");
                jSONObject.put("result", jSONArray);
                com.qiyukf.nimlib.j.b.c("NetPing", "***** Net ping end, total result=" + jSONObject.toString() + " ***** ");
            } catch (Exception e2) {
                e2.printStackTrace();
                com.qiyukf.nimlib.j.b.d("NetPing", "NetPing get network status error", e2);
            }
            k.a.set(false);
            return null;
        }

        @Override
        protected final void onPreExecute() {
            super.onPreExecute();
        }
    }

    private static String c(String str) {
        int lastIndexOf = str.lastIndexOf(58);
        if (lastIndexOf > 0) {
            return str.substring(0, lastIndexOf);
        }
        return str;
    }

    public static String d(String str) {
        StringBuilder sb = new StringBuilder();
        try {
            Process exec = Runtime.getRuntime().exec("ping -c 3 -w 15 ".concat(String.valueOf(str)));
            if (exec.waitFor() == 0) {
                sb.append("ping " + str + " success\n");
                BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(exec.getInputStream()));
                while (true) {
                    String readLine = bufferedReader.readLine();
                    if (readLine == null) {
                        break;
                    }
                    sb.append(readLine + "\n");
                }
            } else {
                com.qiyukf.nimlib.j.b.c("NetPing", "unable to ping host, try socket connect...");
                boolean e = e(str);
                StringBuilder sb2 = new StringBuilder("connect ");
                sb2.append(e ? "success" : "failed");
                sb2.append("\n");
                sb.append(sb2.toString());
            }
        } catch (IOException e2) {
            e2.printStackTrace();
        } catch (InterruptedException e3) {
            e3.printStackTrace();
        }
        return sb.toString();
    }

    private static boolean e(String str) {
        boolean z;
        Socket socket = new Socket();
        try {
            try {
                socket.connect(new InetSocketAddress(str, 80), 15000);
                z = socket.isConnected();
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            } catch (IOException e2) {
                e2.printStackTrace();
                try {
                    socket.close();
                } catch (IOException e3) {
                    e3.printStackTrace();
                }
                z = false;
            }
            StringBuilder sb = new StringBuilder("socket connect ");
            sb.append(str);
            sb.append(z ? " success" : " failed!!!");
            com.qiyukf.nimlib.j.b.c("NetPing", sb.toString());
            return z;
        } catch (Throwable th) {
            try {
                socket.close();
            } catch (IOException e4) {
                e4.printStackTrace();
            }
            throw th;
        }
    }

    public static JSONObject f(String str) {
        int indexOf;
        int indexOf2;
        JSONObject jSONObject = new JSONObject();
        try {
            if (str.contains("0% packet loss")) {
                int indexOf3 = str.indexOf("/mdev = ");
                if (indexOf3 == -1 || (indexOf2 = str.indexOf(" ms\n", indexOf3)) == -1) {
                    return null;
                }
                String[] split = str.substring(indexOf3 + 8, indexOf2).split(InternalZipConstants.ZIP_FILE_SEPARATOR);
                if (split.length != 4) {
                    return null;
                }
                jSONObject.put("min", Double.valueOf(split[0]));
                jSONObject.put("avg", Double.valueOf(split[1]));
                jSONObject.put("max", Double.valueOf(split[2]));
                jSONObject.put("mdev", Double.valueOf(split[3]));
                jSONObject.put("loss", 0);
            } else if (str.contains("100% packet loss")) {
                jSONObject.put("loss", 100);
            } else {
                if (str.contains("% packet loss")) {
                    int indexOf4 = str.indexOf("/mdev = ");
                    if (indexOf4 == -1 || (indexOf = str.indexOf(" ms\n", indexOf4)) == -1) {
                        return null;
                    }
                    String substring = str.substring(indexOf4 + 8, indexOf);
                    String[] split2 = substring.split(InternalZipConstants.ZIP_FILE_SEPARATOR);
                    if (split2.length != 4) {
                        return null;
                    }
                    int indexOf5 = substring.indexOf("% packet loss");
                    int indexOf6 = substring.indexOf("received");
                    if (indexOf5 != -1 && indexOf6 != -1) {
                        String trim = substring.substring(indexOf6 + 10, indexOf5).trim();
                        jSONObject.put("min", Double.valueOf(split2[0]));
                        jSONObject.put("avg", Double.valueOf(split2[1]));
                        jSONObject.put("max", Double.valueOf(split2[2]));
                        jSONObject.put("mdev", Double.valueOf(split2[3]));
                        jSONObject.put("loss", Integer.valueOf(trim));
                    }
                    return null;
                }
                if (str.contains("connect") && str.contains("success")) {
                    jSONObject.put("result", "connect success");
                } else if (str.contains("failed")) {
                    jSONObject.put("result", "failed");
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
            com.qiyukf.nimlib.j.b.d("NetPing", "getPingStatus error", e);
        }
        return jSONObject;
    }

    private static String g() {
        int j = l.j(com.qiyukf.nimlib.c.d());
        if (j == 1) {
            return "2g";
        }
        if (j == 2) {
            return "3g";
        }
        if (j == 3) {
            return "4g";
        }
        if (j == 10) {
            return "wifi";
        }
        return EnvironmentCompat.MEDIA_UNKNOWN;
    }

    static List d() {
        ArrayList arrayList = new ArrayList();
        com.qiyukf.nimlib.net.a.b.a.a.a();
        for (String str : com.qiyukf.nimlib.net.a.b.a.a.b()) {
            String c = c(str);
            if (!arrayList.contains(c)) {
                arrayList.add(c);
            }
        }
        ServerAddresses i = com.qiyukf.nimlib.c.i();
        if (i == null) {
            arrayList.add(c(com.qiyukf.nimlib.e.g.f()));
            arrayList.add(c(com.qiyukf.nimlib.e.g.h()));
            arrayList.add(c("www.163.com"));
        } else {
            if (!TextUtils.isEmpty(i.nosUpload)) {
                arrayList.add(c(i.nosUpload));
            }
            if (!TextUtils.isEmpty(i.nosDownload)) {
                arrayList.add(c(i.nosDownload));
            }
        }
        return arrayList;
    }
}