335 lines
6.6 KiB
Smali
335 lines
6.6 KiB
Smali
.class public final Lio/reactivex/rxjava3/internal/util/b;
|
|
.super Ljava/lang/Object;
|
|
.source "BackpressureHelper.java"
|
|
|
|
|
|
# direct methods
|
|
.method public constructor <init>()V
|
|
.locals 2
|
|
|
|
.line 1
|
|
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
|
|
|
|
.line 2
|
|
new-instance v0, Ljava/lang/IllegalStateException;
|
|
|
|
const-string v1, "No instances!"
|
|
|
|
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
|
|
|
|
throw v0
|
|
.end method
|
|
|
|
.method public static a(Ljava/util/concurrent/atomic/AtomicLong;J)J
|
|
.locals 5
|
|
.param p0 # Ljava/util/concurrent/atomic/AtomicLong;
|
|
.annotation build Lio/reactivex/rxjava3/annotations/NonNull;
|
|
.end annotation
|
|
.end param
|
|
.annotation system Ldalvik/annotation/MethodParameters;
|
|
accessFlags = {
|
|
0x0,
|
|
0x0
|
|
}
|
|
names = {
|
|
"requested",
|
|
"n"
|
|
}
|
|
.end annotation
|
|
|
|
.line 1
|
|
:cond_0
|
|
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
|
|
|
|
move-result-wide v0
|
|
|
|
const-wide v2, 0x7fffffffffffffffL
|
|
|
|
cmp-long v4, v0, v2
|
|
|
|
if-nez v4, :cond_1
|
|
|
|
return-wide v2
|
|
|
|
.line 2
|
|
:cond_1
|
|
invoke-static {v0, v1, p1, p2}, Lio/reactivex/rxjava3/internal/util/b;->c(JJ)J
|
|
|
|
move-result-wide v2
|
|
|
|
.line 3
|
|
invoke-virtual {p0, v0, v1, v2, v3}, Ljava/util/concurrent/atomic/AtomicLong;->compareAndSet(JJ)Z
|
|
|
|
move-result v2
|
|
|
|
if-eqz v2, :cond_0
|
|
|
|
return-wide v0
|
|
.end method
|
|
|
|
.method public static b(Ljava/util/concurrent/atomic/AtomicLong;J)J
|
|
.locals 5
|
|
.param p0 # Ljava/util/concurrent/atomic/AtomicLong;
|
|
.annotation build Lio/reactivex/rxjava3/annotations/NonNull;
|
|
.end annotation
|
|
.end param
|
|
.annotation system Ldalvik/annotation/MethodParameters;
|
|
accessFlags = {
|
|
0x0,
|
|
0x0
|
|
}
|
|
names = {
|
|
"requested",
|
|
"n"
|
|
}
|
|
.end annotation
|
|
|
|
.line 1
|
|
:cond_0
|
|
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
|
|
|
|
move-result-wide v0
|
|
|
|
const-wide/high16 v2, -0x8000000000000000L
|
|
|
|
cmp-long v4, v0, v2
|
|
|
|
if-nez v4, :cond_1
|
|
|
|
return-wide v2
|
|
|
|
:cond_1
|
|
const-wide v2, 0x7fffffffffffffffL
|
|
|
|
cmp-long v4, v0, v2
|
|
|
|
if-nez v4, :cond_2
|
|
|
|
return-wide v2
|
|
|
|
.line 2
|
|
:cond_2
|
|
invoke-static {v0, v1, p1, p2}, Lio/reactivex/rxjava3/internal/util/b;->c(JJ)J
|
|
|
|
move-result-wide v2
|
|
|
|
.line 3
|
|
invoke-virtual {p0, v0, v1, v2, v3}, Ljava/util/concurrent/atomic/AtomicLong;->compareAndSet(JJ)Z
|
|
|
|
move-result v2
|
|
|
|
if-eqz v2, :cond_0
|
|
|
|
return-wide v0
|
|
.end method
|
|
|
|
.method public static c(JJ)J
|
|
.locals 0
|
|
.annotation system Ldalvik/annotation/MethodParameters;
|
|
accessFlags = {
|
|
0x0,
|
|
0x0
|
|
}
|
|
names = {
|
|
"a",
|
|
"b"
|
|
}
|
|
.end annotation
|
|
|
|
add-long/2addr p0, p2
|
|
|
|
const-wide/16 p2, 0x0
|
|
|
|
cmp-long p2, p0, p2
|
|
|
|
if-gez p2, :cond_0
|
|
|
|
const-wide p0, 0x7fffffffffffffffL
|
|
|
|
:cond_0
|
|
return-wide p0
|
|
.end method
|
|
|
|
.method public static d(JJ)J
|
|
.locals 6
|
|
.annotation system Ldalvik/annotation/MethodParameters;
|
|
accessFlags = {
|
|
0x0,
|
|
0x0
|
|
}
|
|
names = {
|
|
"a",
|
|
"b"
|
|
}
|
|
.end annotation
|
|
|
|
mul-long v0, p0, p2
|
|
|
|
or-long v2, p0, p2
|
|
|
|
const/16 v4, 0x1f
|
|
|
|
ushr-long/2addr v2, v4
|
|
|
|
const-wide/16 v4, 0x0
|
|
|
|
cmp-long v2, v2, v4
|
|
|
|
if-eqz v2, :cond_0
|
|
|
|
.line 1
|
|
div-long p0, v0, p0
|
|
|
|
cmp-long p0, p0, p2
|
|
|
|
if-eqz p0, :cond_0
|
|
|
|
const-wide p0, 0x7fffffffffffffffL
|
|
|
|
return-wide p0
|
|
|
|
:cond_0
|
|
return-wide v0
|
|
.end method
|
|
|
|
.method public static e(Ljava/util/concurrent/atomic/AtomicLong;J)J
|
|
.locals 8
|
|
.param p0 # Ljava/util/concurrent/atomic/AtomicLong;
|
|
.annotation build Lio/reactivex/rxjava3/annotations/NonNull;
|
|
.end annotation
|
|
.end param
|
|
.annotation system Ldalvik/annotation/MethodParameters;
|
|
accessFlags = {
|
|
0x0,
|
|
0x0
|
|
}
|
|
names = {
|
|
"requested",
|
|
"n"
|
|
}
|
|
.end annotation
|
|
|
|
.line 1
|
|
:cond_0
|
|
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
|
|
|
|
move-result-wide v0
|
|
|
|
const-wide v2, 0x7fffffffffffffffL
|
|
|
|
cmp-long v4, v0, v2
|
|
|
|
if-nez v4, :cond_1
|
|
|
|
return-wide v2
|
|
|
|
:cond_1
|
|
sub-long v2, v0, p1
|
|
|
|
const-wide/16 v4, 0x0
|
|
|
|
cmp-long v6, v2, v4
|
|
|
|
if-gez v6, :cond_2
|
|
|
|
.line 2
|
|
new-instance v6, Ljava/lang/IllegalStateException;
|
|
|
|
const-string v7, "More produced than requested: "
|
|
|
|
invoke-static {v7, v2, v3}, Landroidx/camera/core/l1;->a(Ljava/lang/String;J)Ljava/lang/String;
|
|
|
|
move-result-object v2
|
|
|
|
invoke-direct {v6, v2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
|
|
|
|
invoke-static {v6}, Lji/a;->Y(Ljava/lang/Throwable;)V
|
|
|
|
move-wide v2, v4
|
|
|
|
.line 3
|
|
:cond_2
|
|
invoke-virtual {p0, v0, v1, v2, v3}, Ljava/util/concurrent/atomic/AtomicLong;->compareAndSet(JJ)Z
|
|
|
|
move-result v0
|
|
|
|
if-eqz v0, :cond_0
|
|
|
|
return-wide v2
|
|
.end method
|
|
|
|
.method public static f(Ljava/util/concurrent/atomic/AtomicLong;J)J
|
|
.locals 8
|
|
.param p0 # Ljava/util/concurrent/atomic/AtomicLong;
|
|
.annotation build Lio/reactivex/rxjava3/annotations/NonNull;
|
|
.end annotation
|
|
.end param
|
|
.annotation system Ldalvik/annotation/MethodParameters;
|
|
accessFlags = {
|
|
0x0,
|
|
0x0
|
|
}
|
|
names = {
|
|
"requested",
|
|
"n"
|
|
}
|
|
.end annotation
|
|
|
|
.line 1
|
|
:cond_0
|
|
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
|
|
|
|
move-result-wide v0
|
|
|
|
const-wide/high16 v2, -0x8000000000000000L
|
|
|
|
cmp-long v4, v0, v2
|
|
|
|
if-nez v4, :cond_1
|
|
|
|
return-wide v2
|
|
|
|
:cond_1
|
|
const-wide v2, 0x7fffffffffffffffL
|
|
|
|
cmp-long v4, v0, v2
|
|
|
|
if-nez v4, :cond_2
|
|
|
|
return-wide v2
|
|
|
|
:cond_2
|
|
sub-long v2, v0, p1
|
|
|
|
const-wide/16 v4, 0x0
|
|
|
|
cmp-long v6, v2, v4
|
|
|
|
if-gez v6, :cond_3
|
|
|
|
.line 2
|
|
new-instance v6, Ljava/lang/IllegalStateException;
|
|
|
|
const-string v7, "More produced than requested: "
|
|
|
|
invoke-static {v7, v2, v3}, Landroidx/camera/core/l1;->a(Ljava/lang/String;J)Ljava/lang/String;
|
|
|
|
move-result-object v2
|
|
|
|
invoke-direct {v6, v2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
|
|
|
|
invoke-static {v6}, Lji/a;->Y(Ljava/lang/Throwable;)V
|
|
|
|
move-wide v2, v4
|
|
|
|
.line 3
|
|
:cond_3
|
|
invoke-virtual {p0, v0, v1, v2, v3}, Ljava/util/concurrent/atomic/AtomicLong;->compareAndSet(JJ)Z
|
|
|
|
move-result v0
|
|
|
|
if-eqz v0, :cond_0
|
|
|
|
return-wide v2
|
|
.end method
|