changed repo structure

This commit is contained in:
2025-06-06 02:50:04 +02:00
parent e887de976a
commit 6e6ee357b8
8848 changed files with 2089898 additions and 9 deletions

View File

@@ -0,0 +1,14 @@
.class synthetic Landroidx/concurrent/futures/AbstractResolvableFuture$1;
.super Ljava/lang/Object;
.source "AbstractResolvableFuture.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/AbstractResolvableFuture;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x1008
name = null
.end annotation

View File

@@ -0,0 +1,81 @@
.class abstract Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;
.super Ljava/lang/Object;
.source "AbstractResolvableFuture.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/AbstractResolvableFuture;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x40a
name = "AtomicHelper"
.end annotation
# direct methods
.method private constructor <init>()V
.locals 0
.line 1069
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
return-void
.end method
.method synthetic constructor <init>(Landroidx/concurrent/futures/AbstractResolvableFuture$1;)V
.locals 0
.line 1069
invoke-direct {p0}, Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;-><init>()V
return-void
.end method
# virtual methods
.method abstract casListeners(Landroidx/concurrent/futures/AbstractResolvableFuture;Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;)Z
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"*>;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;",
")Z"
}
.end annotation
.end method
.method abstract casValue(Landroidx/concurrent/futures/AbstractResolvableFuture;Ljava/lang/Object;Ljava/lang/Object;)Z
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"*>;",
"Ljava/lang/Object;",
"Ljava/lang/Object;",
")Z"
}
.end annotation
.end method
.method abstract casWaiters(Landroidx/concurrent/futures/AbstractResolvableFuture;Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;)Z
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"*>;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
")Z"
}
.end annotation
.end method
.method abstract putNext(Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;)V
.end method
.method abstract putThread(Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Ljava/lang/Thread;)V
.end method

View File

@@ -0,0 +1,84 @@
.class final Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;
.super Ljava/lang/Object;
.source "AbstractResolvableFuture.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/AbstractResolvableFuture;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x1a
name = "Cancellation"
.end annotation
# static fields
.field static final CAUSELESS_CANCELLED:Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;
.field static final CAUSELESS_INTERRUPTED:Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;
# instance fields
.field final cause:Ljava/lang/Throwable;
.field final wasInterrupted:Z
# direct methods
.method static constructor <clinit>()V
.locals 3
.line 243
sget-boolean v0, Landroidx/concurrent/futures/AbstractResolvableFuture;->GENERATE_CANCELLATION_CAUSES:Z
const/4 v1, 0x0
if-eqz v0, :cond_0
.line 244
sput-object v1, Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;->CAUSELESS_CANCELLED:Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;
.line 245
sput-object v1, Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;->CAUSELESS_INTERRUPTED:Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;
goto :goto_0
.line 247
:cond_0
new-instance v0, Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;
const/4 v2, 0x0
invoke-direct {v0, v2, v1}, Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;-><init>(ZLjava/lang/Throwable;)V
sput-object v0, Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;->CAUSELESS_CANCELLED:Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;
.line 248
new-instance v0, Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;
const/4 v2, 0x1
invoke-direct {v0, v2, v1}, Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;-><init>(ZLjava/lang/Throwable;)V
sput-object v0, Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;->CAUSELESS_INTERRUPTED:Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;
:goto_0
return-void
.end method
.method constructor <init>(ZLjava/lang/Throwable;)V
.locals 0
.line 256
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 257
iput-boolean p1, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;->wasInterrupted:Z
.line 258
iput-object p2, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$Cancellation;->cause:Ljava/lang/Throwable;
return-void
.end method

View File

@@ -0,0 +1,38 @@
.class Landroidx/concurrent/futures/AbstractResolvableFuture$Failure$1;
.super Ljava/lang/Throwable;
.source "AbstractResolvableFuture.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/AbstractResolvableFuture$Failure;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x0
name = null
.end annotation
# direct methods
.method constructor <init>(Ljava/lang/String;)V
.locals 0
.line 223
invoke-direct {p0, p1}, Ljava/lang/Throwable;-><init>(Ljava/lang/String;)V
return-void
.end method
# virtual methods
.method public declared-synchronized fillInStackTrace()Ljava/lang/Throwable;
.locals 0
monitor-enter p0
.line 226
monitor-exit p0
return-object p0
.end method

View File

