Cantique de Louanges v12 - k0.java 源代码

package com.adcolony.sdk;

import android.util.Log;
import com.applovin.sdk.AppLovinEventTypes;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.HashMap;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.TimeUnit;

class k0 {

    static boolean f9397f = false;

    static int f9398g = 3;

    static int f9399h = 1;

    private h0 f9400a = x.q();

    private f0 f9401b = null;

    private ExecutorService f9402c = null;

    private final Queue f9403d = new ConcurrentLinkedQueue();

    q1 f9404e;

    class a implements r0 {
        a() {
        }

        @Override
        public void a(m0 m0Var) {
            k0.this.m(x.A(m0Var.a(), "module"), 0, x.E(m0Var.a(), "message"), true);
        }
    }

    class b implements Runnable {

        final int f9406a;

        final String f9407b;

        final int f9408c;

        final boolean f9409d;

        b(int i5, String str, int i6, boolean z4) {
            this.f9406a = i5;
            this.f9407b = str;
            this.f9408c = i6;
            this.f9409d = z4;
        }

        @Override
        public void run() {
            k0.this.e(this.f9406a, this.f9407b, this.f9408c);
            int i5 = 0;
            while (i5 <= this.f9407b.length() / 4000) {
                int i6 = i5 * 4000;
                i5++;
                int min = Math.min(i5 * 4000, this.f9407b.length());
                if (this.f9408c == 3) {
                    k0 k0Var = k0.this;
                    if (k0Var.j(x.C(k0Var.f9400a, Integer.toString(this.f9406a)), 3, this.f9409d)) {
                        Log.d("AdColony [TRACE]", this.f9407b.substring(i6, min));
                    }
                }
                if (this.f9408c == 2) {
                    k0 k0Var2 = k0.this;
                    if (k0Var2.j(x.C(k0Var2.f9400a, Integer.toString(this.f9406a)), 2, this.f9409d)) {
                        Log.i("AdColony [INFO]", this.f9407b.substring(i6, min));
                    }
                }
                if (this.f9408c == 1) {
                    k0 k0Var3 = k0.this;
                    if (k0Var3.j(x.C(k0Var3.f9400a, Integer.toString(this.f9406a)), 1, this.f9409d)) {
                        Log.w("AdColony [WARNING]", this.f9407b.substring(i6, min));
                    }
                }
                if (this.f9408c == 0) {
                    k0 k0Var4 = k0.this;
                    if (k0Var4.j(x.C(k0Var4.f9400a, Integer.toString(this.f9406a)), 0, this.f9409d)) {
                        Log.e("AdColony [ERROR]", this.f9407b.substring(i6, min));
                    }
                }
                if (this.f9408c == -1 && k0.f9398g >= -1) {
                    Log.e("AdColony [FATAL]", this.f9407b.substring(i6, min));
                }
            }
        }
    }

    class c implements r0 {
        c(k0 k0Var) {
        }

        @Override
        public void a(m0 m0Var) {
            k0.f9398g = x.A(m0Var.a(), AppLovinEventTypes.USER_COMPLETED_LEVEL);
        }
    }

    class d implements r0 {
        d() {
        }

        @Override
        public void a(m0 m0Var) {
            k0.this.m(x.A(m0Var.a(), "module"), 3, x.E(m0Var.a(), "message"), false);
        }
    }

    class e implements r0 {
        e() {
        }

        @Override
        public void a(m0 m0Var) {
            k0.this.m(x.A(m0Var.a(), "module"), 3, x.E(m0Var.a(), "message"), true);
        }
    }

    class f implements r0 {
        f() {
        }

        @Override
        public void a(m0 m0Var) {
            k0.this.m(x.A(m0Var.a(), "module"), 2, x.E(m0Var.a(), "message"), false);
        }
    }

    class g implements r0 {
        g() {
        }

        @Override
        public void a(m0 m0Var) {
            k0.this.m(x.A(m0Var.a(), "module"), 2, x.E(m0Var.a(), "message"), true);
        }
    }

    class h implements r0 {
        h() {
        }

        @Override
        public void a(m0 m0Var) {
            k0.this.m(x.A(m0Var.a(), "module"), 1, x.E(m0Var.a(), "message"), false);
        }
    }

    class i implements r0 {
        i() {
        }

