apkfuckery/com.discord/smali_classes2/rx/d/a.smali
2019-02-04 21:08:30 +01:00

216 lines
4.4 KiB
Smali

.class public final Lrx/d/a;
.super Ljava/lang/Object;
# static fields
.field private static final cnd:Ljava/util/concurrent/atomic/AtomicReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReference<",
"Lrx/d/a;",
">;"
}
.end annotation
.end field
# instance fields
.field private final cvp:Lrx/Scheduler;
.field private final cvq:Lrx/Scheduler;
.field private final cvr:Lrx/Scheduler;
# direct methods
.method static constructor <clinit>()V
.locals 1
new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
sput-object v0, Lrx/d/a;->cnd:Ljava/util/concurrent/atomic/AtomicReference;
return-void
.end method
.method private constructor <init>()V
.locals 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
invoke-static {}, Lrx/c/f;->LT()Lrx/c/f;
move-result-object v0
invoke-virtual {v0}, Lrx/c/f;->LY()Lrx/c/g;
invoke-static {}, Lrx/c/g;->LZ()Lrx/Scheduler;
move-result-object v0
iput-object v0, p0, Lrx/d/a;->cvp:Lrx/Scheduler;
invoke-static {}, Lrx/c/g;->Ma()Lrx/Scheduler;
move-result-object v0
iput-object v0, p0, Lrx/d/a;->cvq:Lrx/Scheduler;
invoke-static {}, Lrx/c/g;->Mb()Lrx/Scheduler;
move-result-object v0
iput-object v0, p0, Lrx/d/a;->cvr:Lrx/Scheduler;
return-void
.end method
.method private static Me()Lrx/d/a;
.locals 3
:goto_0
sget-object v0, Lrx/d/a;->cnd:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lrx/d/a;
if-eqz v0, :cond_0
return-object v0
:cond_0
new-instance v0, Lrx/d/a;
invoke-direct {v0}, Lrx/d/a;-><init>()V
sget-object v1, Lrx/d/a;->cnd:Ljava/util/concurrent/atomic/AtomicReference;
const/4 v2, 0x0
invoke-virtual {v1, v2, v0}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v1
if-eqz v1, :cond_1
return-object v0
:cond_1
invoke-direct {v0}, Lrx/d/a;->Mi()V
goto :goto_0
.end method
.method public static Mf()Lrx/Scheduler;
.locals 1
sget-object v0, Lrx/internal/c/m;->ctk:Lrx/internal/c/m;
return-object v0
.end method
.method public static Mg()Lrx/Scheduler;
.locals 1
invoke-static {}, Lrx/d/a;->Me()Lrx/d/a;
move-result-object v0
iget-object v0, v0, Lrx/d/a;->cvp:Lrx/Scheduler;
invoke-static {v0}, Lrx/c/c;->d(Lrx/Scheduler;)Lrx/Scheduler;
move-result-object v0
return-object v0
.end method
.method public static Mh()Lrx/Scheduler;
.locals 1
invoke-static {}, Lrx/d/a;->Me()Lrx/d/a;
move-result-object v0
iget-object v0, v0, Lrx/d/a;->cvq:Lrx/Scheduler;
invoke-static {v0}, Lrx/c/c;->e(Lrx/Scheduler;)Lrx/Scheduler;
move-result-object v0
return-object v0
.end method
.method private declared-synchronized Mi()V
.locals 1
monitor-enter p0
:try_start_0
iget-object v0, p0, Lrx/d/a;->cvp:Lrx/Scheduler;
instance-of v0, v0, Lrx/internal/c/k;
if-eqz v0, :cond_0
iget-object v0, p0, Lrx/d/a;->cvp:Lrx/Scheduler;
check-cast v0, Lrx/internal/c/k;
invoke-interface {v0}, Lrx/internal/c/k;->shutdown()V
:cond_0
iget-object v0, p0, Lrx/d/a;->cvq:Lrx/Scheduler;
instance-of v0, v0, Lrx/internal/c/k;
if-eqz v0, :cond_1
iget-object v0, p0, Lrx/d/a;->cvq:Lrx/Scheduler;
check-cast v0, Lrx/internal/c/k;
invoke-interface {v0}, Lrx/internal/c/k;->shutdown()V
:cond_1
iget-object v0, p0, Lrx/d/a;->cvr:Lrx/Scheduler;
instance-of v0, v0, Lrx/internal/c/k;
if-eqz v0, :cond_2
iget-object v0, p0, Lrx/d/a;->cvr:Lrx/Scheduler;
check-cast v0, Lrx/internal/c/k;
invoke-interface {v0}, Lrx/internal/c/k;->shutdown()V
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
:cond_2
monitor-exit p0
return-void
:catchall_0
move-exception v0
monitor-exit p0
throw v0
.end method
.method public static b(Ljava/util/concurrent/Executor;)Lrx/Scheduler;
.locals 1
new-instance v0, Lrx/internal/c/c;
invoke-direct {v0, p0}, Lrx/internal/c/c;-><init>(Ljava/util/concurrent/Executor;)V
return-object v0
.end method