//#include "HttpPort.hh" //#include "http_layer_factory.hh" //#include "http_layer.hh" //#include "http_codec_emtel.hh" #include "loggers.hh" //#include "LibHttp_TypesAndValues.hh" #include "NG_NasEmu_CtrlAspTypes.hh" namespace NG__NasEmu__CtrlAspTypes { NG__NASCTRL__PORT::NG__NASCTRL__PORT(const char *par_port_name): NG__NASCTRL__PORT_BASE(par_port_name), _cfg_params(), _layer_params(), _layer(nullptr), _time_key("NG__NASCTRL__PORT::contructor") { // Nothing to do } // End of constructor NG__NASCTRL__PORT::~NG__NASCTRL__PORT() { loggers::get_instance().log(">>> NG__NASCTRL__PORT::~NG__NASCTRL__PORT"); if (_layer != nullptr) { delete _layer; } } // End of destructor void NG__NASCTRL__PORT::set_parameter(const char * parameter_name, const char * parameter_value) { loggers::get_instance().log("NG__NASCTRL__PORT::set_parameter: %s=%s", parameter_name, parameter_value); _cfg_params.insert(std::pair(std::string(parameter_name), std::string(parameter_value))); } /*void HttpPort::Handle_Fd_Event(int fd, boolean is_readable, boolean is_writable, boolean is_error) {}*/ void NG__NASCTRL__PORT::Handle_Fd_Event_Error(int /*fd*/) { } void NG__NASCTRL__PORT::Handle_Fd_Event_Writable(int /*fd*/) { } void NG__NASCTRL__PORT::Handle_Fd_Event_Readable(int /*fd*/) { } /*void HttpPort::Handle_Timeout(double time_since_last_call) {}*/ void NG__NASCTRL__PORT::user_map(const char * system_port) { loggers::get_instance().log(">>> NG__NASCTRL__PORT::user_map: %s", system_port); // Build layer stack params::iterator it = _cfg_params.find(std::string("params")); if (it != _cfg_params.end()) { loggers::get_instance().log("NG__NASCTRL__PORT::user_map: %s", it->second.c_str()); // Setup parameters params::convert(_layer_params, it->second); // TODO This _layer_params seems to be useless // Create layer //_layer = layer_stack_builder::get_instance()->create_layer_stack(it->second.c_str()); /*if (static_cast(_layer) == nullptr) { loggers::get_instance().error("NG__NASCTRL__PORT::user_map: Invalid stack configuration: %s", it->second.c_str()); } if (!static_cast(_layer)->set_codec(new http_codec_emtel())) { loggers::get_instance().error("NG__NASCTRL__PORT::user_map: Null codec"); } static_cast(_layer)->add_upper_port(this);*/ } else { loggers::get_instance().error("NG__NASCTRL__PORT::user_map: No layers defined in configuration file"); } } // End of user_map method void NG__NASCTRL__PORT::user_unmap(const char * system_port) { loggers::get_instance().log(">>> NG__NASCTRL__PORT:user_unmap: %s", system_port); // Reset layers //if (_layer != nullptr) { // delete _layer; // _layer = nullptr; //} } // End of user_unmap method void NG__NASCTRL__PORT::user_start() { loggers::get_instance().log(">>> NG__NASCTRL__PORT::user_start"); } // End of user_start method void NG__NASCTRL__PORT::user_stop() { loggers::get_instance().log(">>> NG__NASCTRL__PORT::user_stop"); } // End of user_stop method void NG__NASCTRL__PORT::outgoing_send(const NG__NasEmu__CtrlAspTypes::NG__NAS__CTRL__REQ& send_par) { loggers::get_instance().log_msg(">>> NG__NASCTRL__PORT::outgoing_send: payload=", send_par); float duration; loggers::get_instance().set_start_time(_time_key); params params; //static_cast(_layer)->sendMsg(send_par, params); loggers::get_instance().set_stop_time(_time_key, duration); } void NG__NASCTRL__PORT::receiveMsg (const NG__NasEmu__CtrlAspTypes::NG__NAS__CTRL__CNF& p_ind, const params& p_params) { loggers::get_instance().log_msg(">>> NG__NASCTRL__PORT::receive_msg: ", p_ind); // Sanity check if (!p_ind.is_bound()) { return; } incoming_message(p_ind); } } // End of namespace NG__NasEmu__CtrlAspTypes