package d.a;

import a.a.a.a.c.n0;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes.dex */
public abstract class m {

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

    public static final class a implements d.a.p.b, Runnable {

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

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

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        public Thread f5651d;

        public a(Runnable runnable, c cVar) {
            this.f5649b = runnable;
            this.f5650c = cVar;
        }

        @Override // d.a.p.b
        public void dispose() {
            if (this.f5651d == Thread.currentThread()) {
                c cVar = this.f5650c;
                if (cVar instanceof d.a.s.g.f) {
                    d.a.s.g.f fVar = (d.a.s.g.f) cVar;
                    if (fVar.f5861c) {
                        return;
                    }
                    fVar.f5861c = true;
                    fVar.f5860b.shutdown();
                    return;
                }
            }
            this.f5650c.dispose();
        }

        @Override // d.a.p.b
        public boolean isDisposed() {
            return this.f5650c.isDisposed();
        }

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

    public static final class b implements d.a.p.b, Runnable {

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

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

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        public volatile boolean f5654d;

        public b(Runnable runnable, c cVar) {
            this.f5652b = runnable;
            this.f5653c = cVar;
        }

        @Override // d.a.p.b
        public void dispose() {
            this.f5654d = true;
            this.f5653c.dispose();
        }

        @Override // d.a.p.b
        public boolean isDisposed() {
            return this.f5654d;
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f5654d) {
                return;
            }
            try {
                this.f5652b.run();
            } catch (Throwable th) {
                n0.y(th);
                this.f5653c.dispose();
                throw d.a.s.h.d.a(th);
            }
        }
    }

    public static abstract class c implements d.a.p.b {

        public final class a implements Runnable {

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

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

            /* JADX INFO: renamed from: d, reason: collision with root package name */
            public final long f5657d;

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

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

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

            public a(long j2, Runnable runnable, long j3, d.a.s.a.e eVar, long j4) {
                this.f5655b = runnable;
                this.f5656c = eVar;
                this.f5657d = j4;
                this.f5659f = j3;
                this.f5660g = 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() {
                /*
                    r12 = this;
                    java.lang.Runnable r0 = r12.f5655b
                    r0.run()
                    d.a.s.a.e r0 = r12.f5656c
                    boolean r0 = r0.isDisposed()
                    if (r0 != 0) goto L53
                    d.a.m$c r0 = d.a.m.c.this
                    java.util.concurrent.TimeUnit r1 = java.util.concurrent.TimeUnit.NANOSECONDS
                    long r2 = r0.a(r1)
                    long r4 = d.a.m.f5648a
                    long r6 = r2 + r4
                    long r8 = r12.f5659f
                    int r0 = (r6 > r8 ? 1 : (r6 == r8 ? 0 : -1))
                    r6 = 1
                    if (r0 < 0) goto L34
                    long r10 = r12.f5657d
                    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.f5660g
                    long r8 = r12.f5658e
                    long r8 = r8 + r6
                    r12.f5658e = r8
                    long r8 = r8 * r10
                    long r8 = r8 + r4
                    goto L42
                L34:
                    long r4 = r12.f5657d
                    long r8 = r2 + r4
                    long r10 = r12.f5658e
                    long r10 = r10 + r6
                    r12.f5658e = r10
                    long r4 = r4 * r10
                    long r4 = r8 - r4
                    r12.f5660g = r4
                L42:
                    r12.f5659f = r2
                    long r8 = r8 - r2
                    d.a.s.a.e r0 = r12.f5656c
                    d.a.m$c r2 = d.a.m.c.this
                    d.a.p.b r1 = r2.c(r12, r8, r1)
                    java.util.Objects.requireNonNull(r0)
                    d.a.s.a.b.replace(r0, r1)
                L53:
                    return
                */
                throw new UnsupportedOperationException("Method not decompiled: d.a.m.c.a.run():void");
            }
        }

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

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

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

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

    public abstract c a();

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

    public d.a.p.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 d.a.p.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        c cVarA = a();
        b bVar = new b(runnable, cVarA);
        d.a.p.b bVarD = cVarA.d(bVar, j2, j3, timeUnit);
        return bVarD == d.a.s.a.c.INSTANCE ? bVarD : bVar;
    }
}