.class public final Lz5/my1;
.super Ljava/lang/Thread;
.source ""


# instance fields
.field public final r:Ljava/util/concurrent/BlockingQueue;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/concurrent/BlockingQueue<",
            "Lz5/sy1<",
            "*>;>;"
        }
    .end annotation
.end field

.field public final s:Lz5/ly1;

.field public final t:Lz5/fy1;

.field public volatile u:Z

.field public final v:Lz5/ex0;


# direct methods
.method public constructor <init>(Ljava/util/concurrent/BlockingQueue;Lz5/ly1;Lz5/fy1;Lz5/ex0;)V
    .registers 6
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/util/concurrent/BlockingQueue<",
            "Lz5/sy1<",
            "*>;>;",
            "Lz5/ly1;",
            "Lz5/fy1;",
            "Lz5/ex0;",
            ")V"
        }
    .end annotation

    invoke-direct {p0}, Ljava/lang/Thread;-><init>()V

    const/4 v0, 0x0

    iput-boolean v0, p0, Lz5/my1;->u:Z

    iput-object p1, p0, Lz5/my1;->r:Ljava/util/concurrent/BlockingQueue;

    iput-object p2, p0, Lz5/my1;->s:Lz5/ly1;

    iput-object p3, p0, Lz5/my1;->t:Lz5/fy1;

    iput-object p4, p0, Lz5/my1;->v:Lz5/ex0;

    return-void
.end method


