.class public final Lz9/i$a;
.super Ly9/a;
.source ""


# annotations
.annotation system Ldalvik/annotation/EnclosingMethod;
    value = Lz9/i;-><init>(Ly9/d;IJLjava/util/concurrent/TimeUnit;)V
.end annotation

.annotation system Ldalvik/annotation/InnerClass;
    accessFlags = 0x19
    name = null
.end annotation


# instance fields
.field public final synthetic e:Lz9/i;


# direct methods
.method public constructor <init>(Lz9/i;Ljava/lang/String;)V
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/lang/String;",
            ")V"
        }
    .end annotation

    iput-object p1, p0, Lz9/i$a;->e:Lz9/i;

    const/4 p1, 0x1

    .line 1
    invoke-direct {p0, p2, p1}, Ly9/a;-><init>(Ljava/lang/String;Z)V

    return-void
.end method


# virtual methods
.method public a()J
    .registers 14

    iget-object v0, p0, Lz9/i$a;->e:Lz9/i;

    invoke-static {}, Ljava/lang/System;->nanoTime()J

    move-result-wide v1

    .line 1
    iget-object v3, v0, Lz9/i;->d:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v3}, Ljava/util/concurrent/ConcurrentLinkedQueue;->iterator()Ljava/util/Iterator;

    move-result-object v3

    const/4 v4, 0x0

    const/4 v5, 0x0

    const-wide/high16 v6, -0x8000000000000000L

    move-wide v7, v6

    move-object v6, v5

    move v5, v4

    :goto_13
    invoke-interface {v3}, Ljava/util/Iterator;->hasNext()Z

    move-result v9

    if-eqz v9, :cond_3f

    invoke-interface {v3}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v9

    check-cast v9, Lz9/h;

    const-string v10, "connection"

    invoke-static {v9, v10}, Lx/e;->e(Ljava/lang/Object;Ljava/lang/String;)V

    monitor-enter v9

    :try_start_25
    invoke-virtual {v0, v9, v1, v2}, Lz9/i;->b(Lz9/h;J)I

    move-result v10

    if-lez v10, :cond_2e

    add-int/lit8 v5, v5, 0x1

    goto :goto_3a

    :cond_2e
    add-int/lit8 v4, v4, 0x1

    .line 2
    iget-wide v10, v9, Lz9/h;->p:J
    :try_end_32
    .catchall {:try_start_25 .. :try_end_32} :catchall_3c

    sub-long v10, v1, v10

    cmp-long v12, v10, v7

    if-lez v12, :cond_3a

    move-object v6, v9

    move-wide v7, v10

    .line 3
    :cond_3a
    :goto_3a
    monitor-exit v9

    goto :goto_13

    :catchall_3c
    move-exception v0

    monitor-exit v9

    throw v0

    :cond_3f
    iget-wide v9, v0, Lz9/i;->a:J

    cmp-long v3, v7, v9

    if-gez v3, :cond_54

    iget v3, v0, Lz9/i;->e:I

    if-le v4, v3, :cond_4a

    goto :goto_54

    :cond_4a
    if-lez v4, :cond_4e

    sub-long/2addr v9, v7

    goto :goto_8b

    :cond_4e
    if-lez v5, :cond_51

    goto :goto_8b

    :cond_51
    const-wide/16 v9, -0x1

    goto :goto_8b

    :cond_54
    :goto_54
    invoke-static {v6}, Lx/e;->d(Ljava/lang/Object;)V

    monitor-enter v6

    .line 4
    :try_start_58
    iget-object v3, v6, Lz9/h;->o:Ljava/util/List;

    .line 5
    invoke-interface {v3}, Ljava/util/Collection;->isEmpty()Z

    move-result v3
    :try_end_5e
    .catchall {:try_start_58 .. :try_end_5e} :catchall_8c

    const/4 v4, 0x1

    xor-int/2addr v3, v4

    const-wide/16 v9, 0x0

    if-eqz v3, :cond_66

    :goto_64
    monitor-exit v6

    goto :goto_8b

    .line 6
    :cond_66
    :try_start_66
    iget-wide v11, v6, Lz9/h;->p:J

    add-long/2addr v11, v7

    cmp-long v1, v11, v1

    if-eqz v1, :cond_6e

    goto :goto_64

    .line 7
    :cond_6e
    iput-boolean v4, v6, Lz9/h;->i:Z

    .line 8
    iget-object v1, v0, Lz9/i;->d:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v1, v6}, Ljava/util/concurrent/ConcurrentLinkedQueue;->remove(Ljava/lang/Object;)Z
    :try_end_75
    .catchall {:try_start_66 .. :try_end_75} :catchall_8c

    monitor-exit v6

    .line 9
    iget-object v1, v6, Lz9/h;->c:Ljava/net/Socket;

    invoke-static {v1}, Lx/e;->d(Ljava/lang/Object;)V

    .line 10
    invoke-static {v1}, Lw9/c;->e(Ljava/net/Socket;)V

    iget-object v1, v0, Lz9/i;->d:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->isEmpty()Z

    move-result v1

    if-eqz v1, :cond_8b

    iget-object v0, v0, Lz9/i;->b:Ly9/c;

    invoke-virtual {v0}, Ly9/c;->a()V

    :cond_8b
    :goto_8b
    return-wide v9

    :catchall_8c
    move-exception v0

    monitor-exit v6

    throw v0
.end method
