package defpackage;

import android.content.Context;
import androidx.work.WorkerParameters;
import androidx.work.d;
import androidx.work.f;
import androidx.work.impl.WorkDatabase;
import androidx.work.impl.background.systemalarm.RescheduleReceiver;
import defpackage.hsa;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.LinkedList;
import java.util.Objects;
import java.util.UUID;
import java.util.concurrent.ExecutorService;

/* JADX INFO: loaded from: classes.dex */
@m38
public class jva implements Runnable {
    public static final String t = eh5.d("WorkerWrapper");
    public final Context a;
    public final String b;
    public final lta c;
    public f d;
    public final qsa e;
    public final androidx.work.a i;
    public final ai9 j;
    public final ti7 k;
    public final WorkDatabase l;
    public final mta m;
    public final y42 n;
    public final ArrayList o;
    public String p;
    public f.a f = new f.a.C0067a(d.c);
    public final pm8 q = new pm8();
    public final pm8 r = new pm8();
    public volatile int s = -256;

    @m38
    public static class a {
        public final Context a;
        public final ti7 b;
        public final qsa c;
        public final androidx.work.a d;
        public final WorkDatabase e;
        public final lta f;
        public final ArrayList g;

        public a(Context context, androidx.work.a aVar, qsa qsaVar, ti7 ti7Var, WorkDatabase workDatabase, lta ltaVar, ArrayList arrayList) {
            new WorkerParameters.a();
            this.a = context.getApplicationContext();
            this.c = qsaVar;
            this.b = ti7Var;
            this.d = aVar;
            this.e = workDatabase;
            this.f = ltaVar;
            this.g = arrayList;
        }
    }

    public jva(a aVar) {
        this.a = aVar.a;
        this.e = aVar.c;
        this.k = aVar.b;
        lta ltaVar = aVar.f;
        this.c = ltaVar;
        this.b = ltaVar.a;
        this.d = null;
        androidx.work.a aVar2 = aVar.d;
        this.i = aVar2;
        this.j = aVar2.c;
        WorkDatabase workDatabase = aVar.e;
        this.l = workDatabase;
        this.m = workDatabase.f();
        this.n = workDatabase.a();
        this.o = aVar.g;
    }

    public final void a(f.a aVar) {
        boolean z = aVar instanceof f.a.c;
        lta ltaVar = this.c;
        if (!z) {
            if (aVar instanceof f.a.b) {
                eh5.c().getClass();
                c();
                return;
            }
            eh5.c().getClass();
            if (ltaVar.c()) {
                d();
                return;
            } else {
                g();
                return;
            }
        }
        eh5.c().getClass();
        if (ltaVar.c()) {
            d();
            return;
        }
        y42 y42Var = this.n;
        String str = this.b;
        mta mtaVar = this.m;
        WorkDatabase workDatabase = this.l;
        workDatabase.beginTransaction();
        try {
            mtaVar.e(hsa.c.c, str);
            mtaVar.s(str, ((f.a.c) this.f).a);
            this.j.getClass();
            long jCurrentTimeMillis = System.currentTimeMillis();
            for (String str2 : y42Var.a(str)) {
                if (mtaVar.i(str2) == hsa.c.e && y42Var.b(str2)) {
                    eh5.c().getClass();
                    mtaVar.e(hsa.c.a, str2);
                    mtaVar.r(jCurrentTimeMillis, str2);
                }
            }
            workDatabase.setTransactionSuccessful();
            workDatabase.endTransaction();
            e(false);
        } catch (Throwable th) {
            workDatabase.endTransaction();
            e(false);
            throw th;
        }
    }

    public final void b() {
        if (h()) {
            return;
        }
        this.l.beginTransaction();
        try {
            hsa.c cVarI = this.m.i(this.b);
            this.l.e().a(this.b);
            if (cVarI == null) {
                e(false);
            } else if (cVarI == hsa.c.b) {
                a(this.f);
            } else if (!cVarI.a()) {
                this.s = -512;
                c();
            }
            this.l.setTransactionSuccessful();
            this.l.endTransaction();
        } catch (Throwable th) {
            this.l.endTransaction();
            throw th;
        }
    }

