Server/include/plaqui/server/server.h

   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 #ifndef PLAQUI_SERVER_H
  29 #define PLAQUI_SERVER_H
  30
  31 #include "plaqui/server/tcpserver.h"
  32 #include "plaqui/server/controlserver.h"
  33 #include "plaqui/server/transmitter.h"
  34 #include "plaqui/server/plant.h"
  35 #include "plaqui/server/command.h"
  36 #include <socket++/sockinet.h>
  37 #include <string>
  38 #include <map>
  39
  40 namespace PlaQui {
  41
  42 namespace Server {
  43
  44         /**
  45          * Servidor de plantas químicas.
  46          * Maneja múltiples conexiones, de control o de transmisión.
  47          */
  48         class Server: public TCPServer {
  49
  50                 // Tipos.
  51
  52                 private:
  53
  54                         /// Lista de plantas químicas.
  55                         typedef std::map<std::string, Plant*> PlantList;
  56
  57                 // Atributos.
  58
  59                 private:
  60
  61                         // Plantas disponibles en el servidor.
  62                         PlantList plants;
  63
  64                         /// Mutex para las plantas.
  65                         Glib::Mutex plants_mutex;
  66
  67                 // Métodos.
  68
  69                 protected:
  70
  71                         /**
  72                          * Obtiene una nueva \ref Connection "conexión".
  73                          *
  74                          * \param sd Descriptor del socket de la nueva conexión.
  75                          *
  76                          * \return Nueva conexión.
  77                          */
  78                         virtual Connection* new_connection(const sockbuf::sockdesc& sd);
  79
  80                         /**
  81                          * Maneja el comando server/status.
  82                          */
  83                         HTTPResponse* cmd_server_status(void) const;
  84
  85                         /**
  86                          * Maneja el comando connection/list.
  87                          */
  88                         HTTPResponse* cmd_connection_list(void);
  89
  90                         /**
  91                          * Maneja el comando connection/stop.
  92                          */
  93                         HTTPResponse* cmd_connection_stop(const Command& command);
  94
  95                         /**
  96                          * Maneja el comando transmission/list.
  97                          */
  98                         HTTPResponse* cmd_transmission_list(void);
  99
 100                         /**
 101                          * Maneja el comando transmission/start.
 102                          */
 103                         HTTPResponse* cmd_transmission_start(const Command& command);
 104
 105                         /**
 106                          * Maneja el comando transmission/stop.
 107                          */
 108                         HTTPResponse* cmd_transmission_stop(const Command& command);
 109
 110                         /**
 111                          * Maneja el comando plant/list.
 112                          */
 113                         HTTPResponse* cmd_plant_list(void);
 114
 115                         /**
 116                          * Maneja el comando plant/get.
 117                          */
 118                         HTTPResponse* cmd_plant_get(const Command& command);
 119
 120                         /**
 121                          * Maneja el comando plant/get.
 122                          */
 123                         HTTPResponse* cmd_plant_set(const Command& command);
 124
 125                         /**
 126                          * Maneja el comando plant/stop.
 127                          */
 128                         HTTPResponse* cmd_plant_stop(const Command& command);
 129
 130                 public:
 131
 132                         /**
 133                          * Destructor.
 134                          */
 135                         virtual ~Server(void);
 136
 137                         /**
 138                          * Constructor.
 139                          *
 140                          * \param port Puerto en el cual escuchar.
 141                          */
 142                         Server(const std::string& plant_filename,
 143                                         const Connection::Port& port = 7522) throw(sockerr);
 144
 145                         /**
 146                          * Maneja los comandos recibidos por las conexiones.
 147                          */
 148                         void on_control_command_received(const Command& command,
 149                                         ControlServer* controlserver);
 150
 151                         /**
 152                          * Se encarga de borrar una planta de la lista cuando finaliza.
 153                          *
 154                          * \param connection Conexión a eliminar.
 155                          */
 156                         void on_plant_finished(const char* plant);
 157
 158                         /**
 159                          * Envia el estado de una planta cuando esta se actualiza.
 160                          *
 161                          * \param plant Planta actualizada.
 162                          */
 163                         void on_plant_updated(const Plant* const);
 164
 165         };
 166
 167 }
 168
 169 }
 170
 171 #endif // PLAQUI_SERVER_H