source: pacpussensors/trunk/TelnetClient/TelnetClient.cpp@ 110

/*********************************************************************
//  created:    2012/03/01 - 14:06
//  filename:   TelnetClient.cpp
//
//  author:     Pierre Hudelaine
//              Copyright Heudiasyc UMR UTC/CNRS 7253
// 
//  version:    $Id: $
//
//  purpose:    Create network socket if needed in Pacpus
//
*********************************************************************/

#include "TelnetClient.h" 
#include <string>

using namespace pacpus;
using namespace std;

/// Default host address = 0.0.0.0 (any address)
static const string kDefaultHostAddress = "127.0.0.1";
/// Default host port = 2368
static const uint16_t kDefaultHostPort = 2368;

DECLARE_STATIC_LOGGER("pacpus.base.TelnetClient");


//////////////////////////////////////////////////////////////////////////
// Construct the factory
//////////////////////////////////////////////////////////////////////////
static ComponentFactory <TelnetClient> sFactory("TelnetClient");  


//////////////////////////////////////////////////////////////////////////
// Constructeur
//////////////////////////////////////////////////////////////////////////
TelnetClient::TelnetClient(QString name)
    : ComponentBase(name) 
{
    address_.setAddress(kDefaultHostAddress.c_str());
    port_ = kDefaultHostPort;
} 


//////////////////////////////////////////////////////////////////////////
// Destructor
//////////////////////////////////////////////////////////////////////////
TelnetClient::~TelnetClient() 
{
}


//////////////////////////////////////////////////////////////////////////
// Called by the ComponentManager to pass the XML parameters to the 
// component 
//////////////////////////////////////////////////////////////////////////
ComponentBase::COMPONENT_CONFIGURATION  TelnetClient::configureComponent(XmlComponentConfig config) 
{ 

        return ComponentBase::CONFIGURED_OK; 
} 


//////////////////////////////////////////////////////////////////////////
// Called by the ComponentManager to start the component
//////////////////////////////////////////////////////////////////////////
void TelnetClient::startActivity() 
{ 
        if (!(socket_ = new QTcpSocket()))
                qFatal("Failed to init socket!");

        connect(socket_, SIGNAL(connected()), this, SLOT(ConnectionMessage()));
  
        socket_->connectToHost(address_, port_, QIODevice::ReadWrite); 

        connect(socket_, SIGNAL(readyRead()), this, SLOT(readPendingDatagrams()));
}

void TelnetClient::ConnectionMessage()
{
        qDebug() << "Connected to the server"; 
}

/*
void TelnetClient::sendDatagrams(QString frame) 
{ 
        int sent=0;
        
        if (socketType_ == "client")
        {
            if ((sent = socket_->writeDatagram(frame.toLocal8Bit(), address2send_, port2send_)) == -1) 
                        qDebug() << "Failed to send the frame: " << address2send_ << port2send_ << frame << endl; 
            //else 
                        //qDebug() << "TO NETWORK:" << address2send_ << port2send_ << frame << "size" << sent;
        }
        else if (socketType_ == "server")
        {
            for (int i = 0; i < listClients.size(); i++)
            {
                        if ((sent = socket_->writeDatagram(frame.toLocal8Bit(), listClients[i]->getAddress(), listClients[i]->getPort())) == -1) 
                                qDebug() << "Failed to send the frame: " << listClients[i]->getAddress() << listClients[i]->getPort() << frame << endl; 
                        //else 
                                //qDebug() << "TO NETWORK:" << listClients[i]->getAddress() << listClients[i]->getPort() << frame << "size" << sent;    
            }
        }
} 


void TelnetClient::sendDatagrams(QByteArray frame) 
{ 
        int sent=0;
        
        if (socketType_ == "client")
        {
            if ((sent = socket_->writeDatagram(frame, address2send_, port2send_)) == -1) 
                        qDebug() << "Failed to send the frame: " << address2send_ << port2send_ << frame << endl; 
            //else 
                        //qDebug() << "TO NETWORK:" << address2send_ << port2send_ << frame << "size" << sent;
        }
        else if (socketType_ == "server")
        {
            for (int i = 0; i < listClients.size(); i++)
            {
                        if ((sent = socket_->writeDatagram(frame, listClients[i]->getAddress(), listClients[i]->getPort())) == -1) 
                                qDebug() << "Failed to send the frame: " << listClients[i]->getAddress() << listClients[i]->getPort() << frame << endl; 
                        //else 
                                //qDebug() << "TO NETWORK:" << listClients[i]->getAddress() << listClients[i]->getPort() << frame << "size" << sent;    
            }
        }
} 
*/

void TelnetClient::readPendingDatagrams()
{
        /*
        while (socket_->hasPendingDatagrams())  
        {
                QByteArray datagram; 
                datagram.resize(socket_->pendingDatagramSize()); 
                QHostAddress sender; 
                quint16 senderPort;
    
        }*/

                
        QDataStream in(socket_); 
        QString data; 
        in >> data; 
        qDebug() << "New data: " << data;
}


//////////////////////////////////////////////////////////////////////////
// Called by the ComponentManager to stop the component
//////////////////////////////////////////////////////////////////////////
void TelnetClient::stopActivity()
{
        socket_->close();
        delete socket_;
}