27 #include <dds/dds_seq.hh> 28 #include <dds/dds_map.hh> 30 namespace coredx {
namespace rpc {
154 class DomainParticipantFactory;
155 class DomainParticipant;
160 class TopicDescription;
162 class ContentFilteredTopic;
164 class DomainParticipantListener;
165 class PublisherListener;
166 class SubscriberListener;
168 class DataReaderListener;
169 class DataWriterListener;
171 class GuardCondition;
172 class StatusCondition;
174 class QueryCondition;
194 typedef enum SampleRejectedStatusKind
197 REJECTED_BY_INSTANCE_LIMIT,
198 REJECTED_BY_SAMPLES_LIMIT,
199 REJECTED_BY_SAMPLES_PER_INSTANCE_LIMIT
200 } SampleRejectedStatusKind;
205 typedef unsigned char Octet;
209 typedef long QosPolicyId_t;
210 typedef unsigned long SampleStateKind;
211 typedef unsigned long SampleStateMask;
212 typedef unsigned long ViewStateKind;
213 typedef unsigned long ViewStateMask;
214 typedef unsigned long InstanceStateKind;
215 typedef unsigned long InstanceStateMask;
216 typedef unsigned long StatusKind;
224 Time_t() : sec(0),nanosec(0) {};
225 Time_t(int32_t s, uint32_t nsec) : sec(s), nanosec(nsec) {};
244 typedef struct DCPSTopic TopicBuiltinTopicData;
268 #if defined(_WIN32) && !defined(__MINGW32__) 269 # pragma warning (disable : 4231) 281 #include <dds/dds_builtin.hh> 348 char value[COREDX_ENTITY_NAME_MAX];
371 char uri[COREDX_LOGGING_URI_MAX];
379 typedef struct Locator_t {
382 unsigned char addr[16];
385 typedef sequence<Locator> LocatorSeq;
386 #if defined(_WIN32) && !defined(__MINGW32__) 399 typedef sequence<ParticipantLocator> ParticipantLocatorSeq;
400 #if defined(_WIN32) && !defined(__MINGW32__) 420 void clear() { this->value.clear(); }
491 DDS_BUILTIN_TOPIC_KEY_TYPE_NATIVE guid_pid;
785 const long LENGTH_UNLIMITED = DDS_LENGTH_UNLIMITED;
786 const long DURATION_INFINITE_SEC = DDS_DURATION_INFINITE_SEC;
787 const unsigned long DURATION_INFINITE_NSEC = DDS_DURATION_INFINITE_NSEC;
788 const long DURATION_ZERO_SEC = DDS_DURATION_ZERO_SEC;
789 const unsigned long DURATION_ZERO_NSEC = DDS_DURATION_ZERO_NSEC;
790 const long TIMESTAMP_INVALID_SEC = DDS_TIMESTAMP_INVALID_SEC;
791 const unsigned long TIMESTAMP_INVALID_NSEC = DDS_TIMESTAMP_INVALID_NSEC;
793 #define TIMESTAMP_INVALID { DDS_TIMESTAMP_INVALID_SEC, DDS_TIMESTAMP_INVALID_NSEC } 803 const ReturnCode_t RETCODE_UNSUPPORTED = DDS_RETCODE_UNSUPPORTED;
804 const ReturnCode_t RETCODE_BAD_PARAMETER = DDS_RETCODE_BAD_PARAMETER;
805 const ReturnCode_t RETCODE_PRECONDITION_NOT_MET = DDS_RETCODE_PRECONDITION_NOT_MET;
806 const ReturnCode_t RETCODE_OUT_OF_RESOURCES = DDS_RETCODE_OUT_OF_RESOURCES;
807 const ReturnCode_t RETCODE_NOT_ENABLED = DDS_RETCODE_NOT_ENABLED;
808 const ReturnCode_t RETCODE_IMMUTABLE_POLICY = DDS_RETCODE_IMMUTABLE_POLICY;
809 const ReturnCode_t RETCODE_INCONSISTENT_POLICY = DDS_RETCODE_INCONSISTENT_POLICY;
810 const ReturnCode_t RETCODE_ALREADY_DELETED = DDS_RETCODE_ALREADY_DELETED;
811 const ReturnCode_t RETCODE_TIMEOUT = DDS_RETCODE_TIMEOUT;
812 const ReturnCode_t RETCODE_NO_DATA = DDS_RETCODE_NO_DATA;
815 const unsigned long READ_SAMPLE_STATE = DDS_READ_SAMPLE_STATE;
816 const unsigned long NOT_READ_SAMPLE_STATE = DDS_NOT_READ_SAMPLE_STATE;
817 const unsigned long ANY_SAMPLE_STATE = DDS_ANY_SAMPLE_STATE;
820 const unsigned long NEW_VIEW_STATE = DDS_NEW_VIEW_STATE;
821 const unsigned long NOT_NEW_VIEW_STATE = DDS_NOT_NEW_VIEW_STATE;
822 const unsigned long ANY_VIEW_STATE = DDS_ANY_VIEW_STATE;
825 const unsigned long ALIVE_INSTANCE_STATE = DDS_ALIVE_INSTANCE_STATE;
826 const unsigned long NOT_ALIVE_DISPOSED_INSTANCE_STATE = DDS_NOT_ALIVE_DISPOSED_INSTANCE_STATE;
827 const unsigned long NOT_ALIVE_NO_WRITERS_INSTANCE_STATE= DDS_NOT_ALIVE_NO_WRITERS_INSTANCE_STATE;
828 const unsigned long NOT_ALIVE_INSTANCE_STATE = DDS_NOT_ALIVE_INSTANCE_STATE;
829 const unsigned long ANY_INSTANCE_STATE = DDS_ANY_INSTANCE_STATE;
831 const StatusKind NO_STATUS = DDS_NO_STATUS;
832 const StatusKind STATUS_MASK_NONE = DDS_NO_STATUS;
833 const StatusKind INCONSISTENT_TOPIC_STATUS = DDS_INCONSISTENT_TOPIC_STATUS;
834 const StatusKind OFFERED_DEADLINE_MISSED_STATUS = DDS_OFFERED_DEADLINE_MISSED_STATUS;
835 const StatusKind REQUESTED_DEADLINE_MISSED_STATUS = DDS_REQUESTED_DEADLINE_MISSED_STATUS;
836 const StatusKind OFFERED_INCOMPATIBLE_QOS_STATUS = DDS_OFFERED_INCOMPATIBLE_QOS_STATUS;
837 const StatusKind REQUESTED_INCOMPATIBLE_QOS_STATUS = DDS_REQUESTED_INCOMPATIBLE_QOS_STATUS;
838 const StatusKind SAMPLE_LOST_STATUS = DDS_SAMPLE_LOST_STATUS;
839 const StatusKind SAMPLE_REJECTED_STATUS = DDS_SAMPLE_REJECTED_STATUS;
840 const StatusKind DATA_ON_READERS_STATUS = DDS_DATA_ON_READERS_STATUS;
841 const StatusKind DATA_AVAILABLE_STATUS = DDS_DATA_AVAILABLE_STATUS;
842 const StatusKind LIVELINESS_LOST_STATUS = DDS_LIVELINESS_LOST_STATUS;
843 const StatusKind LIVELINESS_CHANGED_STATUS = DDS_LIVELINESS_CHANGED_STATUS;
844 const StatusKind PUBLICATION_MATCHED_STATUS = DDS_PUBLICATION_MATCHED_STATUS;
845 const StatusKind SUBSCRIPTION_MATCHED_STATUS = DDS_SUBSCRIPTION_MATCHED_STATUS;
846 const StatusKind ALL_STATUS = DDS_ALL_STATUS;
848 const QosPolicyId_t USERDATA_QOS_POLICY_ID = DDS_USERDATA_QOS_POLICY_ID;
849 const QosPolicyId_t DURABILITY_QOS_POLICY_ID = DDS_DURABILITY_QOS_POLICY_ID;
850 const QosPolicyId_t PRESENTATION_QOS_POLICY_ID = DDS_PRESENTATION_QOS_POLICY_ID;
851 const QosPolicyId_t DEADLINE_QOS_POLICY_ID = DDS_DEADLINE_QOS_POLICY_ID;
852 const QosPolicyId_t LATENCYBUDGET_QOS_POLICY_ID = DDS_LATENCYBUDGET_QOS_POLICY_ID;
853 const QosPolicyId_t OWNERSHIP_QOS_POLICY_ID = DDS_OWNERSHIP_QOS_POLICY_ID;
854 const QosPolicyId_t OWNERSHIPSTRENGTH_QOS_POLICY_ID = DDS_OWNERSHIPSTRENGTH_QOS_POLICY_ID;
855 const QosPolicyId_t LIVELINESS_QOS_POLICY_ID = DDS_LIVELINESS_QOS_POLICY_ID;
856 const QosPolicyId_t TIMEBASEDFILTER_QOS_POLICY_ID = DDS_TIMEBASEDFILTER_QOS_POLICY_ID;
857 const QosPolicyId_t PARTITION_QOS_POLICY_ID = DDS_PARTITION_QOS_POLICY_ID;
858 const QosPolicyId_t RELIABILITY_QOS_POLICY_ID = DDS_RELIABILITY_QOS_POLICY_ID;
859 const QosPolicyId_t DESTINATIONORDER_QOS_POLICY_ID = DDS_DESTINATIONORDER_QOS_POLICY_ID;
860 const QosPolicyId_t HISTORY_QOS_POLICY_ID = DDS_HISTORY_QOS_POLICY_ID;
861 const QosPolicyId_t RESOURCELIMITS_QOS_POLICY_ID = DDS_RESOURCELIMITS_QOS_POLICY_ID;
862 const QosPolicyId_t ENTITYFACTORY_QOS_POLICY_ID = DDS_ENTITYFACTORY_QOS_POLICY_ID;
863 const QosPolicyId_t WRITERDATALIFECYCLE_QOS_POLICY_ID = DDS_WRITERDATALIFECYCLE_QOS_POLICY_ID;
864 const QosPolicyId_t READERDATALIFECYCLE_QOS_POLICY_ID = DDS_READERDATALIFECYCLE_QOS_POLICY_ID;
865 const QosPolicyId_t TOPICDATA_QOS_POLICY_ID = DDS_TOPICDATA_QOS_POLICY_ID;
866 const QosPolicyId_t GROUPDATA_QOS_POLICY_ID = DDS_GROUPDATA_QOS_POLICY_ID;
867 const QosPolicyId_t TRANSPORTPRIORITY_QOS_POLICY_ID = DDS_TRANSPORTPRIORITY_QOS_POLICY_ID;
868 const QosPolicyId_t LIFESPAN_QOS_POLICY_ID = DDS_LIFESPAN_QOS_POLICY_ID;
869 const QosPolicyId_t DURABILITYSERVICE_QOS_POLICY_ID = DDS_DURABILITYSERVICE_QOS_POLICY_ID;
870 const QosPolicyId_t DATA_REPRESENTATION_QOS_POLICY_ID = DDS_DATA_REPRESENTATION_QOS_POLICY_ID;
872 COREDX_CPP_CONST
char * USERDATA_QOS_POLICY_NAME ;
873 COREDX_CPP_CONST
char * DURABILITY_QOS_POLICY_NAME ;
874 COREDX_CPP_CONST
char * PRESENTATION_QOS_POLICY_NAME ;
875 COREDX_CPP_CONST
char * DEADLINE_QOS_POLICY_NAME ;
876 COREDX_CPP_CONST
char * LATENCYBUDGET_QOS_POLICY_NAME ;
877 COREDX_CPP_CONST
char * OWNERSHIP_QOS_POLICY_NAME ;
878 COREDX_CPP_CONST
char * OWNERSHIPSTRENGTH_QOS_POLICY_NAME ;
879 COREDX_CPP_CONST
char * LIVELINESS_QOS_POLICY_NAME ;
880 COREDX_CPP_CONST
char * TIMEBASEDFILTER_QOS_POLICY_NAME ;
881 COREDX_CPP_CONST
char * PARTITION_QOS_POLICY_NAME ;
882 COREDX_CPP_CONST
char * RELIABILITY_QOS_POLICY_NAME ;
883 COREDX_CPP_CONST
char * DESTINATIONORDER_QOS_POLICY_NAME ;
884 COREDX_CPP_CONST
char * HISTORY_QOS_POLICY_NAME ;
885 COREDX_CPP_CONST
char * RESOURCELIMITS_QOS_POLICY_NAME ;
886 COREDX_CPP_CONST
char * ENTITYFACTORY_QOS_POLICY_NAME ;
887 COREDX_CPP_CONST
char * WRITERDATALIFECYCLE_QOS_POLICY_NAME ;
888 COREDX_CPP_CONST
char * READERDATALIFECYCLE_QOS_POLICY_NAME ;
889 COREDX_CPP_CONST
char * TOPICDATA_QOS_POLICY_NAME ;
890 COREDX_CPP_CONST
char * GROUPDATA_QOS_POLICY_NAME ;
891 COREDX_CPP_CONST
char * TRANSPORTPRIORITY_QOS_POLICY_NAME ;
892 COREDX_CPP_CONST
char * LIFESPAN_QOS_POLICY_NAME ;
893 COREDX_CPP_CONST
char * DURABILITYSERVICE_POLICY_NAME ;
894 COREDX_CPP_CONST
char * DATA_REPRESENTATION_POLICY_NAME ;
897 COREDX_CPP_CONST
TopicQos TOPIC_QOS_DEFAULT ;
943 void init(
struct _Entity * e);
944 struct _Entity * _entity;
977 static void destroy();
985 static ReturnCode_t set_license(
const char * license );
1047 static void check_cpp_assumptions();
1051 extern "C" void dp_offered_deadline_missed_wrapper(
struct _DataWriter * the_c_writer,
1052 OfferedDeadlineMissedStatus status);
1053 extern "C" void dp_offered_incompatible_qos_wrapper(
struct _DataWriter * the_c_writer,
1054 OfferedIncompatibleQosStatus status );
1055 extern "C" void dp_liveliness_lost_wrapper(
struct _DataWriter * the_c_writer,
1056 LivelinessLostStatus status );
1057 extern "C" void dp_publication_matched_wrapper(
struct _DataWriter * the_c_writer,
1058 PublicationMatchedStatus status );
1059 extern "C" void dp_data_on_readers_wrapper (
struct _Subscriber * the_subscriber );
1060 extern "C" void dp_data_available_wrapper (
struct _DataReader * the_reader );
1061 extern "C" void dp_sample_rejected_wrapper (
struct _DataReader * the_reader,
1062 SampleRejectedStatus status );
1063 extern "C" void dp_liveliness_changed_wrapper (
struct _DataReader * the_reader,
1064 LivelinessChangedStatus status );
1065 extern "C" void dp_requested_deadline_missed_wrapper(
struct _DataReader * the_reader,
1066 RequestedDeadlineMissedStatus status );
1067 extern "C" void dp_requested_incompatible_qos_wrapper(
struct _DataReader * the_reader,
1068 RequestedIncompatibleQosStatus status );
1069 extern "C" void dp_subscription_matched_wrapper(
struct _DataReader * the_reader,
1070 SubscriptionMatchedStatus status );
1071 extern "C" void dp_sample_lost_wrapper (
struct _DataReader * the_reader,
1072 SampleLostStatus status );
1073 extern "C" void dp_inconsistent_topic_wrapper(
struct _Topic * the_topic,
1074 InconsistentTopicStatus status );
1180 class Topic * create_topic(
const char * topic_name,
1181 const char * type_name,
1206 class Topic * find_topic (
const char * topic_name,
1208 class Topic * find_topic (
const char * topic_name,
1209 const DDS_Duration_t & timeout);
1386 class Topic * related_topic,
1387 const char * filter_expression,
1404 class MultiTopic * create_multitopic(
const char * name,
1405 const char * type_name,
1406 const char * subscription_expression,
1413 ReturnCode_t delete_multitopic(
class MultiTopic * a_multitopic);
1420 ReturnCode_t get_discovered_topic_data( TopicBuiltinTopicData * topic_data,
1458 ReturnCode_t add_transport(
struct CoreDX_Transport * transport);
1460 DDS_DomainParticipant get_core_participant();
1489 struct DP_impl * _impl;
1497 static void initialize_listener( DDS_DomainParticipantListener * core_listener,
1500 friend void dp_offered_deadline_missed_wrapper(
struct _DataWriter * the_c_writer,
1501 OfferedDeadlineMissedStatus status);
1502 friend void dp_offered_incompatible_qos_wrapper(
struct _DataWriter * the_c_writer,
1503 OfferedIncompatibleQosStatus status );
1504 friend void dp_liveliness_lost_wrapper(
struct _DataWriter * the_c_writer,
1505 LivelinessLostStatus status );
1506 friend void dp_publication_matched_wrapper(
struct _DataWriter * the_c_writer,
1507 PublicationMatchedStatus status );
1508 friend void dp_data_on_readers_wrapper (
struct _Subscriber * the_subscriber );
1509 friend void dp_data_available_wrapper (
struct _DataReader * the_reader );
1510 friend void dp_sample_rejected_wrapper (
struct _DataReader * the_reader,
1511 SampleRejectedStatus status );
1512 friend void dp_liveliness_changed_wrapper (
struct _DataReader * the_reader,
1513 LivelinessChangedStatus status );
1514 friend void dp_requested_deadline_missed_wrapper(
struct _DataReader * the_reader,
1515 RequestedDeadlineMissedStatus status );
1516 friend void dp_requested_incompatible_qos_wrapper(
struct _DataReader * the_reader,
1517 RequestedIncompatibleQosStatus status );
1518 friend void dp_subscription_matched_wrapper(
struct _DataReader * the_reader,
1519 SubscriptionMatchedStatus status );
1520 friend void dp_sample_lost_wrapper (
struct _DataReader * the_reader,
1521 SampleLostStatus status );
1522 friend void dp_inconsistent_topic_wrapper(
struct _Topic * the_topic,
1523 InconsistentTopicStatus status );
1533 ReturnCode_t register_type( TypeSupport * ts,
const char * type_name );
1549 ReturnCode_t unregister_type(
const char * type_name );
1559 int check_version(
const char * major,
const char * minor,
const char * patch);
1560 int validate_version(
const char * tname,
const char * major,
const char * minor,
const char * patch);
1561 TypeSupport * get_type(
const char * type_name );
1565 void print_stats(
const char * topic_name = NULL );
1566 void get_topic_stats_str(
const char * topic_name,
DDS::OctetSeq * oseq );
1567 void get_topic_stats(
const char * topic_name, CoreDX_TopicStats_t * topic_stats );
1572 extern "C" void pub_offered_deadline_missed_wrapper( _DataWriter * the_c_writer,
1573 OfferedDeadlineMissedStatus status);
1574 extern "C" void pub_offered_incompatible_qos_wrapper( _DataWriter * the_c_writer,
1575 OfferedIncompatibleQosStatus status );
1576 extern "C" void pub_liveliness_lost_wrapper( _DataWriter * the_c_writer,
1577 LivelinessLostStatus status );
1578 extern "C" void pub_publication_matched_wrapper( _DataWriter * the_c_writer,
1579 PublicationMatchedStatus status );
1657 class DataWriter * lookup_datawriter(
const char * topic_name);
1762 static void initialize_listener( DDS_PublisherListener * core_listener,
1764 friend void pub_offered_deadline_missed_wrapper( _DataWriter * the_c_writer,
1765 OfferedDeadlineMissedStatus status);
1766 friend void pub_offered_incompatible_qos_wrapper( _DataWriter * the_c_writer,
1767 OfferedIncompatibleQosStatus status );
1768 friend void pub_liveliness_lost_wrapper( _DataWriter * the_c_writer,
1769 LivelinessLostStatus status );
1770 friend void pub_publication_matched_wrapper( _DataWriter * the_c_writer,
1771 PublicationMatchedStatus status );
1773 struct PUB_impl * _impl;
1776 extern "C" void sub_data_on_readers_wrapper (
struct _Subscriber * the_subscriber );
1777 extern "C" void sub_data_available_wrapper (
struct _DataReader * the_reader );
1778 extern "C" void sub_sample_rejected_wrapper (
struct _DataReader * the_reader,
1779 SampleRejectedStatus status );
1780 extern "C" void sub_liveliness_changed_wrapper (
struct _DataReader * the_reader,
1781 LivelinessChangedStatus status );
1782 extern "C" void sub_requested_deadline_missed_wrapper(
struct _DataReader * the_reader,
1783 RequestedDeadlineMissedStatus status );
1784 extern "C" void sub_requested_incompatible_qos_wrapper(
struct _DataReader * the_reader,
1785 RequestedIncompatibleQosStatus status );
1786 extern "C" void sub_subscription_matched_wrapper(
struct _DataReader * the_reader,
1787 SubscriptionMatchedStatus status );
1788 extern "C" void sub_sample_lost_wrapper (
struct _DataReader * the_reader,
1789 SampleLostStatus status );
1876 DataReader * lookup_datareader(
const char * topic_name);
1894 SampleStateMask sample_states,
1895 ViewStateMask view_states,
1896 InstanceStateMask instance_states) ;
1982 static void initialize_listener( DDS_SubscriberListener * core_listener,
1984 friend void sub_data_on_readers_wrapper (
struct _Subscriber * the_subscriber );
1985 friend void sub_data_available_wrapper (
struct _DataReader * the_reader );
1986 friend void sub_sample_rejected_wrapper (
struct _DataReader * the_reader,
1987 SampleRejectedStatus status );
1988 friend void sub_liveliness_changed_wrapper (
struct _DataReader * the_reader,
1989 LivelinessChangedStatus status );
1990 friend void sub_requested_deadline_missed_wrapper(
struct _DataReader * the_reader,
1991 RequestedDeadlineMissedStatus status );
1992 friend void sub_requested_incompatible_qos_wrapper(
struct _DataReader * the_reader,
1993 RequestedIncompatibleQosStatus status );
1994 friend void sub_subscription_matched_wrapper(
struct _DataReader * the_reader,
1995 SubscriptionMatchedStatus status );
1996 friend void sub_sample_lost_wrapper (
struct _DataReader * the_reader,
1997 SampleLostStatus status );
1999 struct SUB_impl * _impl;
2026 virtual const char * get_type_name ( );
2031 virtual const char * get_name ( );
2033 struct _TopicDescription * _td;
2036 extern "C" void top_inconsistent_topic_wrapper(
struct _Topic * topic,
2037 InconsistentTopicStatus status );
2060 const char * get_type_name ( );
2064 const char * get_name ( );
2131 ReturnCode_t get_inconsistent_topic_status( InconsistentTopicStatus * a_status);
2136 static void initialize_listener( DDS_TopicListener * core_listener,
2138 friend void top_inconsistent_topic_wrapper(
struct _Topic * topic,
2139 InconsistentTopicStatus status );
2140 struct _Topic * _topic;
2184 const char * get_type_name ( );
2185 const char * get_name ( );
2190 Topic * get_related_topic( );
2211 struct _ContentFilteredTopic * _cf_topic;
2212 Topic * _related_topic;
2215 extern "C" void dw_offered_deadline_missed_wrapper( _DataWriter * the_c_writer,
2216 OfferedDeadlineMissedStatus status);
2217 extern "C" void dw_offered_incompatible_qos_wrapper( _DataWriter * the_c_writer,
2218 OfferedIncompatibleQosStatus status );
2219 extern "C" void dw_liveliness_lost_wrapper( _DataWriter * the_c_writer,
2220 LivelinessLostStatus status );
2221 extern "C" void dw_publication_matched_wrapper( _DataWriter * the_c_writer,
2222 PublicationMatchedStatus status );
2304 class Topic * get_topic();
2341 const Time_t & source_timestamp);
2348 ReturnCode_t unregister_instance(
const void * instance_data,
2356 ReturnCode_t unregister_instance_w_timestamp(
const void * instance_data,
2358 const Time_t & source_timestamp);
2385 ReturnCode_t write_w_timestamp(
const void * instance_data,
2387 const Time_t & source_timestamp);
2402 ReturnCode_t dispose_w_timestamp(
const void * instance_data,
2404 const Time_t & source_timestamp);
2424 ReturnCode_t write_request(
const void * instance_data,
2441 ReturnCode_t get_liveliness_lost_status ( LivelinessLostStatus *status );
2446 ReturnCode_t get_offered_deadline_missed_status ( OfferedDeadlineMissedStatus *status );
2451 ReturnCode_t get_offered_incompatible_qos_status( OfferedIncompatibleQosStatus *status );
2456 ReturnCode_t get_publication_matched_status ( PublicationMatchedStatus *status );
2474 ReturnCode_t get_cache_stats( CacheStatistics & stats );
2486 static void initialize_listener( DDS_DataWriterListener * core_listener,
2488 friend void dw_offered_deadline_missed_wrapper( _DataWriter * the_c_writer,
2489 OfferedDeadlineMissedStatus status);
2490 friend void dw_offered_incompatible_qos_wrapper( _DataWriter * the_c_writer,
2491 OfferedIncompatibleQosStatus status );
2492 friend void dw_liveliness_lost_wrapper( _DataWriter * the_c_writer,
2493 LivelinessLostStatus status );
2494 friend void dw_publication_matched_wrapper( _DataWriter * the_c_writer,
2495 PublicationMatchedStatus status );
2497 struct DW_impl * _impl;
2501 extern "C" void dr_requested_deadline_missed_wrapper( _DataReader * dr, RequestedDeadlineMissedStatus status );
2502 extern "C" void dr_requested_incompatible_qos_wrapper( _DataReader * dr, RequestedIncompatibleQosStatus status );
2503 extern "C" void dr_sample_rejected_wrapper( _DataReader * dr, SampleRejectedStatus status );
2504 extern "C" void dr_liveliness_changed_wrapper( _DataReader * dr, LivelinessChangedStatus status );
2505 extern "C" void dr_data_available_wrapper( _DataReader * dr );
2506 extern "C" void dr_subscription_matched_wrapper( _DataReader * dr, SubscriptionMatchedStatus status );
2507 extern "C" void dr_sample_lost_wrapper( _DataReader * dr, SampleLostStatus status );
2524 friend class coredx::rpc::Requester;
2560 ReadCondition * create_readcondition( SampleStateMask sample_states,
2561 ViewStateMask view_states,
2562 InstanceStateMask instance_states);
2635 ReturnCode_t get_sample_rejected_status ( SampleRejectedStatus * status);
2640 ReturnCode_t get_liveliness_changed_status( LivelinessChangedStatus * status);
2645 ReturnCode_t get_requested_deadline_missed_status ( RequestedDeadlineMissedStatus * status);
2650 ReturnCode_t get_requested_incompatible_qos_status( RequestedIncompatibleQosStatus * status);
2655 ReturnCode_t get_subscription_matched_status ( SubscriptionMatchedStatus * status);
2660 ReturnCode_t get_sample_lost_status ( SampleLostStatus * status);
2714 QueryCondition * create_querycondition( SampleStateMask sample_states,
2715 ViewStateMask view_states,
2716 InstanceStateMask instance_states,
2717 const char * query_expression,
2764 SampleStateMask sample_states,
2765 ViewStateMask view_states,
2766 InstanceStateMask instance_states);
2810 SampleStateMask sample_states,
2811 ViewStateMask view_states,
2812 InstanceStateMask instance_states);
2845 SampleInfo * sample_info);
2854 SampleInfo * sample_info);
2867 SampleStateMask sample_states,
2868 ViewStateMask view_states,
2869 InstanceStateMask instance_states);
2882 SampleStateMask sample_states,
2883 ViewStateMask view_states,
2884 InstanceStateMask instance_states);
2897 SampleStateMask sample_states,
2898 ViewStateMask view_states,
2899 InstanceStateMask instance_states);
2912 SampleStateMask sample_states,
2913 ViewStateMask view_states,
2914 InstanceStateMask instance_states);
2979 ReturnCode_t get_cache_stats( CacheStatistics & stats );
2986 static void initialize_listener( DDS_DataReaderListener * core_listener,
2988 friend void dr_requested_deadline_missed_wrapper( _DataReader * dr, RequestedDeadlineMissedStatus status );
2989 friend void dr_requested_incompatible_qos_wrapper( _DataReader * dr, RequestedIncompatibleQosStatus status );
2990 friend void dr_sample_rejected_wrapper( _DataReader * dr, SampleRejectedStatus status );
2991 friend void dr_liveliness_changed_wrapper( _DataReader * dr, LivelinessChangedStatus status );
2992 friend void dr_data_available_wrapper( _DataReader * dr );
2993 friend void dr_subscription_matched_wrapper( _DataReader * dr, SubscriptionMatchedStatus status );
2994 friend void dr_sample_lost_wrapper( _DataReader * dr, SampleLostStatus status );
2996 struct DR_impl * _impl;
3020 virtual bool get_trigger_value();
3025 struct _Condition * _condition;
3048 bool get_trigger_value();
3060 struct _GuardCondition * _guard_condition;
3080 bool get_trigger_value();
3098 struct _StatusCondition * _status_condition;
3121 bool get_trigger_value();
3129 SampleStateKind get_sample_state_mask();
3133 ViewStateKind get_view_state_mask();
3137 InstanceStateKind get_instance_state_mask();
3141 struct _ReadCondition * _read_condition;
3166 const char * get_query_expression (
void );
3197 struct _QueryCondition * _query_condition;
3262 struct _WaitSet * _wait_set;
3268 class COREDX_CPP_CLASS_API Listener
3271 Listener() { nil_listeners = 0; }
3272 virtual ~Listener() {};
3311 const OfferedDeadlineMissedStatus & ) {};
3319 const OfferedIncompatibleQosStatus & ) {};
3326 const LivelinessLostStatus & ) {};
3334 const PublicationMatchedStatus & ) {};
3382 const InconsistentTopicStatus & ) {};
3411 const RequestedDeadlineMissedStatus & ) {};
3419 const RequestedIncompatibleQosStatus & ) {};
3426 const SampleRejectedStatus & ) {};
3433 const LivelinessChangedStatus & ) {};
3446 const SubscriptionMatchedStatus & ) {};
3453 const SampleLostStatus & ) {};
3528 COREDX_CPP_API
bool operator <(
const Time_t &t1,
const Time_t &t2);
3529 COREDX_CPP_API
bool operator <=(
const Time_t &t1,
const Time_t &t2);
3530 COREDX_CPP_API
bool operator ==(
const Time_t &t1,
const Time_t &t2);
3531 COREDX_CPP_API
bool operator >=(
const Time_t &t1,
const Time_t &t2);
3532 COREDX_CPP_API
bool operator >(
const Time_t &t1,
const Time_t &t2);
3537 COREDX_CPP_API
void String_free(
char * str);
3538 COREDX_CPP_API
char * String_dup(
const char * other);
unsigned int precache_max_samples
Maximum number of samples held in pre-cache [only for RELIABLE readers].
Definition: dds.hh:452
DataTagQosPolicy data_tags
Security related data_tags (sequence of name,value pairs).
Definition: dds.hh:730
Definition: dds_builtin.hh:1919
The SubscriberListener provides asynchronous notification of Subscriber events.
Definition: dds.hh:3470
Duration_t dpd_push_period
Multicast DiscoveredParticipantData each period.
Definition: dds.hh:492
HistoryQosPolicy history
The data history requested by the DataReader.
Definition: dds.hh:713
long ReturnCode_t
Definition: dds.hh:208
ResourceLimitsQosPolicy resource_limits
The resource limits set on the DataWriter.
Definition: dds.hh:630
Determines instance ownership in the case of multple writers. CoreDX DDS supports both SHARED_OWNERSH...
Definition: dds_builtin.hh:600
Definition: dds_builtin.hh:1828
LoggingQosPolicy logging
Controls the logging behavior of the DataReader.
Definition: dds.hh:732
The DataWriter entity provides an interface for the application to publish (write) data...
Definition: dds.hh:2233
Status related to the on_offered_incompatible_qos listener methods of the DDS_DataWriter, DDS_Publisher, and DDS_DomainParticipant structures.
Definition: dds_types.h:345
Encapsulates statistics available from a DataReader or DataWriter.
Definition: dds_types.h:420
The DurabilityQosPolicy controls the durablity of data.
Definition: dds_builtin.hh:353
Configures a list of DomainParticipant peers to attempt communication with.
Definition: dds.hh:409
DomainParticipantFactory constructs DomainParticipants. The.
Definition: dds.hh:969
ReaderDataLifecycleQosPolicy reader_data_lifecycle
Controls the auto-purge behavior of the DataReader.
Definition: dds.hh:718
TransportPriorityQosPolicy transport_priority
The transport priority supported by the DataWriter.
Definition: dds.hh:631
EntityNameQosPolicy entity_name
Controls the Entity name of the DataWriter.
Definition: dds.hh:645
The DomainParticipant is used to configure, create and destroy Publisher, Subscriber and Topic object...
Definition: dds.hh:1087
LatencyBudgetQosPolicy latency_budget
The latency allowed by the DataWriter.
Definition: dds.hh:625
Defines the strength, or priority, of a Writer. The strength is used to determine ownership in the ca...
Definition: dds_builtin.hh:652
unsigned int participant_id
participant id start
Definition: dds.hh:394
DurabilityQosPolicy durability
The durability policy of the Topic.
Definition: dds.hh:584
Status related to the on_liveliness_changed listener methods of the DDS_DataReader, DDS_Subscriber, and DDS_DomainParticipant structures.
Definition: dds_types.h:297
LocatorSeq locators
Definition: dds.hh:453
EntityNameQosPolicy entity_name
Controls the Entity name of the DomainParticipant.
Definition: dds.hh:557
A hint to the middleware to help configure the transport priority mechanism.
Definition: dds_builtin.hh:217
DiscoveryQosPolicyDiscoveryKind
This enumeration contains the kinds of Discovery.
Definition: dds.hh:480
EntityFactoryQosPolicy entity_factory
Controls the behavior of the Subscriber.create_datareader() operation.
Definition: dds.hh:771
LivelinessQosPolicy liveliness
Identifies the mechanism used to detect and maintain livelines of DataWriters on the Topic...
Definition: dds.hh:588
virtual void on_offered_deadline_missed(DataWriter *, const OfferedDeadlineMissedStatus &)
Definition: dds.hh:3310
LifespanQosPolicy lifespan
The expiration time for old samples managed by the DataWriter.
Definition: dds.hh:632
DestinationOrderQosPolicy destination_order
The destination order logic offered by the DataWriter.
Definition: dds.hh:628
LivelinessQosPolicy liveliness
The liveliness mechanism offered by the DataWriter.
Definition: dds.hh:626
WriterDataLifecycleQosPolicy writer_data_lifecycle
Indicates if unregistered instances should be automatically disposed by the DataWriter.
Definition: dds.hh:636
virtual void on_requested_incompatible_qos(DataReader *, const RequestedIncompatibleQosStatus &)
Definition: dds.hh:3418
PresentationQosPolicy presentation
Controls the presentation of groups of changes.
Definition: dds.hh:754
Describes the data representation used by a topic.
Definition: dds_builtin.hh:1296
ResourceLimitsQosPolicy resource_limits
The resource limitations for the Topic.
Definition: dds.hh:592
ThreadModelQosPolicy thread_model
Controls the threading behavior of the DomainParticipant.
Definition: dds.hh:561
Indicates the level of reliability offered/provided by the Entity. If kind is RELIABLE_RELIABILITY_QO...
Definition: dds_builtin.hh:941
Duration_t autopurge_disposed_samples_delay
delay after which it is ok to purge samples from instances that are disposed
Definition: dds.hh:331
DDS::sequence< void * > Sequence
sequence of void pointers
Definition: dds.hh:260
Structure that holds Publisher Quality of Service policies.
Definition: dds.hh:664
TimeBasedFilterQosPolicy time_based_filter
The maximum update frequency required/desired by the DataReader.
Definition: dds.hh:717
Structure that holds DomainParticipantFactory Quality of Service policies.
Definition: dds.hh:532
Status related to the on_inconsistent_topic listener methods of the DDS_TopicListener structure...
Definition: dds_types.h:242
RTPSReaderQosPolicy rtps_reader
Controls aspects of the RTPS Reader protocol for the DataReader.
Definition: dds.hh:733
EntityFactoryQosPolicy entity_factory
Controls the behavior of the DomainParticipant 'create' operations.
Definition: dds.hh:536
OwnershipStrengthQosPolicy ownership_strength
The measure of 'ownership strength' offered by the DataWriter.
Definition: dds.hh:635
EntityNameQosPolicy entity_name
Controls the Entity name of the DataReader.
Definition: dds.hh:731
LoggingQosPolicy logging
Controls the logging behavior of the DataWriter.
Definition: dds.hh:646
DDS::sequence< Condition * > ConditionSeq
sequence of Condition pointers
Definition: dds.hh:258
uint32_t nanosec
Definition: dds_types.h:75
LivelinessQosPolicy liveliness
The liveliness mechanism requested by the DataReader.
Definition: dds.hh:710
unsigned char enable_batch_msg
use the 'BATCH' RTPS message to send data if all Readers accept BATCH
Definition: dds.hh:434
Definition: dds_builtin.hh:1218
TypeConsistencyEnforcementQosPolicy type_consistency
Influences the algorithm that matches DataReaders and DataWriters based on their data type compatibil...
Definition: dds.hh:723
Duration_t nack_response_delay
The nack_response_delay to configure for builtin writers.
Definition: dds.hh:495
unsigned char send_typecode
send TYPECODE info for associated data type
Definition: dds.hh:435
DDS_Duration_t reliable_sample_hold_time
Time after which a sample may be flushed even if it hasn't been ACK'd,.
Definition: dds.hh:437
unsigned char send_initial_nack
send a ACKNACK immediately after matching with a new Writer
Definition: dds.hh:500
Duration_t nack_response_delay
ammount of time allowed for responding to NACKs
Definition: dds.hh:428
Specifies the lifecycle behavior of data instances managed by the DataWriter. If autodispose_unregist...
Definition: dds.hh:315
Duration_t dpd_lease_duration
How long we consider a discoverd Participant to be alive without hearing from them.
Definition: dds.hh:493
ReliabilityQosPolicy reliability
The transport reliability requested by the DataReader.
Definition: dds.hh:711
A WaitSet maintains a set of Condition objects and allows the application to wait until one or more o...
Definition: dds.hh:3211
DestinationOrderQosPolicy destination_order
The ordering of received samples on the Topic will be either by SOURCE or RECEPTION timestamp...
Definition: dds.hh:590
DDS::sequence< InstanceHandle_t > InstanceHandleSeq
sequence of InstanceHandle_t s
Definition: dds.hh:256
EntityFactoryQosPolicy entity_factory
Controls the behavior of the Publisher.create_datawriter() operation.
Definition: dds.hh:684
The Subscriber configures, creates, manages and destroys DataReaders.
Definition: dds.hh:1797
ReliabilityQosPolicy reliability
Indicates the level of transport reliability on the Topic.
Definition: dds.hh:589
DataRepresentationQosPolicy representation
Informs DataReader(s) of the single data representation supported by this Writer. This must be consis...
Definition: dds.hh:637
Duration_t nack_suppress_delay
ammount of time to ignore NACKs after a repair
Definition: dds.hh:429
OwnershipQosPolicy ownership
The type of 'ownership' offered by the DataReader.
Definition: dds.hh:716
LatencyBudgetQosPolicy latency_budget
The latency requested by the DataReader.
Definition: dds.hh:709
unsigned int max_buffer_size
max size in bytes of written data
Definition: dds.hh:432
The DomainParticipant will connect to the CoreDX DDS CDD for discovery.
Definition: dds.hh:482
virtual void on_sample_lost(DataReader *, const SampleLostStatus &)
Definition: dds.hh:3452
unsigned char autoenable_created_entities
should created entities be automatically enabled
Definition: dds.hh:299
Status related to the on_liveliness_lost listener methods of the DDS_DataWriter, DDS_Publisher, and DDS_DomainParticipant structures.
Definition: dds_types.h:286
virtual void on_requested_deadline_missed(DataReader *, const RequestedDeadlineMissedStatus &)
Definition: dds.hh:3410
PartitionQosPolicy partition
Establishes a logical data partition.
Definition: dds.hh:762
ContentFilteredTopic provides a topic that may exclude data based on a specified filter. The ContentFilteredTopic is associated with another un-filtered topic related_topic. It applies a filter to the data of the related topic. If a data sample passes the filter, it will be made available to a DataReader associated with the ContentFilteredTopic.
Definition: dds.hh:2179
Definition: dds_types.h:72
TopicDescription is an abstract 'class' that provides the foundation for Topic, ContentFilteredTopic...
Definition: dds.hh:2010
EntityNameQosPolicy entity_name
Controls the Entity name of the Subscriber.
Definition: dds.hh:772
The DataReaderListener provides asynchronous notification of DataReader events.
Definition: dds.hh:3399
Controls the amount and kind of information that is logged.
Definition: dds.hh:363
UserDataQosPolicy user_data
A sequence of octets associated with the DataWriter.
Definition: dds.hh:633
DDS::sequence< DataReader * > DataReaderSeq
sequence of DataReader pointers
Definition: dds.hh:254
unsigned char require_acks
Require ACKS from readers before flushing an otherwise required sample from writer cache...
Definition: dds.hh:436
virtual void on_offered_incompatible_qos(DataWriter *, const OfferedIncompatibleQosStatus &)
Definition: dds.hh:3318
A ReadCondition is a specialized Condition associated with a DataReader.
Definition: dds.hh:3112
Definition: dds_builtin_basic.hh:140
EntityFactoryQosPolicy entity_factory
Controls the behavior of the DomainParticipant create operations.
Definition: dds.hh:556
UserDataQosPolicy user_data
A sequence of octets associated with the DataReader.
Definition: dds.hh:715
GroupDataQosPolicy group_data
A sequence of octets associated with the Publisher.
Definition: dds.hh:683
unsigned char send_initial_nack
send a ACKNACK immediately after matching with a new Writer
Definition: dds.hh:451
LoggingQosPolicy logging
Controls the logging behavior of the Subscriber.
Definition: dds.hh:773
The DataReader entity allows the application to subscribe to and read data.
Definition: dds.hh:2520
A QueryCondition is a specialized ReadCondition which includes a filter.
Definition: dds.hh:3154
DDS::DiscoveryQosPolicyDiscoveryKind discovery_kind
the kind of discovery to employ
Definition: dds.hh:490
Duration_t autopurge_nowriter_samples_delay
delay after which it is ok to purge samples from instances with no writer(s)
Definition: dds.hh:330
virtual void on_data_available(DataReader *)
Definition: dds.hh:3439
A GuardCondition is a condition where the trigger_value is under application control.
Definition: dds.hh:3037
Structure that holds Subscriber Quality of Service policies.
Definition: dds.hh:751
Status related to the on_offered_deadline_missed listener methods of the DDS_DataWriter, DDS_Publisher, and DDS_DomainParticipant structures.
Definition: dds_types.h:311
Specifies allowable latency.
Definition: dds_builtin.hh:541
DeadlineQosPolicy deadline
The requested update frequency for data instances.
Definition: dds.hh:708
unsigned int flags
flags to control logging output
Definition: dds.hh:364
UserDataQosPolicy user_data
A sequence of octets associated with a DomainParticipant.
Definition: dds.hh:555
The PublisherListener provides asynchronous notification of Publisher events.
Definition: dds.hh:3351
Topic is the basic description of data to be published or subscribed.
Definition: dds.hh:2051
Network address.
Definition: dds.hh:379
DeadlineQosPolicy deadline
The deadline committed to by the DataWriter.
Definition: dds.hh:624
Holds a DDS_QosPolicyId_t value and a counter to indicate the number of events associated with that P...
Definition: dds_types.h:333
Definition: dds_builtin.hh:1775
unsigned char strict_match
Definition: dds.hh:411
virtual void on_subscription_matched(DataReader *, const SubscriptionMatchedStatus &)
Definition: dds.hh:3445
Duration_t heartbeat_response_delay
ammount of time allowed for responding to a heartbeat
Definition: dds.hh:448
The SampleInfo structure contains information associated with each sample.
Definition: dds_types.h:160
HistoryQosPolicy history
The amount of historical data maintained for the Topic.
Definition: dds.hh:591
Augment a DataWriter or DataReader with RPC specific information.
Definition: dds_builtin.hh:1458
A StatusCondition is a condition associated with an Entity.
Definition: dds.hh:3071
DDS::sequence< unsigned char > OctetSeq
sequence of octets
Definition: dds.hh:264
DataRepresentationQosPolicy representation
Informs DataWriter(s) of the data representation(s) supported by this Reader. This must be consistent...
Definition: dds.hh:719
RpcQosPolicy rpc
Configure RPC relevant settings: instance_name, related_entity, and topic_aliases.
Definition: dds.hh:641
Provides the DDS infrastructure.
Definition: dds_builtin_basic.hh:27
Duration_t heartbeat_response_delay
The heartbeat_response_delay to configure for builtin readers.
Definition: dds.hh:499
A Condition can be added to a WaitSet to provide synchronous event notification.
Definition: dds.hh:3010
Base class for all DDS Domain Entities.
Definition: dds.hh:956
GroupDataQosPolicy group_data
A sequence of octets associated with the Publisher.
Definition: dds.hh:770
PeerParticipantQosPolicy peer_participants
Specifies a list of DomainParticipant peers to attempt communication with. If empty, default Discovery is used.
Definition: dds.hh:559
RTPSWriterQosPolicy rtps_writer
Controls aspects of the RTPS Writer protocol for the DataWriter.
Definition: dds.hh:647
Controls the ammount of historical data maintained by a DataReader or DataWriter. ...
Definition: dds_builtin.hh:1087
TopicDataQosPolicy topic_data
A sequence of octets associated with a Topic.
Definition: dds.hh:583
OwnershipQosPolicy ownership
The type of 'ownership' expected for data instances on the Topic.
Definition: dds.hh:595
unsigned int max_buffer_size
The max_buffer_size to configure for builtin writers.
Definition: dds.hh:498
Defines a logical data partition.
Definition: dds_builtin.hh:864
Allows the application to attach arbitrary information to a DomainParticipant, DataWriter or DataRead...
Definition: dds_builtin.hh:54
LoggingQosPolicy logging
Controls the logging behavior of the Publisher.
Definition: dds.hh:686
DestinationOrderQosPolicy destination_order
The destination order logic requested by the DataReader.
Definition: dds.hh:712
Allows the application to attach arbitrary information to a Publisher or Subscriber.
Definition: dds_builtin.hh:169
unsigned char accept_batch_msg
allow writers to use the 'BATCH' RTPS message
Definition: dds.hh:449
rules for determining type consistency
Definition: dds_builtin.hh:1357
DDS_DOMAINID_TYPE_NATIVE DomainId_t
Definition: dds.hh:206
DDS::sequence< char * > StringSeq
sequence of character pointers (c strings)
Definition: dds.hh:262
The TopicListener provides asynchronous notification of Topic events.
Definition: dds.hh:3371
LatencyBudgetQosPolicy latency_budget
Identifies the 'urgency' of the data on the Topic. The middleware uses this to batch data samples is ...
Definition: dds.hh:587
Definition: dds_builtin.hh:1624
PropertyQosPolicy properties
Additional name:value pair properties (if propagate=true, included in discovery)
Definition: dds.hh:562
QoS Policy for configuring aspects of the RTPS Reader Protocol.
Definition: dds.hh:447
virtual void on_sample_rejected(DataReader *, const SampleRejectedStatus &)
Definition: dds.hh:3425
Definition: dds_builtin_basic.hh:238
LoggingQosPolicy logging
Controls the logging behavior of the DomainParticipant.
Definition: dds.hh:558
DurabilityQosPolicy durability
The durability policy requested by the DataReader.
Definition: dds.hh:707
Duration_t ack_deadline
after which a realiable reader will be considered unresponsive
Definition: dds.hh:430
HistoryQosPolicy history
The data history maintained by the DataWriter.
Definition: dds.hh:629
Structure that holds Topic Quality of Service policies.
Definition: dds.hh:580
Structure that holds DataWriter Quality of Service policies.
Definition: dds.hh:619
unsigned int participant_id_max
participant id max
Definition: dds.hh:395
LifespanQosPolicy lifespan
The 'expiration time' for old data samples on the Topic.
Definition: dds.hh:594
DeadlineQosPolicy deadline
Defines the expected update frequency for data instances within the Topic.
Definition: dds.hh:586
DurabilityServiceQosPolicy durability_service
The durability service configuration offered by the DataWriter.
Definition: dds.hh:623
unsigned long StatusMask
Definition: dds.hh:217
Describes a the location and identity of a potential peer DomainParticipant.
Definition: dds.hh:393
ReliabilityQosPolicy reliability
The transport reliability offered by the DataWriter.
Definition: dds.hh:627
Base class for all DDS Entities.
Definition: dds.hh:912
QoS Policy for configuring aspects of the Discovery and Builtin entities.
Definition: dds.hh:489
Duration_t heartbeat_period
period to transmit heartbeat messages if required
Definition: dds.hh:427
The DomainParticipantListener provides asynchronous notification of DomainParticipant events...
Definition: dds.hh:3498
The DataWriterListener provides asynchronous notification of DataWriter events.
Definition: dds.hh:3298
DataRepresentationQosPolicy representation
The data representation(s) supported by Writer(s) and Reader(s) of this topic. The first entry in the...
Definition: dds.hh:596
This QoS policy controls how each Subscriber orders received data samples.
Definition: dds_builtin.hh:1008
Duration_t nack_suppress_delay
The nack_suppress_delay to configure for builtin writers.
Definition: dds.hh:496
TransportPriorityQosPolicy transport_priority
The priority to be used for messages on the Topic.
Definition: dds.hh:593
Status related to the on_requested_deadline_missed listener methods of the DDS_DataReader, DDS_Subscriber, and DDS_DomainParticipant structures.
Definition: dds_types.h:322
EntityNameQosPolicy entity_name
Controls the Entity name of the Topic.
Definition: dds.hh:600
DurabilityServiceQosPolicy durability_service
Configures the service supporting the TRANSIENT and PERSITENT durability kinds.
Definition: dds.hh:585
Controls the presentation of received data samples to the application. CoreDX DDS currently supports ...
Definition: dds_builtin.hh:415
Structure that holds DomainParticipant Quality of Service policies.
Definition: dds.hh:553
Determines the mechanism and parameters used by the application to determine whether an Entity is ali...
Definition: dds_builtin.hh:737
unsigned char autodispose_unregistered_instances
should the writer dispose instances that are unregistered
Definition: dds.hh:316
virtual void on_data_on_readers(Subscriber *)
Definition: dds.hh:3481
Allows the application to attach arbitrary information to a Topic QoS.
Definition: dds_builtin.hh:111
Status related to the on_publication_matched listener methods of the DDS_DataWriter, DDS_Publisher, and DDS_DomainParticipant structures.
Definition: dds_types.h:371
Structure that holds DataReader Quality of Service policies.
Definition: dds.hh:704
DataTagQosPolicy data_tags
Security related data_tags (sequence of name,value pairs).
Definition: dds.hh:644
This QoS policy establishes a minimum update period for data instances.
Definition: dds_builtin.hh:483
PartitionQosPolicy partition
Establishes a logical data partition.
Definition: dds.hh:675
virtual void on_publication_matched(DataWriter *, const PublicationMatchedStatus &)
Definition: dds.hh:3333
Specifies the lifecycle behavior of data instances managed by the DataReader.
Definition: dds.hh:329
virtual void on_inconsistent_topic(Topic *, const InconsistentTopicStatus &)
Definition: dds.hh:3381
int sec
Definition: dds_types.h:74
DDS_HANDLE_TYPE_NATIVE InstanceHandle_t
Definition: dds.hh:207
DiscoveryQosPolicy discovery
Controls aspects of the Discovery and Builtin entities.
Definition: dds.hh:560
ParticipantLocatorSeq value
sequence of peer locators with which we should attempt communication
Definition: dds.hh:410
unsigned char create_listener_thread
should the DomainParticipant create a separate thread for invoking listener callback routines ...
Definition: dds.hh:514
The DomainParticipant will use the standard peer-to-peer discovery.
Definition: dds.hh:481
Status related to the on_subscription_matched listener methods of the DDS_DataReader, DDS_Subscriber, and DDS_DomainParticipant structures.
Definition: dds_types.h:385
The Time_t structure contains data to define a time.
Definition: dds.hh:222
virtual void on_liveliness_changed(DataReader *, const LivelinessChangedStatus &)
Definition: dds.hh:3432
unsigned char apply_filters
apply ContentFilter(s) at the writer (writer side filtering)
Definition: dds.hh:433
RpcQosPolicy rpc
Configure RPC relevant settings: instance_name, related_entity, and topic_aliases.
Definition: dds.hh:727
The Publisher configures, creates, manages and destroys DataWriters.
Definition: dds.hh:1588
Status related to the on_requested_incompatible_qos listener methods of the DDS_DataReader, DDS_Subscriber, and DDS_DomainParticipant structures.
Definition: dds_types.h:358
QoS Policy for configuring the threading behavior of the DomainParticipant.
Definition: dds.hh:512
Specifies the maximum duration of validity of the data written by the DataWriter. ...
Definition: dds_builtin.hh:268
LoggingQosPolicy logging
Controls the logging behavior of the Topic.
Definition: dds.hh:601
unsigned int min_buffer_size
min size in bytes of written data
Definition: dds.hh:431
unsigned int min_buffer_size
The min_buffer_size to configure for builtin writers.
Definition: dds.hh:497
virtual void on_liveliness_lost(DataWriter *, const LivelinessLostStatus &)
Definition: dds.hh:3325
DDS::sequence< SampleInfo * > SampleInfoSeq
sequence of SampleInfo pointers
Definition: dds.hh:252
Defines a filter based on time between samples. The DataReader indicates that it wants at most one sa...
Definition: dds_builtin.hh:792
unsigned char use_threads
should the DomainParticipant use threads for internal work
Definition: dds.hh:513
Status related to the on_sample_lost listener methods of the DDS_DataReader, DDS_Subscriber, and DDS_DomainParticipant structures.
Definition: dds_types.h:254
The Duration_t structure contains data to define a time duration.
Definition: dds_builtin_basic.hh:289
unsigned char send_msglen_submsg
include 'msglen' submessage in RTPS header
Definition: dds.hh:501
QoS Policy for configuring aspects of the RTPS Writer Protocol.
Definition: dds.hh:426
EntityNameQosPolicy entity_name
Controls the Entity name of the Publisher.
Definition: dds.hh:685
unsigned char send_typecode
send TYPECODE info for associated data type
Definition: dds.hh:450
Duration_t heartbeat_period
The heartbeat_period to configure for builtin writers.
Definition: dds.hh:494
Locator participant_locator
locator identifying peer participant
Definition: dds.hh:396
Specifies the resources that the Service can use to maintain data samples and instances.
Definition: dds_builtin.hh:1141
DurabilityQosPolicy durability
The durability policy offered by the DataWriter.
Definition: dds.hh:622
PresentationQosPolicy presentation
Controls the presentation of groups of changes.
Definition: dds.hh:667
Status related to the on_sample_rejected listener methods of the DDS_DataReader, DDS_Subscriber, and DDS_DomainParticipant structures.
Definition: dds_types.h:273
ResourceLimitsQosPolicy resource_limits
The resource limits set on the DataReader.
Definition: dds.hh:714
OwnershipQosPolicy ownership
The type of 'ownership' offered by the DataWriter.
Definition: dds.hh:634