package f.a; import java.util.Objects; import java.util.concurrent.TimeUnit; /* JADX INFO: compiled from: Scheduler.java */ /* JADX INFO: loaded from: classes.dex */ public abstract class o { public static final long a = TimeUnit.MINUTES.toNanos(Long.getLong("rx2.scheduler.drift-tolerance", 15).longValue()); /* JADX INFO: compiled from: Scheduler.java */ public static final class a implements f.a.t.b, Runnable { /* JADX INFO: renamed from: b, reason: collision with root package name */ public final Runnable f3698b; /* JADX INFO: renamed from: e, reason: collision with root package name */ public final c f3699e; /* JADX INFO: renamed from: f, reason: collision with root package name */ public Thread f3700f; public a(Runnable runnable, c cVar) { this.f3698b = runnable; this.f3699e = cVar; } @Override // f.a.t.b public void dispose() { if (this.f3700f == Thread.currentThread()) { c cVar = this.f3699e; if (cVar instanceof f.a.w.g.h) { f.a.w.g.h hVar = (f.a.w.g.h) cVar; if (hVar.f4003e) { return; } hVar.f4003e = true; hVar.f4002b.shutdown(); return; } } this.f3699e.dispose(); } @Override // java.lang.Runnable public void run() { this.f3700f = Thread.currentThread(); try { this.f3698b.run(); } finally { dispose(); this.f3700f = null; } } } /* JADX INFO: compiled from: Scheduler.java */ public static final class b implements f.a.t.b, Runnable { /* JADX INFO: renamed from: b, reason: collision with root package name */ public final Runnable f3701b; /* JADX INFO: renamed from: e, reason: collision with root package name */ public final c f3702e; /* JADX INFO: renamed from: f, reason: collision with root package name */ public volatile boolean f3703f; public b(Runnable runnable, c cVar) { this.f3701b = runnable; this.f3702e = cVar; } @Override // f.a.t.b public void dispose() { this.f3703f = true; this.f3702e.dispose(); } @Override // java.lang.Runnable public void run() { if (this.f3703f) { return; } try { this.f3701b.run(); } catch (Throwable th) { d.i.c.a.L(th); this.f3702e.dispose(); throw f.a.w.h.c.a(th); } } } /* JADX INFO: compiled from: Scheduler.java */ public static abstract class c implements f.a.t.b { /* JADX INFO: compiled from: Scheduler.java */ public final class a implements Runnable { /* JADX INFO: renamed from: b, reason: collision with root package name */ public final Runnable f3704b; /* JADX INFO: renamed from: e, reason: collision with root package name */ public final f.a.w.a.f f3705e; /* JADX INFO: renamed from: f, reason: collision with root package name */ public final long f3706f; /* JADX INFO: renamed from: g, reason: collision with root package name */ public long f3707g; /* JADX INFO: renamed from: h, reason: collision with root package name */ public long f3708h; /* JADX INFO: renamed from: i, reason: collision with root package name */ public long f3709i; public a(long j2, Runnable runnable, long j3, f.a.w.a.f fVar, long j4) { this.f3704b = runnable; this.f3705e = fVar; this.f3706f = j4; this.f3708h = j3; this.f3709i = j2; } /* JADX WARN: Removed duplicated region for block: B:10:0x003a */ @Override // java.lang.Runnable /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public void run() { /* r12 = this; java.lang.Runnable r0 = r12.f3704b r0.run() f.a.w.a.f r0 = r12.f3705e java.lang.Object r0 = r0.get() f.a.t.b r0 = (f.a.t.b) r0 boolean r0 = f.a.w.a.b.isDisposed(r0) if (r0 != 0) goto L59 f.a.o$c r0 = f.a.o.c.this java.util.concurrent.TimeUnit r1 = java.util.concurrent.TimeUnit.NANOSECONDS long r2 = r0.a(r1) long r4 = f.a.o.a long r6 = r2 + r4 long r8 = r12.f3708h int r0 = (r6 > r8 ? 1 : (r6 == r8 ? 0 : -1)) r6 = 1 if (r0 < 0) goto L3a long r10 = r12.f3706f long r8 = r8 + r10 long r8 = r8 + r4 int r0 = (r2 > r8 ? 1 : (r2 == r8 ? 0 : -1)) if (r0 < 0) goto L30 goto L3a L30: long r4 = r12.f3709i long r8 = r12.f3707g long r8 = r8 + r6 r12.f3707g = r8 long r8 = r8 * r10 long r8 = r8 + r4 goto L48 L3a: long r4 = r12.f3706f long r8 = r2 + r4 long r10 = r12.f3707g long r10 = r10 + r6 r12.f3707g = r10 long r4 = r4 * r10 long r4 = r8 - r4 r12.f3709i = r4 L48: r12.f3708h = r2 long r8 = r8 - r2 f.a.w.a.f r0 = r12.f3705e f.a.o$c r2 = f.a.o.c.this f.a.t.b r1 = r2.c(r12, r8, r1) java.util.Objects.requireNonNull(r0) f.a.w.a.b.replace(r0, r1) L59: return */ throw new UnsupportedOperationException("Method not decompiled: f.a.o.c.a.run():void"); } } public long a(TimeUnit timeUnit) { return timeUnit.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS); } public f.a.t.b b(Runnable runnable) { return c(runnable, 0L, TimeUnit.NANOSECONDS); } public abstract f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit); public f.a.t.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) { f.a.w.a.f fVar = new f.a.w.a.f(); f.a.w.a.f fVar2 = new f.a.w.a.f(fVar); long nanos = timeUnit.toNanos(j3); long jA = a(TimeUnit.NANOSECONDS); f.a.t.b bVarC = c(new a(timeUnit.toNanos(j2) + jA, runnable, jA, fVar2, nanos), j2, timeUnit); if (bVarC == f.a.w.a.c.INSTANCE) { return bVarC; } f.a.w.a.b.replace(fVar, bVarC); return fVar2; } } public abstract c a(); public f.a.t.b b(Runnable runnable) { return c(runnable, 0L, TimeUnit.NANOSECONDS); } public f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit) { c cVarA = a(); Objects.requireNonNull(runnable, "run is null"); a aVar = new a(runnable, cVarA); cVarA.c(aVar, j2, timeUnit); return aVar; } public f.a.t.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) { c cVarA = a(); Objects.requireNonNull(runnable, "run is null"); b bVar = new b(runnable, cVarA); f.a.t.b bVarD = cVarA.d(bVar, j2, j3, timeUnit); return bVarD == f.a.w.a.c.INSTANCE ? bVarD : bVar; } }