gui/src/data/NetworkReceiver.cpp

   1 #include "NetworkReceiver.h"
   2 #include "NetworkReceiver.moc"
   3
   4 NetworkReceiver::NetworkReceiver(QObject* parent, QString host, quint16 port) : DataReceiver(parent), host(host), port(port) {
   5 }
   6
   7 NetworkReceiver::~NetworkReceiver() {
   8     tcp_socket->deleteLater();
   9 }
  10
  11 void NetworkReceiver::run() {
  12     tcp_socket = new QTcpSocket(NULL);
  13     tcp_socket->connectToHost(host, port);
  14     connect(tcp_socket, SIGNAL(readyRead()), this, SLOT(data_received()));
  15     connect(tcp_socket, SIGNAL(disconnected()), this, SLOT(disconnected()));
  16     exec();
  17 }
  18
  19 void NetworkReceiver::data_received() {
  20     qDebug("NetworkReceiver: Received data from monitor . . .");
  21     QByteArray received = tcp_socket->readAll();
  22     unprocessed += received;
  23     while(unprocessed.size()) {
  24         /* TODO: actually process event */
  25         unprocessed.chop(0);
  26     }
  27 }
  28
  29
  30 void NetworkReceiver::disconnected() {
  31     this->exit(0);
  32     emit no_more_data();
  33 }