x$c$a.smali

.class final Lio/reactivex/x$c$a;
.super Ljava/lang/Object;
.source "Scheduler.java"

# interfaces
.implements Ljava/lang/Runnable;
.implements Lio/reactivex/f/a;


# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
    value = Lio/reactivex/x$c;
.end annotation

.annotation system Ldalvik/annotation/InnerClass;
    accessFlags = 0x10
    name = "a"
.end annotation


# instance fields
.field final a:Ljava/lang/Runnable;

.field final b:Lio/reactivex/internal/disposables/SequentialDisposable;

.field final c:J

.field d:J

.field e:J

.field f:J

.field final synthetic g:Lio/reactivex/x$c;


# direct methods
.method constructor <init>(Lio/reactivex/x$c;JLjava/lang/Runnable;JLio/reactivex/internal/disposables/SequentialDisposable;J)V
    .registers 10

    .line 1
    iput-object p1, p0, Lio/reactivex/x$c$a;->g:Lio/reactivex/x$c;

    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    .line 2
    iput-object p4, p0, Lio/reactivex/x$c$a;->a:Ljava/lang/Runnable;

    .line 3
    iput-object p7, p0, Lio/reactivex/x$c$a;->b:Lio/reactivex/internal/disposables/SequentialDisposable;

    .line 4
    iput-wide p8, p0, Lio/reactivex/x$c$a;->c:J

    .line 5
    iput-wide p5, p0, Lio/reactivex/x$c$a;->e:J

    .line 6
    iput-wide p2, p0, Lio/reactivex/x$c$a;->f:J

    return-void
.end method


# virtual methods
.method public run()V
    .registers 12

    .line 1
    iget-object v0, p0, Lio/reactivex/x$c$a;->a:Ljava/lang/Runnable;

    invoke-interface {v0}, Ljava/lang/Runnable;->run()V

    .line 2
    iget-object v0, p0, Lio/reactivex/x$c$a;->b:Lio/reactivex/internal/disposables/SequentialDisposable;

    invoke-virtual {v0}, Lio/reactivex/internal/disposables/SequentialDisposable;->isDisposed()Z

    move-result v0

    if-nez v0, :cond_55

    .line 3
    iget-object v0, p0, Lio/reactivex/x$c$a;->g:Lio/reactivex/x$c;

    sget-object v1, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;

    invoke-virtual {v0, v1}, Lio/reactivex/x$c;->a(Ljava/util/concurrent/TimeUnit;)J

    move-result-wide v0

    .line 4
    sget-wide v2, Lio/reactivex/x;->a:J

    add-long v4, v0, v2

    iget-wide v6, p0, Lio/reactivex/x$c$a;->e:J

    const-wide/16 v8, 0x1

    cmp-long v10, v4, v6

    if-ltz v10, :cond_35

    iget-wide v4, p0, Lio/reactivex/x$c$a;->c:J

    add-long/2addr v6, v4

    add-long/2addr v6, v2

    cmp-long v2, v0, v6

    if-ltz v2, :cond_2a

    goto :goto_35

    .line 5
    :cond_2a
    iget-wide v2, p0, Lio/reactivex/x$c$a;->f:J

    iget-wide v6, p0, Lio/reactivex/x$c$a;->d:J

    add-long/2addr v6, v8

    iput-wide v6, p0, Lio/reactivex/x$c$a;->d:J

    mul-long v6, v6, v4

    add-long/2addr v2, v6

    goto :goto_45

    .line 6
    :cond_35
    :goto_35
    iget-wide v2, p0, Lio/reactivex/x$c$a;->c:J

    add-long v4, v0, v2

    .line 7
    iget-wide v6, p0, Lio/reactivex/x$c$a;->d:J

    add-long/2addr v6, v8

    iput-wide v6, p0, Lio/reactivex/x$c$a;->d:J

    mul-long v2, v2, v6

    sub-long v2, v4, v2

    iput-wide v2, p0, Lio/reactivex/x$c$a;->f:J

    move-wide v2, v4

    .line 8
    :goto_45
    iput-wide v0, p0, Lio/reactivex/x$c$a;->e:J

    sub-long/2addr v2, v0

    .line 9
    iget-object v0, p0, Lio/reactivex/x$c$a;->b:Lio/reactivex/internal/disposables/SequentialDisposable;

    iget-object v1, p0, Lio/reactivex/x$c$a;->g:Lio/reactivex/x$c;

    sget-object v4, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;

    invoke-virtual {v1, p0, v2, v3, v4}, Lio/reactivex/x$c;->a(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/b;

    move-result-object v1

    invoke-virtual {v0, v1}, Lio/reactivex/internal/disposables/SequentialDisposable;->replace(Lio/reactivex/disposables/b;)Z

    :cond_55
    return-void
.end method