.class public Lcom/google/common/base/internal/Finalizer; .super Ljava/lang/Object; .source "Finalizer.java" # interfaces .implements Ljava/lang/Runnable; # static fields .field private static final FINALIZABLE_REFERENCE:Ljava/lang/String; = "com.google.common.base.FinalizableReference" .field private static final bigThreadConstructor:Ljava/lang/reflect/Constructor; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/lang/reflect/Constructor<", "Ljava/lang/Thread;", ">;" } .end annotation .annotation runtime Lorg/checkerframework/checker/nullness/compatqual/NullableDecl; .end annotation .end field .field private static final inheritableThreadLocals:Ljava/lang/reflect/Field; .annotation runtime Lorg/checkerframework/checker/nullness/compatqual/NullableDecl; .end annotation .end field .field private static final logger:Ljava/util/logging/Logger; # instance fields .field private final finalizableReferenceClassReference:Ljava/lang/ref/WeakReference; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/lang/ref/WeakReference<", "Ljava/lang/Class<", "*>;>;" } .end annotation .end field .field private final frqReference:Ljava/lang/ref/PhantomReference; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/lang/ref/PhantomReference<", "Ljava/lang/Object;", ">;" } .end annotation .end field .field private final queue:Ljava/lang/ref/ReferenceQueue; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/lang/ref/ReferenceQueue<", "Ljava/lang/Object;", ">;" } .end annotation .end field # direct methods .method public static constructor ()V .locals 1 .line 1 const-class v0, Lcom/google/common/base/internal/Finalizer; invoke-virtual {v0}, Ljava/lang/Class;->getName()Ljava/lang/String; move-result-object v0 invoke-static {v0}, Ljava/util/logging/Logger;->getLogger(Ljava/lang/String;)Ljava/util/logging/Logger; move-result-object v0 sput-object v0, Lcom/google/common/base/internal/Finalizer;->logger:Ljava/util/logging/Logger; .line 2 invoke-static {}, Lcom/google/common/base/internal/Finalizer;->getBigThreadConstructor()Ljava/lang/reflect/Constructor; move-result-object v0 sput-object v0, Lcom/google/common/base/internal/Finalizer;->bigThreadConstructor:Ljava/lang/reflect/Constructor; if-nez v0, :cond_0 .line 3 invoke-static {}, Lcom/google/common/base/internal/Finalizer;->getInheritableThreadLocalsField()Ljava/lang/reflect/Field; move-result-object v0 goto :goto_0 :cond_0 const/4 v0, 0x0 :goto_0 sput-object v0, Lcom/google/common/base/internal/Finalizer;->inheritableThreadLocals:Ljava/lang/reflect/Field; return-void .end method .method private constructor (Ljava/lang/Class;Ljava/lang/ref/ReferenceQueue;Ljava/lang/ref/PhantomReference;)V .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "*>;", "Ljava/lang/ref/ReferenceQueue<", "Ljava/lang/Object;", ">;", "Ljava/lang/ref/PhantomReference<", "Ljava/lang/Object;", ">;)V" } .end annotation .line 1 invoke-direct {p0}, Ljava/lang/Object;->()V .line 2 iput-object p2, p0, Lcom/google/common/base/internal/Finalizer;->queue:Ljava/lang/ref/ReferenceQueue; .line 3 new-instance p2, Ljava/lang/ref/WeakReference; invoke-direct {p2, p1}, Ljava/lang/ref/WeakReference;->(Ljava/lang/Object;)V iput-object p2, p0, Lcom/google/common/base/internal/Finalizer;->finalizableReferenceClassReference:Ljava/lang/ref/WeakReference; .line 4 iput-object p3, p0, Lcom/google/common/base/internal/Finalizer;->frqReference:Ljava/lang/ref/PhantomReference; return-void .end method .method private cleanUp(Ljava/lang/ref/Reference;)Z .locals 5 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/ref/Reference<", "*>;)Z" } .end annotation .line 1 invoke-direct {p0}, Lcom/google/common/base/internal/Finalizer;->getFinalizeReferentMethod()Ljava/lang/reflect/Method; move-result-object v0 const/4 v1, 0x0 if-nez v0, :cond_0 return v1 .line 2 :cond_0 invoke-virtual {p1}, Ljava/lang/ref/Reference;->clear()V .line 3 iget-object v2, p0, Lcom/google/common/base/internal/Finalizer;->frqReference:Ljava/lang/ref/PhantomReference; if-ne p1, v2, :cond_1 return v1 :cond_1 :try_start_0 new-array v2, v1, [Ljava/lang/Object; .line 4 invoke-virtual {v0, p1, v2}, Ljava/lang/reflect/Method;->invoke(Ljava/lang/Object;[Ljava/lang/Object;)Ljava/lang/Object; :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 goto :goto_0 :catchall_0 move-exception p1 .line 5 sget-object v2, Lcom/google/common/base/internal/Finalizer;->logger:Ljava/util/logging/Logger; sget-object v3, Ljava/util/logging/Level;->SEVERE:Ljava/util/logging/Level; const-string v4, "Error cleaning up after reference." invoke-virtual {v2, v3, v4, p1}, Ljava/util/logging/Logger;->log(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V .line 6 :goto_0 iget-object p1, p0, Lcom/google/common/base/internal/Finalizer;->queue:Ljava/lang/ref/ReferenceQueue; invoke-virtual {p1}, Ljava/lang/ref/ReferenceQueue;->poll()Ljava/lang/ref/Reference; move-result-object p1 if-nez p1, :cond_0 const/4 p1, 0x1 return p1 .end method .method private static getBigThreadConstructor()Ljava/lang/reflect/Constructor; .locals 4 .annotation system Ldalvik/annotation/Signature; value = { "()", "Ljava/lang/reflect/Constructor<", "Ljava/lang/Thread;", ">;" } .end annotation .annotation runtime Lorg/checkerframework/checker/nullness/compatqual/NullableDecl; .end annotation .line 1 :try_start_0 const-class v0, Ljava/lang/Thread; const/4 v1, 0x5 new-array v1, v1, [Ljava/lang/Class; const/4 v2, 0x0 const-class v3, Ljava/lang/ThreadGroup; aput-object v3, v1, v2 const/4 v2, 0x1 const-class v3, Ljava/lang/Runnable; aput-object v3, v1, v2 const/4 v2, 0x2 const-class v3, Ljava/lang/String; aput-object v3, v1, v2 const/4 v2, 0x3 sget-object v3, Ljava/lang/Long;->TYPE:Ljava/lang/Class; aput-object v3, v1, v2 const/4 v2, 0x4 sget-object v3, Ljava/lang/Boolean;->TYPE:Ljava/lang/Class; aput-object v3, v1, v2 invoke-virtual {v0, v1}, Ljava/lang/Class;->getConstructor([Ljava/lang/Class;)Ljava/lang/reflect/Constructor; move-result-object v0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 return-object v0 :catchall_0 const/4 v0, 0x0 return-object v0 .end method .method private getFinalizeReferentMethod()Ljava/lang/reflect/Method; .locals 3 .annotation runtime Lorg/checkerframework/checker/nullness/compatqual/NullableDecl; .end annotation .line 1 iget-object v0, p0, Lcom/google/common/base/internal/Finalizer;->finalizableReferenceClassReference:Ljava/lang/ref/WeakReference; invoke-virtual {v0}, Ljava/lang/ref/WeakReference;->get()Ljava/lang/Object; move-result-object v0 check-cast v0, Ljava/lang/Class; if-nez v0, :cond_0 const/4 v0, 0x0 return-object v0 :cond_0 :try_start_0 const-string v1, "finalizeReferent" const/4 v2, 0x0 new-array v2, v2, [Ljava/lang/Class; .line 2 invoke-virtual {v0, v1, v2}, Ljava/lang/Class;->getMethod(Ljava/lang/String;[Ljava/lang/Class;)Ljava/lang/reflect/Method; move-result-object v0 :try_end_0 .catch Ljava/lang/NoSuchMethodException; {:try_start_0 .. :try_end_0} :catch_0 return-object v0 :catch_0 move-exception v0 .line 3 new-instance v1, Ljava/lang/AssertionError; invoke-direct {v1, v0}, Ljava/lang/AssertionError;->(Ljava/lang/Object;)V throw v1 .end method .method private static getInheritableThreadLocalsField()Ljava/lang/reflect/Field; .locals 3 .annotation runtime Lorg/checkerframework/checker/nullness/compatqual/NullableDecl; .end annotation .line 1 :try_start_0 const-class v0, Ljava/lang/Thread; const-string v1, "inheritableThreadLocals" invoke-virtual {v0, v1}, Ljava/lang/Class;->getDeclaredField(Ljava/lang/String;)Ljava/lang/reflect/Field; move-result-object v0 const/4 v1, 0x1 .line 2 invoke-virtual {v0, v1}, Ljava/lang/reflect/Field;->setAccessible(Z)V :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 return-object v0 .line 3 :catchall_0 sget-object v0, Lcom/google/common/base/internal/Finalizer;->logger:Ljava/util/logging/Logger; sget-object v1, Ljava/util/logging/Level;->INFO:Ljava/util/logging/Level; const-string v2, "Couldn\'t access Thread.inheritableThreadLocals. Reference finalizer threads will inherit thread local values." invoke-virtual {v0, v1, v2}, Ljava/util/logging/Logger;->log(Ljava/util/logging/Level;Ljava/lang/String;)V const/4 v0, 0x0 return-object v0 .end method .method public static startFinalizer(Ljava/lang/Class;Ljava/lang/ref/ReferenceQueue;Ljava/lang/ref/PhantomReference;)V .locals 6 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "*>;", "Ljava/lang/ref/ReferenceQueue<", "Ljava/lang/Object;", ">;", "Ljava/lang/ref/PhantomReference<", "Ljava/lang/Object;", ">;)V" } .end annotation .line 1 invoke-virtual {p0}, Ljava/lang/Class;->getName()Ljava/lang/String; move-result-object v0 const-string v1, "com.google.common.base.FinalizableReference" invoke-virtual {v0, v1}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z move-result v0 if-eqz v0, :cond_3 .line 2 new-instance v0, Lcom/google/common/base/internal/Finalizer; invoke-direct {v0, p0, p1, p2}, Lcom/google/common/base/internal/Finalizer;->(Ljava/lang/Class;Ljava/lang/ref/ReferenceQueue;Ljava/lang/ref/PhantomReference;)V .line 3 const-class p0, Lcom/google/common/base/internal/Finalizer; invoke-virtual {p0}, Ljava/lang/Class;->getName()Ljava/lang/String; move-result-object p0 .line 4 sget-object p1, Lcom/google/common/base/internal/Finalizer;->bigThreadConstructor:Ljava/lang/reflect/Constructor; const/4 p2, 0x1 const/4 v1, 0x0 if-eqz p1, :cond_0 const-wide/16 v2, 0x0 const/4 v4, 0x5 :try_start_0 new-array v4, v4, [Ljava/lang/Object; const/4 v5, 0x0 aput-object v1, v4, v5 aput-object v0, v4, p2 const/4 v5, 0x2 aput-object p0, v4, v5 const/4 v5, 0x3 .line 5 invoke-static {v2, v3}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long; move-result-object v2 aput-object v2, v4, v5 const/4 v2, 0x4 sget-object v3, Ljava/lang/Boolean;->FALSE:Ljava/lang/Boolean; aput-object v3, v4, v2 .line 6 invoke-virtual {p1, v4}, Ljava/lang/reflect/Constructor;->newInstance([Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 check-cast p1, Ljava/lang/Thread; :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 goto :goto_0 :catchall_0 move-exception p1 .line 7 sget-object v2, Lcom/google/common/base/internal/Finalizer;->logger:Ljava/util/logging/Logger; sget-object v3, Ljava/util/logging/Level;->INFO:Ljava/util/logging/Level; const-string v4, "Failed to create a thread without inherited thread-local values" invoke-virtual {v2, v3, v4, p1}, Ljava/util/logging/Logger;->log(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V :cond_0 move-object p1, v1 :goto_0 if-nez p1, :cond_1 .line 8 new-instance p1, Ljava/lang/Thread; invoke-direct {p1, v1, v0, p0}, Ljava/lang/Thread;->(Ljava/lang/ThreadGroup;Ljava/lang/Runnable;Ljava/lang/String;)V .line 9 :cond_1 invoke-virtual {p1, p2}, Ljava/lang/Thread;->setDaemon(Z)V .line 10 :try_start_1 sget-object p0, Lcom/google/common/base/internal/Finalizer;->inheritableThreadLocals:Ljava/lang/reflect/Field; if-eqz p0, :cond_2 .line 11 invoke-virtual {p0, p1, v1}, Ljava/lang/reflect/Field;->set(Ljava/lang/Object;Ljava/lang/Object;)V :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_1 goto :goto_1 :catchall_1 move-exception p0 .line 12 sget-object p2, Lcom/google/common/base/internal/Finalizer;->logger:Ljava/util/logging/Logger; sget-object v0, Ljava/util/logging/Level;->INFO:Ljava/util/logging/Level; const-string v1, "Failed to clear thread local values inherited by reference finalizer thread." invoke-virtual {p2, v0, v1, p0}, Ljava/util/logging/Logger;->log(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V .line 13 :cond_2 :goto_1 invoke-virtual {p1}, Ljava/lang/Thread;->start()V return-void .line 14 :cond_3 new-instance p0, Ljava/lang/IllegalArgumentException; const-string p1, "Expected com.google.common.base.FinalizableReference." invoke-direct {p0, p1}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p0 .end method # virtual methods .method public run()V .locals 1 .line 1 :catch_0 :cond_0 :try_start_0 iget-object v0, p0, Lcom/google/common/base/internal/Finalizer;->queue:Ljava/lang/ref/ReferenceQueue; invoke-virtual {v0}, Ljava/lang/ref/ReferenceQueue;->remove()Ljava/lang/ref/Reference; move-result-object v0 invoke-direct {p0, v0}, Lcom/google/common/base/internal/Finalizer;->cleanUp(Ljava/lang/ref/Reference;)Z move-result v0 :try_end_0 .catch Ljava/lang/InterruptedException; {:try_start_0 .. :try_end_0} :catch_0 if-nez v0, :cond_0 return-void .end method