package o.a;

import g.h.a.i;
import java.util.Objects;
import java.util.concurrent.TimeUnit;
import o.a.h.a.e;
import o.a.h.g.f;

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

    public static final class a implements o.a.e.b, Runnable {

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

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

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

        public a(Runnable runnable, c cVar) {
            this.f5948f = runnable;
            this.f5949m = cVar;
        }

        @Override // o.a.e.b
        public void b() {
            if (this.f5950n == Thread.currentThread()) {
                c cVar = this.f5949m;
                if (cVar instanceof f) {
                    f fVar = (f) cVar;
                    if (fVar.f6072m) {
                        return;
                    }
                    fVar.f6072m = true;
                    fVar.f6071f.shutdown();
                    return;
                }
            }
            this.f5949m.b();
        }

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

    public static final class b implements o.a.e.b, Runnable {

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

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

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

        public b(Runnable runnable, c cVar) {
            this.f5951f = runnable;
            this.f5952m = cVar;
        }

        @Override // o.a.e.b
        public void b() {
            this.f5953n = true;
            this.f5952m.b();
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f5953n) {
                return;
            }
            try {
                this.f5951f.run();
            } catch (Throwable th) {
                i.F3(th);
                this.f5952m.b();
                throw o.a.h.h.a.a(th);
            }
        }
    }

    public static abstract class c implements o.a.e.b {

        public final class a implements Runnable {

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

            /* JADX INFO: renamed from: m, reason: collision with root package name */
            public final e f5955m;

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

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

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

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

            public a(long j2, Runnable runnable, long j3, e eVar, long j4) {
                this.f5954f = runnable;
                this.f5955m = eVar;
                this.f5956n = j4;
                this.f5958p = j3;
                this.f5959q = j2;
            }

            /* JADX WARN: Removed duplicated region for block: B:13:0x003d  */
            @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.f5954f
                    r0.run()
                    o.a.h.a.e r0 = r12.f5955m
                    java.lang.Object r0 = r0.get()
                    o.a.e.b r0 = (o.a.e.b) r0
                    o.a.h.a.b r1 = o.a.h.a.b.DISPOSED
                    if (r0 != r1) goto L13
                    r0 = 1
                    goto L14
                L13:
                    r0 = 0
                L14:
                    if (r0 != 0) goto L59
                    o.a.d$c r0 = o.a.d.c.this
                    java.util.concurrent.TimeUnit r1 = java.util.concurrent.TimeUnit.NANOSECONDS
                    long r2 = r0.a(r1)
                    long r4 = o.a.d.a
                    long r6 = r2 + r4
                    long r8 = r12.f5958p
                    int r0 = (r6 > r8 ? 1 : (r6 == r8 ? 0 : -1))
                    r6 = 1
                    if (r0 < 0) goto L3d
                    long r10 = r12.f5956n
                    long r8 = r8 + r10
                    long r8 = r8 + r4
                    int r0 = (r2 > r8 ? 1 : (r2 == r8 ? 0 : -1))
                    if (r0 < 0) goto L33
                    goto L3d
                L33:
                    long r4 = r12.f5959q
                    long r8 = r12.f5957o
                    long r8 = r8 + r6
                    r12.f5957o = r8
                    long r8 = r8 * r10
                    long r8 = r8 + r4
                    goto L4b
                L3d:
                    long r4 = r12.f5956n
                    long r8 = r2 + r4
                    long r10 = r12.f5957o
                    long r10 = r10 + r6
                    r12.f5957o = r10
                    long r4 = r4 * r10
                    long r4 = r8 - r4
                    r12.f5959q = r4
                L4b:
                    r12.f5958p = r2
                    long r8 = r8 - r2
                    o.a.h.a.e r0 = r12.f5955m
                    o.a.d$c r2 = o.a.d.c.this
                    o.a.e.b r1 = r2.d(r12, r8, r1)
                    r0.a(r1)
                L59:
                    return
                */
                throw new UnsupportedOperationException("Method not decompiled: o.a.d.c.a.run():void");
            }
        }

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

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

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

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

    public abstract c a();

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

    public o.a.e.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        c cVarA = a();
        Objects.requireNonNull(runnable, "run is null");
        a aVar = new a(runnable, cVarA);
        cVarA.d(aVar, j2, timeUnit);
        return aVar;
    }

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