@@ -0,0 +1,61 @@
.class final Landroidx/concurrent/futures/AbstractResolvableFuture$Failure;
.super Ljava/lang/Object;
.source "AbstractResolvableFuture.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/AbstractResolvableFuture;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x1a
name = "Failure"
.end annotation
# static fields
.field static final FALLBACK_INSTANCE:Landroidx/concurrent/futures/AbstractResolvableFuture$Failure;
# instance fields
.field final exception:Ljava/lang/Throwable;
# direct methods
.method static constructor <clinit>()V
.locals 3
.line 221
new-instance v0, Landroidx/concurrent/futures/AbstractResolvableFuture$Failure;
new-instance v1, Landroidx/concurrent/futures/AbstractResolvableFuture$Failure$1;
const-string v2, "Failure occurred while trying to finish a future."
invoke-direct {v1, v2}, Landroidx/concurrent/futures/AbstractResolvableFuture$Failure$1;-><init>(Ljava/lang/String;)V
invoke-direct {v0, v1}, Landroidx/concurrent/futures/AbstractResolvableFuture$Failure;-><init>(Ljava/lang/Throwable;)V
sput-object v0, Landroidx/concurrent/futures/AbstractResolvableFuture$Failure;->FALLBACK_INSTANCE:Landroidx/concurrent/futures/AbstractResolvableFuture$Failure;
return-void
.end method
.method constructor <init>(Ljava/lang/Throwable;)V
.locals 0
.line 231
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 232
invoke-static {p1}, Landroidx/concurrent/futures/AbstractResolvableFuture;->checkNotNull(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p1
check-cast p1, Ljava/lang/Throwable;
iput-object p1, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$Failure;->exception:Ljava/lang/Throwable;
return-void
.end method

View File

@@ -0,0 +1,58 @@
.class final Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;
.super Ljava/lang/Object;
.source "AbstractResolvableFuture.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/AbstractResolvableFuture;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x1a
name = "Listener"
.end annotation
# static fields
.field static final TOMBSTONE:Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;
# instance fields
.field final executor:Ljava/util/concurrent/Executor;
.field next:Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;
.field final task:Ljava/lang/Runnable;
# direct methods
.method static constructor <clinit>()V
.locals 2
.line 202
new-instance v0, Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;
const/4 v1, 0x0
invoke-direct {v0, v1, v1}, Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;-><init>(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
sput-object v0, Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;->TOMBSTONE:Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;
return-void
.end method
.method constructor <init>(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
.locals 0
.line 210
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 211
iput-object p1, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;->task:Ljava/lang/Runnable;
.line 212
iput-object p2, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;->executor:Ljava/util/concurrent/Executor;
return-void
.end method

View File

@@ -0,0 +1,32 @@
.class public final synthetic Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0;
.super Ljava/lang/Object;
.source "D8$$SyntheticClass"
# direct methods
.method public static synthetic m(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
.locals 1
.line 0
:cond_0
invoke-virtual {p0, p1, p2, p3}, Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v0
if-eqz v0, :cond_1
const/4 p0, 0x1
return p0
:cond_1
invoke-virtual {p0, p1}, Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;->get(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
if-eq v0, p2, :cond_0
const/4 p0, 0x0
return p0
.end method

View File

@@ -0,0 +1,217 @@
.class final Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;
.super Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;
.source "AbstractResolvableFuture.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/AbstractResolvableFuture;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x1a
name = "SafeAtomicHelper"
.end annotation
# instance fields
.field final listenersUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<",
"Landroidx/concurrent/futures/AbstractResolvableFuture;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;",
">;"
}
.end annotation
.end field
.field final valueUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<",
"Landroidx/concurrent/futures/AbstractResolvableFuture;",
"Ljava/lang/Object;",
">;"
}
.end annotation
.end field
.field final waiterNextUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
">;"
}
.end annotation
.end field
.field final waiterThreadUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
"Ljava/lang/Thread;",
">;"
}
.end annotation
.end field
.field final waitersUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<",
"Landroidx/concurrent/futures/AbstractResolvableFuture;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
">;"
}
.end annotation
.end field
# direct methods
.method constructor <init>(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;)V
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
"Ljava/lang/Thread;",
">;",
"Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
">;",
"Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<",
"Landroidx/concurrent/futures/AbstractResolvableFuture;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
">;",
"Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<",
"Landroidx/concurrent/futures/AbstractResolvableFuture;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;",
">;",
"Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<",
"Landroidx/concurrent/futures/AbstractResolvableFuture;",
"Ljava/lang/Object;",
">;)V"
}
.end annotation
const/4 v0, 0x0
.line 1105
invoke-direct {p0, v0}, Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;-><init>(Landroidx/concurrent/futures/AbstractResolvableFuture$1;)V
.line 1106
iput-object p1, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;->waiterThreadUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
.line 1107
iput-object p2, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;->waiterNextUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
.line 1108
iput-object p3, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;->waitersUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
.line 1109
iput-object p4, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;->listenersUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
.line 1110
iput-object p5, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;->valueUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
return-void
.end method
# virtual methods
.method casListeners(Landroidx/concurrent/futures/AbstractResolvableFuture;Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;)Z
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"*>;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;",
")Z"
}
.end annotation
.line 1130
iget-object v0, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;->listenersUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
invoke-static {v0, p1, p2, p3}, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0;->m(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
move-result p1
return p1
.end method
.method casValue(Landroidx/concurrent/futures/AbstractResolvableFuture;Ljava/lang/Object;Ljava/lang/Object;)Z
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"*>;",
"Ljava/lang/Object;",
"Ljava/lang/Object;",
")Z"
}
.end annotation
.line 1135
iget-object v0, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;->valueUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
invoke-static {v0, p1, p2, p3}, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0;->m(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
move-result p1
return p1
.end method
.method casWaiters(Landroidx/concurrent/futures/AbstractResolvableFuture;Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;)Z
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"*>;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
")Z"
}
.end annotation
.line 1125
iget-object v0, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;->waitersUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
invoke-static {v0, p1, p2, p3}, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper$$ExternalSyntheticBackportWithForwarding0;->m(Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
move-result p1
return p1
.end method
.method putNext(Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;)V
.locals 1
.line 1120
iget-object v0, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;->waiterNextUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
invoke-virtual {v0, p1, p2}, Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;->lazySet(Ljava/lang/Object;Ljava/lang/Object;)V
return-void
.end method
.method putThread(Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Ljava/lang/Thread;)V
.locals 1
.line 1115
iget-object v0, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SafeAtomicHelper;->waiterThreadUpdater:Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;
invoke-virtual {v0, p1, p2}, Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;->lazySet(Ljava/lang/Object;Ljava/lang/Object;)V
return-void
.end method

View File

@@ -0,0 +1,115 @@
.class final Landroidx/concurrent/futures/AbstractResolvableFuture$SetFuture;
.super Ljava/lang/Object;
.source "AbstractResolvableFuture.java"
# interfaces
.implements Ljava/lang/Runnable;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/AbstractResolvableFuture;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x1a
name = "SetFuture"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<V:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Ljava/lang/Runnable;"
}
.end annotation
# instance fields
.field final future:Lcom/google/common/util/concurrent/ListenableFuture;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lcom/google/common/util/concurrent/ListenableFuture<",
"+TV;>;"
}
.end annotation
.end field
.field final owner:Landroidx/concurrent/futures/AbstractResolvableFuture;
.annotation system Ldalvik/annotation/Signature;
value = {
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"TV;>;"
}
.end annotation
.end field
# direct methods
.method constructor <init>(Landroidx/concurrent/futures/AbstractResolvableFuture;Lcom/google/common/util/concurrent/ListenableFuture;)V
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"TV;>;",
"Lcom/google/common/util/concurrent/ListenableFuture<",
"+TV;>;)V"
}
.end annotation
.line 267
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 268
iput-object p1, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SetFuture;->owner:Landroidx/concurrent/futures/AbstractResolvableFuture;
.line 269
iput-object p2, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SetFuture;->future:Lcom/google/common/util/concurrent/ListenableFuture;
return-void
.end method
# virtual methods
.method public run()V
.locals 3
.line 274
iget-object v0, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SetFuture;->owner:Landroidx/concurrent/futures/AbstractResolvableFuture;
iget-object v0, v0, Landroidx/concurrent/futures/AbstractResolvableFuture;->value:Ljava/lang/Object;
if-eq v0, p0, :cond_0
return-void
.line 278
:cond_0
iget-object v0, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SetFuture;->future:Lcom/google/common/util/concurrent/ListenableFuture;
invoke-static {v0}, Landroidx/concurrent/futures/AbstractResolvableFuture;->getFutureValue(Lcom/google/common/util/concurrent/ListenableFuture;)Ljava/lang/Object;
move-result-object v0
.line 279
sget-object v1, Landroidx/concurrent/futures/AbstractResolvableFuture;->ATOMIC_HELPER:Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;
iget-object v2, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SetFuture;->owner:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v1, v2, p0, v0}, Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;->casValue(Landroidx/concurrent/futures/AbstractResolvableFuture;Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v0
if-eqz v0, :cond_1
.line 280
iget-object v0, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$SetFuture;->owner:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-static {v0}, Landroidx/concurrent/futures/AbstractResolvableFuture;->complete(Landroidx/concurrent/futures/AbstractResolvableFuture;)V
:cond_1
return-void
.end method

View File

@@ -0,0 +1,200 @@
.class final Landroidx/concurrent/futures/AbstractResolvableFuture$SynchronizedHelper;
.super Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;
.source "AbstractResolvableFuture.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/AbstractResolvableFuture;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x1a
name = "SynchronizedHelper"
.end annotation
# direct methods
.method constructor <init>()V
.locals 1
const/4 v0, 0x0
.line 1146
invoke-direct {p0, v0}, Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;-><init>(Landroidx/concurrent/futures/AbstractResolvableFuture$1;)V
return-void
.end method
# virtual methods
.method casListeners(Landroidx/concurrent/futures/AbstractResolvableFuture;Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;)Z
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"*>;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;",
")Z"
}
.end annotation
.line 1172
monitor-enter p1
.line 1173
:try_start_0
iget-object v0, p1, Landroidx/concurrent/futures/AbstractResolvableFuture;->listeners:Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;
if-ne v0, p2, :cond_0
.line 1174
iput-object p3, p1, Landroidx/concurrent/futures/AbstractResolvableFuture;->listeners:Landroidx/concurrent/futures/AbstractResolvableFuture$Listener;
.line 1175
monitor-exit p1
const/4 p1, 0x1
return p1
.line 1177
:cond_0
monitor-exit p1
const/4 p1, 0x0
return p1
:catchall_0
move-exception p2
.line 1178
monitor-exit p1
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
throw p2
.end method
.method casValue(Landroidx/concurrent/futures/AbstractResolvableFuture;Ljava/lang/Object;Ljava/lang/Object;)Z
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"*>;",
"Ljava/lang/Object;",
"Ljava/lang/Object;",
")Z"
}
.end annotation
.line 1183
monitor-enter p1
.line 1184
:try_start_0
iget-object v0, p1, Landroidx/concurrent/futures/AbstractResolvableFuture;->value:Ljava/lang/Object;
if-ne v0, p2, :cond_0
.line 1185
iput-object p3, p1, Landroidx/concurrent/futures/AbstractResolvableFuture;->value:Ljava/lang/Object;
.line 1186
monitor-exit p1
const/4 p1, 0x1
return p1
.line 1188
:cond_0
monitor-exit p1
const/4 p1, 0x0
return p1
:catchall_0
move-exception p2
.line 1189
monitor-exit p1
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
throw p2
.end method
.method casWaiters(Landroidx/concurrent/futures/AbstractResolvableFuture;Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;)Z
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"*>;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
"Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;",
")Z"
}
.end annotation
.line 1161
monitor-enter p1
.line 1162
:try_start_0
iget-object v0, p1, Landroidx/concurrent/futures/AbstractResolvableFuture;->waiters:Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;
if-ne v0, p2, :cond_0
.line 1163
iput-object p3, p1, Landroidx/concurrent/futures/AbstractResolvableFuture;->waiters:Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;
.line 1164
monitor-exit p1
const/4 p1, 0x1
return p1
.line 1166
:cond_0
monitor-exit p1
const/4 p1, 0x0
return p1
:catchall_0
move-exception p2
.line 1167
monitor-exit p1
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
throw p2
.end method
.method putNext(Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;)V
.locals 0
.line 1156
iput-object p2, p1, Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;->next:Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;
return-void
.end method
.method putThread(Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Ljava/lang/Thread;)V
.locals 0
.line 1151
iput-object p2, p1, Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;->thread:Ljava/lang/Thread;
return-void
.end method