        @Override
        public void a(m0 m0Var) {
            k0.this.m(x.A(m0Var.a(), "module"), 1, x.E(m0Var.a(), "message"), true);
        }
    }

    class j implements r0 {
        j() {
        }

        @Override
        public void a(m0 m0Var) {
            k0.this.m(x.A(m0Var.a(), "module"), 0, x.E(m0Var.a(), "message"), false);
        }
    }

    k0() {
    }

    private Runnable d(int i5, int i6, String str, boolean z4) {
        return new b(i5, str, i6, z4);
    }

    public void e(int i5, String str, int i6) {
        if (this.f9404e == null) {
            return;
        }
        if (i6 == 3 && i(x.C(this.f9400a, Integer.toString(i5)), 3)) {
            this.f9404e.e(str);
            return;
        }
        if (i6 == 2 && i(x.C(this.f9400a, Integer.toString(i5)), 2)) {
            this.f9404e.i(str);
            return;
        }
        if (i6 == 1 && i(x.C(this.f9400a, Integer.toString(i5)), 1)) {
            this.f9404e.j(str);
        } else if (i6 == 0 && i(x.C(this.f9400a, Integer.toString(i5)), 0)) {
            this.f9404e.h(str);
        }
    }

    private boolean k(Runnable runnable) {
        try {
            ExecutorService executorService = this.f9402c;
            if (executorService == null || executorService.isShutdown() || this.f9402c.isTerminated()) {
                return false;
            }
            this.f9402c.submit(runnable);
            return true;
        } catch (RejectedExecutionException unused) {
            Log.e("ADCLogError", "Internal error when submitting log to executor service.");
            return false;
        }
    }

    h0 a(f0 f0Var) {
        h0 q4 = x.q();
        for (int i5 = 0; i5 < f0Var.e(); i5++) {
            h0 f5 = x.f(f0Var, i5);
            x.m(q4, Integer.toString(x.A(f5, "id")), f5);
        }
        return q4;
    }

    q1 c() {
        return this.f9404e;
    }

    void f(int i5, String str, boolean z4) {
        m(0, i5, str, z4);
    }

    void h(HashMap hashMap) {
        try {
            q1 q1Var = new q1(new b0(new URL("https://wd.adcolony.com/logs")), Executors.newSingleThreadScheduledExecutor(), hashMap);
            this.f9404e = q1Var;
            q1Var.d(5L, TimeUnit.SECONDS);
        } catch (MalformedURLException e5) {
            e5.printStackTrace();
        }
    }

    boolean i(h0 h0Var, int i5) {
        int A = x.A(h0Var, "send_level");
        if (h0Var.r()) {
            A = f9399h;
        }
        return A >= i5 && A != 4;
    }

    boolean j(h0 h0Var, int i5, boolean z4) {
        int A = x.A(h0Var, "print_level");
        boolean t4 = x.t(h0Var, "log_private");
        if (h0Var.r()) {
            A = f9398g;
            t4 = f9397f;
        }
        return (!z4 || t4) && A != 4 && A >= i5;
    }

    f0 l() {
        return this.f9401b;
    }

    void m(int i5, int i6, String str, boolean z4) {
        if (k(d(i5, i6, str, z4))) {
            return;
        }
        synchronized (this.f9403d) {
            this.f9403d.add(d(i5, i6, str, z4));
        }
    }

    void n(f0 f0Var) {
        this.f9400a = a(f0Var);
    }

    void o() {
        r.g("Log.set_log_level", new c(this));
        r.g("Log.public.trace", new d());
        r.g("Log.private.trace", new e());
        r.g("Log.public.info", new f());
        r.g("Log.private.info", new g());
        r.g("Log.public.warning", new h());
        r.g("Log.private.warning", new i());
        r.g("Log.public.error", new j());
        r.g("Log.private.error", new a());
    }

    void p(f0 f0Var) {
        if (f0Var != null) {
            f0Var.g(AppLovinEventTypes.USER_COMPLETED_LEVEL);
            f0Var.g("message");
        }
        this.f9401b = f0Var;
    }

    void q() {
        ExecutorService executorService = this.f9402c;
        if (executorService == null || executorService.isShutdown() || this.f9402c.isTerminated()) {
            this.f9402c = Executors.newSingleThreadExecutor();
        }
        synchronized (this.f9403d) {
            while (!this.f9403d.isEmpty()) {
                k((Runnable) this.f9403d.poll());
            }
        }
    }
}