d.smali
.class public Lio/openinstall/sdk/d;
.super Ljava/lang/Object;
# instance fields
.field private volatile a:Lio/openinstall/sdk/e;
.field private final b:Ljava/util/concurrent/CountDownLatch;
.field private final c:Ljava/util/concurrent/LinkedBlockingQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/LinkedBlockingQueue<",
"Ljava/lang/Object;",
">;"
}
.end annotation
.end field
.field private final d:Ljava/lang/Object;
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method public constructor <init>()V
.registers 3
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
const/4 v0, 0x0
iput-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
new-instance v0, Ljava/util/concurrent/CountDownLatch;
const/4 v1, 0x1
invoke-direct {v0, v1}, Ljava/util/concurrent/CountDownLatch;-><init>(I)V
iput-object v0, p0, Lio/openinstall/sdk/d;->b:Ljava/util/concurrent/CountDownLatch;
new-instance v0, Ljava/util/concurrent/LinkedBlockingQueue;
invoke-direct {v0, v1}, Ljava/util/concurrent/LinkedBlockingQueue;-><init>(I)V
iput-object v0, p0, Lio/openinstall/sdk/d;->c:Ljava/util/concurrent/LinkedBlockingQueue;
new-instance v0, Ljava/lang/Object;
invoke-direct {v0}, Ljava/lang/Object;-><init>()V
iput-object v0, p0, Lio/openinstall/sdk/d;->d:Ljava/lang/Object;
return-void
.end method
# virtual methods
.method public a(J)Ljava/lang/Object;
.registers 5
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/InterruptedException;
}
.end annotation
iget-object v0, p0, Lio/openinstall/sdk/d;->c:Ljava/util/concurrent/LinkedBlockingQueue;
sget-object v1, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v0, p1, p2, v1}, Ljava/util/concurrent/LinkedBlockingQueue;->poll(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
move-result-object p1
return-object p1
.end method
.method public a()V
.registers 3
iget-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
if-eqz v0, :cond_10
iget-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
sget-object v1, Lio/openinstall/sdk/e;->a:Lio/openinstall/sdk/e;
if-eq v0, v1, :cond_10
iget-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
sget-object v1, Lio/openinstall/sdk/e;->b:Lio/openinstall/sdk/e;
if-ne v0, v1, :cond_17
:cond_10
iget-object v0, p0, Lio/openinstall/sdk/d;->c:Ljava/util/concurrent/LinkedBlockingQueue;
iget-object v1, p0, Lio/openinstall/sdk/d;->d:Ljava/lang/Object;
invoke-virtual {v0, v1}, Ljava/util/concurrent/LinkedBlockingQueue;->offer(Ljava/lang/Object;)Z
:cond_17
return-void
.end method
.method public declared-synchronized a(Lio/openinstall/sdk/e;)V
.registers 2
monitor-enter p0
:try_start_1
iput-object p1, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
monitor-exit p0
return-void
:catchall_5
move-exception p1
monitor-exit p0
throw p1
.end method
.method public a(Ljava/lang/String;J)V
.registers 6
iget-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
if-eqz v0, :cond_10
iget-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
sget-object v1, Lio/openinstall/sdk/e;->a:Lio/openinstall/sdk/e;
if-eq v0, v1, :cond_10
iget-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
sget-object v1, Lio/openinstall/sdk/e;->b:Lio/openinstall/sdk/e;
if-ne v0, v1, :cond_2f
:cond_10
iget-object v0, p0, Lio/openinstall/sdk/d;->c:Ljava/util/concurrent/LinkedBlockingQueue;
iget-object v1, p0, Lio/openinstall/sdk/d;->d:Ljava/lang/Object;
invoke-virtual {v0, v1}, Ljava/util/concurrent/LinkedBlockingQueue;->offer(Ljava/lang/Object;)Z
:try_start_17
iget-object v0, p0, Lio/openinstall/sdk/d;->b:Ljava/util/concurrent/CountDownLatch;
sget-object v1, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v0, p2, p3, v1}, Ljava/util/concurrent/CountDownLatch;->await(JLjava/util/concurrent/TimeUnit;)Z
:try_end_1e
.catch Ljava/lang/InterruptedException; {:try_start_17 .. :try_end_1e} :catch_1f
goto :goto_2f
:catch_1f
move-exception p2
sget-boolean p2, Lio/openinstall/sdk/cb;->a:Z
if-eqz p2, :cond_2f
const/4 p2, 0x1
new-array p2, p2, [Ljava/lang/Object;
const/4 p3, 0x0
aput-object p1, p2, p3
const-string p1, "%s awaitInit interrupted"
invoke-static {p1, p2}, Lio/openinstall/sdk/cb;->b(Ljava/lang/String;[Ljava/lang/Object;)V
:cond_2f
:goto_2f
return-void
.end method
.method public b()Z
.registers 3
iget-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
sget-object v1, Lio/openinstall/sdk/e;->d:Lio/openinstall/sdk/e;
if-ne v0, v1, :cond_8
const/4 v0, 0x1
goto :goto_9
:cond_8
const/4 v0, 0x0
:goto_9
return v0
.end method
.method public c()Z
.registers 3
iget-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
sget-object v1, Lio/openinstall/sdk/e;->e:Lio/openinstall/sdk/e;
if-eq v0, v1, :cond_f
iget-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
sget-object v1, Lio/openinstall/sdk/e;->d:Lio/openinstall/sdk/e;
if-ne v0, v1, :cond_d
goto :goto_f
:cond_d
const/4 v0, 0x0
goto :goto_10
:cond_f
:goto_f
const/4 v0, 0x1
:goto_10
return v0
.end method
.method public declared-synchronized d()Lio/openinstall/sdk/e;
.registers 2
monitor-enter p0
:try_start_1
iget-object v0, p0, Lio/openinstall/sdk/d;->a:Lio/openinstall/sdk/e;
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
monitor-exit p0
return-object v0
:catchall_5
move-exception v0
monitor-exit p0
throw v0
.end method
.method public e()V
.registers 2
iget-object v0, p0, Lio/openinstall/sdk/d;->b:Ljava/util/concurrent/CountDownLatch;
invoke-virtual {v0}, Ljava/util/concurrent/CountDownLatch;->countDown()V
return-void
.end method