# virtual methods
.method public final a()V
    .registers 7

    iget-object v0, p0, Lz5/my1;->r:Ljava/util/concurrent/BlockingQueue;

    invoke-interface {v0}, Ljava/util/concurrent/BlockingQueue;->take()Ljava/lang/Object;

    move-result-object v0

    check-cast v0, Lz5/sy1;

    invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J

    const/4 v1, 0x3

    invoke-virtual {v0, v1}, Lz5/sy1;->zzf(I)V

    const/4 v1, 0x4

    :try_start_10
    const-string v2, "network-queue-take"

    invoke-virtual {v0, v2}, Lz5/sy1;->zzd(Ljava/lang/String;)V

    invoke-virtual {v0}, Lz5/sy1;->zzm()Z

    invoke-virtual {v0}, Lz5/sy1;->zzc()I

    move-result v2

    invoke-static {v2}, Landroid/net/TrafficStats;->setThreadStatsTag(I)V

    iget-object v2, p0, Lz5/my1;->s:Lz5/ly1;

    invoke-interface {v2, v0}, Lz5/ly1;->zza(Lz5/sy1;)Lz5/oy1;

    move-result-object v2

    const-string v3, "network-http-complete"

    invoke-virtual {v0, v3}, Lz5/sy1;->zzd(Ljava/lang/String;)V

    iget-boolean v3, v2, Lz5/oy1;->e:Z

    if-eqz v3, :cond_40

    invoke-virtual {v0}, Lz5/sy1;->zzr()Z

    move-result v3

    if-eqz v3, :cond_40

    const-string v2, "not-modified"

    invoke-virtual {v0, v2}, Lz5/sy1;->zze(Ljava/lang/String;)V

    invoke-virtual {v0}, Lz5/sy1;->zzx()V
    :try_end_3c
    .catch Lz5/bz1; {:try_start_10 .. :try_end_3c} :catch_9b
    .catch Ljava/lang/Exception; {:try_start_10 .. :try_end_3c} :catch_71
    .catchall {:try_start_10 .. :try_end_3c} :catchall_6f

    invoke-virtual {v0, v1}, Lz5/sy1;->zzf(I)V

    return-void

    :cond_40
    :try_start_40
    invoke-virtual {v0, v2}, Lz5/sy1;->zzs(Lz5/oy1;)Lz5/yy1;

    move-result-object v2

    const-string v3, "network-parse-complete"

    invoke-virtual {v0, v3}, Lz5/sy1;->zzd(Ljava/lang/String;)V

    iget-object v3, v2, Lz5/yy1;->b:Lz5/ey1;

    if-eqz v3, :cond_5f

    iget-object v3, p0, Lz5/my1;->t:Lz5/fy1;

    invoke-virtual {v0}, Lz5/sy1;->zzj()Ljava/lang/String;

    move-result-object v4

    iget-object v5, v2, Lz5/yy1;->b:Lz5/ey1;

    check-cast v3, Lz5/mz1;

    invoke-virtual {v3, v4, v5}, Lz5/mz1;->b(Ljava/lang/String;Lz5/ey1;)V

    const-string v3, "network-cache-written"

    invoke-virtual {v0, v3}, Lz5/sy1;->zzd(Ljava/lang/String;)V

    :cond_5f
    invoke-virtual {v0}, Lz5/sy1;->zzq()V

    iget-object v3, p0, Lz5/my1;->v:Lz5/ex0;

    const/4 v4, 0x0

    invoke-virtual {v3, v0, v2, v4}, Lz5/ex0;->l(Lz5/sy1;Lz5/yy1;Ljava/lang/Runnable;)V

    invoke-virtual {v0, v2}, Lz5/sy1;->zzw(Lz5/yy1;)V
    :try_end_6b
    .catch Lz5/bz1; {:try_start_40 .. :try_end_6b} :catch_9b
    .catch Ljava/lang/Exception; {:try_start_40 .. :try_end_6b} :catch_71
    .catchall {:try_start_40 .. :try_end_6b} :catchall_6f

    invoke-virtual {v0, v1}, Lz5/sy1;->zzf(I)V

    return-void

    :catchall_6f
    move-exception v2

    goto :goto_ab

    :catch_71
    move-exception v2

    const/4 v3, 0x1

    :try_start_73
    new-array v3, v3, [Ljava/lang/Object;

    const/4 v4, 0x0

    invoke-virtual {v2}, Ljava/lang/Exception;->toString()Ljava/lang/String;

    move-result-object v5

    aput-object v5, v3, v4

    const-string v4, "Unhandled exception %s"

    .line 1
    invoke-static {v4, v3}, Lz5/ez1;->d(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;

    move-result-object v3

    const-string v4, "Volley"

    invoke-static {v4, v3, v2}, Landroid/util/Log;->e(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)I

    .line 2
    new-instance v3, Lz5/bz1;

    invoke-direct {v3, v2}, Lz5/bz1;-><init>(Ljava/lang/Throwable;)V

    invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J

    iget-object v2, p0, Lz5/my1;->v:Lz5/ex0;

    invoke-virtual {v2, v0, v3}, Lz5/ex0;->o(Lz5/sy1;Lz5/bz1;)V

    invoke-virtual {v0}, Lz5/sy1;->zzx()V
    :try_end_97
    .catchall {:try_start_73 .. :try_end_97} :catchall_6f

    invoke-virtual {v0, v1}, Lz5/sy1;->zzf(I)V

    return-void

    :catch_9b
    move-exception v2

    :try_start_9c
    invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J

    iget-object v3, p0, Lz5/my1;->v:Lz5/ex0;

    invoke-virtual {v3, v0, v2}, Lz5/ex0;->o(Lz5/sy1;Lz5/bz1;)V

    invoke-virtual {v0}, Lz5/sy1;->zzx()V
    :try_end_a7
    .catchall {:try_start_9c .. :try_end_a7} :catchall_6f

    invoke-virtual {v0, v1}, Lz5/sy1;->zzf(I)V

    return-void

    :goto_ab
    invoke-virtual {v0, v1}, Lz5/sy1;->zzf(I)V

    throw v2
.end method

.method public final run()V
    .registers 3

    const/16 v0, 0xa

    invoke-static {v0}, Landroid/os/Process;->setThreadPriority(I)V

    :goto_5
    :try_start_5
    invoke-virtual {p0}, Lz5/my1;->a()V
    :try_end_8
    .catch Ljava/lang/InterruptedException; {:try_start_5 .. :try_end_8} :catch_9

    goto :goto_5

    :catch_9
    iget-boolean v0, p0, Lz5/my1;->u:Z

    if-eqz v0, :cond_15

    invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;

    move-result-object v0

    invoke-virtual {v0}, Ljava/lang/Thread;->interrupt()V

    return-void

    :cond_15
    const/4 v0, 0x0

    new-array v0, v0, [Ljava/lang/Object;

    const-string v1, "Ignoring spurious interrupt of NetworkDispatcher thread; use quit() to terminate it"

    invoke-static {v1, v0}, Lz5/ez1;->c(Ljava/lang/String;[Ljava/lang/Object;)V

    goto :goto_5
.end method