View File

@@ -0,0 +1,101 @@
.class final Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;
.super Ljava/lang/Object;
.source "AbstractResolvableFuture.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/AbstractResolvableFuture;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x1a
name = "Waiter"
.end annotation
# static fields
.field static final TOMBSTONE:Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;
# instance fields
.field volatile next:Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;
.field volatile thread:Ljava/lang/Thread;
# direct methods
.method static constructor <clinit>()V
.locals 2
.line 121
new-instance v0, Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;
const/4 v1, 0x0
invoke-direct {v0, v1}, Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;-><init>(Z)V
sput-object v0, Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;->TOMBSTONE:Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;
return-void
.end method
.method constructor <init>()V
.locals 2
.line 135
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 137
sget-object v0, Landroidx/concurrent/futures/AbstractResolvableFuture;->ATOMIC_HELPER:Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;
invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;
move-result-object v1
invoke-virtual {v0, p0, v1}, Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;->putThread(Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Ljava/lang/Thread;)V
return-void
.end method
.method constructor <init>(Z)V
.locals 0
.line 132
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
return-void
.end method
# virtual methods
.method setNext(Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;)V
.locals 1
.line 143
sget-object v0, Landroidx/concurrent/futures/AbstractResolvableFuture;->ATOMIC_HELPER:Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;
invoke-virtual {v0, p0, p1}, Landroidx/concurrent/futures/AbstractResolvableFuture$AtomicHelper;->putNext(Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;)V
return-void
.end method
.method unpark()V
.locals 2
.line 151
iget-object v0, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;->thread:Ljava/lang/Thread;
if-eqz v0, :cond_0
const/4 v1, 0x0
.line 153
iput-object v1, p0, Landroidx/concurrent/futures/AbstractResolvableFuture$Waiter;->thread:Ljava/lang/Thread;
.line 154
invoke-static {v0}, Ljava/util/concurrent/locks/LockSupport;->unpark(Ljava/lang/Thread;)V
:cond_0
return-void
.end method

