FaceTSS.cpp File Reference

#include "ace/config-macros.h"
#include "FACE/TS.hpp"
#include "FaceTSS.h"
#include "config/Parser.h"
#include "dds/DCPS/Service_Participant.h"
#include "dds/DCPS/DomainParticipantImpl.h"
#include "dds/DCPS/Registered_Data_Types.h"
#include "dds/DCPS/Marked_Default_Qos.h"
#include "dds/DCPS/BuiltInTopicUtils.h"
#include "dds/DCPS/SafetyProfileStreams.h"
#include "dds/DCPS/SafetyProfilePool.h"
#include "dds/DCPS/Qos_Helper.h"
#include "dds/DdsDcpsCoreC.h"
#include "dds/DCPS/transport/framework/TransportRegistry.h"
#include <cstring>

Include dependency graph for FaceTSS.cpp:

Go to the source code of this file.

Namespaces
namespace	FACE
namespace	FACE::TS
namespace	OpenDDS
namespace	OpenDDS::FaceTSS
Enumerations
enum	{ OpenDDS::FaceTSS::NSEC_PER_SEC = 1000000000 }
Functions
void	FACE::TS::find_or_create_dp (const DDS::DomainId_t &domainId, int participantId, const DDS::DomainParticipantFactory_var &dpf, DDS::DomainParticipant_var &dp)
void	FACE::TS::find_or_create_pub (const DDS::PublisherQos &qos, const DDS::DomainParticipant_var &dp, DDS::Publisher_var &pub)
void	FACE::TS::find_or_create_sub (const DDS::SubscriberQos &qos, const DDS::DomainParticipant_var &dp, DDS::Subscriber_var &sub)
bool	FACE::TS::cleanup_opendds_publisher (const DDS::Publisher_var pub)
bool	FACE::TS::cleanup_opendds_subscriber (const DDS::Subscriber_var sub)
void	FACE::TS::cleanup_opendds_participant (const DDS::DomainParticipant_var dp)
RETURN_CODE_TYPE	FACE::TS::create_opendds_entities (CONNECTION_ID_TYPE connectionId, int participantId, const DDS::DomainId_t domainId, const char *topic, const char *type, CONNECTION_DIRECTION_TYPE dir, QosSettings &qos, const char *transport)
void	FACE::TS::Initialize (const CONFIGURATION_RESOURCE configuration_file, RETURN_CODE_TYPE &return_code)
void	FACE::TS::Create_Connection (const CONNECTION_NAME_TYPE connection_name, MESSAGING_PATTERN_TYPE pattern, CONNECTION_ID_TYPE &connection_id, CONNECTION_DIRECTION_TYPE &connection_direction, MESSAGE_SIZE_TYPE &max_message_size, TIMEOUT_TYPE, RETURN_CODE_TYPE &return_code)
void	FACE::TS::Get_Connection_Parameters (CONNECTION_NAME_TYPE &connection_name, CONNECTION_ID_TYPE &connection_id, TRANSPORT_CONNECTION_STATUS_TYPE &status, RETURN_CODE_TYPE &return_code)
void	FACE::TS::Unregister_Callback (CONNECTION_ID_TYPE connection_id, RETURN_CODE_TYPE &return_code)
void	FACE::TS::Destroy_Connection (CONNECTION_ID_TYPE connection_id, RETURN_CODE_TYPE &return_code)
OpenDDS_FACE_Export void	FACE::TS::receive_header (FACE::CONNECTION_ID_TYPE connection_id, FACE::TIMEOUT_TYPE, FACE::TRANSACTION_ID_TYPE &transaction_id, FACE::TS::MessageHeader &message_header, FACE::MESSAGE_SIZE_TYPE message_size, FACE::RETURN_CODE_TYPE &return_code)
void	FACE::TS::Receive_Message (CONNECTION_ID_TYPE connection_id, TIMEOUT_TYPE timeout, TRANSACTION_ID_TYPE &transaction_id, MessageHeader &message_header, MESSAGE_SIZE_TYPE message_size, RETURN_CODE_TYPE &return_code)
void	FACE::TS::find_or_create_dp (const DDS::DomainId_t &domainId, int participantId, const DDS::DomainParticipantFactory_var &dpf, DDS::DomainParticipant_var &dp)
void	FACE::TS::find_or_create_pub (const DDS::PublisherQos &qos, const DDS::DomainParticipant_var &dp, DDS::Publisher_var &pub)
void	FACE::TS::find_or_create_sub (const DDS::SubscriberQos &qos, const DDS::DomainParticipant_var &dp, DDS::Subscriber_var &sub)
bool	FACE::TS::cleanup_opendds_publisher (const DDS::Publisher_var pub)
bool	FACE::TS::cleanup_opendds_subscriber (const DDS::Subscriber_var sub)
void	FACE::TS::cleanup_opendds_participant (const DDS::DomainParticipant_var dp)
RETURN_CODE_TYPE	FACE::TS::create_opendds_entities (CONNECTION_ID_TYPE connectionId, int participantId, const DDS::DomainId_t domainId, const char *topicName, const char *type, CONNECTION_DIRECTION_TYPE dir, QosSettings &qos_settings, const char *transport)
FACE::RETURN_CODE_TYPE	OpenDDS::FaceTSS::update_status (FACE::CONNECTION_ID_TYPE connection_id, DDS::ReturnCode_t retcode)
DDS::Duration_t	OpenDDS::FaceTSS::convertTimeout (FACE::TIMEOUT_TYPE timeout)
FACE::SYSTEM_TIME_TYPE	OpenDDS::FaceTSS::convertDuration (const DDS::Duration_t &duration)
FACE::SYSTEM_TIME_TYPE	OpenDDS::FaceTSS::convertTime (const DDS::Time_t &timestamp)
FACE::MESSAGE_INSTANCE_GUID	OpenDDS::FaceTSS::create_message_instance_guid (const OpenDDS::DCPS::RepoId &pub, const CORBA::LongLong &orig_seq)
void	OpenDDS::FaceTSS::populate_header_received (const FACE::CONNECTION_ID_TYPE &connection_id, const DDS::DomainParticipant_var part, const DDS::SampleInfo &sinfo, FACE::RETURN_CODE_TYPE &return_code)
Variables
OpenDDS::FaceTSS::config::Parser	FACE::TS::parser

---