#include "EthernetLayerFactory.hh" #include "loggers.hh" EthernetLayer::EthernetLayer(const std::string & p_type, const std::string & param) : Layer(p_type), _params() { loggers::get_instance().log(">>> EthernetLayer::EthernetLayer: %s, %s", to_string().c_str(), param.c_str()); // Setup parameters Params::convert(_params, param); Params::const_iterator it = _params.find("mac_src"); if (it == _params.cend()) { _params.insert(std::pair(std::string("mac_src"), "000000000000")); } it = _params.find("mac_bc"); if (it == _params.cend()) { _params.insert(std::pair(std::string("mac_bc"), "FFFFFFFFFFFF")); } it = _params.find("eth_type"); if (it == _params.cend()) { _params.insert(std::pair(std::string("eth_type"), "8947")); } //_params.log(); } void EthernetLayer::sendData(OCTETSTRING& data, Params& params) { loggers::get_instance().log_msg(">>> EthernetLayer::sendData: ", data); OCTETSTRING eth; // Destination MAC address Params::const_iterator it = params.find(Params::mac_dst); // Find in provided parameters, params if (it != params.cend()) { eth = str2oct(CHARSTRING(it->second.c_str())); } else { eth = str2oct(CHARSTRING(_params[Params::mac_bc].c_str())); } // Source MAC address it = params.find(Params::mac_src); // Find in provided parameters, params if (it != params.cend()) { eth += str2oct(CHARSTRING(it->second.c_str())); } else { eth += str2oct(CHARSTRING(_params[Params::mac_src].c_str())); } it = params.find(Params::eth_type); // Find in layer parameters if (it != params.cend()) { eth += str2oct(CHARSTRING(it->second.c_str())); } else { eth += str2oct(CHARSTRING(_params[Params::eth_type].c_str())); } eth += data; sendToAllLayers(eth, params); } void EthernetLayer::receiveData(OCTETSTRING& data, Params& params) { loggers::get_instance().log_msg(">>> EthernetLayer::receiveData: ", data); // Extract dest MAC Address OCTETSTRING dst = OCTETSTRING(6, static_cast(data)); //loggers::get_instance().log_msg("EthernetLayer::receiveData: dst: ", dst); // Extract source MAC Address OCTETSTRING src = OCTETSTRING(6, 6 + static_cast(data)); //loggers::get_instance().log_msg("EthernetLayer::receiveData: src: ", src); // Extract ethertype OCTETSTRING proto = OCTETSTRING(2, 2 + static_cast(data)); //loggers::get_instance().log_msg("EthernetLayer::receiveData: proto: ", proto); data = OCTETSTRING(data.lengthof() - 14, 14 + static_cast(data)); // Update params CHARSTRING s = oct2str(dst); params.insert(std::pair(Params::mac_dst, std::string(static_cast(s)))); s = oct2str(src); params.insert(std::pair(Params::mac_src, std::string(static_cast(s)))); //loggers::get_instance().log_msg("EthernetLayer::receiveData: payload for upper layer:", data); receiveToAllLayers(data, params); } EthernetLayerFactory EthernetLayerFactory::_f;