Skip to content
GitLab
Hide whitespace changes
Inline Side-by-side
ccsrc/Framework/src/params.cc
View file @ f6d8a00a
......@@ -8,86 +8,86 @@
* All rights reserved.
* \version 0.1
*/
#include <stdexcept>
#include <regex>
#include <stdexcept>
#include "params.hh"
#include "loggers.hh"
#include "params.hh"
const std::string& params::debug = std::string("debug");
const std::string& params::loopback = std::string("loopback");
const std::string& params::mac_src = std::string("mac_src");
const std::string& params::mac_dst = std::string("mac_dst");
const std::string& params::mac_bc = std::string("mac_bc");
const std::string& params::eth_type = std::string("eth_type");
const std::string& params::beaconing = std::string("beaconing");
const std::string& params::timestamp = std::string("timestamp");
const std::string& params::station_type = std::string("station_type");
const std::string& params::country = std::string("country");
const std::string& params::type_of_address = std::string("type_of_address");
const std::string& params::its_aid = std::string("its_aid");
const std::string& params::ssp = std::string("ssp");
const std::string& params::gn_payload = std::string("gn_payload");
const std::string& params::gn_next_header = std::string("gnNextHeader");
const std::string& params::gn_header_type = std::string("gnHeaderType");
const std::string& params::gn_header_sub_type = std::string("gnHeaderSubtype");
const std::string& params::gn_lifetime = std::string("gnLifetime");
const std::string& params::gn_traffic_class = std::string("gnTrafficClass");
const std::string& params::btp_type = std::string("btp_type");
const std::string& params::btp_payload = std::string("btp_payload");
const std::string& params::btp_destination_port = std::string("dst_port");
const std::string& params::btp_info = std::string("btp_info");
const std::string& params::nic = std::string("nic");
const std::string& params::latitude = std::string("latitude");
const std::string& params::longitude = std::string("longitude");
const std::string& params::ll_address = std::string("ll_address");
const std::string& params::expiry = std::string("expiry");
const std::string& params::station_id = std::string("station_id");
const std::string& params::device_mode = std::string("device_mode");
const std::string& params::secured_mode = std::string("secured_mode");
const std::string& params::encrypted_mode = std::string("encrypted_mode");
const std::string& params::enable_security_checks = std::string("enable_security_checks");
const std::string& params::certificate = std::string("certificate");
const std::string& params::peer_certificate = std::string("peer_certificate");
const std::string& params::sec_db_path = std::string("sec_db_path");
const std::string& params::hash = std::string("hash");
const std::string& params::signature = std::string("signature");
const std::string& params::cypher = std::string("cypher");
const std::string& params::distanceA = std::string("distanceA");
const std::string& params::distanceB = std::string("distanceB");
const std::string& params::angle = std::string("angle");
const std::string& params::payload_type = std::string("payload_type");
const std::string& params::next_header = std::string("next_header");
const std::string& params::header_type = std::string("header_type");
const std::string& params::header_sub_type = std::string("header_sub_type");
const std::string& params::interface_id = std::string("interface_id");
const std::string& params::server = std::string("server");
const std::string& params::port = std::string("port");
const std::string& params::use_ssl = std::string("use_ssl");
const std::string& params::server_mode = std::string("server_mode");
const std::string& params::local_port = std::string("local_port");
const std::string& params::method = std::string("method");
const std::string& params::uri = std::string("uri");
const std::string& params::host = std::string("host");
const std::string& params::content_type = std::string("content_type");
//const std::string& params::sip_url = std::string("sip_url");
//const std::string& params::sip_version = std::string("sip_version");
//const std::string& params::payload = std::string("payload");
const std::string& params::codecs = std::string("codecs");
void params::convert(params& p_param, const std::string p_parameters) {
const std::string &params::debug = std::string("debug");
const std::string &params::loopback = std::string("loopback");
const std::string &params::mac_src = std::string("mac_src");
const std::string &params::mac_dst = std::string("mac_dst");
const std::string &params::mac_bc = std::string("mac_bc");
const std::string &params::eth_type = std::string("eth_type");
const std::string &params::beaconing = std::string("beaconing");
const std::string &params::timestamp = std::string("timestamp");
const std::string &params::station_type = std::string("station_type");
const std::string &params::country = std::string("country");
const std::string &params::type_of_address = std::string("type_of_address");
const std::string &params::its_aid = std::string("its_aid");
const std::string &params::ssp = std::string("ssp");
const std::string &params::gn_payload = std::string("gn_payload");
const std::string &params::gn_next_header = std::string("gnNextHeader");
const std::string &params::gn_header_type = std::string("gnHeaderType");
const std::string &params::gn_header_sub_type = std::string("gnHeaderSubtype");
const std::string &params::gn_lifetime = std::string("gnLifetime");
const std::string &params::gn_traffic_class = std::string("gnTrafficClass");
const std::string &params::btp_type = std::string("btp_type");
const std::string &params::btp_payload = std::string("btp_payload");
const std::string &params::btp_destination_port = std::string("dst_port");
const std::string &params::btp_info = std::string("btp_info");
const std::string &params::nic = std::string("nic");
const std::string &params::latitude = std::string("latitude");
const std::string &params::longitude = std::string("longitude");
const std::string &params::ll_address = std::string("ll_address");
const std::string &params::expiry = std::string("expiry");
const std::string &params::station_id = std::string("station_id");
const std::string &params::device_mode = std::string("device_mode");
const std::string &params::secured_mode = std::string("secured_mode");
const std::string &params::encrypted_mode = std::string("encrypted_mode");
const std::string &params::enable_security_checks = std::string("enable_security_checks");
const std::string &params::certificate = std::string("certificate");
const std::string &params::peer_certificate = std::string("peer_certificate");
const std::string &params::sec_db_path = std::string("sec_db_path");
const std::string &params::hash = std::string("hash");
const std::string &params::signature = std::string("signature");
const std::string &params::cypher = std::string("cypher");
const std::string &params::distanceA = std::string("distanceA");
const std::string &params::distanceB = std::string("distanceB");
const std::string &params::angle = std::string("angle");
const std::string &params::payload_type = std::string("payload_type");
const std::string &params::next_header = std::string("next_header");
const std::string &params::header_type = std::string("header_type");
const std::string &params::header_sub_type = std::string("header_sub_type");
const std::string &params::interface_id = std::string("interface_id");
const std::string &params::server = std::string("server");
const std::string &params::port = std::string("port");
const std::string &params::use_ssl = std::string("use_ssl");
const std::string &params::server_mode = std::string("server_mode");
const std::string &params::local_port = std::string("local_port");
const std::string &params::method = std::string("method");
const std::string &params::uri = std::string("uri");
const std::string &params::host = std::string("host");
const std::string &params::content_type = std::string("content_type");
// const std::string& params::sip_url = std::string("sip_url");
// const std::string& params::sip_version = std::string("sip_version");
// const std::string& params::payload = std::string("payload");
const std::string &params::codecs = std::string("codecs");
void params::convert(params &p_param, const std::string p_parameters) {
// Sanity checks
if (p_parameters.length() == 0) {
return;
......@@ -95,16 +95,16 @@ void params::convert(params& p_param, const std::string p_parameters) {
loggers::get_instance().log(">>> params::convert: %s", p_parameters.c_str());
// Extract parameters
try {
std::regex rgx ("(\\w+)=(.*?)(,|$)");
std::regex rgx("(\\w+)=(.*?)(,|$)");
std::sregex_iterator begin(p_parameters.cbegin(), p_parameters.cend(), rgx);
std::sregex_iterator end = std::sregex_iterator();
for (std::sregex_iterator it = begin; it != end; ++it) {
std::smatch m = *it;
loggers::get_instance().log("params::convert: %d - %s - %s - %s - %s", m.size(), m[0].str().c_str(), m[1].str().c_str(), m[2].str().c_str(), m[3].str().c_str());
loggers::get_instance().log("params::convert: %d - %s - %s - %s - %s", m.size(), m[0].str().c_str(), m[1].str().c_str(), m[2].str().c_str(),
m[3].str().c_str());
p_param.insert(std::pair<std::string, std::string>(m[1].str(), m[2].str()));
} // End of 'for' statement
}
catch(const std::logic_error& e){
} catch (const std::logic_error &e) {
p_param.clear();
}
loggers::get_instance().log("<<< params::convert");
......@@ -132,7 +132,7 @@ void params::log() {
}
}
void params::reset() {
void params::reset() {
loggers::get_instance().log("params::reset");
for (iterator it = begin(); it != end(); ++it) {
it->second.clear();
......
ccsrc/Framework/t_layer.hh
View file @ f6d8a00a
......@@ -19,8 +19,8 @@
* A port protocol layer derives from both a layer class and a template port class
*/
template <typename TPort> class t_layer : public layer {
typedef std::vector<TPort*> TPortList;
typedef typename std::vector<TPort*>::iterator TPortListIterator;
typedef std::vector<TPort *> TPortList;
typedef typename std::vector<TPort *>::iterator TPortListIterator;
TPortList upperPorts; //! The list of the upper ports
......@@ -30,7 +30,7 @@ public: //! \publicsection
* Create a new instance of the t_layer class
* \todo Remove logs
*/
explicit t_layer() : layer(), upperPorts() { };
explicit t_layer() : layer(), upperPorts(){};
/*!
* \brief Specialized constructor
......@@ -39,20 +39,20 @@ public: //! \publicsection
* \remark This constructor is called by the layer factory
* \see layer_factory
*/
explicit t_layer(const std::string& p_type) : layer(p_type), upperPorts() { };
explicit t_layer(const std::string &p_type) : layer(p_type), upperPorts(){};
/*!
* \inline
* \fn void add_upper_port(TPort * p_port);
* \brief Add a new upper port layer
* \todo To be done
*/
inline void add_upper_port(TPort * p_port) { upperPorts.push_back(p_port); };
inline void add_upper_port(TPort *p_port) { upperPorts.push_back(p_port); };
/*!
* \fn void remove_upper_port(TPort*);
* \brief Remove the specified upper layer port protocol from the list of the upper layers
* \param[in] p_layer The layer protocol to be removed
*/
void remove_upper_port(TPort*);
void remove_upper_port(TPort *);
protected: //! \protectedsection
/*!
......@@ -62,11 +62,9 @@ protected: //! \protectedsection
* \param[in] p_message The message to be forwarded
* \param[in] p_params Some lower layers parameters values when data was received
*/
template <typename TMessage>
inline void to_all_upper_ports(const TMessage& p_message, const params& p_params) {
for(TPortListIterator it=upperPorts.begin(); it<upperPorts.end(); ++it){
template <typename TMessage> inline void to_all_upper_ports(const TMessage &p_message, const params &p_params) {
for (TPortListIterator it = upperPorts.begin(); it < upperPorts.end(); ++it) {
(*it)->receiveMsg(p_message, p_params);
}
}
}; // End of class t_layer
ccsrc/Ports/LibIts_ports/AdapterControlPort.hh
View file @ f6d8a00a
......@@ -56,10 +56,10 @@
#include "AdapterControlPort_GN.hh"
#endif
/*
#include "AdapterControlPort_Evcsn.partH"
#include "AdapterControlPort_IVIM.partH"
#include "AdapterControlPort_MapemSpatem.partH"
#include "AdapterControlPort_SremSsem.partH"
#include "AdapterControlPort_Evcsn.partH"
*/
//#include "AdapterControlPort_V2G.partH"
#endif //_NO_SOFTLINKS_
ccsrc/Ports/LibIts_ports/AutoInterop_ports/HmiPort.cc
View file @ f6d8a00a
......@@ -11,67 +11,31 @@
namespace ItsAutoInterop__TestSystem {
HmiPort::HmiPort(const char *par_port_name)
: HmiPort_BASE(par_port_name)
{
HmiPort::HmiPort(const char *par_port_name) : HmiPort_BASE(par_port_name) {}
}
HmiPort::~HmiPort() {}
HmiPort::~HmiPort()
{
void HmiPort::set_parameter(const char * /*parameter_name*/, const char * /*parameter_value*/) {}
}
/*void HmiPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void HmiPort::set_parameter(const char * /*parameter_name*/,
const char * /*parameter_value*/)
{
void HmiPort::Handle_Fd_Event_Error(int /*fd*/) {}
}
void HmiPort::Handle_Fd_Event_Writable(int /*fd*/) {}
/*void HmiPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void HmiPort::Handle_Fd_Event_Readable(int /*fd*/) {}
void HmiPort::Handle_Fd_Event_Error(int /*fd*/)
{
/*void HmiPort::Handle_Timeout(double time_since_last_call) {}*/
}
void HmiPort::user_map(const char * /*system_port*/) {}
void HmiPort::Handle_Fd_Event_Writable(int /*fd*/)
{
void HmiPort::user_unmap(const char * /*system_port*/) {}
}
void HmiPort::user_start() {}
void HmiPort::Handle_Fd_Event_Readable(int /*fd*/)
{
void HmiPort::user_stop() {}
}
/*void HmiPort::Handle_Timeout(double time_since_last_call) {}*/
void HmiPort::user_map(const char * /*system_port*/)
{
}
void HmiPort::user_unmap(const char * /*system_port*/)
{
}
void HmiPort::user_start()
{
}
void HmiPort::user_stop()
{
}
void HmiPort::outgoing_send(const ItsAutoInterop__TypesAndValues::HmiInitialize& /*send_par*/)
{
}
} /* end of namespace */
void HmiPort::outgoing_send(const ItsAutoInterop__TypesAndValues::HmiInitialize & /*send_par*/) {}
} // namespace ItsAutoInterop__TestSystem
ccsrc/Ports/LibIts_ports/AutoInterop_ports/HmiPort.hh
View file @ f6d8a00a
......@@ -15,31 +15,30 @@
namespace ItsAutoInterop__TestSystem {
class HmiPort : public HmiPort_BASE {
public:
HmiPort(const char *par_port_name = NULL);
~HmiPort();
void set_parameter(const char *parameter_name,
const char *parameter_value);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error); */
void Handle_Fd_Event_Error(int fd);
void Handle_Fd_Event_Writable(int fd);
void Handle_Fd_Event_Readable(int fd);
/* void Handle_Timeout(double time_since_last_call); */
protected:
void user_map(const char *system_port);
void user_unmap(const char *system_port);
void user_start();
void user_stop();
void outgoing_send(const ItsAutoInterop__TypesAndValues::HmiInitialize& send_par);
};
} /* end of namespace */
class HmiPort : public HmiPort_BASE {
public:
HmiPort(const char *par_port_name = NULL);
~HmiPort();
void set_parameter(const char *parameter_name, const char *parameter_value);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error); */
void Handle_Fd_Event_Error(int fd);
void Handle_Fd_Event_Writable(int fd);
void Handle_Fd_Event_Readable(int fd);
/* void Handle_Timeout(double time_since_last_call); */
protected:
void user_map(const char *system_port);
void user_unmap(const char *system_port);
void user_start();
void user_stop();
void outgoing_send(const ItsAutoInterop__TypesAndValues::HmiInitialize &send_par);
};
} // namespace ItsAutoInterop__TestSystem
#endif
ccsrc/Ports/LibIts_ports/BTP_ports/BtpPort.cc
View file @ f6d8a00a
......@@ -13,10 +13,8 @@
namespace LibItsBtp__TestSystem {
BtpPort::BtpPort(const char *par_port_name) :
BtpPort_BASE(par_port_name), _cfg_params(), _layer_params(), _layer(NULL), _time_key("BtpPort::outgoing_send") {
}
BtpPort::BtpPort(const char *par_port_name)
: BtpPort_BASE(par_port_name), _cfg_params(), _layer_params(), _layer(NULL), _time_key("BtpPort::outgoing_send") {}
BtpPort::~BtpPort() {
if (_layer != NULL) {
......@@ -24,7 +22,7 @@ namespace LibItsBtp__TestSystem {
}
}
void BtpPort::set_parameter(const char * parameter_name, const char * parameter_value) {
void BtpPort::set_parameter(const char *parameter_name, const char *parameter_value) {
loggers::get_instance().log("BtpPort::set_parameter: %s=%s", parameter_name, parameter_value);
_cfg_params.insert(std::pair<std::string, std::string>(std::string(parameter_name), std::string(parameter_value)));
}
......@@ -32,21 +30,15 @@ namespace LibItsBtp__TestSystem {
/*void BtpPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void BtpPort::Handle_Fd_Event_Error(int /*fd*/) {
}
void BtpPort::Handle_Fd_Event_Writable(int /*fd*/) {
}
void BtpPort::Handle_Fd_Event_Error(int /*fd*/) {}
void BtpPort::Handle_Fd_Event_Readable(int /*fd*/) {
void BtpPort::Handle_Fd_Event_Writable(int /*fd*/) {}
}
void BtpPort::Handle_Fd_Event_Readable(int /*fd*/) {}
/*void BtpPort::Handle_Timeout(double time_since_last_call) {}*/
void BtpPort::user_map(const char * system_port) {
void BtpPort::user_map(const char *system_port) {
loggers::get_instance().log(">>> BtpPort::user_map: %s", system_port);
// Build layer stack
params::iterator it = _cfg_params.find(std::string("params"));
......@@ -65,7 +57,7 @@ namespace LibItsBtp__TestSystem {
}
}
void BtpPort::user_unmap(const char * system_port) {
void BtpPort::user_unmap(const char *system_port) {
loggers::get_instance().log(">>> BtpPort::user_unmap: %s", system_port);
if (_layer != NULL) {
delete _layer;
......@@ -73,28 +65,23 @@ namespace LibItsBtp__TestSystem {
}
}
void BtpPort::user_start() {
}
void BtpPort::user_start() {}
void BtpPort::user_stop() {
void BtpPort::user_stop() {}
}
void BtpPort::outgoing_send(const BtpReq &send_par) {
// loggers::get_instance().log_msg(">>> BtpPort::outgoing_send: payload=", send_par);
void BtpPort::outgoing_send(const BtpReq& send_par) {
// loggers::get_instance().log_msg(">>> BtpPort::outgoing_send: payload=", send_par);
float duration;
loggers::get_instance().set_start_time(_time_key);
static_cast<btp_layer *>(_layer)->sendMsg(send_par, _layer_params);
loggers::get_instance().set_stop_time(_time_key, duration);
}
void BtpPort::receiveMsg(const LibItsBtp__TestSystem::BtpInd& p_ind, const params& p_params) {
// loggers::get_instance().log_msg(">>> BtpPort::receive_msg: ", p_ind);
void BtpPort::receiveMsg(const LibItsBtp__TestSystem::BtpInd &p_ind, const params &p_params) {
// loggers::get_instance().log_msg(">>> BtpPort::receive_msg: ", p_ind);
incoming_message(p_ind);
}
} /* end of namespace */
} // namespace LibItsBtp__TestSystem
ccsrc/Ports/LibIts_ports/BTP_ports/BtpPort.hh
View file @ f6d8a00a
......@@ -18,18 +18,18 @@
namespace LibItsBtp__TestSystem {
class BtpPort : public BtpPort_BASE {
params _cfg_params;
params _layer_params;
layer* _layer;
params _cfg_params;
params _layer_params;
layer * _layer;
std::string _time_key;
public:
BtpPort(const char *par_port_name = NULL);
~BtpPort();
void set_parameter(const char *parameter_name,
const char *parameter_value);
void set_parameter(const char *parameter_name, const char *parameter_value);
void receiveMsg (const LibItsBtp__TestSystem::BtpInd&, const params&);
void receiveMsg(const LibItsBtp__TestSystem::BtpInd &, const params &);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
......@@ -45,9 +45,9 @@ namespace LibItsBtp__TestSystem {
void user_start();
void user_stop();
void outgoing_send(const BtpReq& send_par);
void outgoing_send(const BtpReq &send_par);
};
} /* end of namespace */
} // namespace LibItsBtp__TestSystem
#endif
ccsrc/Ports/LibIts_ports/BTP_ports/UpperTesterPort_BTP.cc
View file @ f6d8a00a
......@@ -2,71 +2,33 @@
//=============================================================================
namespace LibItsBtp__TestSystem {
UpperTesterPort::UpperTesterPort(const char *par_port_name)
: UpperTesterPort_BASE(par_port_name)
{
UpperTesterPort::UpperTesterPort(const char *par_port_name) : UpperTesterPort_BASE(par_port_name) {}
}
UpperTesterPort::~UpperTesterPort() {}
UpperTesterPort::~UpperTesterPort()
{
void UpperTesterPort::set_parameter(const char * /*parameter_name*/, const char * /*parameter_value*/) {}
}
/*void UpperTesterPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void UpperTesterPort::set_parameter(const char * /*parameter_name*/,
const char * /*parameter_value*/)
{
void UpperTesterPort::Handle_Fd_Event_Error(int /*fd*/) {}
}
void UpperTesterPort::Handle_Fd_Event_Writable(int /*fd*/) {}
/*void UpperTesterPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void UpperTesterPort::Handle_Fd_Event_Readable(int /*fd*/) {}
void UpperTesterPort::Handle_Fd_Event_Error(int /*fd*/)
{
/*void UpperTesterPort::Handle_Timeout(double time_since_last_call) {}*/
}
void UpperTesterPort::user_map(const char * /*system_port*/) {}
void UpperTesterPort::Handle_Fd_Event_Writable(int /*fd*/)
{
void UpperTesterPort::user_unmap(const char * /*system_port*/) {}
}
void UpperTesterPort::user_start() {}
void UpperTesterPort::Handle_Fd_Event_Readable(int /*fd*/)
{
void UpperTesterPort::user_stop() {}
}
void UpperTesterPort::outgoing_send(const LibItsBtp__TypesAndValues::UtBtpInitialize & /*send_par*/) {}
/*void UpperTesterPort::Handle_Timeout(double time_since_last_call) {}*/
void UpperTesterPort::outgoing_send(const LibItsBtp__TypesAndValues::UtBtpTrigger & /*send_par*/) {}
void UpperTesterPort::user_map(const char * /*system_port*/)
{
}
void UpperTesterPort::user_unmap(const char * /*system_port*/)
{
}
void UpperTesterPort::user_start()
{
}
void UpperTesterPort::user_stop()
{
}
void UpperTesterPort::outgoing_send(const LibItsBtp__TypesAndValues::UtBtpInitialize& /*send_par*/)
{
}
void UpperTesterPort::outgoing_send(const LibItsBtp__TypesAndValues::UtBtpTrigger& /*send_par*/)
{
}
} /* end of namespace */
} // namespace LibItsBtp__TestSystem
ccsrc/Ports/LibIts_ports/BTP_ports/UpperTesterPort_BTP.hh
View file @ f6d8a00a
//=============================================================================
#ifndef UpperTesterPort_BTP_HH
#define UpperTesterPort_BTP_HH
#ifndef UpperTesterPort_BTP_HH
#define UpperTesterPort_BTP_HH
#include "LibItsBtp_TestSystem.hh"
namespace LibItsBtp__TestSystem {
class UpperTesterPort : public UpperTesterPort_BASE {
public:
UpperTesterPort(const char *par_port_name = NULL);
~UpperTesterPort();
class UpperTesterPort : public UpperTesterPort_BASE {
public:
UpperTesterPort(const char *par_port_name = NULL);
~UpperTesterPort();
void set_parameter(const char *parameter_name,
const char *parameter_value);
void set_parameter(const char *parameter_name, const char *parameter_value);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error); */
void Handle_Fd_Event_Error(int fd);
void Handle_Fd_Event_Writable(int fd);
void Handle_Fd_Event_Readable(int fd);
/* void Handle_Timeout(double time_since_last_call); */
protected:
void user_map(const char *system_port);
void user_unmap(const char *system_port);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error); */
void Handle_Fd_Event_Error(int fd);
void Handle_Fd_Event_Writable(int fd);
void Handle_Fd_Event_Readable(int fd);
/* void Handle_Timeout(double time_since_last_call); */
protected:
void user_map(const char *system_port);
void user_unmap(const char *system_port);
void user_start();
void user_stop();
void user_start();
void user_stop();
void outgoing_send(const LibItsBtp__TypesAndValues::UtBtpInitialize& send_par);
void outgoing_send(const LibItsBtp__TypesAndValues::UtBtpTrigger& send_par);
};
void outgoing_send(const LibItsBtp__TypesAndValues::UtBtpInitialize &send_par);
} /* end of namespace */
void outgoing_send(const LibItsBtp__TypesAndValues::UtBtpTrigger &send_par);
};
} // namespace LibItsBtp__TestSystem
#endif
ccsrc/Ports/LibIts_ports/CAM_ports/AdapterControlPort_CAM.cc
View file @ f6d8a00a
......@@ -3,87 +3,51 @@
#include "loggers.hh"
#include "registration.hh"
#include "cam_layer.hh"
#include "AdapterControlPort_CAM.hh"
#include "cam_layer.hh"
//=============================================================================
namespace LibItsCam__TestSystem {
AdapterControlPort::AdapterControlPort(const char *par_port_name)
: AdapterControlPort_BASE(par_port_name)
{
}
AdapterControlPort::~AdapterControlPort()
{
}
void AdapterControlPort::set_parameter(const char * /*parameter_name*/,
const char * /*parameter_value*/)
{
}
/*void AdapterControlPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void AdapterControlPort::Handle_Fd_Event_Error(int /*fd*/)
{
}
void AdapterControlPort::Handle_Fd_Event_Writable(int /*fd*/)
{
}
void AdapterControlPort::Handle_Fd_Event_Readable(int /*fd*/)
{
AdapterControlPort::AdapterControlPort(const char *par_port_name) : AdapterControlPort_BASE(par_port_name) {}
}
AdapterControlPort::~AdapterControlPort() {}
/*void AdapterControlPort::Handle_Timeout(double time_since_last_call) {}*/
void AdapterControlPort::set_parameter(const char * /*parameter_name*/, const char * /*parameter_value*/) {}
void AdapterControlPort::user_map(const char * /*system_port*/)
{
/*void AdapterControlPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
}
void AdapterControlPort::Handle_Fd_Event_Error(int /*fd*/) {}
void AdapterControlPort::user_unmap(const char * /*system_port*/)
{
void AdapterControlPort::Handle_Fd_Event_Writable(int /*fd*/) {}
}
void AdapterControlPort::Handle_Fd_Event_Readable(int /*fd*/) {}
void AdapterControlPort::user_start()
{
/*void AdapterControlPort::Handle_Timeout(double time_since_last_call) {}*/
}
void AdapterControlPort::user_map(const char * /*system_port*/) {}
void AdapterControlPort::user_stop()
{
void AdapterControlPort::user_unmap(const char * /*system_port*/) {}
}
void AdapterControlPort::user_start() {}
void AdapterControlPort::outgoing_send(const LibItsCommon__TypesAndValues::AcGnssPrimitive& /*send_par*/)
{
void AdapterControlPort::user_stop() {}
}
void AdapterControlPort::outgoing_send(const LibItsCommon__TypesAndValues::AcGnssPrimitive & /*send_par*/) {}
void AdapterControlPort::outgoing_send(const LibItsCommon__TypesAndValues::AcSecPrimitive& send_par)
{
void AdapterControlPort::outgoing_send(const LibItsCommon__TypesAndValues::AcSecPrimitive &send_par) {
loggers::get_instance().log_msg(">>> AdapterControlPort::outgoing_send: ", send_par);
// Register this object for AdapterControlPort
cam_layer* p = registration<cam_layer>::get_instance().get_item(std::string("CAM"));
cam_layer *p = registration<cam_layer>::get_instance().get_item(std::string("CAM"));
if (p != NULL) {
loggers::get_instance().log("AdapterControlPort::outgoing_send: Got GN layer %p", p);
LibItsCommon__TypesAndValues::AdapterControlResults response;
response.acSecResponse() = BOOLEAN(true);
if (send_par.ischosen(LibItsCommon__TypesAndValues::AcSecPrimitive::ALT_acEnableSecurity)) {
loggers::get_instance().log("AdapterControlPort::outgoing_send: Enable secured mode");
std::string str(static_cast<const char*>(send_par.acEnableSecurity().certificateId()));
std::string str(static_cast<const char *>(send_par.acEnableSecurity().certificateId()));
if (p->enable_secured_mode(str, send_par.acEnableSecurity().enforceSecurity()) == -1) {
response.acSecResponse() = BOOLEAN(false);
}
......@@ -101,6 +65,6 @@ void AdapterControlPort::outgoing_send(const LibItsCommon__TypesAndValues::AcSec
} else {
loggers::get_instance().error("AdapterControlPort::outgoing_send: CAM not registered");
}
}
}
} /* end of namespace */
} // namespace LibItsCam__TestSystem
ccsrc/Ports/LibIts_ports/CAM_ports/AdapterControlPort_CAM.hh
View file @ f6d8a00a
......@@ -5,33 +5,31 @@
namespace LibItsCam__TestSystem {
class AdapterControlPort : public AdapterControlPort_BASE {
public:
AdapterControlPort(const char *par_port_name = NULL);
~AdapterControlPort();
void set_parameter(const char *parameter_name,
const char *parameter_value);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error); */
void Handle_Fd_Event_Error(int fd);
void Handle_Fd_Event_Writable(int fd);
void Handle_Fd_Event_Readable(int fd);
/* void Handle_Timeout(double time_since_last_call); */
protected:
void user_map(const char *system_port);
void user_unmap(const char *system_port);
void user_start();
void user_stop();
void outgoing_send(const LibItsCommon__TypesAndValues::AcGnssPrimitive& send_par);
void outgoing_send(const LibItsCommon__TypesAndValues::AcSecPrimitive& send_par);
};
} // end of namespace
class AdapterControlPort : public AdapterControlPort_BASE {
public:
AdapterControlPort(const char *par_port_name = NULL);
~AdapterControlPort();
void set_parameter(const char *parameter_name, const char *parameter_value);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error); */
void Handle_Fd_Event_Error(int fd);
void Handle_Fd_Event_Writable(int fd);
void Handle_Fd_Event_Readable(int fd);
/* void Handle_Timeout(double time_since_last_call); */
protected:
void user_map(const char *system_port);
void user_unmap(const char *system_port);
void user_start();
void user_stop();
void outgoing_send(const LibItsCommon__TypesAndValues::AcGnssPrimitive &send_par);
void outgoing_send(const LibItsCommon__TypesAndValues::AcSecPrimitive &send_par);
};
} // namespace LibItsCam__TestSystem
#endif
\ No newline at end of file
ccsrc/Ports/LibIts_ports/CAM_ports/CamPort.cc
View file @ f6d8a00a
......@@ -13,19 +13,16 @@
namespace LibItsCam__TestSystem {
CamPort::CamPort(const char *par_port_name) : CamPort_BASE(par_port_name), _cfg_params(), _layer_params(), _layer(NULL), _time_key("CamPort::outgoing_send") {
CamPort::CamPort(const char *par_port_name)
: CamPort_BASE(par_port_name), _cfg_params(), _layer_params(), _layer(NULL), _time_key("CamPort::outgoing_send") {}
}
CamPort::~CamPort()
{
CamPort::~CamPort() {
if (_layer != NULL) {
delete _layer;
}
}
void CamPort::set_parameter(const char * parameter_name, const char * parameter_value)
{
void CamPort::set_parameter(const char *parameter_name, const char *parameter_value) {
loggers::get_instance().log("CamPort::set_parameter: %s=%s", parameter_name, parameter_value);
_cfg_params.insert(std::pair<std::string, std::string>(std::string(parameter_name), std::string(parameter_value)));
}
......@@ -33,25 +30,15 @@ namespace LibItsCam__TestSystem {
/*void CamPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void CamPort::Handle_Fd_Event_Error(int /*fd*/)
{
}
void CamPort::Handle_Fd_Event_Writable(int /*fd*/)
{
}
void CamPort::Handle_Fd_Event_Error(int /*fd*/) {}
void CamPort::Handle_Fd_Event_Readable(int /*fd*/)
{
void CamPort::Handle_Fd_Event_Writable(int /*fd*/) {}
}
void CamPort::Handle_Fd_Event_Readable(int /*fd*/) {}
/*void CamPort::Handle_Timeout(double time_since_last_call) {}*/
void CamPort::user_map(const char * system_port)
{
void CamPort::user_map(const char *system_port) {
loggers::get_instance().log(">>> CamPort::user_map: %s", system_port);
// Build layer stack
params::iterator it = _cfg_params.find(std::string("params"));
......@@ -62,7 +49,7 @@ namespace LibItsCam__TestSystem {
// Create layer
_layer = layer_stack_builder::get_instance()->create_layer_stack(it->second.c_str());
if (static_cast<cam_layer *>(_layer) == NULL) {
loggers::get_instance().error("CamPort::user_map: Invalid stack configuration: %s", it->second.c_str());
loggers::get_instance().error("CamPort::user_map: Invalid stack configuration: %s", it->second.c_str());
}
static_cast<cam_layer *>(_layer)->add_upper_port(this);
} else {
......@@ -70,8 +57,7 @@ namespace LibItsCam__TestSystem {
}
}
void CamPort::user_unmap(const char * system_port)
{
void CamPort::user_unmap(const char *system_port) {
loggers::get_instance().log(">>> CamPort::user_unmap: %s", system_port);
if (_layer != NULL) {
delete _layer;
......@@ -79,20 +65,13 @@ namespace LibItsCam__TestSystem {
}
}
void CamPort::user_start()
{
}
void CamPort::user_start() {}
void CamPort::user_stop()
{
void CamPort::user_stop() {}
}
void CamPort::outgoing_send(const CamReq& send_par)
{
void CamPort::outgoing_send(const CamReq &send_par) {
loggers::get_instance().log_msg(">>> CamPort::outgoing_send: payload=", send_par);
float duration;
loggers::get_instance().set_start_time(_time_key);
params params;
......@@ -100,11 +79,10 @@ namespace LibItsCam__TestSystem {
loggers::get_instance().set_stop_time(_time_key, duration);
}
void CamPort::receiveMsg(const LibItsCam__TestSystem::CamInd& p_ind, const params& p_params) {
void CamPort::receiveMsg(const LibItsCam__TestSystem::CamInd &p_ind, const params &p_params) {
loggers::get_instance().log_msg(">>> CamPort::receive_msg: ", p_ind);
incoming_message(p_ind);
}
} /* end of namespace */
} // namespace LibItsCam__TestSystem
ccsrc/Ports/LibIts_ports/CAM_ports/CamPort.hh
View file @ f6d8a00a
......@@ -18,18 +18,18 @@
namespace LibItsCam__TestSystem {
class CamPort : public CamPort_BASE {
params _cfg_params;
params _layer_params;
layer* _layer;
params _cfg_params;
params _layer_params;
layer * _layer;
std::string _time_key;
public:
CamPort(const char *par_port_name = NULL);
~CamPort();
void set_parameter(const char *parameter_name,
const char *parameter_value);
void set_parameter(const char *parameter_name, const char *parameter_value);
void receiveMsg (const LibItsCam__TestSystem::CamInd&, const params&);
void receiveMsg(const LibItsCam__TestSystem::CamInd &, const params &);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
......@@ -45,9 +45,9 @@ namespace LibItsCam__TestSystem {
void user_start();
void user_stop();
void outgoing_send(const CamReq& send_par);
void outgoing_send(const CamReq &send_par);
};
} /* end of namespace */
} // namespace LibItsCam__TestSystem
#endif
ccsrc/Ports/LibIts_ports/CAM_ports/UpperTesterPort_CAM.cc
View file @ f6d8a00a
#include "uppertester_cam_layer_factory.hh"
#include "loggers.hh"
#include "UpperTesterPort_CAM.hh"
#include "loggers.hh"
//=============================================================================
namespace LibItsCam__TestSystem {
UpperTesterPort::UpperTesterPort(const char *par_port_name)
: UpperTesterPort_BASE(par_port_name), _cfg_params(), _layer_params(), _layer(NULL), _time_key("UpperTesterPort_Cam::outgoing_send")
{
: UpperTesterPort_BASE(par_port_name), _cfg_params(), _layer_params(), _layer(NULL), _time_key("UpperTesterPort_Cam::outgoing_send") {
loggers::get_instance().log("UpperTesterPort_Cam::UpperTesterPort_Cam");
}
UpperTesterPort::~UpperTesterPort()
{
UpperTesterPort::~UpperTesterPort() {
if (_layer != NULL) {
delete _layer;
}
}
void UpperTesterPort::set_parameter(const char * parameter_name, const char * parameter_value)
{
void UpperTesterPort::set_parameter(const char *parameter_name, const char *parameter_value) {
loggers::get_instance().log("UpperTesterPort_Cam::set_parameter: %s=%s", parameter_name, parameter_value);
_cfg_params.insert(std::pair<std::string, std::string>(std::string(parameter_name), std::string(parameter_value)));
_cfg_params.log();
......@@ -29,25 +26,15 @@ namespace LibItsCam__TestSystem {
/*void UpperTesterPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void UpperTesterPort::Handle_Fd_Event_Error(int /*fd*/)
{
}
void UpperTesterPort::Handle_Fd_Event_Writable(int /*fd*/)
{
void UpperTesterPort::Handle_Fd_Event_Error(int /*fd*/) {}
}
void UpperTesterPort::Handle_Fd_Event_Readable(int /*fd*/)
{
void UpperTesterPort::Handle_Fd_Event_Writable(int /*fd*/) {}
}
void UpperTesterPort::Handle_Fd_Event_Readable(int /*fd*/) {}
/*void UpperTesterPort::Handle_Timeout(double time_since_last_call) {}*/
void UpperTesterPort::user_map(const char * system_port)
{
void UpperTesterPort::user_map(const char *system_port) {
loggers::get_instance().log(">>> UpperTesterPort_Cam::user_map: %s", system_port);
// Build layer stack
params::iterator it = _cfg_params.find(std::string("params"));
......@@ -63,67 +50,50 @@ namespace LibItsCam__TestSystem {
}
}
void UpperTesterPort::user_unmap(const char * system_port)
{
void UpperTesterPort::user_unmap(const char *system_port) {
loggers::get_instance().log(">>> UpperTesterPort_Cam::user_unmap: %s", system_port);
if (_layer != NULL) {
delete _layer;
_layer = NULL;
}
}
void UpperTesterPort::user_start()
{
}
void UpperTesterPort::user_stop()
{
void UpperTesterPort::user_start() {}
}
void UpperTesterPort::user_stop() {}
void UpperTesterPort::outgoing_send(const LibItsCam__TypesAndValues::UtCamInitialize& send_par)
{
void UpperTesterPort::outgoing_send(const LibItsCam__TypesAndValues::UtCamInitialize &send_par) {
loggers::get_instance().log_msg(">>> UppertesterPort_Cam::outgoing_send: ", send_par);
float duration;
loggers::get_instance().set_start_time(_time_key);
static_cast<uppertester_cam_layer *>(_layer)->sendMsg(send_par, _layer_params);
loggers::get_instance().set_stop_time(_time_key, duration);
}
void UpperTesterPort::outgoing_send(const LibItsCam__TypesAndValues::UtCamChangePosition& send_par)
{
void UpperTesterPort::outgoing_send(const LibItsCam__TypesAndValues::UtCamChangePosition &send_par) {
loggers::get_instance().log_msg(">>> UppertesterPort_Cam::outgoing_send: ", send_par);
float duration;
loggers::get_instance().set_start_time(_time_key);
static_cast<uppertester_cam_layer *>(_layer)->sendMsg(send_par, _layer_params);
loggers::get_instance().set_stop_time(_time_key, duration);
}
void UpperTesterPort::outgoing_send(const LibItsCam__TypesAndValues::UtCamTrigger& send_par)
{
void UpperTesterPort::outgoing_send(const LibItsCam__TypesAndValues::UtCamTrigger &send_par) {
loggers::get_instance().log_msg(">>> UppertesterPort_Cam::outgoing_send: ", send_par);
float duration;
loggers::get_instance().set_start_time(_time_key);
static_cast<uppertester_cam_layer *>(_layer)->sendMsg(send_par, _layer_params);
loggers::get_instance().set_stop_time(_time_key, duration);
}
void UpperTesterPort::outgoing_send(const LibItsCam__TypesAndValues::UtActivatePositionTime& /*send_par*/)
{
}
void UpperTesterPort::outgoing_send(const LibItsCam__TypesAndValues::UtActivatePositionTime & /*send_par*/) {}
void UpperTesterPort::outgoing_send(const LibItsCam__TypesAndValues::UtDeactivatePositionTime& /*send_par*/)
{
}
void UpperTesterPort::outgoing_send(const LibItsCam__TypesAndValues::UtDeactivatePositionTime & /*send_par*/) {}
void UpperTesterPort::receiveMsg (const Base_Type& p_ind, const params& p_params) {
void UpperTesterPort::receiveMsg(const Base_Type &p_ind, const params &p_params) {
loggers::get_instance().log_msg(">>> UpperTesterPort_Cam::receive_msg: ", p_ind);
// Sanity check
if (!p_ind.is_bound()) {
......@@ -131,12 +101,12 @@ namespace LibItsCam__TestSystem {
}
if (std::string(p_ind.get_descriptor()->name).compare("@LibItsCam_TypesAndValues.UtCamResults") == 0) { // TODO To be refined
incoming_message(static_cast<const LibItsCam__TypesAndValues::UtCamResults&>(p_ind));
incoming_message(static_cast<const LibItsCam__TypesAndValues::UtCamResults &>(p_ind));
} else if (std::string(p_ind.get_descriptor()->name).compare("@LibItsCam_TypesAndValues.UtCamEventInd") == 0) {
incoming_message(static_cast<const LibItsCam__TypesAndValues::UtCamEventInd&>(p_ind));
incoming_message(static_cast<const LibItsCam__TypesAndValues::UtCamEventInd &>(p_ind));
} else {
loggers::get_instance().warning("UpperTesterPort_Cam::receive_msg: Message not processed: %s", p_ind.get_descriptor()->name);
}
}
} /* end of namespace */
} // namespace LibItsCam__TestSystem
ccsrc/Ports/LibIts_ports/CAM_ports/UpperTesterPort_CAM.hh
View file @ f6d8a00a
......@@ -9,19 +9,18 @@
namespace LibItsCam__TestSystem {
class UpperTesterPort : public UpperTesterPort_BASE {
params _cfg_params;
params _layer_params;
layer* _layer;
params _cfg_params;
params _layer_params;
layer * _layer;
std::string _time_key;
public:
UpperTesterPort(const char *par_port_name = NULL);
~UpperTesterPort();
void set_parameter(const char *parameter_name,
const char *parameter_value);
void set_parameter(const char *parameter_name, const char *parameter_value);
void receiveMsg (const Base_Type&, const params&);
void receiveMsg(const Base_Type &, const params &);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
......@@ -37,17 +36,16 @@ namespace LibItsCam__TestSystem {
void user_start();
void user_stop();
void outgoing_send(const LibItsCam__TypesAndValues::UtCamInitialize& send_par);
void outgoing_send(const LibItsCam__TypesAndValues::UtCamChangePosition& send_par);
void outgoing_send(const LibItsCam__TypesAndValues::UtCamTrigger& send_par);
void outgoing_send(const LibItsCam__TypesAndValues::UtActivatePositionTime& send_par);
void outgoing_send(const LibItsCam__TypesAndValues::UtDeactivatePositionTime& send_par);
void outgoing_send(const LibItsCam__TypesAndValues::UtCamInitialize &send_par);
void outgoing_send(const LibItsCam__TypesAndValues::UtCamChangePosition &send_par);
void outgoing_send(const LibItsCam__TypesAndValues::UtCamTrigger &send_par);
void outgoing_send(const LibItsCam__TypesAndValues::UtActivatePositionTime &send_par);
void outgoing_send(const LibItsCam__TypesAndValues::UtDeactivatePositionTime &send_par);
};
} /* end of namespace */
} // namespace LibItsCam__TestSystem
#endif
ccsrc/Ports/LibIts_ports/DCC_ports/CheckPort.cc
View file @ f6d8a00a
......@@ -11,67 +11,31 @@
namespace LibItsDcc__TestSystem {
CheckPort::CheckPort(const char *par_port_name)
: CheckPort_BASE(par_port_name)
{
CheckPort::CheckPort(const char *par_port_name) : CheckPort_BASE(par_port_name) {}
}
CheckPort::~CheckPort() {}
CheckPort::~CheckPort()
{
void CheckPort::set_parameter(const char * /*parameter_name*/, const char * /*parameter_value*/) {}
}
/*void CheckPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void CheckPort::set_parameter(const char * /*parameter_name*/,
const char * /*parameter_value*/)
{
void CheckPort::Handle_Fd_Event_Error(int /*fd*/) {}
}
void CheckPort::Handle_Fd_Event_Writable(int /*fd*/) {}
/*void CheckPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void CheckPort::Handle_Fd_Event_Readable(int /*fd*/) {}
void CheckPort::Handle_Fd_Event_Error(int /*fd*/)
{
/*void CheckPort::Handle_Timeout(double time_since_last_call) {}*/
}
void CheckPort::user_map(const char * /*system_port*/) {}
void CheckPort::Handle_Fd_Event_Writable(int /*fd*/)
{
void CheckPort::user_unmap(const char * /*system_port*/) {}
}
void CheckPort::user_start() {}
void CheckPort::Handle_Fd_Event_Readable(int /*fd*/)
{
void CheckPort::user_stop() {}
}
/*void CheckPort::Handle_Timeout(double time_since_last_call) {}*/
void CheckPort::user_map(const char * /*system_port*/)
{
}
void CheckPort::user_unmap(const char * /*system_port*/)
{
}
void CheckPort::user_start()
{
}
void CheckPort::user_stop()
{
}
void CheckPort::outgoing_send(const INTEGER& /*send_par*/)
{
}
} /* end of namespace */
void CheckPort::outgoing_send(const INTEGER & /*send_par*/) {}
} // namespace LibItsDcc__TestSystem
ccsrc/Ports/LibIts_ports/DCC_ports/CheckPort.hh
View file @ f6d8a00a
......@@ -14,32 +14,30 @@
namespace LibItsDcc__TestSystem {
class CheckPort : public CheckPort_BASE {
public:
CheckPort(const char *par_port_name = NULL);
~CheckPort();
void set_parameter(const char *parameter_name,
const char *parameter_value);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error); */
void Handle_Fd_Event_Error(int fd);
void Handle_Fd_Event_Writable(int fd);
void Handle_Fd_Event_Readable(int fd);
/* void Handle_Timeout(double time_since_last_call); */
protected:
void user_map(const char *system_port);
void user_unmap(const char *system_port);
void user_start();
void user_stop();
void outgoing_send(const INTEGER& send_par);
};
} /* end of namespace */
class CheckPort : public CheckPort_BASE {
public:
CheckPort(const char *par_port_name = NULL);
~CheckPort();
void set_parameter(const char *parameter_name, const char *parameter_value);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error); */
void Handle_Fd_Event_Error(int fd);
void Handle_Fd_Event_Writable(int fd);
void Handle_Fd_Event_Readable(int fd);
/* void Handle_Timeout(double time_since_last_call); */
protected:
void user_map(const char *system_port);
void user_unmap(const char *system_port);
void user_start();
void user_stop();
void outgoing_send(const INTEGER &send_par);
};
} // namespace LibItsDcc__TestSystem
#endif
ccsrc/Ports/LibIts_ports/DCC_ports/InPort.cc
View file @ f6d8a00a
......@@ -11,68 +11,31 @@
namespace LibItsDcc__TestSystem {
InPort::InPort(const char *par_port_name)
: InPort_BASE(par_port_name)
{
InPort::InPort(const char *par_port_name) : InPort_BASE(par_port_name) {}
}
InPort::~InPort() {}
InPort::~InPort()
{
void InPort::set_parameter(const char * /*parameter_name*/, const char * /*parameter_value*/) {}
}
/*void InPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void InPort::set_parameter(const char * /*parameter_name*/,
const char * /*parameter_value*/)
{
void InPort::Handle_Fd_Event_Error(int /*fd*/) {}
}
void InPort::Handle_Fd_Event_Writable(int /*fd*/) {}
/*void InPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void InPort::Handle_Fd_Event_Readable(int /*fd*/) {}
void InPort::Handle_Fd_Event_Error(int /*fd*/)
{
/*void InPort::Handle_Timeout(double time_since_last_call) {}*/
}
void InPort::user_map(const char * /*system_port*/) {}
void InPort::Handle_Fd_Event_Writable(int /*fd*/)
{
void InPort::user_unmap(const char * /*system_port*/) {}
}
void InPort::user_start() {}
void InPort::Handle_Fd_Event_Readable(int /*fd*/)
{
void InPort::user_stop() {}
}
/*void InPort::Handle_Timeout(double time_since_last_call) {}*/
void InPort::user_map(const char * /*system_port*/)
{
}
void InPort::user_unmap(const char * /*system_port*/)
{
}
void InPort::user_start()
{
}
void InPort::user_stop()
{
}
void InPort::outgoing_send(const LibItsDcc__TypesAndValues::InReq& /*send_par*/)
{
}
} /* end of namespace */
void InPort::outgoing_send(const LibItsDcc__TypesAndValues::InReq & /*send_par*/) {}
} // namespace LibItsDcc__TestSystem
ccsrc/Ports/LibIts_ports/DCC_ports/InPort.hh
View file @ f6d8a00a
......@@ -14,31 +14,30 @@
namespace LibItsDcc__TestSystem {
class InPort : public InPort_BASE {
public:
InPort(const char *par_port_name = NULL);
~InPort();
void set_parameter(const char *parameter_name,
const char *parameter_value);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error); */
void Handle_Fd_Event_Error(int fd);
void Handle_Fd_Event_Writable(int fd);
void Handle_Fd_Event_Readable(int fd);
/* void Handle_Timeout(double time_since_last_call); */
protected:
void user_map(const char *system_port);
void user_unmap(const char *system_port);
void user_start();
void user_stop();
void outgoing_send(const LibItsDcc__TypesAndValues::InReq& send_par);
};
} /* end of namespace */
class InPort : public InPort_BASE {
public:
InPort(const char *par_port_name = NULL);
~InPort();
void set_parameter(const char *parameter_name, const char *parameter_value);
private:
/* void Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error); */
void Handle_Fd_Event_Error(int fd);
void Handle_Fd_Event_Writable(int fd);
void Handle_Fd_Event_Readable(int fd);
/* void Handle_Timeout(double time_since_last_call); */
protected:
void user_map(const char *system_port);
void user_unmap(const char *system_port);
void user_start();
void user_stop();
void outgoing_send(const LibItsDcc__TypesAndValues::InReq &send_par);
};
} // namespace LibItsDcc__TestSystem
#endif
ccsrc/Ports/LibIts_ports/DCC_ports/RrxPort.cc
View file @ f6d8a00a
......@@ -11,63 +11,29 @@
namespace LibItsDcc__TestSystem {
RrxPort::RrxPort(const char *par_port_name)
: RrxPort_BASE(par_port_name)
{
RrxPort::RrxPort(const char *par_port_name) : RrxPort_BASE(par_port_name) {}
}
RrxPort::~RrxPort() {}
RrxPort::~RrxPort()
{
void RrxPort::set_parameter(const char * /*parameter_name*/, const char * /*parameter_value*/) {}
}
/*void RrxPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void RrxPort::set_parameter(const char * /*parameter_name*/,
const char * /*parameter_value*/)
{
void RrxPort::Handle_Fd_Event_Error(int /*fd*/) {}
}
void RrxPort::Handle_Fd_Event_Writable(int /*fd*/) {}
/*void RrxPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void RrxPort::Handle_Fd_Event_Readable(int /*fd*/) {}
void RrxPort::Handle_Fd_Event_Error(int /*fd*/)
{
/*void RrxPort::Handle_Timeout(double time_since_last_call) {}*/
}
void RrxPort::user_map(const char * /*system_port*/) {}
void RrxPort::Handle_Fd_Event_Writable(int /*fd*/)
{
void RrxPort::user_unmap(const char * /*system_port*/) {}
}
void RrxPort::user_start() {}
void RrxPort::Handle_Fd_Event_Readable(int /*fd*/)
{
}
/*void RrxPort::Handle_Timeout(double time_since_last_call) {}*/
void RrxPort::user_map(const char * /*system_port*/)
{
}
void RrxPort::user_unmap(const char * /*system_port*/)
{
}
void RrxPort::user_start()
{
}
void RrxPort::user_stop()
{
}
} /* end of namespace */
void RrxPort::user_stop() {}
} // namespace LibItsDcc__TestSystem