Subversion Repositories HomeAutomation

/*

 *

 *  Copyright (C) 2010  Mattias Runge

 *

 *  This program is free software; you can redistribute it and/or modify

 *  it under the terms of the GNU General Public License as published by

 *  the Free Software Foundation; either version 2 of the License, or

 *  (at your option) any later version.

 *

 *  This program is distributed in the hope that it will be useful,

 *  but WITHOUT ANY WARRANTY; without even the implied warranty of

 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 *  GNU General Public License for more details.

 *

 *  You should have received a copy of the GNU General Public License along

 *  with this program; if not, write to the Free Software Foundation, Inc.,

 *  51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.

 *

 */

#include "Manager.h"

#include <boost/lexical_cast.hpp>

#include "broker/Manager.h"

#include "broker/Message.h"

#include "type/common.h"

#include "timer/Manager.h"

#include "Message.h"

namespace atom {

namespace can {

Manager::Pointer Manager::instance_;

Manager::Manager() : broker::Subscriber(false), LOG("can::Manager")

{

    // 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::Create()

{

    Manager::instance_ = Manager::Pointer(new Manager());

}

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;

    }

    for (NodeList::iterator it = this->nodes_.begin(); it != this->nodes_.end(); it++)

    {

        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());

        }

    }

}

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"]));

                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);

                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);

                    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);

                }

                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::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());

    }

    catch (std::runtime_error& e)

    {

        LOG.Error("Failed to send message, " + std::string(e.what()));

    }

}

void Manager::SendMessage(std::string full_id, std::string command, type::StringMap variables)

{

    this->io_service_.post(boost::bind(&Manager::SendMessageHandler, this, full_id, command, variables));

}

bool Manager::IsModuleAvailable(std::string full_id)

{

    return this->modules_.find(full_id) != this->modules_.end();

}

Node::Pointer Manager::GetNode(Node::Id node_id)

{

    Node::Pointer node;

    NodeList::iterator it = this->nodes_.find(node_id);

    if (it == this->nodes_.end())

    {

        node = Node::Pointer(new Node(node_id));

        this->nodes_[node_id] = node;

    }

    else

    {

        node = it->second;

    }

    return node;

}

Module::Pointer Manager::GetModule(Module::Id module_id, std::string module_name, std::string class_name)

{

    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;

    }

    return module;

}

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;

    for (ModuleList::iterator it = this->modules_.begin(); it != this->modules_.end(); it++)

    {

        if (it->second->GetNodeId() == node_id)

        {

            number_of_modules++;

        }

    }

    return number_of_modules;

}

}; // namespace can

}; // namespace atom