UdpBioReadWriteProcessor$ConnectRunnable.smali

.class Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;
.super Ljava/lang/Object;
.source "UdpBioReadWriteProcessor.java"

# interfaces
.implements Ljava/lang/Runnable;


# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
    value = Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;
.end annotation

.annotation system Ldalvik/annotation/InnerClass;
    accessFlags = 0x2
    name = "ConnectRunnable"
.end annotation


# instance fields
.field final synthetic this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;


# direct methods
.method private constructor <init>(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)V
    .registers 2

    .line 118
    iput-object p1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

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

    return-void
.end method

.method synthetic constructor <init>(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$1;)V
    .registers 3

    .line 118
    invoke-direct {p0, p1}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;-><init>(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)V

    return-void
.end method


# virtual methods
.method public run()V
    .registers 8

    .line 122
    iget-object v0, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mClient:Lcom/open/net/client/structures/BaseClient;
    invoke-static {v0}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$100(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Lcom/open/net/client/structures/BaseClient;

    move-result-object v0

    check-cast v0, Lcom/open/net/client/impl/udp/bio/UdpBioClient;

    iget-object v0, v0, Lcom/open/net/client/impl/udp/bio/UdpBioClient;->mWriteBuff:[B

    .line 123
    iget-object v1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mClient:Lcom/open/net/client/structures/BaseClient;
    invoke-static {v1}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$100(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Lcom/open/net/client/structures/BaseClient;

    move-result-object v1

    check-cast v1, Lcom/open/net/client/impl/udp/bio/UdpBioClient;

    iget-object v1, v1, Lcom/open/net/client/impl/udp/bio/UdpBioClient;->mReadBuff:[B

    const/4 v2, 0x0

    .line 127
    :try_start_15
    iget-object v3, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    new-instance v4, Ljava/net/DatagramSocket;

    invoke-direct {v4}, Ljava/net/DatagramSocket;-><init>()V

    # setter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mSocket:Ljava/net/DatagramSocket;
    invoke-static {v3, v4}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$202(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;Ljava/net/DatagramSocket;)Ljava/net/DatagramSocket;

    .line 128
    iget-object v3, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mIp:Ljava/lang/String;
    invoke-static {v3}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$300(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Ljava/lang/String;

    move-result-object v3

    invoke-static {v3}, Ljava/net/InetAddress;->getByName(Ljava/lang/String;)Ljava/net/InetAddress;

    move-result-object v3

    .line 129
    new-instance v4, Ljava/net/DatagramPacket;

    array-length v5, v0

    iget-object v6, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mPort:I
    invoke-static {v6}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$400(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)I

    move-result v6

    invoke-direct {v4, v0, v5, v3, v6}, Ljava/net/DatagramPacket;-><init>([BILjava/net/InetAddress;I)V

    .line 130
    new-instance v0, Ljava/net/DatagramPacket;

    array-length v3, v1

    invoke-direct {v0, v1, v3}, Ljava/net/DatagramPacket;-><init>([BI)V

    .line 132
    iget-object v1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mConnectStatusListener:Lcom/open/net/client/impl/udp/bio/UdpBioConnectListener;
    invoke-static {v1}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$500(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Lcom/open/net/client/impl/udp/bio/UdpBioConnectListener;

    move-result-object v1

    if-eqz v1, :cond_52

    .line 133
    iget-object v1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mConnectStatusListener:Lcom/open/net/client/impl/udp/bio/UdpBioConnectListener;
    invoke-static {v1}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$500(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Lcom/open/net/client/impl/udp/bio/UdpBioConnectListener;

    move-result-object v1

    iget-object v3, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mSocket:Ljava/net/DatagramSocket;
    invoke-static {v3}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$200(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Ljava/net/DatagramSocket;

    move-result-object v5

    invoke-interface {v1, v3, v5, v4, v0}, Lcom/open/net/client/impl/udp/bio/UdpBioConnectListener;->onConnectSuccess(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;Ljava/net/DatagramSocket;Ljava/net/DatagramPacket;Ljava/net/DatagramPacket;)V

    :cond_52
    const/4 v0, 0x1

    .line 137
    iget-object v1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    new-instance v3, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$WriteRunnable;

    const/4 v4, 0x0

    invoke-direct {v3, v1, v4}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$WriteRunnable;-><init>(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$1;)V

    # setter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mWriteProcessor:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$WriteRunnable;
    invoke-static {v1, v3}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$602(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$WriteRunnable;)Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$WriteRunnable;

    .line 138
    iget-object v1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    new-instance v3, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ReadRunnable;

    invoke-direct {v3, v1, v4}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ReadRunnable;-><init>(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$1;)V

    # setter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mReadProcessor:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ReadRunnable;
    invoke-static {v1, v3}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$802(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ReadRunnable;)Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ReadRunnable;

    .line 140
    iget-object v1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    new-instance v3, Ljava/lang/Thread;

    iget-object v4, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mWriteProcessor:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$WriteRunnable;
    invoke-static {v4}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$600(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$WriteRunnable;

    move-result-object v4

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

    # setter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mWriteThread:Ljava/lang/Thread;
    invoke-static {v1, v3}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$1002(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;Ljava/lang/Thread;)Ljava/lang/Thread;

    .line 141
    iget-object v1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    new-instance v3, Ljava/lang/Thread;

    iget-object v4, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mReadProcessor:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ReadRunnable;
    invoke-static {v4}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$800(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ReadRunnable;

    move-result-object v4

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

    # setter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mReadThread:Ljava/lang/Thread;
    invoke-static {v1, v3}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$1102(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;Ljava/lang/Thread;)Ljava/lang/Thread;

    .line 143
    iget-object v1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mWriteThread:Ljava/lang/Thread;
    invoke-static {v1}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$1000(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Ljava/lang/Thread;

    move-result-object v1

    invoke-virtual {v1}, Ljava/lang/Thread;->start()V

    .line 144
    iget-object v1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mReadThread:Ljava/lang/Thread;
    invoke-static {v1}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$1100(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Ljava/lang/Thread;

    move-result-object v1

    invoke-virtual {v1}, Ljava/lang/Thread;->start()V
    :try_end_9a
    .catch Ljava/net/UnknownHostException; {:try_start_15 .. :try_end_9a} :catch_a1
    .catch Ljava/net/SocketException; {:try_start_15 .. :try_end_9a} :catch_9c

    move v2, v0

    goto :goto_a5

    :catch_9c
    move-exception v0

    .line 150
    invoke-virtual {v0}, Ljava/net/SocketException;->printStackTrace()V

    goto :goto_a5

    :catch_a1
    move-exception v0

    .line 147
    invoke-virtual {v0}, Ljava/net/UnknownHostException;->printStackTrace()V

    :goto_a5
    if-nez v2, :cond_ba

    .line 155
    iget-object v0, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mConnectStatusListener:Lcom/open/net/client/impl/udp/bio/UdpBioConnectListener;
    invoke-static {v0}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$500(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Lcom/open/net/client/impl/udp/bio/UdpBioConnectListener;

    move-result-object v0

    if-eqz v0, :cond_ba

    .line 156
    iget-object v0, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    # getter for: Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->mConnectStatusListener:Lcom/open/net/client/impl/udp/bio/UdpBioConnectListener;
    invoke-static {v0}, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;->access$500(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)Lcom/open/net/client/impl/udp/bio/UdpBioConnectListener;

    move-result-object v0

    iget-object v1, p0, Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor$ConnectRunnable;->this$0:Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;

    invoke-interface {v0, v1}, Lcom/open/net/client/impl/udp/bio/UdpBioConnectListener;->onConnectFailed(Lcom/open/net/client/impl/udp/bio/processor/UdpBioReadWriteProcessor;)V

    :cond_ba
    return-void
.end method