package com.google.firebase.messaging;

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

/* JADX INFO: loaded from: classes.dex */
public final class z implements Runnable {

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

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

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

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public final ThreadPoolExecutor f5957n = new ThreadPoolExecutor(0, 1, 30, TimeUnit.SECONDS, new LinkedBlockingQueue(), new ThreadFactoryC1100a("firebase-iid-executor"));

    public z(FirebaseMessaging firebaseMessaging, long j5) {
        this.f5956m = firebaseMessaging;
        this.f5954k = j5;
        PowerManager.WakeLock wakeLockNewWakeLock = ((PowerManager) firebaseMessaging.f5849b.getSystemService("power")).newWakeLock(1, "fiid-sync");
        this.f5955l = wakeLockNewWakeLock;
        wakeLockNewWakeLock.setReferenceCounted(false);
    }

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

    public final boolean b() throws IOException {
        try {
            if (this.f5956m.a() == null) {
                Log.e("FirebaseMessaging", "Token retrieval failed: null");
                return false;
            }
            if (!Log.isLoggable("FirebaseMessaging", 3)) {
                return true;
            }
            Log.d("FirebaseMessaging", "Token successfully retrieved");
            return true;
        } catch (IOException e2) {
            String message = e2.getMessage();
            if (!"SERVICE_NOT_AVAILABLE".equals(message) && !"INTERNAL_SERVER_ERROR".equals(message) && !"InternalServerError".equals(message)) {
                if (e2.getMessage() != null) {
                    throw e2;
                }
                Log.w("FirebaseMessaging", "Token retrieval failed without exception message. Will retry token retrieval");
                return false;
            }
            Log.w("FirebaseMessaging", "Token retrieval failed: " + e2.getMessage() + ". Will retry token retrieval");
            return false;
        } catch (SecurityException unused) {
            Log.w("FirebaseMessaging", "Token retrieval failed with SecurityException. Will retry token retrieval");
            return false;
        }
    }

    @Override // java.lang.Runnable
    public final void run() {
        w wVarV = w.v();
        FirebaseMessaging firebaseMessaging = this.f5956m;
        boolean zY = wVarV.y(firebaseMessaging.f5849b);
        PowerManager.WakeLock wakeLock = this.f5955l;
        if (zY) {
            wakeLock.acquire();
        }
        try {
            try {
                synchronized (firebaseMessaging) {
                    firebaseMessaging.f5856j = true;
                }
                if (!firebaseMessaging.i.d()) {
                    synchronized (firebaseMessaging) {
                        firebaseMessaging.f5856j = false;
                    }
                    if (w.v().y(firebaseMessaging.f5849b)) {
                        wakeLock.release();
                        return;
                    }
                    return;
                }
                if (w.v().x(firebaseMessaging.f5849b) && !a()) {
                    y yVar = new y();
                    yVar.f5953c = this;
                    yVar.a();
                    if (w.v().y(firebaseMessaging.f5849b)) {
                        wakeLock.release();
                        return;
                    }
                    return;
                }
                if (b()) {
                    synchronized (firebaseMessaging) {
                        firebaseMessaging.f5856j = false;
                    }
                } else {
                    firebaseMessaging.l(this.f5954k);
                }
                if (w.v().y(firebaseMessaging.f5849b)) {
                    wakeLock.release();
                }
            } catch (IOException e2) {
                Log.e("FirebaseMessaging", "Topic sync or token retrieval failed on hard failure exceptions: " + e2.getMessage() + ". Won't retry the operation.");
                synchronized (firebaseMessaging) {
                    firebaseMessaging.f5856j = false;
                    if (w.v().y(firebaseMessaging.f5849b)) {
                        wakeLock.release();
                    }
                }
            }
        } catch (Throwable th) {
            if (w.v().y(firebaseMessaging.f5849b)) {
                wakeLock.release();
            }
            throw th;
        }
    }
}