package com.google.firebase.messaging;

import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.os.PowerManager;
import java.io.IOException;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes2.dex */
public final class f0 implements Runnable {

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final PowerManager.WakeLock f24170b;

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

    public f0(FirebaseMessaging firebaseMessaging, long j10) {
        new ThreadPoolExecutor(0, 1, 30L, TimeUnit.SECONDS, new LinkedBlockingQueue(), new m.c("firebase-iid-executor", 2));
        this.f24171c = firebaseMessaging;
        this.f24169a = j10;
        PowerManager.WakeLock wakeLockNewWakeLock = ((PowerManager) firebaseMessaging.f24122b.getSystemService("power")).newWakeLock(1, "fiid-sync");
        this.f24170b = wakeLockNewWakeLock;
        wakeLockNewWakeLock.setReferenceCounted(false);
    }

    public final boolean a() {
        ConnectivityManager connectivityManager = (ConnectivityManager) this.f24171c.f24122b.getSystemService("connectivity");
        NetworkInfo activeNetworkInfo = connectivityManager != null ? connectivityManager.getActiveNetworkInfo() : null;
        return activeNetworkInfo != null && activeNetworkInfo.isConnected();
    }

    public final boolean b() throws IOException {
        try {
            return this.f24171c.a() != null;
        } catch (IOException e10) {
            String message = e10.getMessage();
            if ("SERVICE_NOT_AVAILABLE".equals(message) || "INTERNAL_SERVER_ERROR".equals(message) || "InternalServerError".equals(message)) {
                e10.getMessage();
                return false;
            }
            if (e10.getMessage() == null) {
                return false;
            }
            throw e10;
        } catch (SecurityException unused) {
            return false;
        }
    }

    @Override // java.lang.Runnable
    public final void run() {
        a0 a0VarA = a0.a();
        FirebaseMessaging firebaseMessaging = this.f24171c;
        boolean zC = a0VarA.c(firebaseMessaging.f24122b);
        PowerManager.WakeLock wakeLock = this.f24170b;
        if (zC) {
            wakeLock.acquire();
        }
        try {
            try {
                synchronized (firebaseMessaging) {
                    firebaseMessaging.f24130j = true;
                }
            } catch (IOException e10) {
                e10.getMessage();
                synchronized (firebaseMessaging) {
                    firebaseMessaging.f24130j = false;
                    if (!a0.a().c(firebaseMessaging.f24122b)) {
                        return;
                    }
                }
            }
            if (!firebaseMessaging.f24129i.c()) {
                synchronized (firebaseMessaging) {
                    firebaseMessaging.f24130j = false;
                }
                if (a0.a().c(firebaseMessaging.f24122b)) {
                    wakeLock.release();
                    return;
                }
                return;
            }
            if (a0.a().b(firebaseMessaging.f24122b) && !a()) {
                new e0(this).a();
                if (a0.a().c(firebaseMessaging.f24122b)) {
                    wakeLock.release();
                    return;
                }
                return;
            }
            if (b()) {
                synchronized (firebaseMessaging) {
                    firebaseMessaging.f24130j = false;
                }
            } else {
                firebaseMessaging.g(this.f24169a);
            }
            if (!a0.a().c(firebaseMessaging.f24122b)) {
                return;
            }
            wakeLock.release();
        } catch (Throwable th) {
            if (a0.a().c(firebaseMessaging.f24122b)) {
                wakeLock.release();
            }
            throw th;
        }
    }
}