ac$d.smali
.class final Lrx/c/a/ac$d;
.super Lrx/i;
.source "SourceFile"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lrx/c/a/ac;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "d"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lrx/i<",
"Lrx/c<",
"+TT;>;>;"
}
.end annotation
# static fields
.field static final q:[Lrx/c/a/ac$b;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lrx/c/a/ac$b<",
"*>;"
}
.end annotation
.end field
# instance fields
.field final a:Lrx/i;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/i<",
"-TT;>;"
}
.end annotation
.end field
.field final b:Z
.field final c:I
.field d:Lrx/c/a/ac$c;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/c/a/ac$c<",
"TT;>;"
}
.end annotation
.end field
.field volatile e:Ljava/util/Queue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Queue<",
"Ljava/lang/Object;",
">;"
}
.end annotation
.end field
.field volatile f:Lrx/i/b;
.field volatile g:Ljava/util/concurrent/ConcurrentLinkedQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/ConcurrentLinkedQueue<",
"Ljava/lang/Throwable;",
">;"
}
.end annotation
.end field
.field final h:Lrx/c/a/f;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/c/a/f<",
"TT;>;"
}
.end annotation
.end field
.field volatile i:Z
.field j:Z
.field k:Z
.field final l:Ljava/lang/Object;
.field volatile m:[Lrx/c/a/ac$b;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lrx/c/a/ac$b<",
"*>;"
}
.end annotation
.end field
.field n:J
.field o:J
.field p:I
.field final r:I
.field s:I
# direct methods
.method static constructor <clinit>()V
.registers 1
const/4 v0, 0x0
new-array v0, v0, [Lrx/c/a/ac$b;
.line 183
sput-object v0, Lrx/c/a/ac$d;->q:[Lrx/c/a/ac$b;
return-void
.end method
.method public constructor <init>(Lrx/i;ZI)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/i<",
"-TT;>;ZI)V"
}
.end annotation
.line 189
invoke-direct {p0}, Lrx/i;-><init>()V
.line 190
iput-object p1, p0, Lrx/c/a/ac$d;->a:Lrx/i;
.line 191
iput-boolean p2, p0, Lrx/c/a/ac$d;->b:Z
.line 192
iput p3, p0, Lrx/c/a/ac$d;->c:I
.line 193
invoke-static {}, Lrx/c/a/f;->a()Lrx/c/a/f;
move-result-object p1
iput-object p1, p0, Lrx/c/a/ac$d;->h:Lrx/c/a/f;
.line 194
new-instance p1, Ljava/lang/Object;
invoke-direct {p1}, Ljava/lang/Object;-><init>()V
iput-object p1, p0, Lrx/c/a/ac$d;->l:Ljava/lang/Object;
.line 195
sget-object p1, Lrx/c/a/ac$d;->q:[Lrx/c/a/ac$b;
iput-object p1, p0, Lrx/c/a/ac$d;->m:[Lrx/c/a/ac$b;
const p1, 0x7fffffff
if-ne p3, p1, :cond_2a
.line 197
iput p1, p0, Lrx/c/a/ac$d;->r:I
const-wide p1, 0x7fffffffffffffffL
.line 198
invoke-virtual {p0, p1, p2}, Lrx/c/a/ac$d;->a(J)V
return-void
:cond_2a
shr-int/lit8 p1, p3, 0x1
const/4 p2, 0x1
.line 200
invoke-static {p2, p1}, Ljava/lang/Math;->max(II)I
move-result p1
iput p1, p0, Lrx/c/a/ac$d;->r:I
int-to-long p1, p3
.line 201
invoke-virtual {p0, p1, p2}, Lrx/c/a/ac$d;->a(J)V
return-void
.end method
.method private a(Lrx/c/a/ac$b;)V
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/c/a/ac$b<",
"TT;>;)V"
}
.end annotation
.line 298
iget-object v0, p1, Lrx/c/a/ac$b;->d:Lrx/c/e/i;
if-eqz v0, :cond_7
.line 300
invoke-virtual {v0}, Lrx/c/e/i;->c()V
.line 304
:cond_7
iget-object v0, p0, Lrx/c/a/ac$d;->f:Lrx/i/b;
invoke-virtual {v0, p1}, Lrx/i/b;->b(Lrx/j;)V
.line 305
iget-object v0, p0, Lrx/c/a/ac$d;->l:Ljava/lang/Object;
monitor-enter v0
.line 306
:try_start_f
iget-object v1, p0, Lrx/c/a/ac$d;->m:[Lrx/c/a/ac$b;
.line 307
array-length v2, v1
const/4 v3, -0x1
const/4 v4, 0x0
const/4 v5, 0x0
:goto_15
if-ge v5, v2, :cond_24
.line 311
aget-object v6, v1, v5
invoke-virtual {p1, v6}, Ljava/lang/Object;->equals(Ljava/lang/Object;)Z
move-result v6
if-eqz v6, :cond_21
move v3, v5
goto :goto_24
:cond_21
add-int/lit8 v5, v5, 0x1
goto :goto_15
:cond_24
:goto_24
if-gez v3, :cond_28
.line 317
monitor-exit v0
return-void
:cond_28
const/4 p1, 0x1
if-ne v2, p1, :cond_31
.line 320
sget-object p1, Lrx/c/a/ac$d;->q:[Lrx/c/a/ac$b;
iput-object p1, p0, Lrx/c/a/ac$d;->m:[Lrx/c/a/ac$b;
.line 321
monitor-exit v0
return-void
:cond_31
add-int/lit8 v5, v2, -0x1
.line 323
new-array v5, v5, [Lrx/c/a/ac$b;
.line 324
invoke-static {v1, v4, v5, v4, v3}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
add-int/lit8 v4, v3, 0x1
sub-int/2addr v2, v3
sub-int/2addr v2, p1
.line 325
invoke-static {v1, v4, v5, v3, v2}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
.line 326
iput-object v5, p0, Lrx/c/a/ac$d;->m:[Lrx/c/a/ac$b;
.line 327
monitor-exit v0
return-void
:catchall_43
move-exception p1
monitor-exit v0
:try_end_45
.catchall {:try_start_f .. :try_end_45} :catchall_43
goto :goto_47
:goto_46
throw p1
:goto_47
goto :goto_46
.end method
.method static a(Lrx/c/a/ac$b;Ljava/lang/Object;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/c/a/ac$b<",
"TT;>;TT;)V"
}
.end annotation
.line 374
iget-object v0, p0, Lrx/c/a/ac$b;->d:Lrx/c/e/i;
if-nez v0, :cond_d
.line 376
invoke-static {}, Lrx/c/e/i;->a()Lrx/c/e/i;
move-result-object v0
.line 377
invoke-virtual {p0, v0}, Lrx/c/a/ac$b;->a(Lrx/j;)V
.line 378
iput-object v0, p0, Lrx/c/a/ac$b;->d:Lrx/c/e/i;
.line 381
:cond_d
:try_start_d
invoke-static {p1}, Lrx/c/a/f;->a(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p1
invoke-virtual {v0, p1}, Lrx/c/e/i;->a(Ljava/lang/Object;)V
:try_end_14
.catch Lrx/exceptions/MissingBackpressureException; {:try_start_d .. :try_end_14} :catch_23
.catch Ljava/lang/IllegalStateException; {:try_start_d .. :try_end_14} :catch_15
return-void
:catch_15
move-exception p1
.line 387
invoke-virtual {p0}, Lrx/c/a/ac$b;->isUnsubscribed()Z
move-result v0
if-nez v0, :cond_22
.line 388
invoke-virtual {p0}, Lrx/c/a/ac$b;->unsubscribe()V
.line 389
invoke-virtual {p0, p1}, Lrx/c/a/ac$b;->a(Ljava/lang/Throwable;)V
:cond_22
return-void
:catch_23
move-exception p1
.line 383
invoke-virtual {p0}, Lrx/c/a/ac$b;->unsubscribe()V
.line 384
invoke-virtual {p0, p1}, Lrx/c/a/ac$b;->a(Ljava/lang/Throwable;)V
return-void
.end method
.method private b(Ljava/lang/Object;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 488
iget-object v0, p0, Lrx/c/a/ac$d;->e:Ljava/util/Queue;
if-nez v0, :cond_37
.line 490
iget v0, p0, Lrx/c/a/ac$d;->c:I
const v1, 0x7fffffff
if-ne v0, v1, :cond_13
.line 492
new-instance v0, Lrx/c/e/a/e;
sget v1, Lrx/c/e/i;->b:I
invoke-direct {v0, v1}, Lrx/c/e/a/e;-><init>(I)V
goto :goto_35
:cond_13
add-int/lit8 v1, v0, -0x1
and-int/2addr v1, v0
if-nez v1, :cond_1a
const/4 v1, 0x1
goto :goto_1b
:cond_1a
const/4 v1, 0x0
:goto_1b
if-eqz v1, :cond_2f
.line 495
invoke-static {}, Lrx/c/e/b/y;->a()Z
move-result v1
if-eqz v1, :cond_29
.line 496
new-instance v1, Lrx/c/e/b/r;
invoke-direct {v1, v0}, Lrx/c/e/b/r;-><init>(I)V
goto :goto_34
.line 498
:cond_29
new-instance v1, Lrx/c/e/a/b;
invoke-direct {v1, v0}, Lrx/c/e/a/b;-><init>(I)V
goto :goto_34
.line 501
:cond_2f
new-instance v1, Lrx/c/e/a/c;
invoke-direct {v1, v0}, Lrx/c/e/a/c;-><init>(I)V
:goto_34
move-object v0, v1
.line 504
:goto_35
iput-object v0, p0, Lrx/c/a/ac$d;->e:Ljava/util/Queue;
.line 506
:cond_37
invoke-static {p1}, Lrx/c/a/f;->a(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
invoke-interface {v0, v1}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z
move-result v0
if-nez v0, :cond_50
.line 507
invoke-virtual {p0}, Lrx/c/a/ac$d;->unsubscribe()V
.line 508
new-instance v0, Lrx/exceptions/MissingBackpressureException;
invoke-direct {v0}, Lrx/exceptions/MissingBackpressureException;-><init>()V
invoke-static {v0, p1}, Lrx/exceptions/OnErrorThrowable;->a(Ljava/lang/Throwable;Ljava/lang/Object;)Ljava/lang/Throwable;
move-result-object p1
invoke-virtual {p0, p1}, Lrx/c/a/ac$d;->a(Ljava/lang/Throwable;)V
:cond_50
return-void
.end method
.method private f()Lrx/i/b;
.registers 3
.line 219
iget-object v0, p0, Lrx/c/a/ac$d;->f:Lrx/i/b;
if-nez v0, :cond_1f
const/4 v0, 0x0
.line 222
monitor-enter p0
.line 223
:try_start_6
iget-object v1, p0, Lrx/c/a/ac$d;->f:Lrx/i/b;
if-nez v1, :cond_14
.line 225
new-instance v0, Lrx/i/b;
invoke-direct {v0}, Lrx/i/b;-><init>()V
.line 226
iput-object v0, p0, Lrx/c/a/ac$d;->f:Lrx/i/b;
const/4 v1, 0x1
move-object v1, v0
const/4 v0, 0x1
.line 229
:cond_14
monitor-exit p0
:try_end_15
.catchall {:try_start_6 .. :try_end_15} :catchall_1c
if-eqz v0, :cond_1a
.line 231
invoke-virtual {p0, v1}, Lrx/c/a/ac$d;->a(Lrx/j;)V
:cond_1a
move-object v0, v1
goto :goto_1f
:catchall_1c
move-exception v0
.line 229
:try_start_1d
monitor-exit p0
:try_end_1e
.catchall {:try_start_1d .. :try_end_1e} :catchall_1c
throw v0
:cond_1f
:goto_1f
return-object v0
.end method
.method private g()V
.registers 4
.line 266
new-instance v0, Ljava/util/ArrayList;
iget-object v1, p0, Lrx/c/a/ac$d;->g:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v0, v1}, Ljava/util/ArrayList;-><init>(Ljava/util/Collection;)V
.line 267
invoke-interface {v0}, Ljava/util/List;->size()I
move-result v1
const/4 v2, 0x1
if-ne v1, v2, :cond_1b
.line 268
iget-object v1, p0, Lrx/c/a/ac$d;->a:Lrx/i;
const/4 v2, 0x0
invoke-interface {v0, v2}, Ljava/util/List;->get(I)Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/lang/Throwable;
invoke-virtual {v1, v0}, Lrx/i;->a(Ljava/lang/Throwable;)V
return-void
.line 270
:cond_1b
iget-object v1, p0, Lrx/c/a/ac$d;->a:Lrx/i;
new-instance v2, Lrx/exceptions/CompositeException;
invoke-direct {v2, v0}, Lrx/exceptions/CompositeException;-><init>(Ljava/util/Collection;)V
invoke-virtual {v1, v2}, Lrx/i;->a(Ljava/lang/Throwable;)V
return-void
.end method
.method private h()Z
.registers 4
.line 818
iget-object v0, p0, Lrx/c/a/ac$d;->a:Lrx/i;
invoke-virtual {v0}, Lrx/i;->isUnsubscribed()Z
move-result v0
const/4 v1, 0x1
if-eqz v0, :cond_a
return v1
.line 821
:cond_a
iget-object v0, p0, Lrx/c/a/ac$d;->g:Ljava/util/concurrent/ConcurrentLinkedQueue;
.line 822
iget-boolean v2, p0, Lrx/c/a/ac$d;->b:Z
if-nez v2, :cond_24
if-eqz v0, :cond_24
invoke-interface {v0}, Ljava/util/Queue;->isEmpty()Z
move-result v0
if-nez v0, :cond_24
.line 824
:try_start_18
invoke-direct {p0}, Lrx/c/a/ac$d;->g()V
:try_end_1b
.catchall {:try_start_18 .. :try_end_1b} :catchall_1f
.line 826
invoke-virtual {p0}, Lrx/c/a/ac$d;->unsubscribe()V
return v1
:catchall_1f
move-exception v0
invoke-virtual {p0}, Lrx/c/a/ac$d;->unsubscribe()V
throw v0
:cond_24
const/4 v0, 0x0
return v0
.end method
# virtual methods
.method public final a()V
.registers 2
const/4 v0, 0x1
.line 282
iput-boolean v0, p0, Lrx/c/a/ac$d;->i:Z
.line 283
invoke-virtual {p0}, Lrx/c/a/ac$d;->d()V
return-void
.end method
.method public final synthetic a(Ljava/lang/Object;)V
.registers 9
.line 147
check-cast p1, Lrx/c;
if-eqz p1, :cond_f4
.line 3795
invoke-static {}, Lrx/c/a/d;->instance()Lrx/c;
move-result-object v0
const/4 v1, 0x1
const/4 v2, 0x0
if-ne p1, v0, :cond_1d
.line 4256
iget p1, p0, Lrx/c/a/ac$d;->s:I
add-int/2addr p1, v1
.line 4257
iget v0, p0, Lrx/c/a/ac$d;->r:I
if-ne p1, v0, :cond_1a
.line 4258
iput v2, p0, Lrx/c/a/ac$d;->s:I
int-to-long v0, p1
.line 4441
invoke-virtual {p0, v0, v1}, Lrx/c/a/ac$d;->a(J)V
return-void
.line 4261
:cond_1a
iput p1, p0, Lrx/c/a/ac$d;->s:I
return-void
.line 3245
:cond_1d
instance-of v0, p1, Lrx/c/e/k;
if-eqz v0, :cond_c5
.line 3246
check-cast p1, Lrx/c/e/k;
.line 5085
iget-object p1, p1, Lrx/c/e/k;->b:Ljava/lang/Object;
.line 5457
iget-object v0, p0, Lrx/c/a/ac$d;->d:Lrx/c/a/ac$c;
invoke-virtual {v0}, Lrx/c/a/ac$c;->get()J
move-result-wide v3
const-wide/16 v5, 0x0
cmp-long v0, v3, v5
if-eqz v0, :cond_4b
.line 5459
monitor-enter p0
.line 5461
:try_start_32
iget-object v0, p0, Lrx/c/a/ac$d;->d:Lrx/c/a/ac$c;
invoke-virtual {v0}, Lrx/c/a/ac$c;->get()J
move-result-wide v3
.line 5462
iget-boolean v0, p0, Lrx/c/a/ac$d;->j:Z
if-nez v0, :cond_44
cmp-long v0, v3, v5
if-eqz v0, :cond_44
.line 5463
iput-boolean v1, p0, Lrx/c/a/ac$d;->j:Z
const/4 v0, 0x1
goto :goto_45
:cond_44
const/4 v0, 0x0
.line 5466
:goto_45
monitor-exit p0
move-wide v5, v3
goto :goto_4c
:catchall_48
move-exception p1
monitor-exit p0
:try_end_4a
.catchall {:try_start_32 .. :try_end_4a} :catchall_48
throw p1
:cond_4b
const/4 v0, 0x0
:goto_4c
if-eqz v0, :cond_be
.line 5469
iget-object v0, p0, Lrx/c/a/ac$d;->e:Ljava/util/Queue;
if-eqz v0, :cond_60
.line 5470
invoke-interface {v0}, Ljava/util/Queue;->isEmpty()Z
move-result v0
if-eqz v0, :cond_59
goto :goto_60
.line 5473
:cond_59
invoke-direct {p0, p1}, Lrx/c/a/ac$d;->b(Ljava/lang/Object;)V
.line 5474
invoke-virtual {p0}, Lrx/c/a/ac$d;->e()V
return-void
.line 5517
:cond_60
:goto_60
:try_start_60
iget-object v0, p0, Lrx/c/a/ac$d;->a:Lrx/i;
invoke-virtual {v0, p1}, Lrx/i;->a(Ljava/lang/Object;)V
:try_end_65
.catchall {:try_start_60 .. :try_end_65} :catchall_66
goto :goto_7e
:catchall_66
move-exception p1
.line 5519
:try_start_67
iget-boolean v0, p0, Lrx/c/a/ac$d;->b:Z
if-nez v0, :cond_77
.line 5520
invoke-static {p1}, Lrx/exceptions/a;->b(Ljava/lang/Throwable;)V
:try_end_6e
.catchall {:try_start_67 .. :try_end_6e} :catchall_b1
.line 5522
:try_start_6e
invoke-virtual {p0}, Lrx/c/a/ac$d;->unsubscribe()V
.line 5523
invoke-virtual {p0, p1}, Lrx/c/a/ac$d;->a(Ljava/lang/Throwable;)V
:try_end_74
.catchall {:try_start_6e .. :try_end_74} :catchall_75
return-void
:catchall_75
move-exception p1
goto :goto_b3
.line 5526
:cond_77
:try_start_77
invoke-virtual {p0}, Lrx/c/a/ac$d;->c()Ljava/util/Queue;
move-result-object v0
invoke-interface {v0, p1}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z
:goto_7e
const-wide v3, 0x7fffffffffffffffL
cmp-long p1, v5, v3
if-eqz p1, :cond_8e
.line 5529
iget-object p1, p0, Lrx/c/a/ac$d;->d:Lrx/c/a/ac$c;
const-wide/16 v3, -0x1
.line 6139
invoke-virtual {p1, v3, v4}, Lrx/c/a/ac$c;->addAndGet(J)J
.line 5532
:cond_8e
iget p1, p0, Lrx/c/a/ac$d;->s:I
add-int/2addr p1, v1
.line 5533
iget v0, p0, Lrx/c/a/ac$d;->r:I
if-ne p1, v0, :cond_9c
.line 5534
iput v2, p0, Lrx/c/a/ac$d;->s:I
int-to-long v3, p1
.line 6441
invoke-virtual {p0, v3, v4}, Lrx/c/a/ac$d;->a(J)V
goto :goto_9e
.line 5537
:cond_9c
iput p1, p0, Lrx/c/a/ac$d;->s:I
.line 5541
:goto_9e
monitor-enter p0
:try_end_9f
.catchall {:try_start_77 .. :try_end_9f} :catchall_b1
.line 5543
:try_start_9f
iget-boolean p1, p0, Lrx/c/a/ac$d;->k:Z
if-nez p1, :cond_a7
.line 5544
iput-boolean v2, p0, Lrx/c/a/ac$d;->j:Z
.line 5545
monitor-exit p0
return-void
.line 5547
:cond_a7
iput-boolean v2, p0, Lrx/c/a/ac$d;->k:Z
.line 5548
monitor-exit p0
:try_end_aa
.catchall {:try_start_9f .. :try_end_aa} :catchall_ae
.line 5563
invoke-virtual {p0}, Lrx/c/a/ac$d;->e()V
return-void
:catchall_ae
move-exception p1
.line 5548
:try_start_af
monitor-exit p0
:try_end_b0
.catchall {:try_start_af .. :try_end_b0} :catchall_ae
:try_start_b0
throw p1
:try_end_b1
.catchall {:try_start_b0 .. :try_end_b1} :catchall_75
:catchall_b1
move-exception p1
const/4 v1, 0x0
:goto_b3
if-nez v1, :cond_bd
.line 5551
monitor-enter p0
.line 5552
:try_start_b6
iput-boolean v2, p0, Lrx/c/a/ac$d;->j:Z
.line 5553
monitor-exit p0
goto :goto_bd
:catchall_ba
move-exception p1
monitor-exit p0
:try_end_bc
.catchall {:try_start_b6 .. :try_end_bc} :catchall_ba
throw p1
:cond_bd
:goto_bd
throw p1
.line 5477
:cond_be
invoke-direct {p0, p1}, Lrx/c/a/ac$d;->b(Ljava/lang/Object;)V
.line 5478
invoke-virtual {p0}, Lrx/c/a/ac$d;->d()V
return-void
.line 3248
:cond_c5
new-instance v0, Lrx/c/a/ac$b;
iget-wide v3, p0, Lrx/c/a/ac$d;->n:J
const-wide/16 v5, 0x1
add-long/2addr v5, v3
iput-wide v5, p0, Lrx/c/a/ac$d;->n:J
invoke-direct {v0, p0, v3, v4}, Lrx/c/a/ac$b;-><init>(Lrx/c/a/ac$d;J)V
.line 7287
invoke-direct {p0}, Lrx/c/a/ac$d;->f()Lrx/i/b;
move-result-object v1
invoke-virtual {v1, v0}, Lrx/i/b;->a(Lrx/j;)V
.line 7288
iget-object v1, p0, Lrx/c/a/ac$d;->l:Ljava/lang/Object;
monitor-enter v1
.line 7289
:try_start_db
iget-object v3, p0, Lrx/c/a/ac$d;->m:[Lrx/c/a/ac$b;
.line 7290
array-length v4, v3
add-int/lit8 v5, v4, 0x1
.line 7291
new-array v5, v5, [Lrx/c/a/ac$b;
.line 7292
invoke-static {v3, v2, v5, v2, v4}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
.line 7293
aput-object v0, v5, v4
.line 7294
iput-object v5, p0, Lrx/c/a/ac$d;->m:[Lrx/c/a/ac$b;
.line 7295
monitor-exit v1
:try_end_ea
.catchall {:try_start_db .. :try_end_ea} :catchall_f1
.line 3250
invoke-virtual {p1, v0}, Lrx/c;->a(Lrx/i;)Lrx/j;
.line 3251
invoke-virtual {p0}, Lrx/c/a/ac$d;->d()V
goto :goto_f4
:catchall_f1
move-exception p1
.line 7295
:try_start_f2
monitor-exit v1
:try_end_f3
.catchall {:try_start_f2 .. :try_end_f3} :catchall_f1
throw p1
:cond_f4
:goto_f4
return-void
.end method
.method public final a(Ljava/lang/Throwable;)V
.registers 3
.line 276
invoke-virtual {p0}, Lrx/c/a/ac$d;->c()Ljava/util/Queue;
move-result-object v0
invoke-interface {v0, p1}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z
const/4 p1, 0x1
.line 277
iput-boolean p1, p0, Lrx/c/a/ac$d;->i:Z
.line 278
invoke-virtual {p0}, Lrx/c/a/ac$d;->d()V
return-void
.end method
.method final c()Ljava/util/Queue;
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Ljava/util/Queue<",
"Ljava/lang/Throwable;",
">;"
}
.end annotation
.line 206
iget-object v0, p0, Lrx/c/a/ac$d;->g:Ljava/util/concurrent/ConcurrentLinkedQueue;
if-nez v0, :cond_15
.line 208
monitor-enter p0
.line 209
:try_start_5
iget-object v0, p0, Lrx/c/a/ac$d;->g:Ljava/util/concurrent/ConcurrentLinkedQueue;
if-nez v0, :cond_10
.line 211
new-instance v0, Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V
.line 212
iput-object v0, p0, Lrx/c/a/ac$d;->g:Ljava/util/concurrent/ConcurrentLinkedQueue;
.line 214
:cond_10
monitor-exit p0
goto :goto_15
:catchall_12
move-exception v0
monitor-exit p0
:try_end_14
.catchall {:try_start_5 .. :try_end_14} :catchall_12
throw v0
:cond_15
:goto_15
return-object v0
.end method
.method final d()V
.registers 3
.line 567
monitor-enter p0
.line 568
:try_start_1
iget-boolean v0, p0, Lrx/c/a/ac$d;->j:Z
const/4 v1, 0x1
if-eqz v0, :cond_a
.line 569
iput-boolean v1, p0, Lrx/c/a/ac$d;->k:Z
.line 570
monitor-exit p0
return-void
.line 572
:cond_a
iput-boolean v1, p0, Lrx/c/a/ac$d;->j:Z
.line 573
monitor-exit p0
:try_end_d
.catchall {:try_start_1 .. :try_end_d} :catchall_11
.line 574
invoke-virtual {p0}, Lrx/c/a/ac$d;->e()V
return-void
:catchall_11
move-exception v0
.line 573
:try_start_12
monitor-exit p0
:try_end_13
.catchall {:try_start_12 .. :try_end_13} :catchall_11
throw v0
.end method
.method final e()V
.registers 25
move-object/from16 v1, p0
.line 582
:try_start_2
iget-object v4, v1, Lrx/c/a/ac$d;->a:Lrx/i;
.line 585
:goto_4
invoke-direct/range {p0 .. p0}, Lrx/c/a/ac$d;->h()Z
move-result v0
if-eqz v0, :cond_b
return-void
.line 589
:cond_b
iget-object v5, v1, Lrx/c/a/ac$d;->e:Ljava/util/Queue;
.line 591
iget-object v0, v1, Lrx/c/a/ac$d;->d:Lrx/c/a/ac$c;
invoke-virtual {v0}, Lrx/c/a/ac$c;->get()J
move-result-wide v6
const-wide v8, 0x7fffffffffffffffL
cmp-long v0, v6, v8
if-nez v0, :cond_1e
const/4 v10, 0x1
goto :goto_1f
:cond_1e
const/4 v10, 0x0
:goto_1f
const-wide/16 v11, 0x1
const-wide/16 v14, 0x0
if-eqz v5, :cond_90
const/4 v0, 0x0
:goto_26
move-wide/from16 v16, v6
const/4 v7, 0x0
move v6, v0
const/4 v0, 0x0
:goto_2b
cmp-long v18, v16, v14
if-lez v18, :cond_6f
.line 603
invoke-interface {v5}, Ljava/util/Queue;->poll()Ljava/lang/Object;
move-result-object v18
.line 605
invoke-direct/range {p0 .. p0}, Lrx/c/a/ac$d;->h()Z
move-result v0
if-eqz v0, :cond_3a
return-void
:cond_3a
if-eqz v18, :cond_6d
.line 612
invoke-static/range {v18 .. v18}, Lrx/c/a/f;->d(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
:try_end_40
.catchall {:try_start_2 .. :try_end_40} :catchall_1b9
.line 615
:try_start_40
invoke-virtual {v4, v0}, Lrx/i;->a(Ljava/lang/Object;)V
:try_end_43
.catchall {:try_start_40 .. :try_end_43} :catchall_44
goto :goto_64
:catchall_44
move-exception v0
move-object/from16 v19, v0
.line 617
:try_start_47
iget-boolean v0, v1, Lrx/c/a/ac$d;->b:Z
if-nez v0, :cond_5b
.line 618
invoke-static/range {v19 .. v19}, Lrx/exceptions/a;->b(Ljava/lang/Throwable;)V
:try_end_4e
.catchall {:try_start_47 .. :try_end_4e} :catchall_1b9
.line 620
:try_start_4e
invoke-virtual/range {p0 .. p0}, Lrx/c/a/ac$d;->unsubscribe()V
move-object/from16 v5, v19
.line 621
invoke-virtual {v4, v5}, Lrx/i;->a(Ljava/lang/Throwable;)V
:try_end_56
.catchall {:try_start_4e .. :try_end_56} :catchall_57
return-void
:catchall_57
move-exception v0
const/4 v2, 0x1
goto/16 :goto_1bb
:cond_5b
move-object/from16 v2, v19
.line 624
:try_start_5d
invoke-virtual/range {p0 .. p0}, Lrx/c/a/ac$d;->c()Ljava/util/Queue;
move-result-object v0
invoke-interface {v0, v2}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z
:goto_64
add-int/lit8 v6, v6, 0x1
add-int/lit8 v7, v7, 0x1
sub-long v16, v16, v11
move-object/from16 v0, v18
goto :goto_2b
:cond_6d
move-object/from16 v0, v18
:cond_6f
if-lez v7, :cond_80
if-eqz v10, :cond_76
move-wide/from16 v16, v8
goto :goto_80
.line 634
:cond_76
iget-object v2, v1, Lrx/c/a/ac$d;->d:Lrx/c/a/ac$c;
neg-int v7, v7
int-to-long v8, v7
.line 2139
invoke-virtual {v2, v8, v9}, Lrx/c/a/ac$c;->addAndGet(J)J
move-result-wide v7
move-wide/from16 v16, v7
:cond_80
:goto_80
cmp-long v2, v16, v14
if-eqz v2, :cond_93
if-nez v0, :cond_87
goto :goto_93
:cond_87
move v0, v6
move-wide/from16 v6, v16
const-wide v8, 0x7fffffffffffffffL
goto :goto_26
:cond_90
move-wide/from16 v16, v6
const/4 v6, 0x0
.line 649
:cond_93
:goto_93
iget-boolean v0, v1, Lrx/c/a/ac$d;->i:Z
.line 652
iget-object v2, v1, Lrx/c/a/ac$d;->e:Ljava/util/Queue;
.line 654
iget-object v5, v1, Lrx/c/a/ac$d;->m:[Lrx/c/a/ac$b;
.line 655
array-length v7, v5
if-eqz v0, :cond_b9
if-eqz v2, :cond_a4
.line 659
invoke-interface {v2}, Ljava/util/Queue;->isEmpty()Z
move-result v0
if-eqz v0, :cond_b9
:cond_a4
if-nez v7, :cond_b9
.line 660
iget-object v0, v1, Lrx/c/a/ac$d;->g:Ljava/util/concurrent/ConcurrentLinkedQueue;
if-eqz v0, :cond_b5
.line 661
invoke-interface {v0}, Ljava/util/Queue;->isEmpty()Z
move-result v0
if-eqz v0, :cond_b1
goto :goto_b5
.line 664
:cond_b1
invoke-direct/range {p0 .. p0}, Lrx/c/a/ac$d;->g()V
return-void
.line 662
:cond_b5
:goto_b5
invoke-virtual {v4}, Lrx/i;->a()V
return-void
:cond_b9
if-lez v7, :cond_192
.line 673
iget-wide v8, v1, Lrx/c/a/ac$d;->o:J
.line 674
iget v0, v1, Lrx/c/a/ac$d;->p:I
if-le v7, v0, :cond_c9
.line 678
aget-object v2, v5, v0
iget-wide v11, v2, Lrx/c/a/ac$b;->b:J
cmp-long v2, v11, v8
if-eqz v2, :cond_e7
:cond_c9
if-gt v7, v0, :cond_cc
const/4 v0, 0x0
:cond_cc
const/4 v2, 0x0
:goto_cd
if-ge v2, v7, :cond_df
.line 685
aget-object v11, v5, v0
iget-wide v11, v11, Lrx/c/a/ac$b;->b:J
cmp-long v18, v11, v8
if-eqz v18, :cond_df
add-int/lit8 v0, v0, 0x1
if-ne v0, v7, :cond_dc
const/4 v0, 0x0
:cond_dc
add-int/lit8 v2, v2, 0x1
goto :goto_cd
.line 697
:cond_df
iput v0, v1, Lrx/c/a/ac$d;->p:I
.line 698
aget-object v2, v5, v0
iget-wide v8, v2, Lrx/c/a/ac$b;->b:J
iput-wide v8, v1, Lrx/c/a/ac$d;->o:J
:cond_e7
const/4 v2, 0x0
const/4 v8, 0x0
:goto_e9
if-ge v2, v7, :cond_188
.line 705
invoke-direct/range {p0 .. p0}, Lrx/c/a/ac$d;->h()Z
move-result v9
if-eqz v9, :cond_f2
return-void
.line 710
:cond_f2
aget-object v9, v5, v0
const/4 v11, 0x0
:goto_f5
const/4 v12, 0x0
:goto_f6
cmp-long v18, v16, v14
if-lez v18, :cond_12b
.line 717
invoke-direct/range {p0 .. p0}, Lrx/c/a/ac$d;->h()Z
move-result v18
if-eqz v18, :cond_101
return-void
.line 721
:cond_101
iget-object v13, v9, Lrx/c/a/ac$b;->d:Lrx/c/e/i;
if-eqz v13, :cond_12b
.line 725
invoke-virtual {v13}, Lrx/c/e/i;->e()Ljava/lang/Object;
move-result-object v11
if-eqz v11, :cond_12b
.line 729
invoke-static {v11}, Lrx/c/a/f;->d(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v13
:try_end_10f
.catchall {:try_start_5d .. :try_end_10f} :catchall_1b9
.line 732
:try_start_10f
invoke-virtual {v4, v13}, Lrx/i;->a(Ljava/lang/Object;)V
:try_end_112
.catchall {:try_start_10f .. :try_end_112} :catchall_119
const-wide/16 v20, 0x1
sub-long v16, v16, v20
add-int/lit8 v12, v12, 0x1
goto :goto_f6
:catchall_119
move-exception v0
move-object v2, v0
.line 735
:try_start_11b
invoke-static {v2}, Lrx/exceptions/a;->b(Ljava/lang/Throwable;)V
:try_end_11e
.catchall {:try_start_11b .. :try_end_11e} :catchall_57
.line 737
:try_start_11e
invoke-virtual {v4, v2}, Lrx/i;->a(Ljava/lang/Throwable;)V
:try_end_121
.catchall {:try_start_11e .. :try_end_121} :catchall_125
.line 739
:try_start_121
invoke-virtual/range {p0 .. p0}, Lrx/c/a/ac$d;->unsubscribe()V
return-void
:catchall_125
move-exception v0
move-object v2, v0
invoke-virtual/range {p0 .. p0}, Lrx/c/a/ac$d;->unsubscribe()V
throw v2
:try_end_12b
.catchall {:try_start_121 .. :try_end_12b} :catchall_57
:cond_12b
const-wide/16 v20, 0x1
if-lez v12, :cond_148
if-nez v10, :cond_13b
.line 748
:try_start_131
iget-object v13, v1, Lrx/c/a/ac$d;->d:Lrx/c/a/ac$c;
neg-int v3, v12
int-to-long v14, v3
.line 3139
invoke-virtual {v13, v14, v15}, Lrx/c/a/ac$c;->addAndGet(J)J
move-result-wide v13
move-object v15, v4
goto :goto_141
:cond_13b
move-object v15, v4
const-wide v13, 0x7fffffffffffffffL
:goto_141
int-to-long v3, v12
.line 752
invoke-virtual {v9, v3, v4}, Lrx/c/a/ac$b;->b(J)V
move-wide/from16 v16, v13
goto :goto_149
:cond_148
move-object v15, v4
:goto_149
const-wide/16 v3, 0x0
cmp-long v12, v16, v3
if-eqz v12, :cond_156
if-nez v11, :cond_152
goto :goto_156
:cond_152
move-object v4, v15
const-wide/16 v14, 0x0
goto :goto_f5
.line 759
:cond_156
:goto_156
iget-boolean v3, v9, Lrx/c/a/ac$b;->c:Z
.line 760
iget-object v4, v9, Lrx/c/a/ac$b;->d:Lrx/c/e/i;
if-eqz v3, :cond_174
if-eqz v4, :cond_164
.line 761
invoke-virtual {v4}, Lrx/c/e/i;->d()Z
move-result v3
if-eqz v3, :cond_174
.line 762
:cond_164
invoke-direct {v1, v9}, Lrx/c/a/ac$d;->a(Lrx/c/a/ac$b;)V
.line 763
invoke-direct/range {p0 .. p0}, Lrx/c/a/ac$d;->h()Z
move-result v3
if-eqz v3, :cond_16e
return-void
:cond_16e
add-int/lit8 v6, v6, 0x1
const-wide/16 v3, 0x0
const/4 v8, 0x1
goto :goto_176
:cond_174
const-wide/16 v3, 0x0
:goto_176
cmp-long v9, v16, v3
if-eqz v9, :cond_189
add-int/lit8 v0, v0, 0x1
if-ne v0, v7, :cond_17f
const/4 v0, 0x0
:cond_17f
add-int/lit8 v2, v2, 0x1
move-wide/from16 v22, v3
move-object v4, v15
move-wide/from16 v14, v22
goto/16 :goto_e9
:cond_188
move-object v15, v4
.line 782
:cond_189
iput v0, v1, Lrx/c/a/ac$d;->p:I
.line 783
aget-object v0, v5, v0
iget-wide v2, v0, Lrx/c/a/ac$b;->b:J
iput-wide v2, v1, Lrx/c/a/ac$d;->o:J
goto :goto_194
:cond_192
move-object v15, v4
const/4 v8, 0x0
:goto_194
if-lez v6, :cond_19a
int-to-long v2, v6
.line 787
invoke-virtual {v1, v2, v3}, Lrx/c/a/ac$d;->a(J)V
:cond_19a
if-nez v8, :cond_1b6
.line 794
monitor-enter p0
:try_end_19d
.catchall {:try_start_131 .. :try_end_19d} :catchall_1b9
.line 795
:try_start_19d
iget-boolean v0, v1, Lrx/c/a/ac$d;->k:Z
:try_end_19f
.catchall {:try_start_19d .. :try_end_19f} :catchall_1ae
if-nez v0, :cond_1a9
const/4 v2, 0x0
.line 797
:try_start_1a2
iput-boolean v2, v1, Lrx/c/a/ac$d;->j:Z
.line 798
monitor-exit p0
:try_end_1a5
.catchall {:try_start_1a2 .. :try_end_1a5} :catchall_1a6
return-void
:catchall_1a6
move-exception v0
const/4 v2, 0x1
goto :goto_1b0
:cond_1a9
const/4 v2, 0x0
.line 800
:try_start_1aa
iput-boolean v2, v1, Lrx/c/a/ac$d;->k:Z
.line 801
monitor-exit p0
:try_end_1ad
.catchall {:try_start_1aa .. :try_end_1ad} :catchall_1ae
goto :goto_1b6
:catchall_1ae
move-exception v0
const/4 v2, 0x0
:goto_1b0
:try_start_1b0
monitor-exit p0
:try_end_1b1
.catchall {:try_start_1b0 .. :try_end_1b1} :catchall_1b4
:try_start_1b1
throw v0
:try_end_1b2
.catchall {:try_start_1b1 .. :try_end_1b2} :catchall_1b2
:catchall_1b2
move-exception v0
goto :goto_1bb
:catchall_1b4
move-exception v0
goto :goto_1b0
:cond_1b6
:goto_1b6
move-object v4, v15
goto/16 :goto_4
:catchall_1b9
move-exception v0
const/4 v2, 0x0
:goto_1bb
if-nez v2, :cond_1c6
.line 805
monitor-enter p0
const/4 v2, 0x0
.line 806
:try_start_1bf
iput-boolean v2, v1, Lrx/c/a/ac$d;->j:Z
.line 807
monitor-exit p0
goto :goto_1c6
:catchall_1c3
move-exception v0
monitor-exit p0
:try_end_1c5
.catchall {:try_start_1bf .. :try_end_1c5} :catchall_1c3
throw v0
:cond_1c6
:goto_1c6
goto :goto_1c8
:goto_1c7
throw v0
:goto_1c8
goto :goto_1c7
.end method