X-Git-Url: https://git.llucax.com/z.facultad/75.42/plaqui.git/blobdiff_plain/989d0da7e93d155dde399bf3047ab6b4af550bb6..9075115540d133ca048025e719884121007b9e87:/Server/include/plaqui/server/plant.h diff --git a/Server/include/plaqui/server/plant.h b/Server/include/plaqui/server/plant.h index 7709063..1430b09 100644 --- a/Server/include/plaqui/server/plant.h +++ b/Server/include/plaqui/server/plant.h @@ -40,7 +40,15 @@ namespace Server { /// Planta Química. class Plant: public Runnable { + ///////////////////////////////////////////////////////////////////// + // Constantes. + private: + + /// Tiempo por defecto a esperar entre iteraciones de la simulación. + static const unsigned DEFAULT_WAIT_TIME = 100000u; + + ///////////////////////////////////////////////////////////////////// // Tipos. private: @@ -48,12 +56,7 @@ namespace Server { /// Lista de conexiones de control. typedef std::list TransmitterList; - public: - - /// Tipo de señal para indicar que se actualizó la planta. - //typedef SigC::Signal0 SignalUpdated; - - + ///////////////////////////////////////////////////////////////////// // Atributos. private: @@ -67,13 +70,25 @@ namespace Server { /// Simulador usado para calcular el estado de la planta. Model::Simulator simulator; - /// Señal para indicar que se actualizó la planta. - //SignalUpdated updated; + /// Mutex para el simulador. + Glib::Mutex simulator_mutex; + + /// Nombre del archivo donde esta el XML de la planta. + std::string filename; - /// Nombre de la planta. - //std::string name; + /// Tiempo que espera entre cada iteración de la simulación. + unsigned wait_time; + /// Mutex para el tiempo de espera. + Glib::Mutex wait_time_mutex; + /// Indica si la planta está pausada o simulando. + bool paused; + + /// Mutex para el indicador de pausa. + Glib::Mutex paused_mutex; + + ///////////////////////////////////////////////////////////////////// // Métodos. protected: @@ -81,7 +96,7 @@ namespace Server { /** * Corre la planta (la monitorea o la simula). */ - virtual void real_run(void); + virtual void real_run(void) throw(); public: @@ -93,7 +108,6 @@ namespace Server { /** * Constructor desde un archivo. * - * \param name Nombre de la planta. * \param filename Nombre del archivo de donde obtener la planta. */ Plant(const std::string& filename); @@ -103,8 +117,7 @@ namespace Server { * * \return true si comenzó la transmisión, false si hubo problemas. */ - bool transmission_start(const string& host, - const Connection::Port& port); + bool transmission_start(string& host, Connection::Port& port); /** * Comienza una transmisión del estado de la planta. @@ -115,9 +128,46 @@ namespace Server { const Connection::Port& port); /** - * Obtiene la señal para indicar que se actualizó la planta. + * Borra una transmisión de la lista de transmisiones al finalizar. + * + * \param transmission Transmisión a eliminar. + */ + void on_transmission_finished(Transmitter* transmission); + + /** + * Abre (o cierra) un elemento de la planta. + * + * Sólo la bomba y la exclusa pueden ser abiertos y cerrados. + * + * \param element Nombre del elemento a abrir o cerrar. + * \param open true si se quiere abrir el elemento, false si se + * lo quiere cerrar. + * + * \return true si se abrió o cerró el elemento, false si no existía + * o si no era una bomba o exclusa. + */ + bool set_open(const std::string& element, bool open = true); + + /** + * Setea la frecuencia de refresco de la simulación. + * Si se setea a cero, se usa el tiempo por omisión. + * + * \param hz Cantidad de veces por segundo que debe refrescarse la + * simulación. + */ + void set_frequency(unsigned hz = 0u); + + /** + * Pausa (o reanuda) la simulación. + * + * \param paused true si se la quiere pausar, false para reanudar. + */ + void set_paused(bool paused = true); + + /** + * Obtiene el XML de la planta. */ - //SignalUpdated& signal_updated(void); + const std::string get_xml(void) const; };