View File

@@ -0,0 +1,287 @@
.class public final Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;
.super Ljava/lang/Object;
.source "CallbackToFutureAdapter.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/CallbackToFutureAdapter;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x19
name = "Completer"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;"
}
.end annotation
# instance fields
.field private attemptedSetting:Z
.field private cancellationFuture:Landroidx/concurrent/futures/ResolvableFuture;
.annotation system Ldalvik/annotation/Signature;
value = {
"Landroidx/concurrent/futures/ResolvableFuture<",
"Ljava/lang/Void;",
">;"
}
.end annotation
.end field
.field future:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
.annotation system Ldalvik/annotation/Signature;
value = {
"Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture<",
"TT;>;"
}
.end annotation
.end field
.field tag:Ljava/lang/Object;
# direct methods
.method constructor <init>()V
.locals 1
.line 234
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 225
invoke-static {}, Landroidx/concurrent/futures/ResolvableFuture;->create()Landroidx/concurrent/futures/ResolvableFuture;
move-result-object v0
iput-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->cancellationFuture:Landroidx/concurrent/futures/ResolvableFuture;
return-void
.end method
.method private setCompletedNormally()V
.locals 1
const/4 v0, 0x0
.line 322
iput-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->tag:Ljava/lang/Object;
.line 323
iput-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->future:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
.line 324
iput-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->cancellationFuture:Landroidx/concurrent/futures/ResolvableFuture;
return-void
.end method
# virtual methods
.method public addCancellationListener(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
.locals 1
.line 306
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->cancellationFuture:Landroidx/concurrent/futures/ResolvableFuture;
if-eqz v0, :cond_0
.line 308
invoke-interface {v0, p1, p2}, Lcom/google/common/util/concurrent/ListenableFuture;->addListener(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
:cond_0
return-void
.end method
.method protected finalize()V
.locals 4
.line 332
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->future:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
if-eqz v0, :cond_0
.line 336
invoke-virtual {v0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->isDone()Z
move-result v1
if-nez v1, :cond_0
.line 337
new-instance v1, Landroidx/concurrent/futures/CallbackToFutureAdapter$FutureGarbageCollectedException;
new-instance v2, Ljava/lang/StringBuilder;
const-string v3, "The completer object was garbage collected - this future would otherwise never complete. The tag was: "
invoke-direct {v2, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v3, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->tag:Ljava/lang/Object;
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
move-result-object v2
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v2
invoke-direct {v1, v2}, Landroidx/concurrent/futures/CallbackToFutureAdapter$FutureGarbageCollectedException;-><init>(Ljava/lang/String;)V
invoke-virtual {v0, v1}, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->setException(Ljava/lang/Throwable;)Z
.line 344
:cond_0
iget-boolean v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->attemptedSetting:Z
if-nez v0, :cond_1
.line 345
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->cancellationFuture:Landroidx/concurrent/futures/ResolvableFuture;
if-eqz v0, :cond_1
const/4 v1, 0x0
.line 349
invoke-virtual {v0, v1}, Landroidx/concurrent/futures/ResolvableFuture;->set(Ljava/lang/Object;)Z
:cond_1
return-void
.end method
.method fireCancellationListeners()V
.locals 2
const/4 v0, 0x0
.line 313
iput-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->tag:Ljava/lang/Object;
.line 314
iput-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->future:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
.line 315
iget-object v1, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->cancellationFuture:Landroidx/concurrent/futures/ResolvableFuture;
invoke-virtual {v1, v0}, Landroidx/concurrent/futures/ResolvableFuture;->set(Ljava/lang/Object;)Z
return-void
.end method
.method public set(Ljava/lang/Object;)Z
.locals 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)Z"
}
.end annotation
const/4 v0, 0x1
.line 247
iput-boolean v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->attemptedSetting:Z
.line 248
iget-object v1, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->future:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
if-eqz v1, :cond_0
.line 249
invoke-virtual {v1, p1}, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->set(Ljava/lang/Object;)Z
move-result p1
if-eqz p1, :cond_0
goto :goto_0
:cond_0
const/4 v0, 0x0
:goto_0
if-eqz v0, :cond_1
.line 251
invoke-direct {p0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->setCompletedNormally()V
:cond_1
return v0
.end method
.method public setCancelled()Z
.locals 2
const/4 v0, 0x1
.line 285
iput-boolean v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->attemptedSetting:Z
.line 286
iget-object v1, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->future:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
if-eqz v1, :cond_0
.line 287
invoke-virtual {v1, v0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->cancelWithoutNotifyingCompleter(Z)Z
move-result v1
if-eqz v1, :cond_0
goto :goto_0
:cond_0
const/4 v0, 0x0
:goto_0
if-eqz v0, :cond_1
.line 290
invoke-direct {p0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->setCompletedNormally()V
:cond_1
return v0
.end method
.method public setException(Ljava/lang/Throwable;)Z
.locals 2
const/4 v0, 0x1
.line 267
iput-boolean v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->attemptedSetting:Z
.line 268
iget-object v1, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->future:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
if-eqz v1, :cond_0
.line 269
invoke-virtual {v1, p1}, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->setException(Ljava/lang/Throwable;)Z
move-result p1
if-eqz p1, :cond_0
goto :goto_0
:cond_0
const/4 v0, 0x0
:goto_0
if-eqz v0, :cond_1
.line 271
invoke-direct {p0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->setCompletedNormally()V
:cond_1
return v0
.end method

View File

@@ -0,0 +1,38 @@
.class final Landroidx/concurrent/futures/CallbackToFutureAdapter$FutureGarbageCollectedException;
.super Ljava/lang/Throwable;
.source "CallbackToFutureAdapter.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/CallbackToFutureAdapter;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "FutureGarbageCollectedException"
.end annotation
# direct methods
.method constructor <init>(Ljava/lang/String;)V
.locals 0
.line 357
invoke-direct {p0, p1}, Ljava/lang/Throwable;-><init>(Ljava/lang/String;)V
return-void
.end method
# virtual methods
.method public declared-synchronized fillInStackTrace()Ljava/lang/Throwable;
.locals 0
monitor-enter p0
.line 362
monitor-exit p0
return-object p0
.end method

View File

@@ -0,0 +1,42 @@
.class public interface abstract Landroidx/concurrent/futures/CallbackToFutureAdapter$Resolver;
.super Ljava/lang/Object;
.source "CallbackToFutureAdapter.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/CallbackToFutureAdapter;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x609
name = "Resolver"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;"
}
.end annotation
# virtual methods
.method public abstract attachCompleter(Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;)Ljava/lang/Object;
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer<",
"TT;>;)",
"Ljava/lang/Object;"
}
.end annotation
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/Exception;
}
.end annotation
.end method

View File

@@ -0,0 +1,88 @@
.class Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture$1;
.super Landroidx/concurrent/futures/AbstractResolvableFuture;
.source "CallbackToFutureAdapter.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x0
name = null
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"TT;>;"
}
.end annotation
# instance fields
.field final synthetic this$0:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
# direct methods
.method constructor <init>(Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;)V
.locals 0
.line 147
iput-object p1, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture$1;->this$0:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
invoke-direct {p0}, Landroidx/concurrent/futures/AbstractResolvableFuture;-><init>()V
return-void
.end method
# virtual methods
.method protected pendingToString()Ljava/lang/String;
.locals 3
.line 151
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture$1;->this$0:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
iget-object v0, v0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->completerWeakReference:Ljava/lang/ref/WeakReference;
invoke-virtual {v0}, Ljava/lang/ref/WeakReference;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;
if-nez v0, :cond_0
.line 153
const-string v0, "Completer object has been garbage collected, future will fail soon"
return-object v0
.line 155
:cond_0
new-instance v1, Ljava/lang/StringBuilder;
const-string v2, "tag=["
invoke-direct {v1, v2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget-object v0, v0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->tag:Ljava/lang/Object;
invoke-virtual {v1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
move-result-object v0
const-string v1, "]"
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
move-result-object v0
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
return-object v0
.end method

View File

@@ -0,0 +1,260 @@
.class final Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
.super Ljava/lang/Object;
.source "CallbackToFutureAdapter.java"
# interfaces
.implements Lcom/google/common/util/concurrent/ListenableFuture;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Landroidx/concurrent/futures/CallbackToFutureAdapter;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x1a
name = "SafeFuture"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lcom/google/common/util/concurrent/ListenableFuture<",
"TT;>;"
}
.end annotation
# instance fields
.field final completerWeakReference:Ljava/lang/ref/WeakReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/lang/ref/WeakReference<",
"Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer<",
"TT;>;>;"
}
.end annotation
.end field
.field private final delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
.annotation system Ldalvik/annotation/Signature;
value = {
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"TT;>;"
}
.end annotation
.end field
# direct methods
.method constructor <init>(Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;)V
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer<",
"TT;>;)V"
}
.end annotation
.line 143
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 147
new-instance v0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture$1;
invoke-direct {v0, p0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture$1;-><init>(Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;)V
iput-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
.line 144
new-instance v0, Ljava/lang/ref/WeakReference;
invoke-direct {v0, p1}, Ljava/lang/ref/WeakReference;-><init>(Ljava/lang/Object;)V
iput-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->completerWeakReference:Ljava/lang/ref/WeakReference;
return-void
.end method
# virtual methods
.method public addListener(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
.locals 1
.line 210
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v0, p1, p2}, Landroidx/concurrent/futures/AbstractResolvableFuture;->addListener(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
return-void
.end method
.method public cancel(Z)Z
.locals 2
.line 164
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->completerWeakReference:Ljava/lang/ref/WeakReference;
invoke-virtual {v0}, Ljava/lang/ref/WeakReference;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;
.line 165
iget-object v1, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v1, p1}, Landroidx/concurrent/futures/AbstractResolvableFuture;->cancel(Z)Z
move-result p1
if-eqz p1, :cond_0
if-eqz v0, :cond_0
.line 168
invoke-virtual {v0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->fireCancellationListeners()V
:cond_0
return p1
.end method
.method cancelWithoutNotifyingCompleter(Z)Z
.locals 1
.line 174
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v0, p1}, Landroidx/concurrent/futures/AbstractResolvableFuture;->cancel(Z)Z
move-result p1
return p1
.end method
.method public get()Ljava/lang/Object;
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()TT;"
}
.end annotation
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/InterruptedException;,
Ljava/util/concurrent/ExecutionException;
}
.end annotation
.line 199
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v0}, Landroidx/concurrent/futures/AbstractResolvableFuture;->get()Ljava/lang/Object;
move-result-object v0
return-object v0
.end method
.method public get(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(J",
"Ljava/util/concurrent/TimeUnit;",
")TT;"
}
.end annotation
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/InterruptedException;,
Ljava/util/concurrent/ExecutionException;,
Ljava/util/concurrent/TimeoutException;
}
.end annotation
.line 205
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v0, p1, p2, p3}, Landroidx/concurrent/futures/AbstractResolvableFuture;->get(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
move-result-object p1
return-object p1
.end method
.method public isCancelled()Z
.locals 1
.line 189
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v0}, Landroidx/concurrent/futures/AbstractResolvableFuture;->isCancelled()Z
move-result v0
return v0
.end method
.method public isDone()Z
.locals 1
.line 194
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v0}, Landroidx/concurrent/futures/AbstractResolvableFuture;->isDone()Z
move-result v0
return v0
.end method
.method set(Ljava/lang/Object;)Z
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)Z"
}
.end annotation
.line 180
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v0, p1}, Landroidx/concurrent/futures/AbstractResolvableFuture;->set(Ljava/lang/Object;)Z
move-result p1
return p1
.end method
.method setException(Ljava/lang/Throwable;)Z
.locals 1
.line 184
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v0, p1}, Landroidx/concurrent/futures/AbstractResolvableFuture;->setException(Ljava/lang/Throwable;)Z
move-result p1
return p1
.end method
.method public toString()Ljava/lang/String;
.locals 1
.line 215
iget-object v0, p0, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->delegate:Landroidx/concurrent/futures/AbstractResolvableFuture;
invoke-virtual {v0}, Landroidx/concurrent/futures/AbstractResolvableFuture;->toString()Ljava/lang/String;
move-result-object v0
return-object v0
.end method

