package c.a;

import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: Scheduler.java */
/* JADX INFO: loaded from: classes.dex */
public abstract class g {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    static final long f1707a = TimeUnit.MINUTES.toNanos(Long.getLong("rx2.scheduler.drift-tolerance", 15).longValue());

    /* JADX INFO: compiled from: Scheduler.java */
    static final class a implements Runnable, c.a.n.b {

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

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

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

        a(Runnable runnable, c cVar) {
            this.f1708c = runnable;
            this.f1709d = cVar;
        }

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

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

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

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

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

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

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

        @Override // c.a.n.b
        public void dispose() {
            this.f1713e = true;
            this.f1712d.dispose();
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f1713e) {
                return;
            }
            try {
                this.f1711c.run();
            } catch (Throwable th) {
                c.a.o.b.b(th);
                this.f1712d.dispose();
                throw c.a.q.h.b.a(th);
            }
        }
    }

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

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

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

            /* JADX INFO: renamed from: d, reason: collision with root package name */
            final c.a.q.a.e f1715d;

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

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

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

            a(long j, Runnable runnable, long j2, c.a.q.a.e eVar, long j3) {
                this.f1714c = runnable;
                this.f1715d = eVar;
                this.f1716e = j3;
                this.f1718g = j2;
                this.h = j;
            }

            /* 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() {
                /*
                    r12 = this;
                    java.lang.Runnable r0 = r12.f1714c
                    r0.run()
                    c.a.q.a.e r0 = r12.f1715d
                    boolean r0 = r0.a()
                    if (r0 != 0) goto L51
                    c.a.g$c r0 = c.a.g.c.this
                    java.util.concurrent.TimeUnit r1 = java.util.concurrent.TimeUnit.NANOSECONDS
                    long r2 = r0.a(r1)
                    long r4 = c.a.g.f1707a
                    long r6 = r2 + r4
                    long r8 = r12.f1718g
                    int r0 = (r6 > r8 ? 1 : (r6 == r8 ? 0 : -1))
                    r6 = 1
                    if (r0 < 0) goto L34
                    long r10 = r12.f1716e
                    long r8 = r8 + r10
                    long r8 = r8 + r4
                    int r0 = (r2 > r8 ? 1 : (r2 == r8 ? 0 : -1))
                    if (r0 < 0) goto L2a
                    goto L34
                L2a:
                    long r4 = r12.h
                    long r8 = r12.f1717f
                    long r8 = r8 + r6
                    r12.f1717f = r8
                    long r8 = r8 * r10
                    long r4 = r4 + r8
                    goto L43
                L34:
                    long r4 = r12.f1716e
                    long r8 = r2 + r4
                    long r10 = r12.f1717f
                    long r10 = r10 + r6
                    r12.f1717f = r10
                    long r4 = r4 * r10
                    long r4 = r8 - r4
                    r12.h = r4
                    r4 = r8
                L43:
                    r12.f1718g = r2
                    long r4 = r4 - r2
                    c.a.q.a.e r0 = r12.f1715d
                    c.a.g$c r2 = c.a.g.c.this
                    c.a.n.b r1 = r2.c(r12, r4, r1)
                    r0.b(r1)
                L51:
                    return
                */
                throw new UnsupportedOperationException("Method not decompiled: c.a.g.c.a.run():void");
            }
        }

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

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

        public abstract c.a.n.b c(Runnable runnable, long j, TimeUnit timeUnit);

        public c.a.n.b d(Runnable runnable, long j, long j2, TimeUnit timeUnit) {
            c.a.q.a.e eVar = new c.a.q.a.e();
            c.a.q.a.e eVar2 = new c.a.q.a.e(eVar);
            Runnable runnableQ = c.a.r.a.q(runnable);
            long nanos = timeUnit.toNanos(j2);
            long jA = a(TimeUnit.NANOSECONDS);
            c.a.n.b bVarC = c(new a(jA + timeUnit.toNanos(j), runnableQ, jA, eVar2, nanos), j, timeUnit);
            if (bVarC == c.a.q.a.c.INSTANCE) {
                return bVarC;
            }
            eVar.b(bVarC);
            return eVar2;
        }
    }

    public abstract c a();

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

    public c.a.n.b c(Runnable runnable, long j, TimeUnit timeUnit) {
        c cVarA = a();
        a aVar = new a(c.a.r.a.q(runnable), cVarA);
        cVarA.c(aVar, j, timeUnit);
        return aVar;
    }

    public c.a.n.b d(Runnable runnable, long j, long j2, TimeUnit timeUnit) {
        c cVarA = a();
        b bVar = new b(c.a.r.a.q(runnable), cVarA);
        c.a.n.b bVarD = cVarA.d(bVar, j, j2, timeUnit);
        return bVarD == c.a.q.a.c.INSTANCE ? bVarD : bVar;
    }
}