package e.a;

import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: Scheduler.java */
/* JADX INFO: loaded from: classes.dex */
public abstract class n {
    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, e.a.r.b {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        final Runnable f3614b;

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

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

        a(Runnable runnable, c cVar) {
            this.f3614b = runnable;
            this.f3615f = cVar;
        }

        @Override // e.a.r.b
        public void dispose() {
            if (this.f3616g == Thread.currentThread()) {
                c cVar = this.f3615f;
                if (cVar instanceof e.a.u.g.e) {
                    ((e.a.u.g.e) cVar).h();
                    return;
                }
            }
            this.f3615f.dispose();
        }

        @Override // e.a.r.b
        public boolean isDisposed() {
            return this.f3615f.isDisposed();
        }

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

    /* JADX INFO: compiled from: Scheduler.java */
    static class b implements Runnable, e.a.r.b {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        final Runnable f3617b;

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

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

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

        @Override // e.a.r.b
        public void dispose() {
            this.f3619g = true;
            this.f3618f.dispose();
        }

        @Override // e.a.r.b
        public boolean isDisposed() {
            return this.f3619g;
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f3619g) {
                return;
            }
            try {
                this.f3617b.run();
            } catch (Throwable th) {
                e.a.s.b.b(th);
                this.f3618f.dispose();
                throw e.a.u.h.c.c(th);
            }
        }
    }

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

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

            /* JADX INFO: renamed from: b, reason: collision with root package name */
            final Runnable f3620b;

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

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

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

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

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

            a(long j2, Runnable runnable, long j3, e.a.u.a.e eVar, long j4) {
                this.f3620b = runnable;
                this.f3621f = eVar;
                this.f3622g = j4;
                this.f3624i = j3;
                this.f3625j = j2;
            }

            /* JADX WARN: Removed duplicated region for block: B:10:0x0034  */
            @Override // java.lang.Runnable
            /*
                Code decompiled incorrectly, please refer to instructions dump.
                To view partially-correct add '--show-bad-code' argument
            */
            public void run() {
                /*
                    r10 = this;
                    java.lang.Runnable r0 = r10.f3620b
                    r0.run()
                    e.a.u.a.e r0 = r10.f3621f
                    boolean r0 = r0.isDisposed()
                    if (r0 != 0) goto L53
                    e.a.n$c r0 = e.a.n.c.this
                    java.util.concurrent.TimeUnit r1 = java.util.concurrent.TimeUnit.NANOSECONDS
                    long r0 = r0.a(r1)
                    long r2 = e.a.n.a
                    long r4 = r0 + r2
                    long r6 = r10.f3624i
                    int r4 = (r4 > r6 ? 1 : (r4 == r6 ? 0 : -1))
                    r8 = 1
                    if (r4 < 0) goto L34
                    long r4 = r10.f3622g
                    long r6 = r6 + r4
                    long r6 = r6 + r2
                    int r2 = (r0 > r6 ? 1 : (r0 == r6 ? 0 : -1))
                    if (r2 < 0) goto L2a
                    goto L34
                L2a:
                    long r2 = r10.f3625j
                    long r6 = r10.f3623h
                    long r6 = r6 + r8
                    r10.f3623h = r6
                    long r6 = r6 * r4
                    long r2 = r2 + r6
                    goto L43
                L34:
                    long r2 = r10.f3622g
                    long r4 = r0 + r2
                    long r6 = r10.f3623h
                    long r6 = r6 + r8
                    r10.f3623h = r6
                    long r2 = r2 * r6
                    long r2 = r4 - r2
                    r10.f3625j = r2
                    r2 = r4
                L43:
                    r10.f3624i = r0
                    long r2 = r2 - r0
                    e.a.u.a.e r0 = r10.f3621f
                    e.a.n$c r1 = e.a.n.c.this
                    java.util.concurrent.TimeUnit r4 = java.util.concurrent.TimeUnit.NANOSECONDS
                    e.a.r.b r1 = r1.c(r10, r2, r4)
                    r0.a(r1)
                L53:
                    return
                */
                throw new UnsupportedOperationException("Method not decompiled: e.a.n.c.a.run():void");
            }
        }

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

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

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

        public e.a.r.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
            e.a.u.a.e eVar = new e.a.u.a.e();
            e.a.u.a.e eVar2 = new e.a.u.a.e(eVar);
            Runnable runnableS = e.a.w.a.s(runnable);
            long nanos = timeUnit.toNanos(j3);
            long jA = a(TimeUnit.NANOSECONDS);
            e.a.r.b bVarC = c(new a(jA + timeUnit.toNanos(j2), runnableS, jA, eVar2, nanos), j2, timeUnit);
            if (bVarC == e.a.u.a.c.INSTANCE) {
                return bVarC;
            }
            eVar.a(bVarC);
            return eVar2;
        }
    }

    public abstract c a();

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

    public e.a.r.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        c cVarA = a();
        a aVar = new a(e.a.w.a.s(runnable), cVarA);
        cVarA.c(aVar, j2, timeUnit);
        return aVar;
    }

    public e.a.r.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        c cVarA = a();
        b bVar = new b(e.a.w.a.s(runnable), cVarA);
        e.a.r.b bVarD = cVarA.d(bVar, j2, j3, timeUnit);
        return bVarD == e.a.u.a.c.INSTANCE ? bVarD : bVar;
    }
}