b.smali

.class public final Lcom/beetalklib/network/thread/b;
.super Landroid/os/HandlerThread;
.source "SourceFile"

# interfaces
.implements Lcom/beetalklib/network/tcp/a;


# instance fields
.field public a:Lcom/beetalklib/network/tcp/h;

.field public b:Lcom/beetalklib/network/thread/a;

.field public final c:Lcom/beetalklib/network/tcp/c;

.field public d:Lcom/beetalklib/network/tcp/d;

.field public final e:Ljava/util/concurrent/ExecutorService;


# direct methods
.method public constructor <init>(Lcom/beetalklib/network/tcp/h;Lcom/beetalklib/network/tcp/c;)V
    .registers 4

    const-string v0, "NETWORK_THREAD"

    .line 1
    invoke-direct {p0, v0}, Landroid/os/HandlerThread;-><init>(Ljava/lang/String;)V

    .line 2
    iput-object p1, p0, Lcom/beetalklib/network/thread/b;->a:Lcom/beetalklib/network/tcp/h;

    .line 3
    iput-object p2, p0, Lcom/beetalklib/network/thread/b;->c:Lcom/beetalklib/network/tcp/c;

    .line 4
    invoke-static {}, Ljava/util/concurrent/Executors;->newSingleThreadExecutor()Ljava/util/concurrent/ExecutorService;

    move-result-object p1

    iput-object p1, p0, Lcom/beetalklib/network/thread/b;->e:Ljava/util/concurrent/ExecutorService;

    return-void
.end method


