WebSVN – HomeAutomation – Diff – /trunk/PcSoftware/Atom1.5/src/control/Manager.cpp

 #include "broker/Manager.h"
 #include "broker/Message.h"
 #include "type/common.h"
 #include "timer/Manager.h"
+#include "storage/Manager.h"
 #include "Message.h"
 namespace atom {
 namespace can {
 Manager::Pointer Manager::instance_;
 Manager::Manager() : broker::Subscriber(false), LOG("can::Manager")
+{
+    Node::SetupStateMachine();
     // Nyquist–Shannon sampling theorem state that we need to double the time, modules send every 10 seconds
     this->timer_id_ = timer::Manager::Instance()->Set(20000, true);
 }
 Manager::~Manager()
 {
 }
 Manager::Pointer Manager::Instance()
+{
     return Manager::instance_;
+}
+}
 void Manager::Delete()
+{
     Manager::instance_.reset();
 }
 void Manager::ConnectSlots(const SignalOnNodeChange::slot_type& signal_on_node_change_, const SignalOnModuleChange::slot_type& slot_on_module_change, const SignalOnModuleMessage::slot_type& slot_on_module_message)
+{
     this->signal_on_node_change_.connect(signal_on_node_change_);
     this->signal_on_module_change_.connect(slot_on_module_change);
     this->signal_on_module_message_.connect(slot_on_module_message);
 }
 void Manager::SlotOnTimeoutHandler(timer::TimerId timer_id, bool repeat)
 {
     if (timer_id != this->timer_id_)
+    {
         return;
+    }
+    {
         if (!it->second->CheckTimeout())
+        {
             LOG.Info("Node " + type::ToHex(it->second->GetId()) + " has not sent anything in a long time, setting offline.");
             this->RemoveModules(it->second->GetId());
+            storage::Manager::Instance()->FlushStore("NodeList");
+            storage::Manager::Instance()->FlushStore("ModuleList");
         }
     }
 }
 void Manager::SlotOnMessageHandler(broker::Message::Pointer message)
 {
     if (message->GetType() == broker::Message::CAN_MESSAGE)
+    {
         //LOG.Debug("Message received");
         Message* payload = static_cast<Message*>(message->GetPayload().get());
         Node::Pointer node;
         if (payload->GetClassName() == "nmt")
+        {
             if (payload->GetCommandName() == "Bios_Start")
             {
                 node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
-                node->ResetTimeout();
-                this->RemoveModules(node->GetId());
-                node->SetState(Node::STATE_ONLINE);
-                LOG.Info("Node " + type::ToHex(node->GetId()) + " went online.");
-            }
-            else if (payload->GetCommandName() == "Reset")
-            {
-                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
+                node->Trigger(Node::EVENT_BIOS_START, payload->GetVariables());
-                this->RemoveModules(node->GetId());
-                node->SetState(Node::STATE_OFFLINE);
-                LOG.Info("Node " + type::ToHex(node->GetId()) + " went offline.");
             }
             else if (payload->GetCommandName() == "App_Start")
+            {
                 node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
-                node->ResetTimeout();
-                this->RequestModules(node->GetId());
-                node->SetState(Node::STATE_PENDING);
+                node->Trigger(Node::EVENT_APP_START, payload->GetVariables());
-                LOG.Info("Node " + type::ToHex(node->GetId()) + " started, requesting modules...");
+            }
             else if (payload->GetCommandName() == "Heartbeat")
             {
                 node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
-                node->ResetTimeout();
-                if (node->GetState() == Node::STATE_OFFLINE || node->GetState() == Node::STATE_ONLINE)
-                {
-                    this->RequestModules(node->GetId());
-                    node->SetState(Node::STATE_PENDING);
+                node->Trigger(Node::EVENT_HEARTBEAT, payload->GetVariables());
-                    LOG.Info("Node " + type::ToHex(node->GetId()) + " was found, requesting modules...");
-                }
-                else if (node->GetState() == Node::STATE_INITIALIZED)
-                {
-                    if (this->GetNumberOfModules(node->GetId()) != boost::lexical_cast<unsigned int>(payload->GetVariables()["NumberOfModules"]))
-                    {
-                        this->RequestModules(node->GetId());
-                        node->SetState(Node::STATE_PENDING);
-                        LOG.Info("Node " + type::ToHex(node->GetId()) + " reports a different number of modules than previously known, requesting modules...");
-                    }
-                }
             }
+        }
         else if (payload->GetDirectionName() == "From_Owner")
         {
             Module::Pointer module = this->GetModule(boost::lexical_cast<unsigned int>(payload->GetId()), payload->GetModuleName(), payload->GetClassName());
             if (payload->GetCommandName() == "List")
+            {
                 node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
                 node->ResetTimeout();
                 module->SetNodeId(node->GetId());
                 if (this->GetNumberOfModules(node->GetId()) == boost::lexical_cast<unsigned int>(payload->GetVariables()["NumberOfModules"]))
                 {
-                    node->SetState(Node::STATE_INITIALIZED);
+                    node->Trigger(Node::EVENT_LIST_DONE, payload->GetVariables());
                 }
                 LOG.Info("Module " + module->GetFullId() + " is available on node " + type::ToHex(node->GetId()) + ".");
                 this->signal_on_module_change_(module->GetFullId(), true);
+            }
             else
+            {
                 node = this->GetNode(module->GetNodeId());
                 node->ResetTimeout();
                 this->signal_on_module_message_(module->GetFullId(), payload->GetCommandName(), payload->GetVariables());
+            }
         }
+    }
+}
+void Manager::SlotOnNewState(Node::Id node_id, Node::State current_state, Node::State target_state)
+{
+    if (target_state != Node::STATE_NORM_INITIALIZED)
+    {
+        this->RemoveModules(node_id);
     }
 }
 void Manager::SendMessageHandler(std::string full_id, std::string command, type::StringMap variables)
 {
     ModuleList::iterator it = this->modules_.find(full_id);
     if (it == this->modules_.end())
+    {
         LOG.Warning("Can not send message to " + full_id + ", it is not available");
         return;
+    }
     try
     {
         Message* payload = new Message(it->second->GetClassName(), "To_Owner", it->second->GetName(), it->second->GetId(), command);
         payload->SetVariables(variables);
         broker::Manager::Instance()->Post(broker::Message::Pointer(new broker::Message(broker::Message::CAN_MESSAGE, broker::Message::PayloadPointer(payload), this)));
         //LOG.Debug("Command " + command + " sent to " + it->second->GetName());
     NodeList::iterator it = this->nodes_.find(node_id);
     if (it == this->nodes_.end())
+    {
         node = Node::Pointer(new Node(node_id));
+        node->ConnectSlots(Node::SignalOnNewState::slot_type(&Manager::SlotOnNewState, this, _1, _2, _3).track(this->tracker_));
         this->nodes_[node_id] = node;
+    }
     else
+    {
         node = it->second;
+{
     Module::Pointer module;
     ModuleList::iterator it = this->modules_.find(Module::MakeFullId(module_id, module_name));
     if (it == this->modules_.end())
     {
         module = Module::Pointer(new Module(module_id, module_name, class_name));
         this->modules_[module->GetFullId()] = module;
     }
     else
+    {
         module = it->second;
+    }
+}
 void Manager::RemoveModules(Node::Id node_id)
+{
     for (ModuleList::iterator it = this->modules_.begin(); it != this->modules_.end(); it++)
     {
         if (it->second->GetNodeId() == node_id)
+        {
             LOG.Info("Module " + it->second->GetFullId() + " is unavailable.");
             this->signal_on_module_change_(it->second->GetFullId(), false);
             this->modules_.erase(it);
+        }
+    }
-}
-void Manager::RequestModules(Node::Id node_id)
-{
-    this->RemoveModules(node_id);
-    Message* payload = new Message("mnmt", "To_Owner", "", 0, "List");
-    payload->SetVariable("HardwareId", boost::lexical_cast<std::string>(node_id));
-    broker::Manager::Instance()->Post(broker::Message::Pointer(new broker::Message(broker::Message::CAN_MESSAGE, broker::Message::PayloadPointer(payload), this)));
+}
 unsigned int Manager::GetNumberOfModules(Node::Id node_id)
+{
     unsigned int number_of_modules = 0;

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/Atom1.5/src/control/Manager.cpp @ 2139 – Rev 1619 → 1627