package l4;

import android.content.Context;
import android.content.IntentFilter;
import android.net.ConnectivityManager;
import android.util.Log;
import com.google.firebase.firestore.remote.g;
import java.util.concurrent.TimeUnit;
import k4.AbstractC2397j;
import k4.C2394g;
import k4.EnumC2404q;
import k4.W;
import k4.i0;

/* JADX INFO: loaded from: classes3.dex */
public final class c extends W {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final W f20318a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final Context f20319b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final ConnectivityManager f20320c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final Object f20321d = new Object();

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public Runnable f20322e;

    public c(W w6, Context context) {
        this.f20318a = w6;
        this.f20319b = context;
        if (context == null) {
            this.f20320c = null;
            return;
        }
        this.f20320c = (ConnectivityManager) context.getSystemService("connectivity");
        try {
            y();
        } catch (SecurityException e6) {
            Log.w("AndroidChannelBuilder", "Failed to configure network monitoring. Does app have ACCESS_NETWORK_STATE permission?", e6);
        }
    }

    @Override // k4.AbstractC2384C
    public final AbstractC2397j l(i0 i0Var, C2394g c2394g) {
        return this.f20318a.l(i0Var, c2394g);
    }

    @Override // k4.W
    public final boolean s(long j4) {
        TimeUnit timeUnit = TimeUnit.SECONDS;
        return this.f20318a.s(j4);
    }

    @Override // k4.W
    public final void t() {
        this.f20318a.t();
    }

    @Override // k4.W
    public final EnumC2404q u() {
        return this.f20318a.u();
    }

    @Override // k4.W
    public final void v(EnumC2404q enumC2404q, g gVar) {
        this.f20318a.v(enumC2404q, gVar);
    }

    @Override // k4.W
    public final W w() {
        synchronized (this.f20321d) {
            try {
                Runnable runnable = this.f20322e;
                if (runnable != null) {
                    runnable.run();
                    this.f20322e = null;
                }
            } catch (Throwable th) {
                throw th;
            }
        }
        return this.f20318a.w();
    }

    @Override // k4.W
    public final W x() {
        synchronized (this.f20321d) {
            try {
                Runnable runnable = this.f20322e;
                if (runnable != null) {
                    runnable.run();
                    this.f20322e = null;
                }
            } catch (Throwable th) {
                throw th;
            }
        }
        return this.f20318a.x();
    }

    public final void y() {
        ConnectivityManager connectivityManager = this.f20320c;
        if (connectivityManager != null) {
            C2455a c2455a = new C2455a(this);
            connectivityManager.registerDefaultNetworkCallback(c2455a);
            this.f20322e = new C1.a(13, this, false, c2455a);
        } else {
            b bVar = new b(this);
            this.f20319b.registerReceiver(bVar, new IntentFilter("android.net.conn.CONNECTIVITY_CHANGE"));
            this.f20322e = new C1.a(14, this, false, bVar);
        }
    }
}