package com.google.firebase.messaging;

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.util.Log;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes.dex */
public final class E extends BroadcastReceiver {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public F f5836a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ F f5837b;

    public E(F f6, F f7) {
        this.f5837b = f6;
        this.f5836a = f7;
    }

    public final void a() {
        if (Log.isLoggable("FirebaseMessaging", 3)) {
            Log.d("FirebaseMessaging", "Connectivity change received registered");
        }
        F f6 = this.f5837b;
        f6.f5839k.registerReceiver(this, new IntentFilter("android.net.conn.CONNECTIVITY_CHANGE"));
    }

    @Override // android.content.BroadcastReceiver
    public final synchronized void onReceive(Context context, Intent intent) {
        try {
            F f6 = this.f5836a;
            if (f6 == null) {
                return;
            }
            if (f6.d()) {
                if (Log.isLoggable("FirebaseMessaging", 3)) {
                    Log.d("FirebaseMessaging", "Connectivity changed. Starting background sync.");
                }
                F f7 = this.f5836a;
                f7.f5842n.f5833f.schedule(f7, 0L, TimeUnit.SECONDS);
                context.unregisterReceiver(this);
                this.f5836a = null;
            }
        } catch (Throwable th) {
            throw th;
        }
    }
}