Server/src/receiver.cpp

   1 // vim: set noexpandtab tabstop=4 shiftwidth=4:
   2 //----------------------------------------------------------------------------
   3 //                                  PlaQui
   4 //----------------------------------------------------------------------------
   5 // This file is part of PlaQui.
   6 //
   7 // PlaQui is free software; you can redistribute it and/or modify it under the
   8 // terms of the GNU General Public License as published by the Free Software
   9 // Foundation; either version 2 of the License, or (at your option) any later
  10 // version.
  11 //
  12 // PlaQui is distributed in the hope that it will be useful, but WITHOUT ANY
  13 // WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  14 // FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
  15 // details.
  16 //
  17 // You should have received a copy of the GNU General Public License along
  18 // with PlaQui; if not, write to the Free Software Foundation, Inc., 59 Temple
  19 // Place, Suite 330, Boston, MA  02111-1307  USA
  20 //----------------------------------------------------------------------------
  21 // Creado:  Sat Oct 18 18:18:36 2003
  22 // Autores: Leandro Lucarella <llucare@fi.uba.ar>
  23 //----------------------------------------------------------------------------
  24 //
  25 // $Id$
  26 //
  27
  28 #include "plaqui/server/receiver.h"
  29 #include <sstream>
  30 #ifdef DEBUG
  31 #       include <iostream>
  32 #endif // DEBUG
  33
  34 using namespace std;
  35
  36 namespace PlaQui {
  37
  38 namespace Server {
  39
  40 const string Receiver::FRAME_BEGIN("<plantstatus");
  41
  42 const string Receiver::FRAME_END("</plantstatus>");
  43
  44 Receiver::~Receiver(void) {
  45 #ifdef DEBUG
  46         cerr << __FILE__ << ": destructor." << endl;
  47 #endif // DEBUG
  48 }
  49
  50 Receiver::Receiver(const Connection::Port& port, const string& host):
  51                 Connection(sockbuf::sock_dgram, host, port) {
  52 #ifdef DEBUG
  53         cerr << __FILE__ << ": port = " << port
  54                 << " | host = " << host << endl;
  55 #endif // DEBUG
  56         //socket->bind(port);
  57         socket->bind(host.c_str(), port);
  58 }
  59
  60 // XXX EL XML DEBE EMPEZAR Y FINALIZAR EN UNA LINEA SEPARADA.
  61 void Receiver::real_run(void) {
  62 #ifdef DEBUG
  63         cerr << __FILE__ << ": real_run." << endl;
  64 #endif // DEBUG
  65         char buf[BUFSIZ];
  66         bool in_frame = false;
  67         stringstream ss;
  68         while (!stop && socket.getline(buf, BUFSIZ)) {
  69                 string sbuf = buf;
  70                 if (in_frame) {
  71                         string::size_type pos = sbuf.find(FRAME_END);
  72                         if (pos == string::npos) { // No encuentra el fin
  73                                 ss << sbuf << endl;
  74                         } else { // Encuentra el fin.
  75                                 // Agrego al mensaje actual hasta el final </plantstatus>.
  76                                 ss << sbuf.substr(0, pos + FRAME_END.length());
  77                                 frame_received(ss.str());
  78                                 ss.str("");
  79                                 in_frame = false;
  80                         }
  81                 } else { // No esta en un frame.
  82                         string::size_type pos = sbuf.find(FRAME_BEGIN);
  83                         if (pos != string::npos) { // Encuentra el inicio
  84                                 ss << sbuf.substr(pos) << endl;
  85                                 in_frame = true;
  86                         }
  87                 }
  88         }
  89 }
  90
  91 Receiver::SignalFrameReceived& Receiver::signal_frame_received(void) {
  92         return frame_received;
  93 }
  94
  95 } // namespace Server
  96
  97 } // namespace PlaQui
  98