package com.vungle.warren.utility;

import android.content.Context;
import android.net.ConnectivityManager;
import android.net.Network;
import android.net.NetworkInfo;
import android.net.NetworkRequest;
import android.os.Handler;
import android.os.Looper;
import android.util.Log;
import java.util.Iterator;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.concurrent.atomic.AtomicInteger;

/* loaded from: classes2.dex */
public class o {

    /* renamed from: i, reason: collision with root package name */
    private static final String f8605i = "o";

    /* renamed from: j, reason: collision with root package name */
    private static o f8606j;

    /* renamed from: a, reason: collision with root package name */
    private final Context f8607a;

    /* renamed from: b, reason: collision with root package name */
    private final ConnectivityManager f8608b;

    /* renamed from: c, reason: collision with root package name */
    private final AtomicInteger f8609c;

    /* renamed from: d, reason: collision with root package name */
    private ConnectivityManager.NetworkCallback f8610d;

    /* renamed from: e, reason: collision with root package name */
    private final Set f8611e;

    /* renamed from: f, reason: collision with root package name */
    private boolean f8612f;

    /* renamed from: g, reason: collision with root package name */
    private final Handler f8613g;

    /* renamed from: h, reason: collision with root package name */
    private Runnable f8614h;

    class a extends ConnectivityManager.NetworkCallback {
        a() {
        }

        @Override // android.net.ConnectivityManager.NetworkCallback
        public void onAvailable(Network network) {
            super.onAvailable(network);
            o.this.h();
        }

        @Override // android.net.ConnectivityManager.NetworkCallback
        public void onLost(Network network) {
            super.onLost(network);
            o.this.h();
        }
    }

    class b implements Runnable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ int f8616a;

        b(int i10) {
            this.f8616a = i10;
        }

        @Override // java.lang.Runnable
        public void run() {
            Iterator it = o.this.f8611e.iterator();
            while (it.hasNext()) {
                ((d) it.next()).a(this.f8616a);
            }
        }
    }

    class c implements Runnable {
        c() {
        }

        @Override // java.lang.Runnable
        public void run() {
            if (o.this.f8611e.isEmpty()) {
                return;
            }
            o.this.h();
            o.this.f8613g.postDelayed(o.this.f8614h, 30000L);
        }
    }

    public interface d {
        void a(int i10);
    }

    private o(Context context) {
        AtomicInteger atomicInteger = new AtomicInteger();
        this.f8609c = atomicInteger;
        this.f8611e = new CopyOnWriteArraySet();
        this.f8613g = new Handler(Looper.getMainLooper());
        this.f8614h = new c();
        Context applicationContext = context.getApplicationContext();
        this.f8607a = applicationContext;
        this.f8608b = (ConnectivityManager) applicationContext.getSystemService("connectivity");
        atomicInteger.set(e());
    }

    public static synchronized o f(Context context) {
        o oVar;
        synchronized (o.class) {
            if (f8606j == null) {
                f8606j = new o(context);
            }
            oVar = f8606j;
        }
        return oVar;
    }

    private ConnectivityManager.NetworkCallback g() {
        ConnectivityManager.NetworkCallback networkCallback = this.f8610d;
        if (networkCallback != null) {
            return networkCallback;
        }
        a aVar = new a();
        this.f8610d = aVar;
        return aVar;
    }

    private void i(int i10) {
        this.f8613g.post(new b(i10));
    }

    private synchronized void k(boolean z10) {
        if (this.f8612f == z10) {
            return;
        }
        this.f8612f = z10;
        ConnectivityManager connectivityManager = this.f8608b;
        if (connectivityManager != null) {
            try {
                if (z10) {
                    NetworkRequest.Builder builder = new NetworkRequest.Builder();
                    builder.addCapability(12);
                    this.f8608b.registerNetworkCallback(builder.build(), g());
                } else {
                    connectivityManager.unregisterNetworkCallback(g());
                }
            } catch (Exception e10) {
                Log.e(f8605i, e10.getMessage());
            }
        }
    }

    public void d(d dVar) {
        this.f8611e.add(dVar);
        k(true);
    }

    public int e() {
        int i10 = -1;
        if (this.f8608b == null || androidx.core.content.c.a(this.f8607a, "android.permission.ACCESS_NETWORK_STATE") != 0) {
            this.f8609c.set(-1);
            return -1;
        }
        NetworkInfo activeNetworkInfo = this.f8608b.getActiveNetworkInfo();
        if (activeNetworkInfo != null && activeNetworkInfo.isConnectedOrConnecting()) {
            i10 = activeNetworkInfo.getType();
        }
        int andSet = this.f8609c.getAndSet(i10);
        if (i10 != andSet) {
            Log.d(f8605i, "on network changed: " + andSet + "->" + i10);
            i(i10);
        }
        k(!this.f8611e.isEmpty());
        return i10;
    }

    public void h() {
        e();
    }

    public void j(d dVar) {
        this.f8611e.remove(dVar);
        k(!this.f8611e.isEmpty());
    }
}