package f.a;

import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: Scheduler.java */
/* JADX INFO: loaded from: classes.dex */
public abstract class g {
    static final long a = TimeUnit.MINUTES.toNanos(Long.getLong("rx2.scheduler.drift-tolerance", 15).longValue());

    /* JADX INFO: compiled from: Scheduler.java */
    static final class a implements Runnable, f.a.k.b {
        final Runnable b;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        final c f810e;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        Thread f811f;

        a(Runnable runnable, c cVar) {
            this.b = runnable;
            this.f810e = cVar;
        }

        @Override // f.a.k.b
        public void dispose() {
            if (this.f811f == Thread.currentThread()) {
                c cVar = this.f810e;
                if (cVar instanceof f.a.n.g.f) {
                    ((f.a.n.g.f) cVar).h();
                    return;
                }
            }
            this.f810e.dispose();
        }

        @Override // java.lang.Runnable
        public void run() {
            this.f811f = Thread.currentThread();
            try {
                this.b.run();
            } finally {
                dispose();
                this.f811f = null;
            }
        }
    }

    /* JADX INFO: compiled from: Scheduler.java */
    static class b implements Runnable, f.a.k.b {
        final Runnable b;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        final c f812e;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        volatile boolean f813f;

        b(Runnable runnable, c cVar) {
            this.b = runnable;
            this.f812e = cVar;
        }

        @Override // f.a.k.b
        public void dispose() {
            this.f813f = true;
            this.f812e.dispose();
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f813f) {
                return;
            }
            try {
                this.b.run();
            } catch (Throwable th) {
                f.a.l.b.b(th);
                this.f812e.dispose();
                throw f.a.n.h.b.a(th);
            }
        }
    }

    /* JADX INFO: compiled from: Scheduler.java */
    public static abstract class c implements f.a.k.b {

        /* JADX INFO: compiled from: Scheduler.java */
        final class a implements Runnable {
            final Runnable b;

            /* JADX INFO: renamed from: e, reason: collision with root package name */
            final f.a.n.a.e f814e;

            /* JADX INFO: renamed from: f, reason: collision with root package name */
            final long f815f;

            /* JADX INFO: renamed from: g, reason: collision with root package name */
            long f816g;

            /* JADX INFO: renamed from: h, reason: collision with root package name */
            long f817h;

            /* JADX INFO: renamed from: i, reason: collision with root package name */
            long f818i;

            a(long j2, Runnable runnable, long j3, f.a.n.a.e eVar, long j4) {
                this.b = runnable;
                this.f814e = eVar;
                this.f815f = j4;
                this.f817h = j3;
                this.f818i = j2;
            }

            /* JADX WARN: Removed duplicated region for block: B:10:0x0035  */
            @Override // java.lang.Runnable
            /*
                Code decompiled incorrectly, please refer to instructions dump.
                To view partially-correct add '--show-bad-code' argument
            */
            public void run() {
                /*
                    r11 = this;
                    java.lang.Runnable r0 = r11.b
                    r0.run()
                    f.a.n.a.e r0 = r11.f814e
                    boolean r0 = r0.a()
                    if (r0 != 0) goto L55
                    f.a.g$c r0 = f.a.g.c.this
                    java.util.concurrent.TimeUnit r1 = java.util.concurrent.TimeUnit.NANOSECONDS
                    long r0 = r0.a(r1)
                    long r2 = f.a.g.a
                    long r4 = r0 + r2
                    long r6 = r11.f817h
                    r8 = 1
                    int r10 = (r4 > r6 ? 1 : (r4 == r6 ? 0 : -1))
                    if (r10 < 0) goto L35
                    long r4 = r11.f815f
                    long r6 = r6 + r4
                    long r6 = r6 + r2
                    int r2 = (r0 > r6 ? 1 : (r0 == r6 ? 0 : -1))
                    if (r2 < 0) goto L2a
                    goto L35
                L2a:
                    long r2 = r11.f818i
                    long r6 = r11.f816g
                    long r6 = r6 + r8
                    r11.f816g = r6
                    long r6 = r6 * r4
                    long r2 = r2 + r6
                    goto L45
                L35:
                    long r2 = r11.f815f
                    long r4 = r0 + r2
                    long r6 = r11.f816g
                    long r6 = r6 + r8
                    r11.f816g = r6
                    long r2 = r2 * r6
                    long r2 = r4 - r2
                    r11.f818i = r2
                    r2 = r4
                L45:
                    r11.f817h = r0
                    long r2 = r2 - r0
                    f.a.n.a.e r0 = r11.f814e
                    f.a.g$c r1 = f.a.g.c.this
                    java.util.concurrent.TimeUnit r4 = java.util.concurrent.TimeUnit.NANOSECONDS
                    f.a.k.b r1 = r1.c(r11, r2, r4)
                    r0.b(r1)
                L55:
                    return
                */
                throw new UnsupportedOperationException("Method not decompiled: f.a.g.c.a.run():void");
            }
        }

        public long a(TimeUnit timeUnit) {
            return timeUnit.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS);
        }

        public f.a.k.b b(Runnable runnable) {
            return c(runnable, 0L, TimeUnit.NANOSECONDS);
        }

        public abstract f.a.k.b c(Runnable runnable, long j2, TimeUnit timeUnit);

        public f.a.k.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
            f.a.n.a.e eVar = new f.a.n.a.e();
            f.a.n.a.e eVar2 = new f.a.n.a.e(eVar);
            Runnable runnableO = f.a.p.a.o(runnable);
            long nanos = timeUnit.toNanos(j3);
            long jA = a(TimeUnit.NANOSECONDS);
            f.a.k.b bVarC = c(new a(jA + timeUnit.toNanos(j2), runnableO, jA, eVar2, nanos), j2, timeUnit);
            if (bVarC == f.a.n.a.c.INSTANCE) {
                return bVarC;
            }
            eVar.b(bVarC);
            return eVar2;
        }
    }

    public abstract c a();

    public f.a.k.b b(Runnable runnable) {
        return c(runnable, 0L, TimeUnit.NANOSECONDS);
    }

    public f.a.k.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        c cVarA = a();
        a aVar = new a(f.a.p.a.o(runnable), cVarA);
        cVarA.c(aVar, j2, timeUnit);
        return aVar;
    }

    public f.a.k.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        c cVarA = a();
        b bVar = new b(f.a.p.a.o(runnable), cVarA);
        f.a.k.b bVarD = cVarA.d(bVar, j2, j3, timeUnit);
        return bVarD == f.a.n.a.c.INSTANCE ? bVarD : bVar;
    }
}