package p037.p123.p124;

import android.content.Context;
import android.os.PowerManager;
import androidx.work.ListenableWorker;
import androidx.work.WorkerParameters;
import androidx.work.impl.WorkDatabase;
import androidx.work.impl.foreground.SystemForegroundService;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ExecutionException;
import p037.p065.p068.C1850;
import p037.p123.AbstractC2562;
import p037.p123.C2544;
import p037.p123.C2557;
import p037.p123.p124.RunnableC2607;
import p037.p123.p124.p132.C2650;
import p037.p123.p124.p132.InterfaceC2648;
import p037.p123.p124.p132.RunnableC2652;
import p037.p123.p124.p134.C2709;
import p037.p123.p124.p134.p135.C2729;
import p037.p123.p124.p134.p136.C2731;
import p037.p123.p124.p134.p136.InterfaceC2730;
import p138.p176.p271.p276.p277.InterfaceFutureC5175;

/* JADX INFO: renamed from: މ.ޗ.ޘ.ށ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public class C2588 implements InterfaceC2586, InterfaceC2648 {

    /* JADX INFO: renamed from: ގ, reason: contains not printable characters */
    public static final String f8099 = AbstractC2562.m4622("Processor");

    /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
    public Context f8101;

    /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
    public C2544 f8102;

    /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
    public InterfaceC2730 f8103;

    /* JADX INFO: renamed from: އ, reason: contains not printable characters */
    public WorkDatabase f8104;

    /* JADX INFO: renamed from: ފ, reason: contains not printable characters */
    public List<InterfaceC2590> f8107;

    /* JADX INFO: renamed from: މ, reason: contains not printable characters */
    public Map<String, RunnableC2607> f8106 = new HashMap();

    /* JADX INFO: renamed from: ވ, reason: contains not printable characters */
    public Map<String, RunnableC2607> f8105 = new HashMap();

    /* JADX INFO: renamed from: ދ, reason: contains not printable characters */
    public Set<String> f8108 = new HashSet();

    /* JADX INFO: renamed from: ތ, reason: contains not printable characters */
    public final List<InterfaceC2586> f8109 = new ArrayList();

    /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
    public PowerManager.WakeLock f8100 = null;

    /* JADX INFO: renamed from: ލ, reason: contains not printable characters */
    public final Object f8110 = new Object();

    /* JADX INFO: renamed from: މ.ޗ.ޘ.ށ$֏, reason: contains not printable characters */
    public static class RunnableC2589 implements Runnable {

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public InterfaceC2586 f8111;

        /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
        public String f8112;

        /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
        public InterfaceFutureC5175<Boolean> f8113;

        public RunnableC2589(InterfaceC2586 interfaceC2586, String str, InterfaceFutureC5175<Boolean> interfaceFutureC5175) {
            this.f8111 = interfaceC2586;
            this.f8112 = str;
            this.f8113 = interfaceFutureC5175;
        }

        @Override // java.lang.Runnable
        public void run() {
            boolean zBooleanValue;
            try {
                zBooleanValue = this.f8113.get().booleanValue();
            } catch (InterruptedException | ExecutionException unused) {
                zBooleanValue = true;
            }
            this.f8111.mo870(this.f8112, zBooleanValue);
        }
    }

    public C2588(Context context, C2544 c2544, InterfaceC2730 interfaceC2730, WorkDatabase workDatabase, List<InterfaceC2590> list) {
        this.f8101 = context;
        this.f8102 = c2544;
        this.f8103 = interfaceC2730;
        this.f8104 = workDatabase;
        this.f8107 = list;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public static boolean m4639(String str, RunnableC2607 runnableC2607) {
        boolean zIsDone;
        if (runnableC2607 == null) {
            AbstractC2562.m4623().mo4625(f8099, String.format("WorkerWrapper could not be found for %s", str), new Throwable[0]);
            return false;
        }
        runnableC2607.f8171 = true;
        runnableC2607.m4677();
        InterfaceFutureC5175<ListenableWorker.AbstractC0240> interfaceFutureC5175 = runnableC2607.f8170;
        if (interfaceFutureC5175 != null) {
            zIsDone = interfaceFutureC5175.isDone();
            runnableC2607.f8170.cancel(true);
        } else {
            zIsDone = false;
        }
        ListenableWorker listenableWorker = runnableC2607.f8158;
        if (listenableWorker == null || zIsDone) {
            AbstractC2562.m4623().mo4625(RunnableC2607.f8152, String.format("WorkSpec %s is already done. Not interrupting.", runnableC2607.f8157), new Throwable[0]);
        } else {
            listenableWorker.f1423 = true;
            listenableWorker.mo835();
        }
        AbstractC2562.m4623().mo4625(f8099, String.format("WorkerWrapper interrupted for %s", str), new Throwable[0]);
        return true;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final void m4640() {
        synchronized (this.f8110) {
            if (!(!this.f8105.isEmpty())) {
                SystemForegroundService systemForegroundService = SystemForegroundService.f1461;
                if (systemForegroundService != null) {
                    AbstractC2562.m4623().mo4625(f8099, "No more foreground work. Stopping SystemForegroundService", new Throwable[0]);
                    systemForegroundService.f1462.post(new RunnableC2652(systemForegroundService));
                } else {
                    AbstractC2562.m4623().mo4625(f8099, "No more foreground work. SystemForegroundService is already stopped", new Throwable[0]);
                }
                if (this.f8100 != null) {
                    this.f8100.release();
                    this.f8100 = null;
                }
            }
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m4641(String str, C2557 c2557) {
        synchronized (this.f8110) {
            AbstractC2562.m4623().mo4627(f8099, String.format("Moving WorkSpec (%s) to the foreground", str), new Throwable[0]);
            RunnableC2607 runnableC2607Remove = this.f8106.remove(str);
            if (runnableC2607Remove != null) {
                if (this.f8100 == null) {
                    PowerManager.WakeLock wakeLockM4777 = C2709.m4777(this.f8101, "ProcessorForegroundLck");
                    this.f8100 = wakeLockM4777;
                    wakeLockM4777.acquire();
                }
                this.f8105.put(str, runnableC2607Remove);
                C1850.m3649(this.f8101, C2650.m4732(this.f8101, str, c2557));
            }
        }
    }

    @Override // p037.p123.p124.InterfaceC2586
    /* JADX INFO: renamed from: ֏ */
    public void mo870(String str, boolean z) {
        synchronized (this.f8110) {
            this.f8106.remove(str);
            AbstractC2562.m4623().mo4625(f8099, String.format("%s %s executed; reschedule = %s", getClass().getSimpleName(), str, Boolean.valueOf(z)), new Throwable[0]);
            Iterator<InterfaceC2586> it = this.f8109.iterator();
            while (it.hasNext()) {
                it.next().mo870(str, z);
            }
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m4642(InterfaceC2586 interfaceC2586) {
        synchronized (this.f8110) {
            this.f8109.add(interfaceC2586);
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public boolean m4643(String str) {
        boolean zContains;
        synchronized (this.f8110) {
            zContains = this.f8108.contains(str);
        }
        return zContains;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public boolean m4644(String str, WorkerParameters.C0245 c0245) {
        synchronized (this.f8110) {
            if (m4646(str)) {
                AbstractC2562.m4623().mo4625(f8099, String.format("Work %s is already enqueued for processing", str), new Throwable[0]);
                return false;
            }
            RunnableC2607.C2608 c2608 = new RunnableC2607.C2608(this.f8101, this.f8102, this.f8103, this, this.f8104, str);
            c2608.f8179 = this.f8107;
            if (c0245 != null) {
                c2608.f8180 = c0245;
            }
            RunnableC2607 runnableC2607 = new RunnableC2607(c2608);
            C2729<Boolean> c2729 = runnableC2607.f8169;
            c2729.mo4788(new RunnableC2589(this, str, c2729), ((C2731) this.f8103).f8442);
            this.f8106.put(str, runnableC2607);
            ((C2731) this.f8103).f8440.execute(runnableC2607);
            AbstractC2562.m4623().mo4625(f8099, String.format("%s: processing %s", C2588.class.getSimpleName(), str), new Throwable[0]);
            return true;
        }
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public void m4645(InterfaceC2586 interfaceC2586) {
        synchronized (this.f8110) {
            this.f8109.remove(interfaceC2586);
        }
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public boolean m4646(String str) {
        boolean z;
        synchronized (this.f8110) {
            z = this.f8106.containsKey(str) || this.f8105.containsKey(str);
        }
        return z;
    }

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public boolean m4647(String str) {
        boolean zContainsKey;
        synchronized (this.f8110) {
            zContainsKey = this.f8105.containsKey(str);
        }
        return zContainsKey;
    }

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public boolean m4648(String str) {
        boolean zM4639;
        synchronized (this.f8110) {
            boolean z = true;
            AbstractC2562.m4623().mo4625(f8099, String.format("Processor cancelling %s", str), new Throwable[0]);
            this.f8108.add(str);
            RunnableC2607 runnableC2607Remove = this.f8105.remove(str);
            if (runnableC2607Remove == null) {
                z = false;
            }
            if (runnableC2607Remove == null) {
                runnableC2607Remove = this.f8106.remove(str);
            }
            zM4639 = m4639(str, runnableC2607Remove);
            if (z) {
                m4640();
            }
        }
        return zM4639;
    }

    /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
    public void m4649(String str) {
        synchronized (this.f8110) {
            this.f8105.remove(str);
            m4640();
        }
    }

    /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
    public boolean m4650(String str) {
        boolean zM4639;
        synchronized (this.f8110) {
            AbstractC2562.m4623().mo4625(f8099, String.format("Processor stopping foreground work %s", str), new Throwable[0]);
            zM4639 = m4639(str, this.f8105.remove(str));
        }
        return zM4639;
    }

    /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
    public boolean m4651(String str) {
        boolean zM4639;
        synchronized (this.f8110) {
            AbstractC2562.m4623().mo4625(f8099, String.format("Processor stopping background work %s", str), new Throwable[0]);
            zM4639 = m4639(str, this.f8106.remove(str));
        }
        return zM4639;
    }
}