View File

@@ -0,0 +1,85 @@
.class public final Landroidx/concurrent/futures/CallbackToFutureAdapter;
.super Ljava/lang/Object;
.source "CallbackToFutureAdapter.java"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Landroidx/concurrent/futures/CallbackToFutureAdapter$FutureGarbageCollectedException;,
Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;,
Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;,
Landroidx/concurrent/futures/CallbackToFutureAdapter$Resolver;
}
.end annotation
# direct methods
.method private constructor <init>()V
.locals 0
.line 77
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
return-void
.end method
.method public static getFuture(Landroidx/concurrent/futures/CallbackToFutureAdapter$Resolver;)Lcom/google/common/util/concurrent/ListenableFuture;
.locals 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Landroidx/concurrent/futures/CallbackToFutureAdapter$Resolver<",
"TT;>;)",
"Lcom/google/common/util/concurrent/ListenableFuture<",
"TT;>;"
}
.end annotation
.line 89
new-instance v0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;
invoke-direct {v0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;-><init>()V
.line 90
new-instance v1, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
invoke-direct {v1, v0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;-><init>(Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;)V
.line 91
iput-object v1, v0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->future:Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;
.line 98
invoke-virtual {p0}, Ljava/lang/Object;->getClass()Ljava/lang/Class;
move-result-object v2
iput-object v2, v0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->tag:Ljava/lang/Object;
.line 102
:try_start_0
invoke-interface {p0, v0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$Resolver;->attachCompleter(Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;)Ljava/lang/Object;
move-result-object p0
if-eqz p0, :cond_0
.line 104
iput-object p0, v0, Landroidx/concurrent/futures/CallbackToFutureAdapter$Completer;->tag:Ljava/lang/Object;
:try_end_0
.catch Ljava/lang/Exception; {:try_start_0 .. :try_end_0} :catch_0
goto :goto_0
:catch_0
move-exception p0
.line 107
invoke-virtual {v1, p0}, Landroidx/concurrent/futures/CallbackToFutureAdapter$SafeFuture;->setException(Ljava/lang/Throwable;)Z
:cond_0
:goto_0
return-object v1
.end method

View File

@@ -0,0 +1,113 @@
.class public final enum Landroidx/concurrent/futures/DirectExecutor;
.super Ljava/lang/Enum;
.source "DirectExecutor.java"
# interfaces
.implements Ljava/util/concurrent/Executor;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/lang/Enum<",
"Landroidx/concurrent/futures/DirectExecutor;",
">;",
"Ljava/util/concurrent/Executor;"
}
.end annotation
# static fields
.field private static final synthetic $VALUES:[Landroidx/concurrent/futures/DirectExecutor;
.field public static final enum INSTANCE:Landroidx/concurrent/futures/DirectExecutor;
# direct methods
.method static constructor <clinit>()V
.locals 3
.line 31
new-instance v0, Landroidx/concurrent/futures/DirectExecutor;
const-string v1, "INSTANCE"
const/4 v2, 0x0
invoke-direct {v0, v1, v2}, Landroidx/concurrent/futures/DirectExecutor;-><init>(Ljava/lang/String;I)V
sput-object v0, Landroidx/concurrent/futures/DirectExecutor;->INSTANCE:Landroidx/concurrent/futures/DirectExecutor;
.line 29
filled-new-array {v0}, [Landroidx/concurrent/futures/DirectExecutor;
move-result-object v0
sput-object v0, Landroidx/concurrent/futures/DirectExecutor;->$VALUES:[Landroidx/concurrent/futures/DirectExecutor;
return-void
.end method
.method private constructor <init>(Ljava/lang/String;I)V
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"()V"
}
.end annotation
.line 30
invoke-direct {p0, p1, p2}, Ljava/lang/Enum;-><init>(Ljava/lang/String;I)V
return-void
.end method
.method public static valueOf(Ljava/lang/String;)Landroidx/concurrent/futures/DirectExecutor;
.locals 1
.line 29
const-class v0, Landroidx/concurrent/futures/DirectExecutor;
invoke-static {v0, p0}, Ljava/lang/Enum;->valueOf(Ljava/lang/Class;Ljava/lang/String;)Ljava/lang/Enum;
move-result-object p0
check-cast p0, Landroidx/concurrent/futures/DirectExecutor;
return-object p0
.end method
.method public static values()[Landroidx/concurrent/futures/DirectExecutor;
.locals 1
.line 29
sget-object v0, Landroidx/concurrent/futures/DirectExecutor;->$VALUES:[Landroidx/concurrent/futures/DirectExecutor;
invoke-virtual {v0}, [Landroidx/concurrent/futures/DirectExecutor;->clone()Ljava/lang/Object;
move-result-object v0
check-cast v0, [Landroidx/concurrent/futures/DirectExecutor;
return-object v0
.end method
# virtual methods
.method public execute(Ljava/lang/Runnable;)V
.locals 0
.line 35
invoke-interface {p1}, Ljava/lang/Runnable;->run()V
return-void
.end method
.method public toString()Ljava/lang/String;
.locals 1
.line 40
const-string v0, "DirectExecutor"
return-object v0
.end method

View File

@@ -0,0 +1,93 @@
.class public final Landroidx/concurrent/futures/ResolvableFuture;
.super Landroidx/concurrent/futures/AbstractResolvableFuture;
.source "ResolvableFuture.java"
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<V:",
"Ljava/lang/Object;",
">",
"Landroidx/concurrent/futures/AbstractResolvableFuture<",
"TV;>;"
}
.end annotation
# direct methods
.method private constructor <init>()V
.locals 0
.line 63
invoke-direct {p0}, Landroidx/concurrent/futures/AbstractResolvableFuture;-><init>()V
return-void
.end method
.method public static create()Landroidx/concurrent/futures/ResolvableFuture;
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"<V:",
"Ljava/lang/Object;",
">()",
"Landroidx/concurrent/futures/ResolvableFuture<",
"TV;>;"
}
.end annotation
.line 45
new-instance v0, Landroidx/concurrent/futures/ResolvableFuture;
invoke-direct {v0}, Landroidx/concurrent/futures/ResolvableFuture;-><init>()V
return-object v0
.end method
# virtual methods
.method public set(Ljava/lang/Object;)Z
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"(TV;)Z"
}
.end annotation
.line 50
invoke-super {p0, p1}, Landroidx/concurrent/futures/AbstractResolvableFuture;->set(Ljava/lang/Object;)Z
move-result p1
return p1
.end method
.method public setException(Ljava/lang/Throwable;)Z
.locals 0
.line 55
invoke-super {p0, p1}, Landroidx/concurrent/futures/AbstractResolvableFuture;->setException(Ljava/lang/Throwable;)Z
move-result p1
return p1
.end method
.method public setFuture(Lcom/google/common/util/concurrent/ListenableFuture;)Z
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/google/common/util/concurrent/ListenableFuture<",
"+TV;>;)Z"
}
.end annotation
.line 60
invoke-super {p0, p1}, Landroidx/concurrent/futures/AbstractResolvableFuture;->setFuture(Lcom/google/common/util/concurrent/ListenableFuture;)Z
move-result p1
return p1
.end method