2022-06-10 21:38:30 +09:00

263 lines
5.2 KiB
Smali

.class public final Lki/c;
.super Lai/o0;
.source "TestScheduler.java"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lki/c$a;,
Lki/c$b;
}
.end annotation
# instance fields
.field public final b:Ljava/util/Queue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Queue<",
"Lki/c$b;",
">;"
}
.end annotation
.end field
.field public c:J
.field public volatile d:J
# direct methods
.method public constructor <init>()V
.locals 2
.line 1
invoke-direct {p0}, Lai/o0;-><init>()V
.line 2
new-instance v0, Ljava/util/concurrent/PriorityBlockingQueue;
const/16 v1, 0xb
invoke-direct {v0, v1}, Ljava/util/concurrent/PriorityBlockingQueue;-><init>(I)V
iput-object v0, p0, Lki/c;->b:Ljava/util/Queue;
return-void
.end method
.method public constructor <init>(JLjava/util/concurrent/TimeUnit;)V
.locals 2
.annotation system Ldalvik/annotation/MethodParameters;
accessFlags = {
0x0,
0x0
}
names = {
"delayTime",
"unit"
}
.end annotation
.line 3
invoke-direct {p0}, Lai/o0;-><init>()V
.line 4
new-instance v0, Ljava/util/concurrent/PriorityBlockingQueue;
const/16 v1, 0xb
invoke-direct {v0, v1}, Ljava/util/concurrent/PriorityBlockingQueue;-><init>(I)V
iput-object v0, p0, Lki/c;->b:Ljava/util/Queue;
.line 5
invoke-virtual {p3, p1, p2}, Ljava/util/concurrent/TimeUnit;->toNanos(J)J
move-result-wide p1
iput-wide p1, p0, Lki/c;->d:J
return-void
.end method
# virtual methods
.method public d()Lai/o0$c;
.locals 1
.annotation build Lio/reactivex/rxjava3/annotations/NonNull;
.end annotation
.line 1
new-instance v0, Lki/c$a;
invoke-direct {v0, p0}, Lki/c$a;-><init>(Lki/c;)V
return-object v0
.end method
.method public e(Ljava/util/concurrent/TimeUnit;)J
.locals 3
.param p1 # Ljava/util/concurrent/TimeUnit;
.annotation build Lio/reactivex/rxjava3/annotations/NonNull;
.end annotation
.end param
.annotation system Ldalvik/annotation/MethodParameters;
accessFlags = {
0x0
}
names = {
"unit"
}
.end annotation
.line 1
iget-wide v0, p0, Lki/c;->d:J
sget-object v2, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {p1, v0, v1, v2}, Ljava/util/concurrent/TimeUnit;->convert(JLjava/util/concurrent/TimeUnit;)J
move-result-wide v0
return-wide v0
.end method
.method public u(JLjava/util/concurrent/TimeUnit;)V
.locals 2
.annotation system Ldalvik/annotation/MethodParameters;
accessFlags = {
0x0,
0x0
}
names = {
"delayTime",
"unit"
}
.end annotation
.line 1
iget-wide v0, p0, Lki/c;->d:J
invoke-virtual {p3, p1, p2}, Ljava/util/concurrent/TimeUnit;->toNanos(J)J
move-result-wide p1
add-long/2addr p1, v0
sget-object p3, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {p0, p1, p2, p3}, Lki/c;->v(JLjava/util/concurrent/TimeUnit;)V
return-void
.end method
.method public v(JLjava/util/concurrent/TimeUnit;)V
.locals 0
.annotation system Ldalvik/annotation/MethodParameters;
accessFlags = {
0x0,
0x0
}
names = {
"delayTime",
"unit"
}
.end annotation
.line 1
invoke-virtual {p3, p1, p2}, Ljava/util/concurrent/TimeUnit;->toNanos(J)J
move-result-wide p1
.line 2
invoke-virtual {p0, p1, p2}, Lki/c;->x(J)V
return-void
.end method
.method public w()V
.locals 2
.line 1
iget-wide v0, p0, Lki/c;->d:J
invoke-virtual {p0, v0, v1}, Lki/c;->x(J)V
return-void
.end method
.method public final x(J)V
.locals 5
.annotation system Ldalvik/annotation/MethodParameters;
accessFlags = {
0x0
}
names = {
"targetTimeInNanoseconds"
}
.end annotation
.line 1
:cond_0
:goto_0
iget-object v0, p0, Lki/c;->b:Ljava/util/Queue;
invoke-interface {v0}, Ljava/util/Queue;->peek()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lki/c$b;
if-eqz v0, :cond_3
.line 2
iget-wide v1, v0, Lki/c$b;->a:J
cmp-long v3, v1, p1
if-lez v3, :cond_1
goto :goto_1
:cond_1
const-wide/16 v3, 0x0
cmp-long v3, v1, v3
if-nez v3, :cond_2
.line 3
iget-wide v1, p0, Lki/c;->d:J
:cond_2
iput-wide v1, p0, Lki/c;->d:J
.line 4
iget-object v1, p0, Lki/c;->b:Ljava/util/Queue;
invoke-interface {v1, v0}, Ljava/util/Queue;->remove(Ljava/lang/Object;)Z
.line 5
iget-object v1, v0, Lki/c$b;->c:Lki/c$a;
iget-boolean v1, v1, Lki/c$a;->a:Z
if-nez v1, :cond_0
.line 6
iget-object v0, v0, Lki/c$b;->b:Ljava/lang/Runnable;
invoke-interface {v0}, Ljava/lang/Runnable;->run()V
goto :goto_0
.line 7
:cond_3
:goto_1
iput-wide p1, p0, Lki/c;->d:J
return-void
.end method