proto-debuger/protoDebuger/network_controller.cpp

#include "network_controller.h"


NetworkController::NetworkController(NetworkController::NetWorkType type, QString ip, uint16_t port)
{
    mType = type;
    if(_checkType(type) == TYPE_UNKOWN){

    }
    if(type == NetWorkType::TYPE_TCP_CLIENT){
        mTcp = new QTcpSocket();
        mCnn = mTcp;

        QObject::connect(mTcp, SIGNAL(readyRead()), this, SLOT(on_ready_read()));
        QObject::connect(mTcp, SIGNAL(disconnected()), this, SLOT(on_disconect()));

        mTcp->connectToHost(ip,port,QIODevice::ReadWrite);
    }

    if(type == NetWorkType::TYPE_TCP_SERVER){

        mTcpServer = new QTcpServer();
        connect(mTcpServer,SIGNAL(newConnection()),
                this,SLOT(on_server_accept()));
        connect(mTcpServer, SIGNAL(acceptError(QAbstractSocket::SocketError socketError)),
                this, SLOT(displayError()));

        if (!mTcpServer->listen(QHostAddress::Any, port))
        {
            qDebug() << "m_pTcpServer->listen() error";
        }
    }

}

int NetworkController::SendData(int8_t *data, uint32_t len)
{
    if(nullptr == data)
        return -1;
    return mCnn->write((const char *)data,len);
}

int NetworkController::ReadData(int8_t *data)
{
    if(nullptr != data){
        return -1;
    }
    memcpy(data,mCnn->readAll().data(),mCnn->size());
}


NetworkController::~NetworkController()
{
    delete  mTcp;
}

void NetworkController::on_ready_read()
{
    qDebug()<<QString::fromStdString(mTcp->readAll().toStdString());
    emit(on_data_recv());
}

void NetworkController::on_disconect()
{
    qDebug()<<"close";
    if(nullptr != mCnn){
        emit(this->on_conection_close());
        mCnn->close();
    }
}

void NetworkController::on_server_accept()
{
    if(mType == TYPE_TCP_SERVER){
        mTcpServer->pauseAccepting();
        QTcpSocket* pClientConnection = mTcpServer->nextPendingConnection();
        if(nullptr != pClientConnection){
            QObject::connect(pClientConnection, SIGNAL(readyRead()), this, SLOT(on_ready_read()));
            QObject::connect(pClientConnection, SIGNAL(disconnected()), this, SLOT(on_disconect()));
        }
        mTcp = pClientConnection;
    }
}

NetworkController::NetWorkType NetworkController::_checkType(NetWorkType type){
    if(type < TYPE_UNKOWN){
        return type;
    }else{
        return TYPE_UNKOWN;
    }
}