Subversion Repositories HomeAutomation

Rev

Rev 1599 | Rev 1602 | Go to most recent revision | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | SVN | RSS feed

Rev 1599 Rev 1601
Line 22... Line 22...
22 
 
 22 
 
23 
#include <boost/lexical_cast.hpp>
 23 
#include <boost/lexical_cast.hpp>
24 
 
 24 
 
25 
#include "broker/Manager.h"
 25 
#include "broker/Manager.h"
26 
#include "broker/Message.h"
 26 
#include "broker/Message.h"
- 
 
 27 
#include "type/common.h"
- 
 
 28 
#include "timer/Manager.h"
- 
 
 29 
 
27 
#include "Message.h"
 30 
#include "Message.h"
28 
#include <type/common.h>
 - 
 
29 
 
 31 
 
30 
namespace atom {
 32 
namespace atom {
31 
namespace can {
 33 
namespace can {
32 
 
 - 
 
33 
   
 34 
   
34 
Manager::Pointer Manager::instance_;
 35 
Manager::Pointer Manager::instance_;
35 
 
 36 
 
36 
Manager::Manager() : broker::Subscriber(false), LOG("can::Manager")
 37 
Manager::Manager() : broker::Subscriber(false), LOG("can::Manager")
37 
{
 38 
{
38 
    // TODO: Set offline timer
 39 
    this->timer_id_ = timer::Manager::Instance()->Set(10000, true);
39 
}
 40 
}
40 
 
 41 
 
41 
Manager::~Manager()
 42 
Manager::~Manager()
42 
{
 43 
{
43 
}
 44 
}
44 
 
 45 
 
45 
Manager::Pointer Manager::Instance()
 46 
Manager::Pointer Manager::Instance()
46 
{
 47 
{
47 
    return Manager::instance_;
 48 
    return Manager::instance_;
48 
}
 49 
}
49 
 
 50 
 
50 
void Manager::Create()
 51 
void Manager::Create()
51 
{
 52 
{
52 
    Manager::instance_ = Manager::Pointer(new Manager());
 53 
    Manager::instance_ = Manager::Pointer(new Manager());
53 
}
 54 
}
54 
 
 55 
 
55 
void Manager::Delete()
 56 
void Manager::Delete()
56 
{
 57 
{
57 
    Manager::instance_.reset();
 58 
    Manager::instance_.reset();
- 
 
 59 
}
- 
 
 60 
 
- 
 
 61 
void Manager::SlotOnTimeoutHandler(timer::TimerId timer_id, bool repeat)
- 
 
 62 
{
- 
 
 63 
    if (timer_id != this->timer_id_)
- 
 
 64 
    {
- 
 
 65 
        return;
- 
 
 66 
    }
- 
 
 67 
   
- 
 
 68 
    for (NodeList::iterator it = this->nodes_.begin(); it != this->nodes_.end(); it++)
- 
 
 69 
    {
- 
 
 70 
        if (!it->second->CheckTimeout())
- 
 
 71 
        {
- 
 
 72 
            LOG.Info("Node " + type::ToHex(it->second->GetId()) + " has not sent anything in a long time, setting offline.");
- 
 
 73 
            this->RemoveModules(it->second->GetId());
- 
 
 74 
        }
- 
 
 75 
    }
58 
}
 76 
}
59 
 