    public final void c() {
        String str = this.b;
        mta mtaVar = this.m;
        WorkDatabase workDatabase = this.l;
        workDatabase.beginTransaction();
        try {
            mtaVar.e(hsa.c.a, str);
            this.j.getClass();
            mtaVar.r(System.currentTimeMillis(), str);
            mtaVar.f(this.c.v, str);
            mtaVar.c(-1L, str);
            workDatabase.setTransactionSuccessful();
        } finally {
            workDatabase.endTransaction();
            e(true);
        }
    }

    public final void d() {
        String str = this.b;
        mta mtaVar = this.m;
        WorkDatabase workDatabase = this.l;
        workDatabase.beginTransaction();
        try {
            this.j.getClass();
            mtaVar.r(System.currentTimeMillis(), str);
            mtaVar.e(hsa.c.a, str);
            mtaVar.y(str);
            mtaVar.f(this.c.v, str);
            mtaVar.b(str);
            mtaVar.c(-1L, str);
            workDatabase.setTransactionSuccessful();
        } finally {
            workDatabase.endTransaction();
            e(false);
        }
    }

    public final void e(boolean z) {
        this.l.beginTransaction();
        try {
            if (!this.l.f().v()) {
                b07.a(this.a, RescheduleReceiver.class, false);
            }
            if (z) {
                this.m.e(hsa.c.a, this.b);
                this.m.setStopReason(this.b, this.s);
                this.m.c(-1L, this.b);
            }
            this.l.setTransactionSuccessful();
            this.l.endTransaction();
            this.q.h(Boolean.valueOf(z));
        } catch (Throwable th) {
            this.l.endTransaction();
            throw th;
        }
    }

    public final void f() {
        hsa.c cVarI = this.m.i(this.b);
        if (cVarI == hsa.c.b) {
            eh5.c().getClass();
            e(true);
        } else {
            eh5 eh5VarC = eh5.c();
            Objects.toString(cVarI);
            eh5VarC.getClass();
            e(false);
        }
    }

    public final void g() {
        String str = this.b;
        WorkDatabase workDatabase = this.l;
        workDatabase.beginTransaction();
        try {
            LinkedList linkedList = new LinkedList();
            linkedList.add(str);
            while (true) {
                boolean zIsEmpty = linkedList.isEmpty();
                mta mtaVar = this.m;
                if (zIsEmpty) {
                    d dVar = ((f.a.C0067a) this.f).a;
                    mtaVar.f(this.c.v, str);
                    mtaVar.s(str, dVar);
                    workDatabase.setTransactionSuccessful();
                    return;
                }
                String str2 = (String) linkedList.remove();
                if (mtaVar.i(str2) != hsa.c.f) {
                    mtaVar.e(hsa.c.d, str2);
                }
                linkedList.addAll(this.n.a(str2));
            }
        } finally {
            workDatabase.endTransaction();
            e(false);
        }
    }

    public final boolean h() {
        if (this.s == -256) {
            return false;
        }
        eh5.c().getClass();
        if (this.m.i(this.b) == null) {
            e(false);
            return true;
        }
        e(!r0.a());
        return true;
    }