# virtual methods
.method public final a()Z
    .registers 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Ljava/util/concurrent/RejectedExecutionException;
        }
    .end annotation

    .line 1
    iget-object v0, p0, Lcom/beetalklib/network/thread/b;->e:Ljava/util/concurrent/ExecutorService;

    invoke-interface {v0}, Ljava/util/concurrent/ExecutorService;->isShutdown()Z

    move-result v0

    if-nez v0, :cond_28

    iget-object v0, p0, Lcom/beetalklib/network/thread/b;->e:Ljava/util/concurrent/ExecutorService;

    invoke-interface {v0}, Ljava/util/concurrent/ExecutorService;->isTerminated()Z

    move-result v0

    if-eqz v0, :cond_11

    goto :goto_28

    .line 2
    :cond_11
    new-instance v0, Lcom/beetalklib/network/tcp/g;

    iget-object v1, p0, Lcom/beetalklib/network/thread/b;->a:Lcom/beetalklib/network/tcp/h;

    .line 3
    iget-object v2, v1, Lcom/beetalklib/network/tcp/h;->b:Ljava/io/InputStream;

    .line 4
    invoke-direct {v0, v2}, Lcom/beetalklib/network/tcp/g;-><init>(Ljava/io/InputStream;)V

    .line 5
    new-instance v2, Lcom/beetalklib/network/tcp/e;

    iget-object v3, p0, Lcom/beetalklib/network/thread/b;->c:Lcom/beetalklib/network/tcp/c;

    invoke-direct {v2, v1, v0, v3}, Lcom/beetalklib/network/tcp/e;-><init>(Lcom/beetalklib/network/tcp/h;Lcom/beetalklib/network/tcp/g;Lcom/beetalklib/network/tcp/c;)V

    .line 6
    iget-object v0, p0, Lcom/beetalklib/network/thread/b;->e:Ljava/util/concurrent/ExecutorService;

    invoke-interface {v0, v2}, Ljava/util/concurrent/ExecutorService;->submit(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;

    const/4 v0, 0x1

    return v0

    :cond_28
    :goto_28
    const/4 v0, 0x0

    return v0
.end method

.method public final b()V
    .registers 5

    .line 1
    iget-object v0, p0, Lcom/beetalklib/network/thread/b;->a:Lcom/beetalklib/network/tcp/h;

    invoke-virtual {v0}, Lcom/beetalklib/network/tcp/h;->c()Z

    move-result v0

    const/4 v1, 0x0

    if-eqz v0, :cond_14

    .line 2
    iget-object v0, p0, Lcom/beetalklib/network/thread/b;->d:Lcom/beetalklib/network/tcp/d;

    iget-object v2, p0, Lcom/beetalklib/network/thread/b;->a:Lcom/beetalklib/network/tcp/h;

    invoke-static {v2}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;)Ljava/lang/Object;

    invoke-virtual {v0, v1}, Lcom/beetalklib/network/tcp/d;->d(I)V

    return-void

    .line 3
    :cond_14
    :try_start_14
    iget-object v0, p0, Lcom/beetalklib/network/thread/b;->a:Lcom/beetalklib/network/tcp/h;

    invoke-virtual {v0}, Lcom/beetalklib/network/tcp/h;->a()V

    .line 4
    invoke-virtual {p0}, Lcom/beetalklib/network/thread/b;->a()Z

    move-result v0

    if-eqz v0, :cond_2a

    .line 5
    iget-object v0, p0, Lcom/beetalklib/network/thread/b;->d:Lcom/beetalklib/network/tcp/d;

    iget-object v2, p0, Lcom/beetalklib/network/thread/b;->a:Lcom/beetalklib/network/tcp/h;

    invoke-static {v2}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;)Ljava/lang/Object;

    invoke-virtual {v0, v1}, Lcom/beetalklib/network/tcp/d;->d(I)V

    goto :goto_52

    .line 6
    :cond_2a
    iget-object v0, p0, Lcom/beetalklib/network/thread/b;->a:Lcom/beetalklib/network/tcp/h;

    invoke-virtual {v0}, Lcom/beetalklib/network/tcp/h;->b()V
    :try_end_2f
    .catch Lcom/beetalklib/network/exception/d; {:try_start_14 .. :try_end_2f} :catch_3c
    .catch Ljava/util/concurrent/RejectedExecutionException; {:try_start_14 .. :try_end_2f} :catch_30

    goto :goto_52

    .line 7
    :catch_30
    iget-object v0, p0, Lcom/beetalklib/network/thread/b;->d:Lcom/beetalklib/network/tcp/d;

    iget-object v2, p0, Lcom/beetalklib/network/thread/b;->a:Lcom/beetalklib/network/tcp/h;

    invoke-static {v2}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;)Ljava/lang/Object;

    const/4 v2, 0x3

    invoke-virtual {v0, v1, v2}, Lcom/beetalklib/network/tcp/d;->c(II)V

    goto :goto_52

    :catch_3c
    move-exception v0

    .line 8
    iget-object v2, p0, Lcom/beetalklib/network/thread/b;->d:Lcom/beetalklib/network/tcp/d;

    iget-object v3, p0, Lcom/beetalklib/network/thread/b;->a:Lcom/beetalklib/network/tcp/h;

    invoke-static {v3}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;)Ljava/lang/Object;

    .line 9
    invoke-virtual {v0}, Ljava/lang/Throwable;->getCause()Ljava/lang/Throwable;

    move-result-object v0

    instance-of v0, v0, Ljava/net/UnknownHostException;

    if-eqz v0, :cond_4e

    const/4 v0, 0x1

    goto :goto_4f

    :cond_4e
    const/4 v0, 0x2

    .line 10
    :goto_4f
    invoke-virtual {v2, v1, v0}, Lcom/beetalklib/network/tcp/d;->c(II)V

    :goto_52
    return-void
.end method

.method public final onLooperPrepared()V
    .registers 4

    .line 1
    invoke-super {p0}, Landroid/os/HandlerThread;->onLooperPrepared()V

    .line 2
    new-instance v0, Lcom/beetalklib/network/tcp/d;

    invoke-virtual {p0}, Landroid/os/HandlerThread;->getLooper()Landroid/os/Looper;

    move-result-object v1

    iget-object v2, p0, Lcom/beetalklib/network/thread/b;->c:Lcom/beetalklib/network/tcp/c;

    invoke-direct {v0, v1, v2}, Lcom/beetalklib/network/tcp/d;-><init>(Landroid/os/Looper;Lcom/beetalklib/network/tcp/c;)V

    iput-object v0, p0, Lcom/beetalklib/network/thread/b;->d:Lcom/beetalklib/network/tcp/d;

    return-void
.end method