Skip to content
GitLab
Projects
Groups
Topics
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in
Toggle navigation
Menu
ITS - Intelligent Transport Systems
ITS
Compare revisions
84c42dd2049756813c8e4a7c927f9ea7e2b11cb9...f6d8a00aca4f3cb86d4506ea06bafdf6faf119b2
Show 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"
);
...
...
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
::
set_parameter
(
const
char
*
/*parameter_name*/
,
const
char
*
/*parameter_value*/
)
{
}
/*void HmiPort::Handle_Fd_Event(int fd, boolean is_readable,
/*void HmiPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void
HmiPort
::
Handle_Fd_Event_Error
(
int
/*fd*/
)
{
}
void
HmiPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
HmiPort
::
Handle_Fd_Event_Readable
(
int
/*fd*/
)
{
}
/*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
::
Handle_Fd_Event_Error
(
int
/*fd*/
)
{}
}
void
HmiPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
HmiPort
::
user_start
()
{
void
HmiPort
::
Handle_Fd_Event_Readable
(
int
/*fd*/
)
{}
}
/*void HmiPort::Handle_Timeout(double time_since_last_call) {}*/
void
HmiPort
::
user_stop
()
{
void
HmiPort
::
user_map
(
const
char
*
/*system_port*/
)
{}
}
void
HmiPort
::
user_unmap
(
const
char
*
/*system_port*/
)
{
}
void
HmiPort
::
outgoing_send
(
const
ItsAutoInterop__TypesAndValues
::
HmiInitialize
&
/*send_par*/
)
{
void
HmiPort
::
user_start
()
{}
}
void
HmiPort
::
user_stop
()
{
}
}
/* 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:
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
);
void
set_parameter
(
const
char
*
parameter_name
,
const
char
*
parameter_value
);
private:
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:
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
);
};
void
outgoing_send
(
const
ItsAutoInterop__TypesAndValues
::
HmiInitialize
&
send_par
);
};
}
/
* end of
namespace
*/
}
/
/
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_Error
(
int
/*fd*/
)
{
}
}
void
BtpPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
BtpPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
BtpPort
::
Handle_Fd_Event_Readable
(
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,16 +65,12 @@ namespace LibItsBtp__TestSystem {
}
}
void
BtpPort
::
user_start
()
{
}
void
BtpPort
::
user_stop
()
{
void
BtpPort
::
user_start
()
{}
}
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
);
...
...
@@ -90,11 +78,10 @@ namespace LibItsBtp__TestSystem {
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
...
...
@@ -20,16 +20,16 @@ namespace LibItsBtp__TestSystem {
class
BtpPort
:
public
BtpPort_BASE
{
params
_cfg_params
;
params
_layer_params
;
layer
*
_layer
;
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
::
set_parameter
(
const
char
*
/*parameter_name*/
,
const
char
*
/*parameter_value*/
)
{
}
/*void UpperTesterPort::Handle_Fd_Event(int fd, boolean is_readable,
/*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_Readable
(
int
/*fd*/
)
{
}
/*void UpperTesterPort::Handle_Timeout(double time_since_last_call) {}*/
void
UpperTesterPort
::
user_map
(
const
char
*
/*system_port*/
)
{
}
void
UpperTesterPort
::
user_unmap
(
const
char
*
/*system_port*/
)
{
void
UpperTesterPort
::
Handle_Fd_Event_Error
(
int
/*fd*/
)
{}
}
void
UpperTesterPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
UpperTesterPort
::
user_start
()
{
void
UpperTesterPort
::
Handle_Fd_Event_Readable
(
int
/*fd*/
)
{}
}
/*void UpperTesterPort::Handle_Timeout(double time_since_last_call) {}*/
void
UpperTesterPort
::
user_stop
()
{
void
UpperTesterPort
::
user_map
(
const
char
*
/*system_port*/
)
{}
}
void
UpperTesterPort
::
user_unmap
(
const
char
*
/*system_port*/
)
{
}
void
UpperTesterPort
::
outgoing_send
(
const
LibItsBtp__TypesAndValues
::
UtBtpInitialize
&
/*send_par*/
)
{
void
UpperTesterPort
::
user_start
()
{}
}
void
UpperTesterPort
::
user_stop
()
{
}
void
UpperTesterPort
::
outgoing_send
(
const
LibItsBtp__TypesAndValues
::
UtBtpTrigger
&
/*send_par*/
)
{
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
...
...
@@ -4,32 +4,31 @@
#include
"LibItsBtp_TestSystem.hh"
namespace
LibItsBtp__TestSystem
{
class
UpperTesterPort
:
public
UpperTesterPort_BASE
{
public:
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:
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:
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
LibItsBtp__TypesAndValues
::
UtBtpInitialize
&
send_par
);
void
outgoing_send
(
const
LibItsBtp__TypesAndValues
::
UtBtpInitialize
&
send_par
);
void
outgoing_send
(
const
LibItsBtp__TypesAndValues
::
UtBtpTrigger
&
send_par
);
};
void
outgoing_send
(
const
LibItsBtp__TypesAndValues
::
UtBtpTrigger
&
send_par
);
};
}
/
* end of
namespace
*/
}
/
/
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
()
{
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
::
set_parameter
(
const
char
*
/*parameter_name*/
,
const
char
*
/*parameter_value*/
)
{}
}
/*void AdapterControlPort::Handle_Fd_Event(int fd, boolean is_readable,
/*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_Error
(
int
/*fd*/
)
{}
}
void
AdapterControlPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
AdapterControlPort
::
Handle_Fd_Event_Readable
(
int
/*fd*/
)
{
void
AdapterControlPort
::
Handle_Fd_Event_Readable
(
int
/*fd*/
)
{}
}
/*void AdapterControlPort::Handle_Timeout(double time_since_last_call) {}*/
/*
void AdapterControlPort::
Handle_Timeout(double time_since_last_call
) {}
*/
void
AdapterControlPort
::
user_map
(
const
char
*
/*system_port*/
)
{}
void
AdapterControlPort
::
user_map
(
const
char
*
/*system_port*/
)
{
void
AdapterControlPort
::
user_unmap
(
const
char
*
/*system_port*/
)
{}
}
void
AdapterControlPort
::
user_start
()
{
}
void
AdapterControlPort
::
user_unmap
(
const
char
*
/*system_port*/
)
{
void
AdapterControlPort
::
user_stop
()
{}
}
void
AdapterControlPort
::
outgoing_send
(
const
LibItsCommon__TypesAndValues
::
AcGnssPrimitive
&
/*send_par*/
)
{
}
void
AdapterControlPort
::
user_start
()
{
}
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:
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
);
void
set_parameter
(
const
char
*
parameter_name
,
const
char
*
parameter_value
);
private:
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:
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
::
AcGnssPrimitive
&
send_par
);
void
outgoing_send
(
const
LibItsCommon__TypesAndValues
::
AcSecPrimitive
&
send_par
);
void
outgoing_send
(
const
LibItsCommon__TypesAndValues
::
AcSecPrimitive
&
send_par
);
};
};
}
// end of namespace
}
// 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_Error
(
int
/*fd*/
)
{}
}
void
CamPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
CamPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
CamPort
::
Handle_Fd_Event_Readable
(
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"
));
...
...
@@ -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,18 +65,11 @@ namespace LibItsCam__TestSystem {
}
}
void
CamPort
::
user_start
()
{
}
void
CamPort
::
user_stop
()
{
void
CamPort
::
user_start
()
{}
}
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
;
...
...
@@ -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
...
...
@@ -20,16 +20,16 @@ namespace LibItsCam__TestSystem {
class
CamPort
:
public
CamPort_BASE
{
params
_cfg_params
;
params
_layer_params
;
layer
*
_layer
;
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_Error
(
int
/*fd*/
)
{}
}
void
UpperTesterPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
UpperTesterPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
UpperTesterPort
::
Handle_Fd_Event_Readable
(
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,28 +50,19 @@ 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_start
()
{}
}
void
UpperTesterPort
::
user_stop
()
{
}
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
;
...
...
@@ -93,8 +71,7 @@ namespace LibItsCam__TestSystem {
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
;
...
...
@@ -103,8 +80,7 @@ namespace LibItsCam__TestSystem {
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
;
...
...
@@ -113,17 +89,11 @@ namespace LibItsCam__TestSystem {
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
...
...
@@ -11,17 +11,16 @@ namespace LibItsCam__TestSystem {
class
UpperTesterPort
:
public
UpperTesterPort_BASE
{
params
_cfg_params
;
params
_layer_params
;
layer
*
_layer
;
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
::
UtCamInitialize
&
send_par
);
void
outgoing_send
(
const
LibItsCam__TypesAndValues
::
UtCamChangePosition
&
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
::
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
::
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
::
set_parameter
(
const
char
*
/*parameter_name*/
,
const
char
*
/*parameter_value*/
)
{
}
/*void CheckPort::Handle_Fd_Event(int fd, boolean is_readable,
/*void CheckPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void
CheckPort
::
Handle_Fd_Event_Error
(
int
/*fd*/
)
{
}
void
CheckPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
CheckPort
::
Handle_Fd_Event_Readable
(
int
/*fd*/
)
{
}
/*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
::
Handle_Fd_Event_Error
(
int
/*fd*/
)
{}
}
void
CheckPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
CheckPort
::
user_start
()
{
void
CheckPort
::
Handle_Fd_Event_Readable
(
int
/*fd*/
)
{}
}
/*void CheckPort::Handle_Timeout(double time_since_last_call) {}*/
void
CheckPort
::
user_stop
()
{
void
CheckPort
::
user_map
(
const
char
*
/*system_port*/
)
{}
}
void
CheckPort
::
user_unmap
(
const
char
*
/*system_port*/
)
{
}
void
CheckPort
::
outgoing_send
(
const
INTEGER
&
/*send_par*/
)
{
void
CheckPort
::
user_start
()
{}
}
void
CheckPort
::
user_stop
()
{
}
}
/* 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:
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
);
void
set_parameter
(
const
char
*
parameter_name
,
const
char
*
parameter_value
);
private:
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:
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
);
void
outgoing_send
(
const
INTEGER
&
send_par
);
};
};
}
/* end of namespace */
}
// 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
::
set_parameter
(
const
char
*
/*parameter_name*/
,
const
char
*
/*parameter_value*/
)
{
}
/*void InPort::Handle_Fd_Event(int fd, boolean is_readable,
/*void InPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void
InPort
::
Handle_Fd_Event_Error
(
int
/*fd*/
)
{
}
void
InPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
InPort
::
Handle_Fd_Event_Readable
(
int
/*fd*/
)
{
}
/*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
::
Handle_Fd_Event_Error
(
int
/*fd*/
)
{}
void
InPort
::
user_start
()
{
void
InPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{}
}
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
::
outgoing_send
(
const
LibItsDcc__TypesAndValues
::
InReq
&
/*send_par*/
)
{
void
InPort
::
user_unmap
(
const
char
*
/*system_port*/
)
{}
}
void
InPort
::
user_start
()
{
}
void
InPort
::
user_stop
()
{}
}
/* 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:
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
);
void
set_parameter
(
const
char
*
parameter_name
,
const
char
*
parameter_value
);
private:
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:
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
);
};
void
outgoing_send
(
const
LibItsDcc__TypesAndValues
::
InReq
&
send_par
);
};
}
/
* end of
namespace
*/
}
/
/
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
::
set_parameter
(
const
char
*
/*parameter_name*/
,
const
char
*
/*parameter_value*/
)
{
}
/*void RrxPort::Handle_Fd_Event(int fd, boolean is_readable,
/*void RrxPort::Handle_Fd_Event(int fd, boolean is_readable,
boolean is_writable, boolean is_error) {}*/
void
RrxPort
::
Handle_Fd_Event_Error
(
int
/*fd*/
)
{
}
void
RrxPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
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
::
Handle_Fd_Event_Error
(
int
/*fd*/
)
{}
}
void
RrxPort
::
Handle_Fd_Event_Writable
(
int
/*fd*/
)
{
}
void
RrxPort
::
user_start
()
{
void
RrxPort
::
Handle_Fd_Event_Readable
(
int
/*fd*/
)
{}
}
/*void RrxPort::Handle_Timeout(double time_since_last_call) {}*/
void
RrxPort
::
user_stop
()
{
void
RrxPort
::
user_map
(
const
char
*
/*system_port*/
)
{}
}
void
RrxPort
::
user_unmap
(
const
char
*
/*system_port*/
)
{
}
void
RrxPort
::
user_start
()
{}
}
/* end of namespace */
void
RrxPort
::
user_stop
()
{}
}
// namespace LibItsDcc__TestSystem
Prev
1
2
3
4
5
6
7
…
17
Next