BaseClient.smali

.class public abstract Lcom/open/net/client/structures/BaseClient;
.super Ljava/lang/Object;
.source "BaseClient.java"


# instance fields
.field protected mMessageProcessor:Lcom/open/net/client/structures/BaseMessageProcessor;

.field public mReadMessageQueen:Lcom/open/net/client/structures/message/MessageReadQueen;

.field public mWriteMessageQueen:Lcom/open/net/client/structures/message/MessageWriteQueen;


# direct methods
.method public constructor <init>(Lcom/open/net/client/structures/BaseMessageProcessor;)V
    .registers 3

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

    .line 17
    new-instance v0, Lcom/open/net/client/structures/message/MessageReadQueen;

    invoke-direct {v0}, Lcom/open/net/client/structures/message/MessageReadQueen;-><init>()V

    iput-object v0, p0, Lcom/open/net/client/structures/BaseClient;->mReadMessageQueen:Lcom/open/net/client/structures/message/MessageReadQueen;

    .line 20
    new-instance v0, Lcom/open/net/client/structures/message/MessageWriteQueen;

    invoke-direct {v0}, Lcom/open/net/client/structures/message/MessageWriteQueen;-><init>()V

    iput-object v0, p0, Lcom/open/net/client/structures/BaseClient;->mWriteMessageQueen:Lcom/open/net/client/structures/message/MessageWriteQueen;

    .line 25
    iput-object p1, p0, Lcom/open/net/client/structures/BaseClient;->mMessageProcessor:Lcom/open/net/client/structures/BaseMessageProcessor;

    return-void
.end method


# virtual methods
.method public clearUnreachableMessages()V
    .registers 2

    .line 30
    invoke-virtual {p0}, Lcom/open/net/client/structures/BaseClient;->pollWriteMessage()Lcom/open/net/client/structures/message/Message;

    move-result-object v0

    :goto_4
    if-eqz v0, :cond_e

    .line 32
    invoke-virtual {p0, v0}, Lcom/open/net/client/structures/BaseClient;->removeWriteMessage(Lcom/open/net/client/structures/message/Message;)V

    .line 33
    invoke-virtual {p0}, Lcom/open/net/client/structures/BaseClient;->pollWriteMessage()Lcom/open/net/client/structures/message/Message;

    move-result-object v0

    goto :goto_4

    :cond_e
    return-void
.end method

.method public abstract onCheckConnect()V
.end method

.method public abstract onClose()V
.end method

.method public abstract onRead()Z
.end method

.method public onReceiveData([BII)V
    .registers 5

    .line 38
    iget-object v0, p0, Lcom/open/net/client/structures/BaseClient;->mReadMessageQueen:Lcom/open/net/client/structures/message/MessageReadQueen;

    invoke-virtual {v0, p1, p2, p3}, Lcom/open/net/client/structures/message/MessageReadQueen;->build([BII)Lcom/open/net/client/structures/message/Message;

    move-result-object p1

    .line 39
    iget-object p2, p0, Lcom/open/net/client/structures/BaseClient;->mReadMessageQueen:Lcom/open/net/client/structures/message/MessageReadQueen;

    invoke-virtual {p2, p1}, Lcom/open/net/client/structures/message/MessageReadQueen;->add(Lcom/open/net/client/structures/message/Message;)V

    return-void
.end method

.method public onReceiveMessageClear()V
    .registers 3

    .line 43
    iget-object v0, p0, Lcom/open/net/client/structures/BaseClient;->mReadMessageQueen:Lcom/open/net/client/structures/message/MessageReadQueen;

    iget-object v0, v0, Lcom/open/net/client/structures/message/MessageReadQueen;->mReadQueen:Ljava/util/LinkedList;

    invoke-virtual {v0}, Ljava/util/LinkedList;->poll()Ljava/lang/Object;

    move-result-object v0

    check-cast v0, Lcom/open/net/client/structures/message/Message;

    :goto_a
    if-eqz v0, :cond_1c

    .line 45
    iget-object v1, p0, Lcom/open/net/client/structures/BaseClient;->mReadMessageQueen:Lcom/open/net/client/structures/message/MessageReadQueen;

    invoke-virtual {v1, v0}, Lcom/open/net/client/structures/message/MessageReadQueen;->remove(Lcom/open/net/client/structures/message/Message;)V

    .line 46
    iget-object v0, p0, Lcom/open/net/client/structures/BaseClient;->mReadMessageQueen:Lcom/open/net/client/structures/message/MessageReadQueen;

    iget-object v0, v0, Lcom/open/net/client/structures/message/MessageReadQueen;->mReadQueen:Ljava/util/LinkedList;

    invoke-virtual {v0}, Ljava/util/LinkedList;->poll()Ljava/lang/Object;

    move-result-object v0

    check-cast v0, Lcom/open/net/client/structures/message/Message;

    goto :goto_a

    :cond_1c
    return-void
.end method

.method public onSendMessage([BII)V
    .registers 5

    .line 52
    iget-object v0, p0, Lcom/open/net/client/structures/BaseClient;->mWriteMessageQueen:Lcom/open/net/client/structures/message/MessageWriteQueen;

    invoke-virtual {v0, p1, p2, p3}, Lcom/open/net/client/structures/message/MessageWriteQueen;->build([BII)Lcom/open/net/client/structures/message/Message;

    move-result-object p1

    .line 53
    iget-object p2, p0, Lcom/open/net/client/structures/BaseClient;->mWriteMessageQueen:Lcom/open/net/client/structures/message/MessageWriteQueen;

    invoke-virtual {p2, p1}, Lcom/open/net/client/structures/message/MessageWriteQueen;->add(Lcom/open/net/client/structures/message/Message;)V

    .line 54
    invoke-virtual {p0}, Lcom/open/net/client/structures/BaseClient;->onCheckConnect()V

    return-void
.end method

.method public abstract onWrite()Z
.end method

.method protected pollWriteMessage()Lcom/open/net/client/structures/message/Message;
    .registers 2

    .line 58
    iget-object v0, p0, Lcom/open/net/client/structures/BaseClient;->mWriteMessageQueen:Lcom/open/net/client/structures/message/MessageWriteQueen;

    iget-object v0, v0, Lcom/open/net/client/structures/message/MessageWriteQueen;->mWriteQueen:Ljava/util/LinkedList;

    invoke-virtual {v0}, Ljava/util/LinkedList;->poll()Ljava/lang/Object;

    move-result-object v0

    check-cast v0, Lcom/open/net/client/structures/message/Message;

    return-object v0
.end method

.method protected removeWriteMessage(Lcom/open/net/client/structures/message/Message;)V
    .registers 3

    .line 62
    iget-object v0, p0, Lcom/open/net/client/structures/BaseClient;->mWriteMessageQueen:Lcom/open/net/client/structures/message/MessageWriteQueen;

    invoke-virtual {v0, p1}, Lcom/open/net/client/structures/message/MessageWriteQueen;->remove(Lcom/open/net/client/structures/message/Message;)V

    return-void
.end method