package p037.p123.p124; import android.content.Context; import android.database.Cursor; import androidx.work.ListenableWorker; import androidx.work.WorkerParameters; import androidx.work.impl.WorkDatabase; import androidx.work.impl.background.systemalarm.RescheduleReceiver; import java.util.ArrayList; import java.util.Iterator; import java.util.LinkedList; import java.util.List; import java.util.UUID; import p037.p109.C2409; import p037.p109.p111.C2421; import p037.p123.AbstractC2559; import p037.p123.AbstractC2561; import p037.p123.AbstractC2562; import p037.p123.C2544; import p037.p123.C2552; import p037.p123.C2578; import p037.p123.p124.p132.InterfaceC2648; import p037.p123.p124.p133.C2655; import p037.p123.p124.p133.C2672; import p037.p123.p124.p133.C2676; import p037.p123.p124.p133.C2682; import p037.p123.p124.p133.C2694; import p037.p123.p124.p133.InterfaceC2654; import p037.p123.p124.p133.InterfaceC2680; import p037.p123.p124.p133.InterfaceC2693; import p037.p123.p124.p134.C2703; import p037.p123.p124.p134.C2711; import p037.p123.p124.p134.C2712; 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 RunnableC2607 implements Runnable { /* JADX INFO: renamed from: ޖ, reason: contains not printable characters */ public static final String f8152 = AbstractC2562.m4622("WorkerWrapper"); /* JADX INFO: renamed from: ރ, reason: contains not printable characters */ public Context f8153; /* JADX INFO: renamed from: ބ, reason: contains not printable characters */ public String f8154; /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */ public List f8155; /* JADX INFO: renamed from: ކ, reason: contains not printable characters */ public WorkerParameters.C0245 f8156; /* JADX INFO: renamed from: އ, reason: contains not printable characters */ public C2676 f8157; /* JADX INFO: renamed from: ވ, reason: contains not printable characters */ public ListenableWorker f8158; /* JADX INFO: renamed from: ފ, reason: contains not printable characters */ public C2544 f8160; /* JADX INFO: renamed from: ދ, reason: contains not printable characters */ public InterfaceC2730 f8161; /* JADX INFO: renamed from: ތ, reason: contains not printable characters */ public InterfaceC2648 f8162; /* JADX INFO: renamed from: ލ, reason: contains not printable characters */ public WorkDatabase f8163; /* JADX INFO: renamed from: ގ, reason: contains not printable characters */ public InterfaceC2680 f8164; /* JADX INFO: renamed from: ޏ, reason: contains not printable characters */ public InterfaceC2654 f8165; /* JADX INFO: renamed from: ސ, reason: contains not printable characters */ public InterfaceC2693 f8166; /* JADX INFO: renamed from: ޑ, reason: contains not printable characters */ public List f8167; /* JADX INFO: renamed from: ޒ, reason: contains not printable characters */ public String f8168; /* JADX INFO: renamed from: ޕ, reason: contains not printable characters */ public volatile boolean f8171; /* JADX INFO: renamed from: މ, reason: contains not printable characters */ public ListenableWorker.AbstractC0240 f8159 = new ListenableWorker.AbstractC0240.C0241(); /* JADX INFO: renamed from: ޓ, reason: contains not printable characters */ public C2729 f8169 = new C2729<>(); /* JADX INFO: renamed from: ޔ, reason: contains not printable characters */ public InterfaceFutureC5175 f8170 = null; /* JADX INFO: renamed from: މ.ޗ.ޘ.ދ$֏, reason: contains not printable characters */ public static class C2608 { /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public Context f8172; /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */ public ListenableWorker f8173; /* JADX INFO: renamed from: ހ, reason: contains not printable characters */ public InterfaceC2648 f8174; /* JADX INFO: renamed from: ށ, reason: contains not printable characters */ public InterfaceC2730 f8175; /* JADX INFO: renamed from: ނ, reason: contains not printable characters */ public C2544 f8176; /* JADX INFO: renamed from: ރ, reason: contains not printable characters */ public WorkDatabase f8177; /* JADX INFO: renamed from: ބ, reason: contains not printable characters */ public String f8178; /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */ public List f8179; /* JADX INFO: renamed from: ކ, reason: contains not printable characters */ public WorkerParameters.C0245 f8180 = new WorkerParameters.C0245(); public C2608(Context context, C2544 c2544, InterfaceC2730 interfaceC2730, InterfaceC2648 interfaceC2648, WorkDatabase workDatabase, String str) { this.f8172 = context.getApplicationContext(); this.f8175 = interfaceC2730; this.f8174 = interfaceC2648; this.f8176 = c2544; this.f8177 = workDatabase; this.f8178 = str; } } public RunnableC2607(C2608 c2608) { this.f8153 = c2608.f8172; this.f8161 = c2608.f8175; this.f8162 = c2608.f8174; this.f8154 = c2608.f8178; this.f8155 = c2608.f8179; this.f8156 = c2608.f8180; this.f8158 = c2608.f8173; this.f8160 = c2608.f8176; WorkDatabase workDatabase = c2608.f8177; this.f8163 = workDatabase; this.f8164 = workDatabase.mo850(); this.f8165 = this.f8163.mo845(); this.f8166 = this.f8163.mo851(); } /* JADX WARN: Removed duplicated region for block: B:43:0x0111 */ /* JADX WARN: Removed duplicated region for block: B:45:0x0118 */ /* JADX WARN: Removed duplicated region for block: B:65:0x01d7 */ /* JADX WARN: Removed duplicated region for block: B:68:0x01eb */ /* JADX WARN: Removed duplicated region for block: B:69:0x020a */ @Override // java.lang.Runnable /* Code decompiled incorrectly, please refer to instructions dump. */ public void run() { C2552 c2552Mo832; ListenableWorker listenableWorker; List listM4765 = ((C2694) this.f8166).m4765(this.f8154); this.f8167 = listM4765; StringBuilder sb = new StringBuilder("Work [ id="); sb.append(this.f8154); sb.append(", tags={ "); boolean z = true; boolean z2 = true; for (String str : listM4765) { if (z2) { z2 = false; } else { sb.append(", "); } sb.append(str); } sb.append(" } ]"); this.f8168 = sb.toString(); if (m4677()) { return; } this.f8163.m4479(); try { C2676 c2676M4761 = ((C2682) this.f8164).m4761(this.f8154); this.f8157 = c2676M4761; if (c2676M4761 == null) { AbstractC2562.m4623().mo4626(f8152, String.format("Didn't find WorkSpec for id %s", this.f8154), new Throwable[0]); m4672(false); } else if (c2676M4761.f8321 != C2578.EnumC2579.ENQUEUED) { m4675(); this.f8163.m4484(); AbstractC2562.m4623().mo4625(f8152, String.format("%s is not in ENQUEUED state. Nothing more to do.", this.f8157.f8322), new Throwable[0]); } else { if (!c2676M4761.m4746()) { C2676 c2676 = this.f8157; if (c2676.f8321 == C2578.EnumC2579.ENQUEUED && c2676.f8330 > 0) { } this.f8163.m4484(); this.f8163.m4481(); if (this.f8157.m4746()) { AbstractC2561 abstractC2561 = this.f8160.f8009; String str2 = this.f8157.f8323; if (abstractC2561 == null) { throw null; } AbstractC2559 abstractC2559M4621 = AbstractC2559.m4621(str2); if (abstractC2559M4621 == null) { AbstractC2562.m4623().mo4626(f8152, String.format("Could not create Input Merger %s", this.f8157.f8323), new Throwable[0]); m4676(); return; } ArrayList arrayList = new ArrayList(); arrayList.add(this.f8157.f8324); InterfaceC2680 interfaceC2680 = this.f8164; String str3 = this.f8154; C2682 c2682 = (C2682) interfaceC2680; if (c2682 == null) { throw null; } C2409 c2409M4490 = C2409.m4490("SELECT output FROM workspec WHERE id IN (SELECT prerequisite_id FROM dependency WHERE work_spec_id=?)", 1); if (str3 == null) { c2409M4490.bindNull(1); } else { c2409M4490.bindString(1, str3); } c2682.f8347.m4478(); Cursor cursorM4504 = C2421.m4504(c2682.f8347, c2409M4490, false, null); try { ArrayList arrayList2 = new ArrayList(cursorM4504.getCount()); while (cursorM4504.moveToNext()) { arrayList2.add(C2552.m4616(cursorM4504.getBlob(0))); } cursorM4504.close(); c2409M4490.m4493(); arrayList.addAll(arrayList2); c2552Mo832 = abstractC2559M4621.mo832(arrayList); } catch (Throwable th) { cursorM4504.close(); c2409M4490.m4493(); throw th; } } else { c2552Mo832 = this.f8157.f8324; } C2552 c2552 = c2552Mo832; UUID uuidFromString = UUID.fromString(this.f8154); List list = this.f8167; WorkerParameters.C0245 c0245 = this.f8156; int i = this.f8157.f8330; C2544 c2544 = this.f8160; WorkerParameters workerParameters = new WorkerParameters(uuidFromString, c2552, list, c0245, i, c2544.f8006, this.f8161, c2544.f8008, new C2712(this.f8163, this.f8161), new C2711(this.f8163, this.f8162, this.f8161)); if (this.f8158 == null) { this.f8158 = this.f8160.f8008.m4637(this.f8153, this.f8157.f8322, workerParameters); } listenableWorker = this.f8158; if (listenableWorker != null) { AbstractC2562.m4623().mo4626(f8152, String.format("Could not create Worker %s", this.f8157.f8322), new Throwable[0]); m4676(); return; } if (listenableWorker.f1424) { AbstractC2562.m4623().mo4626(f8152, String.format("Received an already-used Worker %s; WorkerFactory should return new instances", this.f8157.f8322), new Throwable[0]); m4676(); return; } listenableWorker.f1424 = true; this.f8163.m4479(); try { if (((C2682) this.f8164).m4755(this.f8154) == C2578.EnumC2579.ENQUEUED) { ((C2682) this.f8164).m4748(C2578.EnumC2579.RUNNING, this.f8154); ((C2682) this.f8164).m4763(this.f8154); } else { z = false; } this.f8163.m4484(); if (!z) { m4675(); return; } else { if (m4677()) { return; } C2729 c2729 = new C2729(); ((C2731) this.f8161).f8442.execute(new RunnableC2605(this, c2729)); c2729.mo4788(new RunnableC2606(this, c2729, this.f8168), ((C2731) this.f8161).f8440); return; } } finally { } } long jCurrentTimeMillis = System.currentTimeMillis(); if (!(this.f8157.f8333 == 0) && jCurrentTimeMillis < this.f8157.m4744()) { AbstractC2562.m4623().mo4625(f8152, String.format("Delaying execution for %s because it is being executed before schedule.", this.f8157.f8322), new Throwable[0]); m4672(true); } this.f8163.m4484(); this.f8163.m4481(); if (this.f8157.m4746()) { } C2552 c25522 = c2552Mo832; UUID uuidFromString2 = UUID.fromString(this.f8154); List list2 = this.f8167; WorkerParameters.C0245 c02452 = this.f8156; int i2 = this.f8157.f8330; C2544 c25442 = this.f8160; WorkerParameters workerParameters2 = new WorkerParameters(uuidFromString2, c25522, list2, c02452, i2, c25442.f8006, this.f8161, c25442.f8008, new C2712(this.f8163, this.f8161), new C2711(this.f8163, this.f8162, this.f8161)); if (this.f8158 == null) { } listenableWorker = this.f8158; if (listenableWorker != null) { } } } finally { } } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public void m4669() { if (!m4677()) { this.f8163.m4479(); try { C2578.EnumC2579 enumC2579M4755 = ((C2682) this.f8164).m4755(this.f8154); ((C2672) this.f8163.mo849()).m4743(this.f8154); if (enumC2579M4755 == null) { m4672(false); } else if (enumC2579M4755 == C2578.EnumC2579.RUNNING) { m4670(this.f8159); } else if (!enumC2579M4755.m4631()) { m4673(); } this.f8163.m4484(); } finally { this.f8163.m4481(); } } List list = this.f8155; if (list != null) { Iterator it = list.iterator(); while (it.hasNext()) { it.next().mo4652(this.f8154); } C2591.m4656(this.f8160, this.f8163, this.f8155); } } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public final void m4670(ListenableWorker.AbstractC0240 abstractC0240) { if (!(abstractC0240 instanceof ListenableWorker.AbstractC0240.C0243)) { if (abstractC0240 instanceof ListenableWorker.AbstractC0240.C0242) { AbstractC2562.m4623().mo4627(f8152, String.format("Worker result RETRY for %s", this.f8168), new Throwable[0]); m4673(); return; } AbstractC2562.m4623().mo4627(f8152, String.format("Worker result FAILURE for %s", this.f8168), new Throwable[0]); if (this.f8157.m4746()) { m4674(); return; } else { m4676(); return; } } AbstractC2562.m4623().mo4627(f8152, String.format("Worker result SUCCESS for %s", this.f8168), new Throwable[0]); if (this.f8157.m4746()) { m4674(); return; } this.f8163.m4479(); try { ((C2682) this.f8164).m4748(C2578.EnumC2579.SUCCEEDED, this.f8154); ((C2682) this.f8164).m4752(this.f8154, ((ListenableWorker.AbstractC0240.C0243) this.f8159).f1427); long jCurrentTimeMillis = System.currentTimeMillis(); for (String str : (ArrayList) ((C2655) this.f8165).m4735(this.f8154)) { if (((C2682) this.f8164).m4755(str) == C2578.EnumC2579.BLOCKED && ((C2655) this.f8165).m4736(str)) { AbstractC2562.m4623().mo4627(f8152, String.format("Setting status to enqueued for %s", str), new Throwable[0]); ((C2682) this.f8164).m4748(C2578.EnumC2579.ENQUEUED, str); ((C2682) this.f8164).m4756(str, jCurrentTimeMillis); } } this.f8163.m4484(); } finally { this.f8163.m4481(); m4672(false); } } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public final void m4671(String str) { LinkedList linkedList = new LinkedList(); linkedList.add(str); while (!linkedList.isEmpty()) { String str2 = (String) linkedList.remove(); if (((C2682) this.f8164).m4755(str2) != C2578.EnumC2579.CANCELLED) { ((C2682) this.f8164).m4748(C2578.EnumC2579.FAILED, str2); } linkedList.addAll(((C2655) this.f8165).m4735(str2)); } } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public final void m4672(boolean z) { this.f8163.m4479(); try { if (((ArrayList) ((C2682) this.f8163.mo850()).m4754()).isEmpty()) { C2703.m4773(this.f8153, RescheduleReceiver.class, false); } if (z) { ((C2682) this.f8164).m4747(this.f8154, -1L); } if (this.f8157 != null && this.f8158 != null && this.f8158.mo840()) { ((C2588) this.f8162).m4649(this.f8154); } this.f8163.m4484(); this.f8163.m4481(); this.f8169.m4798(Boolean.valueOf(z)); } catch (Throwable th) { this.f8163.m4481(); throw th; } } /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */ public final void m4673() { this.f8163.m4479(); try { ((C2682) this.f8164).m4748(C2578.EnumC2579.ENQUEUED, this.f8154); ((C2682) this.f8164).m4756(this.f8154, System.currentTimeMillis()); ((C2682) this.f8164).m4747(this.f8154, -1L); this.f8163.m4484(); } finally { this.f8163.m4481(); m4672(true); } } /* JADX INFO: renamed from: ހ, reason: contains not printable characters */ public final void m4674() { this.f8163.m4479(); try { ((C2682) this.f8164).m4756(this.f8154, System.currentTimeMillis()); ((C2682) this.f8164).m4748(C2578.EnumC2579.ENQUEUED, this.f8154); ((C2682) this.f8164).m4764(this.f8154); ((C2682) this.f8164).m4747(this.f8154, -1L); this.f8163.m4484(); } finally { this.f8163.m4481(); m4672(false); } } /* JADX INFO: renamed from: ށ, reason: contains not printable characters */ public final void m4675() { C2578.EnumC2579 enumC2579M4755 = ((C2682) this.f8164).m4755(this.f8154); if (enumC2579M4755 == C2578.EnumC2579.RUNNING) { AbstractC2562.m4623().mo4625(f8152, String.format("Status for %s is RUNNING;not doing any work and rescheduling for later execution", this.f8154), new Throwable[0]); m4672(true); } else { AbstractC2562.m4623().mo4625(f8152, String.format("Status for %s is %s; not doing any work", this.f8154, enumC2579M4755), new Throwable[0]); m4672(false); } } /* JADX INFO: renamed from: ނ, reason: contains not printable characters */ public void m4676() { this.f8163.m4479(); try { m4671(this.f8154); ((C2682) this.f8164).m4752(this.f8154, ((ListenableWorker.AbstractC0240.C0241) this.f8159).f1426); this.f8163.m4484(); } finally { this.f8163.m4481(); m4672(false); } } /* JADX INFO: renamed from: ރ, reason: contains not printable characters */ public final boolean m4677() { if (!this.f8171) { return false; } AbstractC2562.m4623().mo4625(f8152, String.format("Work interrupted for %s", this.f8168), new Throwable[0]); if (((C2682) this.f8164).m4755(this.f8154) == null) { m4672(false); } else { m4672(!r0.m4631()); } return true; } }