1 #ifndef _MADARA_SPLICE_DDS_TRANSPORT_H__ 2 #define _MADARA_SPLICE_DDS_TRANSPORT_H_ 9 #include "ccpp_dds_dcps.h" 10 #include "madara/transport/splice/ccpp_SpliceKnowledgeUpdate.h" 63 long start_latency (
void);
70 #endif // #ifdef _USE_CID_ 139 void check_status (DDS::ReturnCode_t status,
const char * info);
DDS::SubscriberQos sub_qos_
DDS::DataReader_var datareader_
DDS::DataWriterQos datawriter_qos_
int reliability(void) const
Accesses reliability setting.
This class stores variables and their values for use by any entity needing state information in a thr...
DDS::Publisher_var publisher_
DDS::DomainParticipant_var domain_participant_
Knowledge::UpdateDataReader_var update_reader_
Holds basic transport settings.
Knowledge::UpdateDataWriter_var update_writer_
DDS::DomainParticipantFactory_var domain_factory_
DDS::PublisherQos pub_qos_
~SpliceDDSTransport()
Destructor.
static const char * partition_
DDS::Topic_var update_topic_
static const char * ret_code_names[]
long send_data(const knowledge::KnowledgeRecords &updates)
Sends a list of knowledge updates to listeners.
DDS::DataWriter_var datawriter_
threads::Threader read_threads_
threads for reading knowledge updates
void check_handle(void *handle, const char *info)
Splice handle checker.
This class provides an interface into the Open Splice dissemination transport.
SpliceDDSTransport(const std::string &id, knowledge::ThreadSafeContext &context, TransportSettings &config, bool launch_transport)
Constructor.
This class provides a distributed knowledge base to users.
::std::map< std::string, KnowledgeRecord * > KnowledgeRecords
knowledge::KnowledgeBase knowledge_
knowledge base for threads to use
Knowledge::UpdateDataWriter_var latency_update_writer_
DDS::DomainParticipantQos part_qos_
DDS::Subscriber_var subscriber_
Knowledge::UpdateTypeSupport update_type_support_
int setup(void)
Activates this transport.
DDS::DataWriter_var latencywriter_
Starts threads with first class support of MADARA contexts.
void close(void)
Closes this transport.
DDS::DataReaderQos datareader_qos_
static const char * topic_names_[]
static const int PROFILES
void check_status(DDS::ReturnCode_t status, const char *info)
Splice status checker.
Copyright (c) 2015 Carnegie Mellon University.
const char * get_error_name(DDS::ReturnCode_t status)
Returns error name of the specific status.
Base class from which all transports must be derived.