    /* JADX WARN: Removed duplicated region for block: B:31:0x007f A[Catch: all -> 0x0069, TryCatch #1 {all -> 0x0069, blocks: (B:14:0x004e, B:17:0x0058, B:22:0x006c, B:24:0x0072, B:26:0x0076, B:36:0x00a1, B:31:0x007f, B:33:0x0090), top: B:79:0x004e }] */
    @Override // java.lang.Runnable
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final void run() {
        an4 an4Var;
        d dVarA;
        boolean z;
        StringBuilder sb = new StringBuilder("Work [ id=");
        String str = this.b;
        sb.append(str);
        sb.append(", tags={ ");
        ArrayList<String> arrayList = this.o;
        boolean z2 = true;
        for (String str2 : arrayList) {
            if (z2) {
                z2 = false;
            } else {
                sb.append(", ");
            }
            sb.append(str2);
        }
        sb.append(" } ]");
        this.p = sb.toString();
        lta ltaVar = this.c;
        if (h()) {
            return;
        }
        WorkDatabase workDatabase = this.l;
        workDatabase.beginTransaction();
        try {
            hsa.c cVar = ltaVar.b;
            String str3 = ltaVar.d;
            String str4 = ltaVar.c;
            hsa.c cVar2 = hsa.c.a;
            if (cVar != cVar2) {
                f();
                workDatabase.setTransactionSuccessful();
                eh5.c().getClass();
                return;
            }
            if (ltaVar.c()) {
                this.j.getClass();
                if (System.currentTimeMillis() < ltaVar.a()) {
                    eh5.c().getClass();
                    e(true);
                    workDatabase.setTransactionSuccessful();
                    return;
                }
            } else if (ltaVar.b == cVar2 && ltaVar.k > 0) {
            }
            workDatabase.setTransactionSuccessful();
            workDatabase.endTransaction();
            boolean zC = ltaVar.c();
            mta mtaVar = this.m;
            androidx.work.a aVar = this.i;
            String str5 = t;
            if (zC) {
                dVarA = ltaVar.e;
            } else {
                aVar.e.getClass();
                cr4.g(str3, "className");
                String str6 = cn4.a;
                try {
                    Object objNewInstance = Class.forName(str3).getDeclaredConstructor(null).newInstance(null);
                    cr4.e(objNewInstance, "null cannot be cast to non-null type androidx.work.InputMerger");
                    an4Var = (an4) objNewInstance;
                } catch (Exception e) {
                    eh5.c().b(cn4.a, "Trouble instantiating ".concat(str3), e);
                    an4Var = null;
                }
                if (an4Var == null) {
                    eh5.c().a(str5, "Could not create Input Merger ".concat(str3));
                    g();
                    return;
                } else {
                    ArrayList arrayList2 = new ArrayList();
                    arrayList2.add(ltaVar.e);
                    arrayList2.addAll(mtaVar.m(str));
                    dVarA = an4Var.a(arrayList2);
                }
            }
            UUID uuidFromString = UUID.fromString(str);
            ExecutorService executorService = aVar.a;
            cva cvaVar = aVar.d;
            qsa qsaVar = this.e;
            eta etaVar = new eta(workDatabase, qsaVar);
            fsa fsaVar = new fsa(workDatabase, this.k, qsaVar);
            WorkerParameters workerParameters = new WorkerParameters();
            workerParameters.a = uuidFromString;
            workerParameters.b = dVarA;
            new HashSet(arrayList);
            workerParameters.c = executorService;
            workerParameters.d = qsaVar;
            workerParameters.e = cvaVar;
            workerParameters.f = etaVar;
            if (this.d == null) {
                this.d = cvaVar.b(this.a, str4, workerParameters);
            }
            f fVar = this.d;
            if (fVar == null) {
                eh5.c().a(str5, "Could not create Worker " + str4);
                g();
                return;
            }
            if (fVar.d) {
                eh5.c().a(str5, "Received an already-used Worker " + str4 + "; Worker Factory should return new instances");
                g();
                return;
            }
            fVar.d = true;
            workDatabase.beginTransaction();
            try {
                if (mtaVar.i(str) == cVar2) {
                    mtaVar.e(hsa.c.b, str);
                    mtaVar.z(str);
                    mtaVar.setStopReason(str, -256);
                    z = true;
                } else {
                    z = false;
                }
                workDatabase.setTransactionSuccessful();
                if (!z) {
                    f();
                    return;
                }
                if (h()) {
                    return;
                }
                dsa dsaVar = new dsa(this.a, this.c, this.d, fsaVar, qsaVar);
                qsaVar.d.execute(dsaVar);
                pm8 pm8Var = dsaVar.a;
                fda fdaVar = new fda(this, pm8Var, 8);
                mh9 mh9Var = new mh9();
                pm8 pm8Var2 = this.r;
                pm8Var2.addListener(fdaVar, mh9Var);
                pm8Var.addListener(new hva(this, pm8Var), qsaVar.d);
                pm8Var2.addListener(new iva(this, this.p), qsaVar.a);
            } catch (Throwable th) {
                throw th;
            }
        } finally {
            workDatabase.endTransaction();
        }
    }
}