Subversion Repositories HomeAutomation

Rev

Rev 2090 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | SVN | RSS feed

  1. /*
  2.  *
  3.  *  Copyright (C) 2010  Mattias Runge
  4.  *
  5.  *  This program is free software; you can redistribute it and/or modify
  6.  *  it under the terms of the GNU General Public License as published by
  7.  *  the Free Software Foundation; either version 2 of the License, or
  8.  *  (at your option) any later version.
  9.  *
  10.  *  This program is distributed in the hope that it will be useful,
  11.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  12.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13.  *  GNU General Public License for more details.
  14.  *
  15.  *  You should have received a copy of the GNU General Public License along
  16.  *  with this program; if not, write to the Free Software Foundation, Inc.,
  17.  *  51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  18.  *
  19.  */
  20.  
  21. #include "Network.h"
  22.  
  23. #include <vector>
  24.  
  25. #include <boost/algorithm/string.hpp>
  26. #include <boost/lexical_cast.hpp>
  27.  
  28. #include "net/Manager.h"
  29.  
  30. #include "broker/Manager.h"
  31.  
  32. #include "Protocol.h"
  33. #include "Message.h"
  34.  
  35. #include "common/Bitset.h"
  36. #include "common/common.h"
  37. #include "common/log.h"
  38.  
  39. namespace atom {
  40. namespace can {
  41.  
  42. enum
  43. {
  44.     PACKET_START = 253,
  45.     PACKET_END   = 250,
  46.     PACKET_PING  = 251
  47. };
  48.  
  49. static const std::string log_module_ = "can::network";
  50.  
  51. Network::Network(std::string address): broker::Subscriber(false), LOG("can::Network")
  52. {
  53.     this->address_ = address;
  54.     this->client_id_ = 0;
  55.  
  56.     // Examples of address
  57.     // udp:192.168.1.250:1100
  58.     // serial:/dev/ttyUSB0:38400
  59.  
  60.     common::StringList parts;
  61.     boost::algorithm::split(parts, address, boost::is_any_of(":"), boost::algorithm::token_compress_off);
  62.  
  63.     if (parts.size() < 3)
  64.     {
  65.         LOG.Error("Malformed address string: " + address);
  66.         return;
  67.     }
  68.  
  69.     boost::algorithm::to_lower(parts[0]);
  70.  
  71.     if (parts[0] == "udp")
  72.     {
  73.         this->protocol_ = net::TRANSPORT_PROTOCOL_UDP;
  74.     }
  75.     else if (parts[0] == "serial")
  76.     {
  77.         this->protocol_ = net::TRANSPORT_PROTOCOL_SERIAL;
  78.     }
  79.     else
  80.     {
  81.         LOG.Error("Unknown protocol, only support udp and serial, got " + parts[0]);
  82.         return;
  83.     }
  84.  
  85.     this->address_ = parts[1];
  86.     this->port_or_baud_ = boost::lexical_cast<unsigned int>(parts[2]);
  87.  
  88.     try
  89.     {
  90.         this->client_id_ = net::Manager::Instance()->Connect(this->protocol_, this->address_, this->port_or_baud_);
  91.         LOG.Info("Connected to " + address);
  92.  
  93.         LOG.Info("Sending ping...");
  94.  
  95.         common::Byteset buffer(1);
  96.         buffer[0] = PACKET_PING;
  97.  
  98.         net::Manager::Instance()->SendTo(this->client_id_, buffer);
  99.     }
  100.     catch (std::runtime_error& e)
  101.     {
  102.         LOG.Error(e.what());
  103.     }
  104. }
  105.  
  106. Network::~Network()
  107. {
  108.     net::Manager::Instance()->Disconnect(this->client_id_);
  109. }
  110.  
  111. void Network::SlotOnTimeout(timer::TimerId timer_id)
  112. {
  113.     if (timer_id == this->timer_id_)
  114.     {
  115.         this->io_service_.post(boost::bind(&Network::SlotOnTimeoutHandler, this, timer_id));
  116.     }
  117. }
  118.  
  119. void Network::SlotOnMessageHandler(broker::Message::Pointer message)
  120. {
  121.     if (message->GetType() == broker::Message::CAN_RAW_BYTES)
  122.     {
  123.       net::Manager::Instance()->SendTo(this->client_id_, message->GetRawData());
  124.     }
  125.     else if (message->GetType() == broker::Message::CAN_MESSAGE)
  126.     {
  127.         Message* payload = static_cast<Message*>(message->GetPayload().get());
  128.         common::Byteset data(17);
  129.  
  130.         data[0] = PACKET_START;
  131.  
  132.         unsigned int class_id = Protocol::Instance()->ResolveClassId(payload->GetClassName());
  133.         data[4] = class_id << 1;
  134.  
  135.         if (payload->GetClassName() == "nmt")
  136.         {
  137.             unsigned int command_id = Protocol::Instance()->ResolveNMTCommandId(payload->GetCommandName());
  138.             data[3] = command_id;
  139.         }
  140.         else
  141.         {
  142.             unsigned int direction_flag = Protocol::Instance()->ResolveDirectionFlag(payload->GetDirectionName());
  143.             data[4] |= (direction_flag & 0x01);
  144.  
  145.             unsigned int module_id = Protocol::Instance()->ResolveModuleId(payload->GetModuleName());
  146.             data[3] = module_id;
  147.  
  148.             data[2] = payload->GetId();
  149.  
  150.             unsigned int command_id = Protocol::Instance()->ResolveCommandId(payload->GetCommandName(), payload->GetModuleName());
  151.             data[1] = command_id;
  152.         }
  153.  
  154.         unsigned int highest_bit = 0;
  155.         common::Bitset databits(64);
  156.  
  157.         xml::Node::NodeList variable_nodes;
  158.         unsigned int start_bit;
  159.         unsigned int bit_length;
  160.         std::string type;
  161.         std::string value;
  162.  
  163.         if (payload->GetClassName() == "nmt")
  164.         {
  165.             variable_nodes = Protocol::Instance()->GetNMTCommandVariables(payload->GetCommandName());
  166.         }
  167.         else
  168.         {
  169.             variable_nodes = Protocol::Instance()->GetCommandVariables(payload->GetCommandName(), payload->GetModuleName());
  170.         }
  171.  
  172.         for (unsigned int n = 0; n < variable_nodes.size(); n++)
  173.         {
  174.             value = payload->GetVariable(variable_nodes[n].GetAttributeValue("name"));
  175.             //LOG.Debug(variable_nodes[n].GetAttributeValue("name") + "=" + value);
  176.             if (value == "")
  177.             {
  178.                 continue;
  179.             }
  180.  
  181.             start_bit = boost::lexical_cast<unsigned int>(variable_nodes[n].GetAttributeValue("start_bit"));
  182.             bit_length = boost::lexical_cast<unsigned int>(variable_nodes[n].GetAttributeValue("bit_length"));
  183.             type = variable_nodes[n].GetAttributeValue("type");
  184.  
  185.             if (type == "int")
  186.             {
  187.                 Protocol::Instance()->EncodeInt(databits, start_bit, bit_length, value);
  188.             }
  189.             else if (type == "float")
  190.             {
  191.                 Protocol::Instance()->EncodeFloat(databits, start_bit, bit_length, value);
  192.             }
  193.             else if (type == "ascii")
  194.             {
  195.                 Protocol::Instance()->EncodeAscii(databits, start_bit, bit_length, value);
  196.                 bit_length = value.length() * 8;
  197.             }
  198.             else if (type == "hexstring")
  199.             {
  200.                 Protocol::Instance()->EncodeHexstring(databits, start_bit, bit_length, value);
  201.                 bit_length = value.length() * 4;
  202.             }
  203.             else if (type == "enum")
  204.             {
  205.                 value = variable_nodes[n].SelectChild("name", value).GetAttributeValue("id");
  206.                 Protocol::Instance()->EncodeUint(databits, start_bit, bit_length, value);
  207.             }
  208.             else// if (type == "uint")
  209.             {
  210.                 Protocol::Instance()->EncodeUint(databits, start_bit, bit_length, value);
  211.             }
  212.  
  213.             if (highest_bit < start_bit + bit_length)
  214.             {
  215.                 highest_bit = start_bit + bit_length;
  216.             }
  217.         }
  218.  
  219.         //LOG.Debug(databits.ToDebugString());
  220.  
  221.         unsigned int length = std::min((int)ceil((float)highest_bit / 8.0f), 8);
  222.  
  223.         data[5] = 1;
  224.         data[6] = 0;
  225.  
  226.         data[7] = length;
  227.  
  228.         for (unsigned int n = 0; n < 8; n++)
  229.         {
  230.             data[8 + n] = databits.GetBytes()[n];
  231.         }
  232.  
  233.         data[16] = PACKET_END;
  234.  
  235.         //LOG.Debug("Bytes: " + data.ToDebugString());
  236.         net::Manager::Instance()->SendTo(this->client_id_, data);
  237.     }
  238.     else if (message->GetType() == broker::Message::CAN_RAW_MESSAGE)
  239.     {
  240.         std::string* payload_str;
  241.     payload_str = static_cast<std::string*>(message->GetPayload().get());
  242.     std::string line = *payload_str;
  243.  
  244.         if (line.length() < 16)
  245.         {
  246.           log::Error(log_module_, "Packet was to short: \"%s\", length was %u.", line.data(), line.length());
  247.           return;
  248.         }
  249.  
  250.  
  251.         common::Byteset data(17);
  252.         //LOG.Info("Got "+ line + "end");
  253.  
  254.         data[0] = PACKET_START;
  255.         std::string value = line.substr(4,2);
  256.     //LOG.Info("<"+ value + ">");
  257.     data[4] = common::FromHex(value);
  258.     //LOG.Info("id1: " + value + " data: ");//+ data[1]);
  259.  
  260.     value = line.substr(6,2);
  261.     //LOG.Info("<"+ value + ">");
  262.  
  263.     data[3] = common::FromHex(value);
  264.     //LOG.Info("id2: " + value + " data: ");//+ data[2]);
  265.  
  266.     value = line.substr(8,2);
  267.     data[2] = common::FromHex(value);
  268.     //LOG.Info("id3: " + value + " data: ");//+ data[3]);
  269.  
  270.     value = line.substr(10,2);
  271.     data[1] = common::FromHex(value);
  272.     //LOG.Info("id4: " + value + " data: ");//+ data[4]);
  273.  
  274.     value = line.substr(13,1);
  275.     data[5] = common::FromHex(value);
  276.     //LOG.Info("1: " + value + " data: ");//+ data[5]);
  277.  
  278.     value = line.substr(15,1);
  279.     data[6] = common::FromHex(value);
  280.     //LOG.Info("1: " + value + " data: ");//+ data[6]);
  281.  
  282.         unsigned char length = 0;
  283.         unsigned char index = 0;
  284.         while (length < 8 && index + 16 < (unsigned char)line.length())
  285.         {
  286.             value = line.substr(index+17,2);
  287.         data[8+length] = common::FromHex(value);
  288.         //LOG.Info("data: " + value + " data: ");//+ data[6]);
  289.         index += 3;
  290.         length++;
  291.         }
  292.  
  293.         data[7] = length;
  294.         data[16] = PACKET_END;
  295.  
  296.  
  297.         //LOG.Info("Bytes: " + data.ToDebugString());
  298.         net::Manager::Instance()->SendTo(this->client_id_, data);
  299.     }
  300. }
  301.  
  302. void Network::SlotOnNewDataHandler(net::SocketId client_id, common::Byteset data)
  303. {
  304.   if (client_id != this->client_id_)
  305.   {
  306.     return;
  307.   }
  308.  
  309.   broker::Manager::Instance()->Post(broker::Message::Pointer(new broker::Message(broker::Message::CAN_RAW_BYTES, data, this)));
  310.  
  311.   static bool have_start = false;
  312.  
  313.   for (unsigned int n = 0; n < data.size(); n++)
  314.   {
  315.     log::Extreme(log_module_, "data[%u] = %u, have_start = %s, this->buffer_.size() = %u", n, (unsigned int)data[n], have_start ? "true" : "false", this->buffer_.size());
  316.  
  317.     if (have_start)
  318.     {
  319.       if (data[n] == PACKET_END && this->buffer_.size() >= 15)
  320.       {
  321.         log::Extreme(log_module_, "PACKET_END");
  322.  
  323.         while (this->buffer_.size() < 15)
  324.         {
  325.           this->buffer_.push_back(0);
  326.         }
  327.  
  328.         for (unsigned int k = 0; k < this->buffer_.size(); k++)
  329.         {
  330.           log::Extreme(log_module_, "this->buffer_[%u]=%u", k, (unsigned int)this->buffer_[k]);
  331.         }
  332.  
  333.         this->ProcessBuffer();
  334.  
  335.         have_start = false;
  336.       }
  337.       else
  338.       {
  339.         this->buffer_.push_back(data[n]);
  340.       }
  341.     }
  342.     else if (data[n] == PACKET_START)
  343.     {
  344.       log::Extreme(log_module_, "PACKET_START");
  345.  
  346.       common::Byteset empty_vector;
  347.       this->buffer_.swap(empty_vector);
  348.  
  349.       have_start = true;
  350.     }
  351.     else if (data[n] == PACKET_PING)
  352.     {
  353.       log::Info(log_module_, "Got Pong!");
  354.     }
  355.   }
  356. }
  357.  
  358. void Network::SlotOnNewClientHandler(net::SocketId id, net::SocketId server_id)
  359. {
  360.  
  361. }
  362.  
  363. void Network::SlotOnNewStateHandler(net::SocketId client_id, net::ClientState client_state)
  364. {
  365.     if (client_id != this->client_id_)
  366.     {
  367.         return;
  368.     }
  369.  
  370.     if (client_state == net::CLIENT_STATE_DISCONNECTED)
  371.     {
  372.         LOG.Warning("Got disconnected, setting reconnect timer...");
  373.  
  374.         this->timer_id_ = timer::Manager::Instance()->SetTimer(10000, true);
  375.         this->client_id_ = 0;
  376.     }
  377.     else
  378.     {
  379.         LOG.Debug("Got state: " + boost::lexical_cast<std::string>((int)client_state));
  380.     }
  381. }
  382.  
  383. void Network::SlotOnTimeoutHandler(timer::TimerId timer_id)
  384. {
  385.     try
  386.     {
  387.         this->client_id_ = net::Manager::Instance()->Connect(this->protocol_, this->address_, this->port_or_baud_);
  388.         LOG.Info("Connected again.");
  389.  
  390.         timer::Manager::Instance()->Cancel(timer_id);
  391.         this->timer_id_ = 0;
  392.     }
  393.     catch (std::runtime_error& e)
  394.     {
  395.         LOG.Error(e.what());
  396.         LOG.Warning("Will try again soon...");
  397.     }
  398. }
  399.  
  400. void Network::ProcessBuffer()
  401. {
  402.   LOG_DEBUG_ENTER;
  403.  
  404.     try
  405.     {
  406.         std::string class_name = "";
  407.         std::string direction_name = "";
  408.         std::string module_name = "";
  409.         unsigned int id = 0;
  410.         std::string command_name = "";
  411.  
  412.     std::string PKTstring = "PKT " +
  413.                 atom::common::ToHex8bit((unsigned int)this->buffer_[3]) +
  414.                 atom::common::ToHex8bit((unsigned int)this->buffer_[2]) +
  415.                 atom::common::ToHex8bit((unsigned int)this->buffer_[1]) +
  416.                 atom::common::ToHex8bit((unsigned int)this->buffer_[0]) +
  417.                 " " +
  418.                 atom::common::ToHex4bit((unsigned int)this->buffer_[4]) +
  419.                 " " +
  420.                 atom::common::ToHex4bit((unsigned int)this->buffer_[5]);
  421.  
  422.     for (unsigned int index = 7; index < 7 + (unsigned int)this->buffer_[6]; index++)
  423.     {
  424.         PKTstring += " " + atom::common::ToHex8bit((unsigned int)this->buffer_[index]) ;
  425.     }
  426.  
  427.     PKTstring += "\n";
  428.  
  429.     LOG.Extreme(PKTstring);
  430.  
  431.   for (unsigned int n = 0; n < this->buffer_.size(); n++)
  432.   {
  433.      log::Extreme(log_module_, "this->buffer_[%u]=%u", n, (unsigned int)this->buffer_[n]);
  434.   }
  435.  
  436.     std::string* payload_str = new std::string(PKTstring);
  437.     broker::Manager::Instance()->Post(broker::Message::Pointer(new broker::Message(broker::Message::CAN_RAW_MESSAGE, broker::Message::PayloadPointer(payload_str), this)));
  438.  
  439.  
  440.         unsigned int class_id = (this->buffer_[3] >> 1) & 0x0F;
  441.         LOG.Extreme("class_id=" + boost::lexical_cast<std::string>(class_id));
  442.         class_name = Protocol::Instance()->LookupClassName(class_id);
  443.  
  444.         if (class_name == "nmt")
  445.         {
  446.             unsigned int command_id = this->buffer_[2];
  447.             LOG.Extreme("command_id=" + boost::lexical_cast<std::string>(command_id));
  448.             command_name = Protocol::Instance()->LookupNMTCommandName(command_id);
  449.         }
  450.         else
  451.         {
  452.             unsigned int direction_flag = this->buffer_[3] & 0x01;
  453.             LOG.Extreme("direction_flag=" + boost::lexical_cast<std::string>(direction_flag));
  454.             direction_name = Protocol::Instance()->LookupDirectionFlag(direction_flag);
  455.  
  456.             unsigned int module_id = this->buffer_[2];
  457.             LOG.Extreme("module_id=" + boost::lexical_cast<std::string>(module_id));
  458.             module_name = Protocol::Instance()->LookupModuleName(module_id);
  459.             LOG.Extreme("module_name=" + module_name);
  460.             id = this->buffer_[1];
  461.  
  462.             unsigned int command_id = this->buffer_[0];
  463.             LOG.Extreme("command_id=" + boost::lexical_cast<std::string>(command_id));
  464.             command_name = Protocol::Instance()->LookupCommandName(command_id, module_name);
  465.             LOG.Extreme("command_name=" + command_name);
  466.         }
  467.  
  468.         Message* payload = new Message(class_name, direction_name, module_name, id, command_name);
  469.  
  470.         unsigned int length = this->buffer_[6];
  471.  
  472.         common::Byteset data_set;
  473.         data_set.reserve(length);
  474.  
  475.         for (unsigned int n = 0; n < length; n++)
  476.         {
  477.             data_set.push_back(this->buffer_[n + 7]);
  478.         }
  479.  
  480.         for (unsigned int n = 0; n < data_set.size(); n++)
  481.         {
  482.            log::Extreme(log_module_, "data_set[%u]=%u", n, (unsigned int)data_set[n]);
  483.         }
  484.  
  485.         common::Bitset databits(data_set);
  486.         xml::Node::NodeList variable_nodes;
  487.         unsigned int start_bit;
  488.         int bit_length;
  489.         std::string type;
  490.         std::string value;
  491.         std::string name;
  492.  
  493.         if (class_name == "nmt")
  494.         {
  495.             variable_nodes = Protocol::Instance()->GetNMTCommandVariables(command_name);
  496.         }
  497.         else
  498.         {
  499.             variable_nodes = Protocol::Instance()->GetCommandVariables(command_name, module_name);
  500.         }
  501.  
  502.         for (unsigned int n = 0; n < variable_nodes.size(); n++)
  503.         {
  504.             name = variable_nodes[n].GetAttributeValue("name");
  505.             start_bit = boost::lexical_cast<unsigned int>(variable_nodes[n].GetAttributeValue("start_bit"));
  506.             bit_length = boost::lexical_cast<unsigned int>(variable_nodes[n].GetAttributeValue("bit_length"));
  507.  
  508.             if (databits.GetCount() < start_bit + bit_length)
  509.             {
  510.                 bit_length = databits.GetCount() - start_bit;
  511.  
  512.                 if (bit_length <= 0)
  513.                 {
  514.                     LOG.Warning("Can not read variable " + name + " for command " + command_name + ", message is to short, is there a match between the module and the protocol XML file?");
  515.                     LOG.Debug("start_bit=" + boost::lexical_cast<std::string>(start_bit) + ", bit_length=" + boost::lexical_cast<std::string>(bit_length) + ", databits.GetCount()=" + boost::lexical_cast<std::string>(databits.GetCount()));
  516.                     continue;
  517.                 }
  518.             }
  519.  
  520.             type = variable_nodes[n].GetAttributeValue("type");
  521.             LOG.Extreme("type: type=" + type);
  522.  
  523.             if (type == "int")
  524.             {
  525.                 value = Protocol::Instance()->DecodeInt(databits, start_bit, bit_length);
  526.             }
  527.             else if (type == "float")
  528.             {
  529.                 value = Protocol::Instance()->DecodeFloat(databits, start_bit, bit_length);
  530.             }
  531.             else if (type == "ascii")
  532.             {
  533.                 value = Protocol::Instance()->DecodeAscii(databits, start_bit, bit_length);
  534.             }
  535.             else if (type == "hexstring")
  536.             {
  537.                 value = Protocol::Instance()->DecodeHexstring(databits, start_bit, bit_length);
  538.             }
  539.             else if (type == "enum")
  540.             {
  541.                 LOG.Extreme("Enum: command name=" + command_name);
  542.                 value = Protocol::Instance()->DecodeUint(databits, start_bit, bit_length);
  543.                 LOG.Extreme("Enum: value=" + boost::lexical_cast<std::string>(value));
  544.                 LOG.Extreme("start_bit=" + boost::lexical_cast<std::string>(start_bit) + ", bit_length=" + boost::lexical_cast<std::string>(bit_length));
  545.  
  546.                 value = variable_nodes[n].SelectChild("id", value).GetAttributeValue("name");
  547.             }
  548.             else// if (type == "uint")
  549.             {
  550.                 value = Protocol::Instance()->DecodeUint(databits, start_bit, bit_length);
  551.             }
  552.  
  553.             LOG.Extreme("value=\"" + value + "\"");
  554.  
  555.             payload->SetVariable(name, value);
  556.         }
  557.  
  558.         broker::Manager::Instance()->Post(broker::Message::Pointer(new broker::Message(broker::Message::CAN_MESSAGE, broker::Message::PayloadPointer(payload), this)));
  559.     }
  560.     catch (std::runtime_error& e)
  561.     {
  562.         LOG.Error("Malformed message received, " + std::string(e.what()));
  563.         LOG.Debug("Bytes: " + std::string(this->buffer_.begin(), this->buffer_.end()));
  564.     }
  565.  
  566.     common::Byteset empty_vector;
  567.     this->buffer_.swap(empty_vector);
  568.  
  569.  
  570.     LOG_DEBUG_EXIT;
  571. }
  572.  
  573. }; // namespace can
  574. }; // namespace atom
  575.