 77 
 
60 
void Manager::SlotOnMessageHandler(broker::Message::Pointer message)
 78 
void Manager::SlotOnMessageHandler(broker::Message::Pointer message)
61 
{
 79 
{
62 
    if (message->GetType() == broker::Message::CAN_MESSAGE)
 80 
    if (message->GetType() == broker::Message::CAN_MESSAGE)
Line 67... Line 85...
67 
        if (payload->GetClassName() == "nmt")
 85 
        if (payload->GetClassName() == "nmt")
68 
        {
 86 
        {
69 
            if (payload->GetCommandName() == "Bios_Start")
 87 
            if (payload->GetCommandName() == "Bios_Start")
70 
            {
 88 
            {
71 
                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
 89 
                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
- 
 
 90 
                node->ResetTimeout();
- 
 
 91 
               
72 
                this->RemoveModules(node->GetId());
 92 
                this->RemoveModules(node->GetId());
73 
                node->SetState(Node::STATE_ONLINE);
 93 
                node->SetState(Node::STATE_ONLINE);
74 
                LOG.Info("Node " + type::ToHex(node->GetId()) + " went online.");
 94 
                LOG.Info("Node " + type::ToHex(node->GetId()) + " went online.");
75 
            }
 95 
            }
76 
            else if (payload->GetCommandName() == "Reset")
 96 
            else if (payload->GetCommandName() == "Reset")
77 
            {
 97 
            {
78 
                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
 98 
                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
- 
 
 99 
 
79 
                this->RemoveModules(node->GetId());
 100 
                this->RemoveModules(node->GetId());
80 
                node->SetState(Node::STATE_OFFLINE);
 101 
                node->SetState(Node::STATE_OFFLINE);
81 
                LOG.Info("Node " + type::ToHex(node->GetId()) + " went offline.");
 102 
                LOG.Info("Node " + type::ToHex(node->GetId()) + " went offline.");
82 
            }
 103 
            }
83 
            else if (payload->GetCommandName() == "App_start")
 104 
            else if (payload->GetCommandName() == "App_Start")
84 
            {
 105 
            {
85 
                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
 106 
                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
- 
 
 107 
                node->ResetTimeout();
- 
 
 108 
               
86 
                this->RequestModules(node->GetId());
 109 
                this->RequestModules(node->GetId());
87 
                node->SetState(Node::STATE_PENDING);
 110 
                node->SetState(Node::STATE_PENDING);
88 
                LOG.Info("Node " + type::ToHex(node->GetId()) + " started, requesting modules...");
 111 
                LOG.Info("Node " + type::ToHex(node->GetId()) + " started, requesting modules...");
89 
            }
 112 
            }
90 
            else if (payload->GetCommandName() == "Heartbeat")
 113 
            else if (payload->GetCommandName() == "Heartbeat")
91 
            {
 114 
            {
92 
                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
 115 
                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
- 
 
 116 
                node->ResetTimeout();
93 
               
 117 
               
94 
                if (node->GetState() == Node::STATE_OFFLINE || node->GetState() == Node::STATE_ONLINE)
 118 
                if (node->GetState() == Node::STATE_OFFLINE || node->GetState() == Node::STATE_ONLINE)
95 
                {
 119 
                {
96 
                    this->RequestModules(node->GetId());
 120 
                    this->RequestModules(node->GetId());
97 
                    node->SetState(Node::STATE_PENDING);
 121 
                    node->SetState(Node::STATE_PENDING);
Line 102... Line 126...
102 
                    if (this->GetNumberOfModules(node->GetId()) != boost::lexical_cast<unsigned int>(payload->GetVariables()["NumberOfModules"]))
 126 
                    if (this->GetNumberOfModules(node->GetId()) != boost::lexical_cast<unsigned int>(payload->GetVariables()["NumberOfModules"]))
103 
                    {
 127 
                    {
104 
                        this->RequestModules(node->GetId());
 128 
                        this->RequestModules(node->GetId());
105 
                        node->SetState(Node::STATE_PENDING);
 129 
                        node->SetState(Node::STATE_PENDING);
106 
                        LOG.Info("Node " + type::ToHex(node->GetId()) + " reports a different number of modules than previously known, requesting modules...");
 130 
                        LOG.Info("Node " + type::ToHex(node->GetId()) + " reports a different number of modules than previously known, requesting modules...");
107 
                    }
 131 
                    }
108 
                }
 132 
                }
109 
            }
 133 
            }
110 
        }
 134 
        }
111 
        else
 135 
        else
112 
        {
 136 
        {
113 
            if (payload->GetCommandName() == "List" && payload->GetDirectionName() == "From_Owner")
 137 
            if (payload->GetCommandName() == "List" && payload->GetDirectionName() == "From_Owner")
114 
            {
 138 
            {
115 
                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
 139 
                node = this->GetNode(boost::lexical_cast<unsigned int>(payload->GetVariables()["HardwareId"]));
- 
 
 140 
                node->ResetTimeout();
116 
               
 141 
               
117 
                Module::Pointer module = this->GetModule(boost::lexical_cast<unsigned int>(payload->GetId()), payload->GetModuleName(), payload->GetClassName());
 142 
                Module::Pointer module = this->GetModule(boost::lexical_cast<unsigned int>(payload->GetId()), payload->GetModuleName(), payload->GetClassName());
118 
                module->SetNodeId(node->GetId());
 143 
                module->SetNodeId(node->GetId());
119 
               
 144 
               
120 
                if (this->GetNumberOfModules(node->GetId()) == boost::lexical_cast<unsigned int>(payload->GetVariables()["NumberOfModules"]))
 145 
                if (this->GetNumberOfModules(node->GetId()) == boost::lexical_cast<unsigned int>(payload->GetVariables()["NumberOfModules"]))
Line 122... Line 147...
122 
                    node->SetState(Node::STATE_INITIALIZED);
 147 
                    node->SetState(Node::STATE_INITIALIZED);
123 
                }
 148 
                }
124 
               
 149 
               
125 
                LOG.Info("Module " + module->GetFullId() + " is available on node " + type::ToHex(node->GetId()) + ".");
 150 
                LOG.Info("Module " + module->GetFullId() + " is available on node " + type::ToHex(node->GetId()) + ".");
126 
                // TODO: Notify that module is available
 151 
                // TODO: Notify that module is available
127 
            }
 152 
            }
128 
        }
 153 
        }
129 
    }
 154 
    }
130 
}
 155 
}
131 
 
 156 
 
132 
Node::Pointer Manager::GetNode(Node::Id node_id)
 157 
Node::Pointer Manager::GetNode(Node::Id node_id)
133 
{
 158 
{
134 
    Node::Pointer node;
 159 
    Node::Pointer node;
135 
    NodeList::iterator it = this->nodes_.find(node_id);
 160 
    NodeList::iterator it = this->nodes_.find(node_id);
Line 185... Line 210...
185 
   
 210 
   
186 
    Message* payload = new Message("mnmt", "To_Owner", "", 0, "List");
 211 
    Message* payload = new Message("mnmt", "To_Owner", "", 0, "List");
187 
    payload->SetVariable("HardwareId", boost::lexical_cast<std::string>(node_id));
 212 
    payload->SetVariable("HardwareId", boost::lexical_cast<std::string>(node_id));
188 
   
 213 
   
189 
    broker::Manager::Instance()->Post(broker::Message::Pointer(new broker::Message(broker::Message::CAN_MESSAGE, broker::Message::PayloadPointer(payload), this)));
 214 
    broker::Manager::Instance()->Post(broker::Message::Pointer(new broker::Message(broker::Message::CAN_MESSAGE, broker::Message::PayloadPointer(payload), this)));
190 
   
 - 
 
191 
    // TODO: Set timeout if no response
 - 
 
192 
}
 215 
}
193 
 
 216 
 
194 
unsigned int Manager::GetNumberOfModules(Node::Id node_id)
 217 
unsigned int Manager::GetNumberOfModules(Node::Id node_id)
195 
{
 218 
{
196 
    unsigned int number_of_modules = 0;
 219 
    unsigned int number_of_modules = 0;