diff options
Diffstat (limited to 'modules/CIAO/connectors/dds4ccm/impl/dds/ndds')
53 files changed, 2271 insertions, 0 deletions
diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/BuiltinTopicKey_t.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/BuiltinTopicKey_t.h new file mode 100644 index 00000000000..b9499075d09 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/BuiltinTopicKey_t.h @@ -0,0 +1,28 @@ + /** + * @author Marcel Smit <msmit@dre.vanderbilt.edu> + * + * $Id$ + * + */ + +#ifndef BUILTINTOPICKEY_T_H +#define BUILTINTOPICKEY_T_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::BuiltinTopicKey_t &ddsbuiltintopickey, const ::DDS_BuiltinTopicKey_t & builtintopickey) +{ + ACE_OS::memcpy (ddsbuiltintopickey.value, builtintopickey.value, sizeof (builtintopickey.value)); +} + +inline void +operator<<= (::DDS_BuiltinTopicKey_t &ddsbuiltintopickey, const ::DDS::BuiltinTopicKey_t & builtintopickey) +{ + ACE_OS::memcpy (ddsbuiltintopickey.value, builtintopickey.value, sizeof (builtintopickey.value)); +} + +#endif + +#endif /* BUILTINTOPICKEY_T_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DataReaderQos.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DataReaderQos.h new file mode 100644 index 00000000000..8df844a7386 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DataReaderQos.h @@ -0,0 +1,68 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_DATAREADERQOS_H +#define DDS4CCM_DATAREADERQOS_H + +#include "DurabilityQosPolicy.h" +#include "DeadlineQosPolicy.h" +#include "LatencyBudgetQosPolicy.h" +#include "LivelinessQosPolicy.h" +#include "ReliabilityQosPolicy.h" +#include "DestinationOrderQosPolicy.h" +#include "HistoryQosPolicy.h" +#include "ResourceLimitsQosPolicy.h" +#include "UserDataQosPolicy.h" +#include "OwnershipQosPolicy.h" +#include "TimeBasedFilterQosPolicy.h" +#include "ReaderDataLifecycleQosPolicy.h" + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::DataReaderQos DDS_DataReaderQos; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::DataReaderQos &ddsqos, const ::DDS_DataReaderQos & qos) +{ + ddsqos.durability <<= qos.durability; + ddsqos.deadline <<= qos.deadline; + ddsqos.latency_budget <<= qos.latency_budget; + ddsqos.liveliness <<= qos.liveliness; + ddsqos.reliability <<= qos.reliability; + ddsqos.destination_order <<= qos.destination_order; + ddsqos.history <<= qos.history; + ddsqos.resource_limits <<= qos.resource_limits; + ddsqos.user_data <<= qos.user_data; + ddsqos.ownership <<= qos.ownership; + ddsqos.time_based_filter <<= qos.time_based_filter; + ddsqos.reader_data_lifecycle <<= qos.reader_data_lifecycle; +} + +inline void +operator<<= (::DDS_DataReaderQos &ddsqos, const ::DDS::DataReaderQos & qos) +{ + ddsqos.durability <<= qos.durability; + ddsqos.deadline <<= qos.deadline; + ddsqos.latency_budget <<= qos.latency_budget; + ddsqos.liveliness <<= qos.liveliness; + ddsqos.reliability <<= qos.reliability; + ddsqos.destination_order <<= qos.destination_order; + ddsqos.history <<= qos.history; + ddsqos.resource_limits <<= qos.resource_limits; + ddsqos.user_data <<= qos.user_data; + ddsqos.ownership <<= qos.ownership; + ddsqos.time_based_filter <<= qos.time_based_filter; + ddsqos.reader_data_lifecycle <<= qos.reader_data_lifecycle; +} + +#endif + +#endif /* DDS4CCM_DATAREADERQOS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DataWriterQos.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DataWriterQos.h new file mode 100644 index 00000000000..28eef81e587 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DataWriterQos.h @@ -0,0 +1,77 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_DATAWRITERQOS_H +#define DDS4CCM_DATAWRITERQOS_H + +#include "DurabilityQosPolicy.h" +#include "DurabilityServiceQosPolicy.h" +#include "DeadlineQosPolicy.h" +#include "LatencyBudgetQosPolicy.h" +#include "LivelinessQosPolicy.h" +#include "ReliabilityQosPolicy.h" +#include "DestinationOrderQosPolicy.h" +#include "HistoryQosPolicy.h" +#include "ResourceLimitsQosPolicy.h" +#include "TransportPriorityQosPolicy.h" +#include "LifespanQosPolicy.h" +#include "UserDataQosPolicy.h" +#include "OwnershipQosPolicy.h" +#include "OwnershipStrengthQosPolicy.h" +#include "WriterDataLifecycleQosPolicy.h" + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::DataWriterQos DDS_DataWriterQos; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::DataWriterQos &ddsqos, const ::DDS_DataWriterQos & qos) +{ + ddsqos.durability <<= qos.durability; + ddsqos.durability_service <<= qos.durability_service; + ddsqos.deadline <<= qos.deadline; + ddsqos.latency_budget <<= qos.latency_budget; + ddsqos.liveliness <<= qos.liveliness; + ddsqos.reliability <<= qos.reliability; + ddsqos.destination_order <<= qos.destination_order; + ddsqos.history <<= qos.history; + ddsqos.resource_limits <<= qos.resource_limits; + ddsqos.transport_priority <<= qos.transport_priority; + ddsqos.lifespan <<= qos.lifespan; + ddsqos.user_data <<= qos.user_data; + ddsqos.ownership <<= qos.ownership; + ddsqos.ownership_strength <<= qos.ownership_strength; + ddsqos.writer_data_lifecycle <<= qos.writer_data_lifecycle; +} + +inline void +operator<<= (::DDS_DataWriterQos &ddsqos, const ::DDS::DataWriterQos & qos) +{ + ddsqos.durability <<= qos.durability; + ddsqos.durability_service <<= qos.durability_service; + ddsqos.deadline <<= qos.deadline; + ddsqos.latency_budget <<= qos.latency_budget; + ddsqos.liveliness <<= qos.liveliness; + ddsqos.reliability <<= qos.reliability; + ddsqos.destination_order <<= qos.destination_order; + ddsqos.history <<= qos.history; + ddsqos.resource_limits <<= qos.resource_limits; + ddsqos.transport_priority <<= qos.transport_priority; + ddsqos.lifespan <<= qos.lifespan; + ddsqos.user_data <<= qos.user_data; + ddsqos.ownership <<= qos.ownership; + ddsqos.ownership_strength <<= qos.ownership_strength; + ddsqos.writer_data_lifecycle <<= qos.writer_data_lifecycle; +} + +#endif + +#endif /* DDS4CCM_DATAWRITERQOS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DeadlineQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DeadlineQosPolicy.h new file mode 100644 index 00000000000..59baeba5405 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DeadlineQosPolicy.h @@ -0,0 +1,34 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_DEADLINEQOSPOLICY_H +#define DDS4CCM_DEADLINEQOSPOLICY_H + +#include "Duration_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::DeadlineQosPolicy DDS_DeadlineQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::DeadlineQosPolicy &ddsqos, const ::DDS_DeadlineQosPolicy & qos) +{ + ddsqos.period <<= qos.period; +} + +inline void +operator<<= (::DDS_DeadlineQosPolicy &ddsqos, const ::DDS::DeadlineQosPolicy & qos) +{ + ddsqos.period <<= qos.period; +} + +#endif + +#endif /* DDS4CCM_DEADLINEQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DestinationOrderQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DestinationOrderQosPolicy.h new file mode 100644 index 00000000000..b28d8bedf75 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DestinationOrderQosPolicy.h @@ -0,0 +1,34 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_DESTINATIONORDERQOSPOLICY_H +#define DDS4CCM_DESTINATIONORDERQOSPOLICY_H + +#include "Duration_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::DestinationOrderQosPolicy DDS_DestinationOrderQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::DestinationOrderQosPolicy &ddsqos, const ::DDS_DestinationOrderQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS::DestinationOrderQosPolicyKind> (qos.kind); +} + +inline void +operator<<= (::DDS_DestinationOrderQosPolicy &ddsqos, const ::DDS::DestinationOrderQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS_DestinationOrderQosPolicyKind> (qos.kind); +} + +#endif + +#endif /* DDS4CCM_DESTINATIONORDERQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DomainParticipantFactoryQos.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DomainParticipantFactoryQos.h new file mode 100644 index 00000000000..5a392830c03 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DomainParticipantFactoryQos.h @@ -0,0 +1,34 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_DOMAINPARTICIPANTFACTORYQOSPOLICY_H +#define DDS4CCM_DOMAINPARTICIPANTFACTORYQOSPOLICY_H + +#include "EntityFactoryQosPolicy.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::DomainParticipantFactoryQos DDS_DomainParticipantFactoryQos; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::DomainParticipantFactoryQos &ddsqos, const ::DDS_DomainParticipantFactoryQos & qos) +{ + ddsqos.entity_factory <<= qos.entity_factory; +} + +inline void +operator<<= (::DDS_DomainParticipantFactoryQos &ddsqos, const ::DDS::DomainParticipantFactoryQos & qos) +{ + ddsqos.entity_factory <<= qos.entity_factory; +} + +#endif + +#endif /* DDS4CCM_DOMAINPARTICIPANTFACTORYQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DomainParticipantQos.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DomainParticipantQos.h new file mode 100644 index 00000000000..e6f8429ca35 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DomainParticipantQos.h @@ -0,0 +1,38 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_DOMAINPARTICIPANTQOSPOLICY_H +#define DDS4CCM_DOMAINPARTICIPANTQOSPOLICY_H + +#include "UserDataQosPolicy.h" +#include "EntityFactoryQosPolicy.h" + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::DomainParticipantQos DDS_DomainParticipantQos; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::DomainParticipantQos &ddsqos, const ::DDS_DomainParticipantQos & qos) +{ + ddsqos.user_data <<= qos.user_data; + ddsqos.entity_factory <<= qos.entity_factory; +} + +inline void +operator<<= (::DDS_DomainParticipantQos &ddsqos, const ::DDS::DomainParticipantQos & qos) +{ + ddsqos.user_data <<= qos.user_data; + ddsqos.entity_factory <<= qos.entity_factory; +} + +#endif + +#endif /* DDS4CCM_DOMAINPARTICIPANTQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DurabilityQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DurabilityQosPolicy.h new file mode 100644 index 00000000000..08ad411e188 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DurabilityQosPolicy.h @@ -0,0 +1,33 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_DURABILITYQOSPOLICY_H +#define DDS4CCM_DURABILITYQOSPOLICY_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::DurabilityQosPolicy DDS_DurabilityQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::DurabilityQosPolicy &ddsqos, const ::DDS_DurabilityQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS::DurabilityQosPolicyKind> (qos.kind); +} + +inline void +operator<<= (::DDS_DurabilityQosPolicy &ddsqos, const ::DDS::DurabilityQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS_DurabilityQosPolicyKind> (qos.kind); +} + +#endif + +#endif /* DDS4CCM_DURABILITYQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DurabilityServiceQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DurabilityServiceQosPolicy.h new file mode 100644 index 00000000000..9686b01e59d --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/DurabilityServiceQosPolicy.h @@ -0,0 +1,44 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_DURABILITYSERVICEQOSPOLICY_H +#define DDS4CCM_DURABILITYSERVICEQOSPOLICY_H + +#include "Duration_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::DurabilityServiceQosPolicy DDS_DurabilityServiceQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::DurabilityServiceQosPolicy &ddsqos, const ::DDS_DurabilityServiceQosPolicy & qos) +{ + ddsqos.service_cleanup_delay <<= qos.service_cleanup_delay; + ddsqos.history_kind = static_cast < ::DDS::HistoryQosPolicyKind> (qos.history_kind); + ddsqos.history_depth = qos.history_depth; + ddsqos.max_samples = qos.max_samples; + ddsqos.max_instances = qos.max_instances; + ddsqos.max_samples_per_instance = qos.max_samples_per_instance; +} + +inline void +operator<<= (::DDS_DurabilityServiceQosPolicy &ddsqos, const ::DDS::DurabilityServiceQosPolicy & qos) +{ + ddsqos.service_cleanup_delay <<= qos.service_cleanup_delay; + ddsqos.history_kind = static_cast < ::DDS_HistoryQosPolicyKind> (qos.history_kind); + ddsqos.history_depth = qos.history_depth; + ddsqos.max_samples = qos.max_samples; + ddsqos.max_instances = qos.max_instances; + ddsqos.max_samples_per_instance = qos.max_samples_per_instance; +} + +#endif + +#endif /* DDS4CCM_DURABILITYSERVICEQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/Duration_t.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/Duration_t.h new file mode 100644 index 00000000000..597339c10ab --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/Duration_t.h @@ -0,0 +1,37 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_DURATION_T_H +#define DDS4CCM_DURATION_T_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::Duration_t DDS_Duration_t; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::Duration_t &ddsduration, const ::DDS_Duration_t & duration) +{ + ddsduration.sec = duration.sec; + ddsduration.nanosec = duration.nanosec; +} + +inline void +operator<<= (::DDS_Duration_t &ddsduration, const ::DDS::Duration_t & duration) +{ + ddsduration.sec = duration.sec; + ddsduration.nanosec = duration.nanosec; +} + +#endif + +#endif /* DDS4CCM_DURATION_T_H */ + diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/EntityFactoryQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/EntityFactoryQosPolicy.h new file mode 100644 index 00000000000..356de511292 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/EntityFactoryQosPolicy.h @@ -0,0 +1,33 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_ENTITYFACTORYQOSPOLICY_H +#define DDS4CCM_ENTITYFACTORYQOSPOLICY_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::EntityFactoryQosPolicy DDS_EntityFactoryQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::EntityFactoryQosPolicy &ddsqos, const ::DDS_EntityFactoryQosPolicy & qos) +{ + ddsqos.autoenable_created_entities = qos.autoenable_created_entities; +} + +inline void +operator<<= (::DDS_EntityFactoryQosPolicy &ddsqos, const ::DDS::EntityFactoryQosPolicy & qos) +{ + ddsqos.autoenable_created_entities = qos.autoenable_created_entities; +} + +#endif + +#endif /* DDS4CCM_ENTITYFACTORYQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/GroupDataQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/GroupDataQosPolicy.h new file mode 100644 index 00000000000..c8c63445f29 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/GroupDataQosPolicy.h @@ -0,0 +1,35 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_GROUPDATAQOSPOLICY_H +#define DDS4CCM_GROUPDATAQOSPOLICY_H + +#include "OctetSeq.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::GroupDataQosPolicy DDS_GroupDataQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) + +inline void +operator<<= (::DDS::GroupDataQosPolicy &ddsqos, const ::DDS_GroupDataQosPolicy & qos) +{ + ddsqos.value <<= qos.value; +} + +inline void +operator<<= (::DDS_GroupDataQosPolicy &ddsqos, const ::DDS::GroupDataQosPolicy & qos) +{ + ddsqos.value <<= qos.value; +} + +#endif + +#endif /* DDS4CCM_GROUPDATAQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/HistoryQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/HistoryQosPolicy.h new file mode 100644 index 00000000000..d2140f4ca63 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/HistoryQosPolicy.h @@ -0,0 +1,35 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_HISTORYQOSPOLICY_H +#define DDS4CCM_HISTORYQOSPOLICY_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::HistoryQosPolicy DDS_HistoryQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::HistoryQosPolicy &ddsqos, const ::DDS_HistoryQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS::HistoryQosPolicyKind> (qos.kind); + ddsqos.depth = qos.depth; +} + +inline void +operator<<= (::DDS_HistoryQosPolicy &ddsqos, const ::DDS::HistoryQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS_HistoryQosPolicyKind> (qos.kind); + ddsqos.depth = qos.depth; +} + +#endif + +#endif /* DDS4CCM_HISTORYQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/InconsistentTopicStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/InconsistentTopicStatus.h new file mode 100644 index 00000000000..6946874f57c --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/InconsistentTopicStatus.h @@ -0,0 +1,36 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_INCONSISTENTTOPICSTATUS_H +#define DDS4CCM_INCONSISTENTTOPICSTATUS_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::InconsistentTopicStatus DDS_InconsistentTopicStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::InconsistentTopicStatus &ddsstatus, const ::DDS_InconsistentTopicStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; +} + +inline void +operator<<= (::DDS_InconsistentTopicStatus &ddsstatus, const ::DDS::InconsistentTopicStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; +} + +#endif + +#endif /* DDS4CCM_INCONSISTENTTOPICSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/InstanceHandleSeq.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/InstanceHandleSeq.h new file mode 100644 index 00000000000..6a95c92a610 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/InstanceHandleSeq.h @@ -0,0 +1,48 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_INSTANCEHANDLESEQ_H +#define DDS4CCM_INSTANCEHANDLESEQ_H + +#include "InstanceHandle_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::InstanceHandleSeq DDS_InstanceHandleSeq; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +template <typename corbaseq, typename ddsseq> +void convert_dds_to_corba_sequence(corbaseq & target, const ddsseq& source) { + target.length (source.length ()); + for (::DDS_Long index = 0; index < source.length (); index++) + { + target[index] <<= source[index]; + } +} + +inline void +operator<<= (::DDS::InstanceHandleSeq &ddsinstancehandleseqseq, const ::DDS_InstanceHandleSeq & instancehandleseq) +{ + convert_dds_to_corba_sequence (ddsinstancehandleseqseq, instancehandleseq); +} + +inline void +operator<<= (::DDS_InstanceHandleSeq &ddsinstancehandleseqseq, const ::DDS::InstanceHandleSeq & instancehandleseq) +{ + ddsinstancehandleseqseq.length (instancehandleseq.length ()); + for (::DDS::InstanceHandleSeq::size_type index = 0; index < instancehandleseq.length (); index++) + { + ddsinstancehandleseqseq[index] <<= instancehandleseq[index]; + } +} + +#endif + +#endif /* DDS4CCM_INSTANCEHANDLESEQ_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/InstanceHandle_t.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/InstanceHandle_t.h new file mode 100644 index 00000000000..8b2517eaa35 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/InstanceHandle_t.h @@ -0,0 +1,92 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_INSTANCEHANDLE_T_H +#define DDS4CCM_INSTANCEHANDLE_T_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_NDDS==1) +#include "ndds/ndds_cpp.h" +#define DDS_INSTANCE_HANDLE_T_IN const ::DDS::InstanceHandle_t & +#define DDS_INSTANCE_HANDLE_T_RETN ::DDS::InstanceHandle_t +#endif + +#if (CIAO_DDS4CCM_OPENDDS==1) +#define DDS_INSTANCE_HANDLE_T_IN ::DDS::InstanceHandle_t +#define DDS_INSTANCE_HANDLE_T_RETN ::DDS::InstanceHandle_t +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::InstanceHandle_t &ddsinstancehandle, const ::DDS_InstanceHandle_t & instancehandle) +{ + ACE_OS::memcpy (ddsinstancehandle.value, instancehandle.keyHash.value, sizeof (instancehandle.keyHash.value)); + ddsinstancehandle.length = instancehandle.keyHash.length; + ddsinstancehandle.isValid = instancehandle.isValid; +} + +inline void +operator<<= (::DDS_InstanceHandle_t &ddsinstancehandle, const ::DDS::InstanceHandle_t & instancehandle) +{ + ACE_OS::memcpy (ddsinstancehandle.keyHash.value, instancehandle.value, sizeof (instancehandle.value)); + ddsinstancehandle.keyHash.length = instancehandle.length; + ddsinstancehandle.isValid = instancehandle.isValid; +} + +inline bool +operator== (const ::DDS::InstanceHandle_t & instancehandle1, const ::DDS::InstanceHandle_t & instancehandle2) +{ + return instancehandle1.length == instancehandle2.length && + instancehandle1.isValid == instancehandle2.isValid && + ACE_OS::memcmp (instancehandle1.value, instancehandle2.value, sizeof (instancehandle1.value)) == 0; +} + +inline bool +operator== (const DDS_InstanceHandle_t & dds_instancehandle, const ::DDS::InstanceHandle_t & ccm_instancehandle) +{ + return dds_instancehandle.keyHash.length == ccm_instancehandle.length && + static_cast<CORBA::ULong>(dds_instancehandle.isValid) == ccm_instancehandle.isValid && + ACE_OS::memcmp (dds_instancehandle.keyHash.value, ccm_instancehandle.value, sizeof (dds_instancehandle.keyHash.value)) == 0; +} + +inline bool +operator== (const ::DDS::InstanceHandle_t & ccm_instancehandle, const DDS_InstanceHandle_t & dds_instancehandle) +{ + return ccm_instancehandle.length == dds_instancehandle.keyHash.length && + ccm_instancehandle.isValid == static_cast<CORBA::ULong>(dds_instancehandle.isValid) && + ACE_OS::memcmp (ccm_instancehandle.value, dds_instancehandle.keyHash.value, sizeof (ccm_instancehandle.value)) == 0; +} + +inline bool +operator!= (const ::DDS::InstanceHandle_t & instancehandle1, const ::DDS::InstanceHandle_t & instancehandle2) +{ + return instancehandle1.length != instancehandle2.length || + instancehandle1.isValid != instancehandle2.isValid || + ACE_OS::memcmp (instancehandle1.value, instancehandle2.value, sizeof (instancehandle1.value)) != 0; +} + +inline bool +operator!= (const DDS_InstanceHandle_t & dds_instancehandle, const ::DDS::InstanceHandle_t & ccm_instancehandle) +{ + return dds_instancehandle.keyHash.length != ccm_instancehandle.length || + static_cast<CORBA::ULong>(dds_instancehandle.isValid) != ccm_instancehandle.isValid || + ACE_OS::memcmp (dds_instancehandle.keyHash.value, ccm_instancehandle.value, sizeof (dds_instancehandle.keyHash.value)) != 0; +} + +inline bool +operator!= (const ::DDS::InstanceHandle_t & ccm_instancehandle, const DDS_InstanceHandle_t & dds_instancehandle) +{ + return ccm_instancehandle.length != dds_instancehandle.keyHash.length || + ccm_instancehandle.isValid != static_cast<CORBA::ULong>(dds_instancehandle.isValid) || + ACE_OS::memcmp (ccm_instancehandle.value, dds_instancehandle.keyHash.value, sizeof (ccm_instancehandle.value)) != 0; +} +#endif + +#endif /* DDS4CCM_INSTANCEHANDLE_T_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LatencyBudgetQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LatencyBudgetQosPolicy.h new file mode 100644 index 00000000000..27900434e79 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LatencyBudgetQosPolicy.h @@ -0,0 +1,34 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_LATENCYBUDGETQOSPOLICY_H +#define DDS4CCM_LATENCYBUDGETQOSPOLICY_H + +#include "Duration_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::LatencyBudgetQosPolicy DDS_LatencyBudgetQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::LatencyBudgetQosPolicy &ddsqos, const ::DDS_LatencyBudgetQosPolicy & qos) +{ + ddsqos.duration <<= qos.duration; +} + +inline void +operator<<= (::DDS_LatencyBudgetQosPolicy &ddsqos, const ::DDS::LatencyBudgetQosPolicy & qos) +{ + ddsqos.duration <<= qos.duration; +} + +#endif + +#endif /* DDS4CCM_LATENCYBUDGETQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LifespanQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LifespanQosPolicy.h new file mode 100644 index 00000000000..53220c3b745 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LifespanQosPolicy.h @@ -0,0 +1,34 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_LIFESPANQOSPOLICY_H +#define DDS4CCM_LIFESPANQOSPOLICY_H + +#include "Duration_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::LifespanQosPolicy DDS_LifespanQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::LifespanQosPolicy &ddsqos, const ::DDS_LifespanQosPolicy & qos) +{ + ddsqos.duration <<= qos.duration; +} + +inline void +operator<<= (::DDS_LifespanQosPolicy &ddsqos, const ::DDS::LifespanQosPolicy & qos) +{ + ddsqos.duration <<= qos.duration; +} + +#endif + +#endif /* DDS4CCM_LIFESPANQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LivelinessChangedStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LivelinessChangedStatus.h new file mode 100644 index 00000000000..a588bb4cf31 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LivelinessChangedStatus.h @@ -0,0 +1,43 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_LIVELINESSCHANGEDSTATUS_H +#define DDS4CCM_LIVELINESSCHANGEDSTATUS_H + +#include "InstanceHandle_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::LivelinessChangedStatus DDS_LivelinessChangedStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::LivelinessChangedStatus &ddsstatus, const ::DDS_LivelinessChangedStatus & status) +{ + ddsstatus.alive_count = status.alive_count; + ddsstatus.not_alive_count = status.not_alive_count; + ddsstatus.alive_count_change = status.alive_count_change; + ddsstatus.not_alive_count_change = status.not_alive_count_change; + ddsstatus.last_publication_handle <<= status.last_publication_handle; +} + +inline void +operator<<= (::DDS_LivelinessChangedStatus &ddsstatus, const ::DDS::LivelinessChangedStatus & status) +{ + ddsstatus.alive_count = status.alive_count; + ddsstatus.not_alive_count = status.not_alive_count; + ddsstatus.alive_count_change = status.alive_count_change; + ddsstatus.not_alive_count_change = status.not_alive_count_change; + ddsstatus.last_publication_handle <<= status.last_publication_handle; +} + +#endif + +#endif /* DDS4CCM_LIVELINESSCHANGEDSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LivelinessLostStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LivelinessLostStatus.h new file mode 100644 index 00000000000..dff10ab7ab3 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LivelinessLostStatus.h @@ -0,0 +1,36 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_LIVELINESSLOSTSTATUS_H +#define DDS4CCM_LIVELINESSLOSTSTATUS_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::LivelinessLostStatus DDS_LivelinessLostStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::LivelinessLostStatus &ddsstatus, const ::DDS_LivelinessLostStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; +} + +inline void +operator<<= (::DDS_LivelinessLostStatus &ddsstatus, const ::DDS::LivelinessLostStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; +} + +#endif + +#endif /* DDS4CCM_LIVELINESSLOSTSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LivelinessQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LivelinessQosPolicy.h new file mode 100644 index 00000000000..18b56dae8cf --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/LivelinessQosPolicy.h @@ -0,0 +1,36 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_LIVELINESSQOSPOLICY_H +#define DDS4CCM_LIVELINESSQOSPOLICY_H + +#include "Duration_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::LivelinessQosPolicy DDS_LivelinessQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::LivelinessQosPolicy &ddsqos, const ::DDS_LivelinessQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS::LivelinessQosPolicyKind> (qos.kind); + ddsqos.lease_duration <<= qos.lease_duration; +} + +inline void +operator<<= (::DDS_LivelinessQosPolicy &ddsqos, const ::DDS::LivelinessQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS_LivelinessQosPolicyKind> (qos.kind); + ddsqos.lease_duration <<= qos.lease_duration; +} + +#endif + +#endif /* DDS4CCM_LIVELINESSQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OctetSeq.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OctetSeq.h new file mode 100644 index 00000000000..ed0cc97a018 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OctetSeq.h @@ -0,0 +1,32 @@ +/** + * @author Marcel Smit <msmit@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_OCTETSEQ_H +#define DDS4CCM_OCTETSEQ_H + +inline void +operator<<= (::DDS::OctetSeq &ddsseq, const ::DDS_OctetSeq & seq) +{ + ddsseq.length (seq.length ()); + for (::DDS_Long i = 0; i < seq.length (); ++i) + { + ddsseq[i] = seq[i]; + } +} + +inline void +operator<<= (::DDS_OctetSeq &ddsseq, const ::DDS::OctetSeq & seq) +{ + ddsseq.length (seq.length ()); + for (::CORBA::ULong i = 0; i < seq.length (); ++i) + { + ddsseq[i] = seq[i]; + } +} + +#endif /* DDS4CCM_OCTETSEQ_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OfferedDeadlineMissedStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OfferedDeadlineMissedStatus.h new file mode 100644 index 00000000000..164d6a571c4 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OfferedDeadlineMissedStatus.h @@ -0,0 +1,39 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_OFFEREDDEADLINEMISSEDSTATUS_H +#define DDS4CCM_OFFEREDDEADLINEMISSEDSTATUS_H + +#include "InstanceHandle_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::OfferedDeadlineMissedStatus DDS_OfferedDeadlineMissedStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::OfferedDeadlineMissedStatus &ddsstatus, const ::DDS_OfferedDeadlineMissedStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.last_instance_handle <<= status.last_instance_handle; +} + +inline void +operator<<= (::DDS_OfferedDeadlineMissedStatus &ddsstatus, const ::DDS::OfferedDeadlineMissedStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.last_instance_handle <<= status.last_instance_handle; +} + +#endif + +#endif /* DDS4CCM_OFFEREDDEADLINEMISSEDSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OfferedIncompatibleQosStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OfferedIncompatibleQosStatus.h new file mode 100644 index 00000000000..9b6391a747b --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OfferedIncompatibleQosStatus.h @@ -0,0 +1,41 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_OFFEREDINCOMPATIBLEQOSSTATUS_H +#define DDS4CCM_OFFEREDINCOMPATIBLEQOSSTATUS_H + +#include "QosPolicyCountSeq.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::OfferedIncompatibleQosStatus DDS_OfferedIncompatibleQosStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::OfferedIncompatibleQosStatus &ddsstatus, const ::DDS_OfferedIncompatibleQosStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.last_policy_id = status.last_policy_id; + ddsstatus.policies <<= status.policies; +} + +inline void +operator<<= (::DDS_OfferedIncompatibleQosStatus &ddsstatus, const ::DDS::OfferedIncompatibleQosStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.last_policy_id = static_cast <DDS_QosPolicyId_t>(status.last_policy_id); + ddsstatus.policies <<= status.policies; +} + +#endif + +#endif /* DDS4CCM_OFFEREDINCOMPATIBLEQOSSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OwnershipQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OwnershipQosPolicy.h new file mode 100644 index 00000000000..eec42c30ed1 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OwnershipQosPolicy.h @@ -0,0 +1,33 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_OWNERSHIPQOSPOLICY_H +#define DDS4CCM_OWNERSHIPQOSPOLICY_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::OwnershipQosPolicy DDS_OwnershipQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::OwnershipQosPolicy &ddsqos, const ::DDS_OwnershipQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS::OwnershipQosPolicyKind> (qos.kind); +} + +inline void +operator<<= (::DDS_OwnershipQosPolicy &ddsqos, const ::DDS::OwnershipQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS_OwnershipQosPolicyKind> (qos.kind); +} + +#endif + +#endif /* DDS4CCM_OWNERSHIPQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OwnershipStrengthQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OwnershipStrengthQosPolicy.h new file mode 100644 index 00000000000..77401f1d9e2 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/OwnershipStrengthQosPolicy.h @@ -0,0 +1,33 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_OWNERSHIPSTRENGTHQOSPOLICY_H +#define DDS4CCM_OWNERSHIPSTRENGTHQOSPOLICY_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::OwnershipStrengthQosPolicy DDS_OwnershipStrengthQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::OwnershipStrengthQosPolicy &ddsqos, const ::DDS_OwnershipStrengthQosPolicy & qos) +{ + ddsqos.value = qos.value; +} + +inline void +operator<<= (::DDS_OwnershipStrengthQosPolicy &ddsqos, const ::DDS::OwnershipStrengthQosPolicy & qos) +{ + ddsqos.value = qos.value; +} + +#endif + +#endif /* DDS4CCM_OWNERSHIPSTRENGTHQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PartitionQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PartitionQosPolicy.h new file mode 100644 index 00000000000..0059665c277 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PartitionQosPolicy.h @@ -0,0 +1,35 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_PARTITIONQOSPOLICY_H +#define DDS4CCM_PARTITIONQOSPOLICY_H + +#include "StringSeq.h" + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::PartitionQosPolicy DDS_PartitionQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::PartitionQosPolicy &ddsqos, const ::DDS_PartitionQosPolicy & qos) +{ + ddsqos.name <<= qos.name; +} + +inline void +operator<<= (::DDS_PartitionQosPolicy &ddsqos, const ::DDS::PartitionQosPolicy & qos) +{ + ddsqos.name <<= qos.name; +} + +#endif + +#endif /* DDS4CCM_PARTITIONQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PresentationQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PresentationQosPolicy.h new file mode 100644 index 00000000000..7d5ab4fc283 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PresentationQosPolicy.h @@ -0,0 +1,37 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_PRESENTATIONQOSPOLICY_H +#define DDS4CCM_PRESENTATIONQOSPOLICY_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::PresentationQosPolicy DDS_PresentationQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::PresentationQosPolicy &ddsqos, const ::DDS_PresentationQosPolicy & qos) +{ + ddsqos.access_scope = static_cast < ::DDS::PresentationQosPolicyAccessScopeKind> (qos.access_scope); + ddsqos.coherent_access = qos.coherent_access; + ddsqos.ordered_access = qos.ordered_access; +} + +inline void +operator<<= (::DDS_PresentationQosPolicy &ddsqos, const ::DDS::PresentationQosPolicy & qos) +{ + ddsqos.access_scope = static_cast < DDS_PresentationQosPolicyAccessScopeKind> (qos.access_scope); + ddsqos.coherent_access = qos.coherent_access; + ddsqos.ordered_access = qos.ordered_access; +} + +#endif + +#endif /* DDS4CCM_PRESENTATIONQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PublicationBuiltinTopicData.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PublicationBuiltinTopicData.h new file mode 100644 index 00000000000..ce578f36e82 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PublicationBuiltinTopicData.h @@ -0,0 +1,81 @@ +/** + * @author Marcel Smit <msmit@remedy.nl> + * + * $Id$ + * + */ + +#ifndef PUBLICATIONBUILTINTOPICDATA_H_ +#define PUBLICATIONBUILTINTOPICDATA_H_ + +#include "BuiltinTopicKey_t.h" +#include "DurabilityQosPolicy.h" +#include "DurabilityServiceQosPolicy.h" +#include "DeadlineQosPolicy.h" +#include "LatencyBudgetQosPolicy.h" +#include "LivelinessQosPolicy.h" +#include "ReliabilityQosPolicy.h" +#include "LifespanQosPolicy.h" +#include "UserDataQosPolicy.h" +#include "OwnershipQosPolicy.h" +#include "OwnershipStrengthQosPolicy.h" +#include "DestinationOrderQosPolicy.h" +#include "PresentationQosPolicy.h" +#include "PartitionQosPolicy.h" +#include "TopicDataQosPolicy.h" +#include "GroupDataQosPolicy.h" + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::PublicationBuiltinTopicData &ddstopicdata, const ::DDS_PublicationBuiltinTopicData & topicdata) +{ + ddstopicdata.key <<= topicdata.key; + ddstopicdata.participant_key <<= topicdata.participant_key; + ddstopicdata.topic_name = topicdata.topic_name; + ddstopicdata.type_name = topicdata.type_name; + ddstopicdata.durability <<= topicdata.durability; + ddstopicdata.durability_service <<= topicdata.durability_service; + ddstopicdata.deadline <<= topicdata.deadline; + ddstopicdata.latency_budget <<= topicdata.latency_budget; + ddstopicdata.liveliness <<= topicdata.liveliness; + ddstopicdata.reliability <<= topicdata.reliability; + ddstopicdata.lifespan <<= topicdata.lifespan; + ddstopicdata.user_data <<= topicdata.user_data; + ddstopicdata.ownership <<= topicdata.ownership; + ddstopicdata.ownership_strength <<= topicdata.ownership_strength; + ddstopicdata.destination_order <<= topicdata.destination_order; + ddstopicdata.presentation <<= topicdata.presentation; + ddstopicdata.partition <<= topicdata.partition; + ddstopicdata.topic_data <<= topicdata.topic_data; + ddstopicdata.group_data <<= topicdata.group_data; +} + +inline void +operator<<= (::DDS_PublicationBuiltinTopicData & ddstopicdata, const ::DDS::PublicationBuiltinTopicData & topicdata) +{ + ddstopicdata.key <<= topicdata.key; + ddstopicdata.participant_key <<= topicdata.participant_key; + ddstopicdata.topic_name = CORBA::string_dup (topicdata.topic_name); + ddstopicdata.type_name = CORBA::string_dup (topicdata.type_name); + ddstopicdata.durability <<= topicdata.durability; + ddstopicdata.durability_service <<= topicdata.durability_service; + ddstopicdata.deadline <<= topicdata.deadline; + ddstopicdata.latency_budget <<= topicdata.latency_budget; + ddstopicdata.liveliness <<= topicdata.liveliness; + ddstopicdata.reliability <<= topicdata.reliability; + ddstopicdata.lifespan <<= topicdata.lifespan; + ddstopicdata.user_data <<= topicdata.user_data; + ddstopicdata.ownership <<= topicdata.ownership; + ddstopicdata.ownership_strength <<= topicdata.ownership_strength; + ddstopicdata.destination_order <<= topicdata.destination_order; + ddstopicdata.presentation <<= topicdata.presentation; + ddstopicdata.partition <<= topicdata.partition; + ddstopicdata.topic_data <<= topicdata.topic_data; + ddstopicdata.group_data <<= topicdata.group_data; +} + +#endif + +#endif diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PublicationMatchedStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PublicationMatchedStatus.h new file mode 100644 index 00000000000..2374f58d2c2 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PublicationMatchedStatus.h @@ -0,0 +1,43 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_PUBLICATIONMATCHEDSTATUS_H +#define DDS4CCM_PUBLICATIONMATCHEDSTATUS_H + +#include "InstanceHandle_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::PublicationMatchedStatus DDS_PublicationMatchedStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::PublicationMatchedStatus &ddsstatus, const ::DDS_PublicationMatchedStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.current_count = status.current_count; + ddsstatus.current_count_change = status.current_count_change; + ddsstatus.last_subscription_handle <<= status.last_subscription_handle; +} + +inline void +operator<<= (::DDS_PublicationMatchedStatus &ddsstatus, const ::DDS::PublicationMatchedStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.current_count = status.current_count; + ddsstatus.current_count_change = status.current_count_change; + ddsstatus.last_subscription_handle <<= status.last_subscription_handle; +} + +#endif + +#endif /* DDS4CCM_PUBLICATIONMATCHEDSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PublisherQos.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PublisherQos.h new file mode 100644 index 00000000000..6a129795137 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/PublisherQos.h @@ -0,0 +1,44 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_PUBLISHERQOS_H +#define DDS4CCM_PUBLISHERQOS_H + +#include "PresentationQosPolicy.h" +#include "PartitionQosPolicy.h" +#include "GroupDataQosPolicy.h" +#include "EntityFactoryQosPolicy.h" + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::PublisherQos DDS_PublisherQos; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::PublisherQos &ddsqos, const ::DDS_PublisherQos & qos) +{ + ddsqos.presentation <<= qos.presentation; + ddsqos.partition <<= qos.partition; + ddsqos.group_data <<= qos.group_data; + ddsqos.entity_factory <<= qos.entity_factory; +} + +inline void +operator<<= (::DDS_PublisherQos &ddsqos, const ::DDS::PublisherQos & qos) +{ + ddsqos.presentation <<= qos.presentation; + ddsqos.partition <<= qos.partition; + ddsqos.group_data <<= qos.group_data; + ddsqos.entity_factory <<= qos.entity_factory; +} + +#endif + +#endif /* DDS4CCM_PUBLISHERQOS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/QosPolicyCountSeq.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/QosPolicyCountSeq.h new file mode 100644 index 00000000000..5a6224d84a7 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/QosPolicyCountSeq.h @@ -0,0 +1,44 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_QOSPOLICYCOUNTSEQ_H +#define DDS4CCM_QOSPOLICYCOUNTSEQ_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::QosPolicyCountSeq DDS_QosPolicyCountSeq; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::QosPolicyCountSeq & ddspolicycount, const ::DDS_QosPolicyCountSeq & policycount) +{ + ddspolicycount.length (policycount.length ()); + for (::DDS_Long i = 0 ; i < policycount.length (); ++i) + { + ddspolicycount[i].policy_id = policycount[i].policy_id; + ddspolicycount[i].count = policycount[i].count; + } +} + +inline void +operator<<= (::DDS_QosPolicyCountSeq & ddspolicycount, const ::DDS::QosPolicyCountSeq & policycount) +{ + ddspolicycount.length (policycount.length ()); + for (::CORBA::ULong i = 0 ; i < policycount.length (); ++i) + { + ddspolicycount[i].policy_id = static_cast <DDS_QosPolicyId_t> (policycount[i].policy_id); + ddspolicycount[i].count = policycount[i].count; + } +} + +#endif + +#endif /* DDS4CCM_QOSPOLICYCOUNTSEQ_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReaderDataLifecycleQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReaderDataLifecycleQosPolicy.h new file mode 100644 index 00000000000..8d0ab08b72a --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReaderDataLifecycleQosPolicy.h @@ -0,0 +1,38 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_READERDATALIFECYCLEQOSPOLICY_H +#define DDS4CCM_READERDATALIFECYCLEQOSPOLICY_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::ReaderDataLifecycleQosPolicy DDS_ReaderDataLifecycleQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) + +#include "Duration_t.h" + +inline void +operator<<= (::DDS::ReaderDataLifecycleQosPolicy &ddsqos, const ::DDS_ReaderDataLifecycleQosPolicy & qos) +{ + ddsqos.autopurge_nowriter_samples_delay <<= qos.autopurge_nowriter_samples_delay; + ddsqos.autopurge_disposed_samples_delay <<= qos.autopurge_disposed_samples_delay; +} + +inline void +operator<<= (::DDS_ReaderDataLifecycleQosPolicy &ddsqos, const ::DDS::ReaderDataLifecycleQosPolicy & qos) +{ + ddsqos.autopurge_nowriter_samples_delay <<= qos.autopurge_nowriter_samples_delay; + ddsqos.autopurge_disposed_samples_delay <<= qos.autopurge_disposed_samples_delay; +} + +#endif + +#endif /* DDS4CCM_READERDATALIFECYCLEQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReliabilityQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReliabilityQosPolicy.h new file mode 100644 index 00000000000..d4253585857 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReliabilityQosPolicy.h @@ -0,0 +1,36 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_RELIABILITYSQOSPOLICY_H +#define DDS4CCM_RELIABILITYSQOSPOLICY_H + +#include "Duration_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::ReliabilityQosPolicy DDS_ReliabilityQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::ReliabilityQosPolicy &ddsqos, const ::DDS_ReliabilityQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS::ReliabilityQosPolicyKind> (qos.kind); + ddsqos.max_blocking_time <<= qos.max_blocking_time; +} + +inline void +operator<<= (::DDS_ReliabilityQosPolicy &ddsqos, const ::DDS::ReliabilityQosPolicy & qos) +{ + ddsqos.kind = static_cast < ::DDS_ReliabilityQosPolicyKind> (qos.kind); + ddsqos.max_blocking_time <<= qos.max_blocking_time; +} + +#endif + +#endif /* DDS4CCM_RELIABILITYSQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReliableReaderActivityChangedStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReliableReaderActivityChangedStatus.h new file mode 100644 index 00000000000..113a27393a7 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReliableReaderActivityChangedStatus.h @@ -0,0 +1,42 @@ +/** + * @author Marcel Smit <msmit@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_RELIABLEREADERACTIVITYCHANGEDSTATUS_H +#define DDS4CCM_RELIABLEREADERACTIVITYCHANGEDSTATUS_H + +#include "dds4ccm/impl/dds/ndds/InstanceHandle_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::ReliableReaderActivityChangedStatus DDS_ReliableReaderActivityChangedStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::ReliableReaderActivityChangedStatus &ddsstatus, const ::DDS_ReliableReaderActivityChangedStatus & status) +{ + ddsstatus.active_count = status.active_count; + ddsstatus.active_count_change = status.active_count_change; + ddsstatus.inactive_count = status.inactive_count; + ddsstatus.inactive_count_change = status.inactive_count_change; + ddsstatus.last_instance_handle <<= status.last_instance_handle; +} + +inline void +operator<<= (::DDS_ReliableReaderActivityChangedStatus &ddsstatus, const ::DDS::ReliableReaderActivityChangedStatus & status) +{ + ddsstatus.active_count = status.active_count; + ddsstatus.active_count_change = status.active_count_change; + ddsstatus.inactive_count = status.inactive_count; + ddsstatus.inactive_count_change = status.inactive_count_change; + ddsstatus.last_instance_handle <<= status.last_instance_handle; +} + +#endif + +#endif /* DDS4CCM_RELIABLEREADERACTIVITYCHANGEDSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReliableWriterCacheChangedStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReliableWriterCacheChangedStatus.h new file mode 100644 index 00000000000..31e8653b8be --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ReliableWriterCacheChangedStatus.h @@ -0,0 +1,51 @@ +/** + * @author Marcel Smit <msmit@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_RELIABLEWRITERCACHECHANGEDSTATUS_H +#define DDS4CCM_RELIABLEWRITERCACHECHANGEDSTATUS_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::ReliableWriterCacheChangedStatus DDS_ReliableWriterCacheChangedStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::ReliableWriterCacheChangedStatus &ddsstatus, const ::DDS_ReliableWriterCacheChangedStatus & status) +{ + ddsstatus.empty_reliable_writer_cache.total_count = status.empty_reliable_writer_cache.total_count; + ddsstatus.empty_reliable_writer_cache.total_count_change = status.empty_reliable_writer_cache.total_count_change; + ddsstatus.full_reliable_writer_cache.total_count = status.full_reliable_writer_cache.total_count; + ddsstatus.full_reliable_writer_cache.total_count_change = status.full_reliable_writer_cache.total_count_change; + ddsstatus.low_watermark_reliable_writer_cache.total_count = status.low_watermark_reliable_writer_cache.total_count; + ddsstatus.low_watermark_reliable_writer_cache.total_count_change = status.low_watermark_reliable_writer_cache.total_count_change; + ddsstatus.high_watermark_reliable_writer_cache.total_count = status.high_watermark_reliable_writer_cache.total_count; + ddsstatus.high_watermark_reliable_writer_cache.total_count_change = status.high_watermark_reliable_writer_cache.total_count_change; + ddsstatus.unacknowledged_sample_count = status.unacknowledged_sample_count; + ddsstatus.unacknowledged_sample_count_peak = status.unacknowledged_sample_count_peak; +} + +inline void +operator<<= (::DDS_ReliableWriterCacheChangedStatus &ddsstatus, const ::DDS::ReliableWriterCacheChangedStatus & status) +{ + ddsstatus.empty_reliable_writer_cache.total_count = status.empty_reliable_writer_cache.total_count; + ddsstatus.empty_reliable_writer_cache.total_count_change = status.empty_reliable_writer_cache.total_count_change; + ddsstatus.full_reliable_writer_cache.total_count = status.full_reliable_writer_cache.total_count; + ddsstatus.full_reliable_writer_cache.total_count_change = status.full_reliable_writer_cache.total_count_change; + ddsstatus.low_watermark_reliable_writer_cache.total_count = status.low_watermark_reliable_writer_cache.total_count; + ddsstatus.low_watermark_reliable_writer_cache.total_count_change = status.low_watermark_reliable_writer_cache.total_count_change; + ddsstatus.high_watermark_reliable_writer_cache.total_count = status.high_watermark_reliable_writer_cache.total_count; + ddsstatus.high_watermark_reliable_writer_cache.total_count_change = status.high_watermark_reliable_writer_cache.total_count_change; + ddsstatus.unacknowledged_sample_count = status.unacknowledged_sample_count; + ddsstatus.unacknowledged_sample_count_peak = status.unacknowledged_sample_count_peak; +} + +#endif + +#endif /* DDS4CCM_RELIABLEWRITERCACHECHANGEDSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/RequestedDeadlineMissedStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/RequestedDeadlineMissedStatus.h new file mode 100644 index 00000000000..9d26f544d4b --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/RequestedDeadlineMissedStatus.h @@ -0,0 +1,38 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_REQUESTEDDEADLINEMISSEDSTATUS_H +#define DDS4CCM_REQUESTEDDEADLINEMISSEDSTATUS_H + +#include "InstanceHandle_t.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::RequestedDeadlineMissedStatus DDS_RequestedDeadlineMissedStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::RequestedDeadlineMissedStatus &ddsstatus, const ::DDS_RequestedDeadlineMissedStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.last_instance_handle <<= status.last_instance_handle; +} + +inline void +operator<<= (::DDS_RequestedDeadlineMissedStatus &ddsstatus, const ::DDS::RequestedDeadlineMissedStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.last_instance_handle <<= status.last_instance_handle; +} + +#endif + +#endif /* DDS4CCM_REQUESTEDDEADLINEMISSEDSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/RequestedIncompatibleQosStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/RequestedIncompatibleQosStatus.h new file mode 100644 index 00000000000..d36b9d7da1c --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/RequestedIncompatibleQosStatus.h @@ -0,0 +1,41 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_REQUESTEDINCOMPATIBLEQOSSTATUS_H +#define DDS4CCM_REQUESTEDINCOMPATIBLEQOSSTATUS_H + +#include "QosPolicyCountSeq.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::RequestedIncompatibleQosStatus DDS_RequestedIncompatibleQosStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::RequestedIncompatibleQosStatus &ddsstatus, const ::DDS_RequestedIncompatibleQosStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.last_policy_id = status.last_policy_id; + ddsstatus.policies <<= status.policies; +} + +inline void +operator<<= (::DDS_RequestedIncompatibleQosStatus &ddsstatus, const ::DDS::RequestedIncompatibleQosStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.last_policy_id = static_cast <DDS_QosPolicyId_t>(status.last_policy_id); + ddsstatus.policies <<= status.policies; +} + +#endif + +#endif /* DDS4CCM_REQUESTEDINCOMPATIBLEQOSSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ResourceLimitsQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ResourceLimitsQosPolicy.h new file mode 100644 index 00000000000..f7d2f2dd1f0 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/ResourceLimitsQosPolicy.h @@ -0,0 +1,37 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_RESOURCELIMITSQOSPOLICY_H +#define DDS4CCM_RESOURCELIMITSQOSPOLICY_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::ResourceLimitsQosPolicy DDS_ResourceLimitsQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::ResourceLimitsQosPolicy &ddsqos, const ::DDS_ResourceLimitsQosPolicy & qos) +{ + ddsqos.max_samples = qos.max_samples; + ddsqos.max_instances = qos.max_instances; + ddsqos.max_samples_per_instance = qos.max_samples_per_instance; +} + +inline void +operator<<= (::DDS_ResourceLimitsQosPolicy &ddsqos, const ::DDS::ResourceLimitsQosPolicy & qos) +{ + ddsqos.max_samples = qos.max_samples; + ddsqos.max_instances = qos.max_instances; + ddsqos.max_samples_per_instance = qos.max_samples_per_instance; +} + +#endif + +#endif /* DDS4CCM_RESOURCELIMITSQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SampleInfo.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SampleInfo.h new file mode 100644 index 00000000000..5b1122e1db8 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SampleInfo.h @@ -0,0 +1,71 @@ +/** + * @author Marcel Smit <msmit@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef SAMPLE_INFO_H +#define SAMPLE_INFO_H + +#include "dds4ccm/idl/dds_rtf2_dcpsC.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#include "Time_t.h" +#include "InstanceHandle_t.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::SampleStateKind DDS_SampleStateKind; +typedef ::DDS::SampleInfo DDS_SampleInfo; +#endif + +inline void +operator<<= (::CCM_DDS::AccessStatus & access_status, const ::DDS_SampleStateKind & sample_state) +{ + if (sample_state == ::DDS::NOT_READ_SAMPLE_STATE) + { + access_status = ::CCM_DDS::FRESH_INFO; + } + else if (sample_state == ::DDS::READ_SAMPLE_STATE) + { + access_status = ::CCM_DDS::ALREADY_SEEN; + } +} + +inline void +operator<<= (::CCM_DDS::ReadInfo& ccm_dds_readinfo, const ::DDS_SampleInfo& sample_info) +{ +#if (CIAO_DDS4CCM_NDDS==1) + ccm_dds_readinfo.source_timestamp <<= sample_info.source_timestamp; +#else + ccm_dds_readinfo.source_timestamp = sample_info.source_timestamp; +#endif + ccm_dds_readinfo.access_status <<= sample_info.sample_state; +#if (CIAO_DDS4CCM_NDDS==1) + ccm_dds_readinfo.instance_handle <<= sample_info.instance_handle; +#else + ccm_dds_readinfo.instance_handle = sample_info.instance_handle; +#endif + + if (sample_info.instance_state == ::DDS::ALIVE_INSTANCE_STATE && + sample_info.view_state == ::DDS::NEW_VIEW_STATE) + { + // Instance_status new + ccm_dds_readinfo.instance_status = ::CCM_DDS::INSTANCE_CREATED; + } + else if (sample_info.instance_state == ::DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE) + { + // Instance_status deleted + ccm_dds_readinfo.instance_status = ::CCM_DDS::INSTANCE_DELETED; + } + else if ((sample_info.instance_state == ::DDS::ALIVE_INSTANCE_STATE && + sample_info.view_state == ::DDS::NOT_NEW_VIEW_STATE) || + sample_info.instance_state == ::DDS::NOT_ALIVE_NO_WRITERS_INSTANCE_STATE) + { + // Instance_status updated + ccm_dds_readinfo.instance_status = ::CCM_DDS::INSTANCE_UPDATED; + } +} + +#endif diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SampleLostStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SampleLostStatus.h new file mode 100644 index 00000000000..6191c745c17 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SampleLostStatus.h @@ -0,0 +1,36 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_SAMPLELOSTSTATUS_H +#define DDS4CCM_SAMPLELOSTSTATUS_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::SampleLostStatus DDS_SampleLostStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::SampleLostStatus &ddsstatus, const ::DDS_SampleLostStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; +} + +inline void +operator>>= (const ::DDS_SampleLostStatus &status, ::DDS::SampleLostStatus & ddsstatus) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; +} +#endif + +#endif /* DDS4CCM_SAMPLELOSTSTATUS_H */ + diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SampleRejectedStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SampleRejectedStatus.h new file mode 100644 index 00000000000..2467b100e13 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SampleRejectedStatus.h @@ -0,0 +1,41 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_SAMPLEREJECTEDSTATUS_H +#define DDS4CCM_SAMPLEREJECTEDSTATUS_H + +#include "InstanceHandle_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::SampleRejectedStatus DDS_SampleRejectedStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::SampleRejectedStatus &ddsstatus, const ::DDS_SampleRejectedStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.last_reason = static_cast < ::DDS::SampleRejectedStatusKind> (status.last_reason); + ddsstatus.last_instance_handle <<= status.last_instance_handle; +} + +inline void +operator<<= (::DDS_SampleRejectedStatus &ddsstatus, const ::DDS::SampleRejectedStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.last_reason = static_cast < ::DDS_SampleRejectedStatusKind> (status.last_reason); + ddsstatus.last_instance_handle <<= status.last_instance_handle; +} + +#endif + +#endif /* DDS4CCM_SAMPLEREJECTEDSTATUS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/StringSeq.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/StringSeq.h new file mode 100644 index 00000000000..6fcc769b4f2 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/StringSeq.h @@ -0,0 +1,45 @@ +/** + * @author Marcel Smit <msmit@remedy.nl> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + */ + +#ifndef DDS4CCM_STRINGSEQ_T_H +#define DDS4CCM_STRINGSEQ_T_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::StringSeq DDS_StringSeq; +typedef long DDS_Long; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::StringSeq & string_seq, const ::DDS_StringSeq & dds_string_seq) +{ + string_seq.length (dds_string_seq.length ()); + for (::DDS_Long i = 0 ; i < dds_string_seq.length(); ++i) + { + string_seq[i] = CORBA::string_dup (dds_string_seq[i]); + } +} + +inline void +operator<<= (::DDS_StringSeq & dds_string_seq, const ::DDS::StringSeq & string_seq) +{ + const char** parameterlist = new const char*[string_seq.length ()]; + + for (CORBA::ULong i = 0; i < string_seq.length (); ++i) + { + parameterlist[i] = string_seq[i].in (); + } + dds_string_seq.length (string_seq.length ()); + dds_string_seq.from_array (parameterlist, string_seq.length ()); + delete [] parameterlist; +} +#endif + +#endif /* DDS4CCM_STRINGSEQ_T_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SubscriberQos.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SubscriberQos.h new file mode 100644 index 00000000000..9741f0b9682 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SubscriberQos.h @@ -0,0 +1,44 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_SUBSCRIBERQOS_H +#define DDS4CCM_SUBSCRIBERQOS_H + +#include "EntityFactoryQosPolicy.h" +#include "GroupDataQosPolicy.h" +#include "PartitionQosPolicy.h" +#include "PresentationQosPolicy.h" + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::SubscriberQos DDS_SubscriberQos; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::SubscriberQos &ddsqos, const ::DDS_SubscriberQos & qos) +{ + ddsqos.presentation <<= qos.presentation; + ddsqos.partition <<= qos.partition; + ddsqos.group_data <<= qos.group_data; + ddsqos.entity_factory <<= qos.entity_factory; +} + +inline void +operator<<= (::DDS_SubscriberQos &ddsqos, const ::DDS::SubscriberQos & qos) +{ + ddsqos.presentation <<= qos.presentation; + ddsqos.partition <<= qos.partition; + ddsqos.group_data <<= qos.group_data; + ddsqos.entity_factory <<= qos.entity_factory; +} + +#endif + +#endif /* DDS4CCM_SUBSCRIBERQOS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SubscriptionBuiltinTopicData.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SubscriptionBuiltinTopicData.h new file mode 100644 index 00000000000..06f39b23e4b --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SubscriptionBuiltinTopicData.h @@ -0,0 +1,80 @@ +/** + * @author Marcel Smit <msmit@remedy.nl> + * + * $Id$ + * + */ + +#ifndef SUBSCRIPTIONBUILTINTOPICDATA_H_ +#define SUBSCRIPTIONBUILTINTOPICDATA_H_ + +#include "BuiltinTopicKey_t.h" +#include "DurabilityQosPolicy.h" +#include "DeadlineQosPolicy.h" +#include "LatencyBudgetQosPolicy.h" +#include "LivelinessQosPolicy.h" +#include "ReliabilityQosPolicy.h" +#include "OwnershipQosPolicy.h" +#include "OwnershipStrengthQosPolicy.h" +#include "DestinationOrderQosPolicy.h" +#include "UserDataQosPolicy.h" +#include "TimeBasedFilterQosPolicy.h" +#include "PresentationQosPolicy.h" +#include "PartitionQosPolicy.h" +#include "TopicDataQosPolicy.h" +#include "GroupDataQosPolicy.h" + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::SubscriptionBuiltinTopicData &ddstopicdata, const ::DDS_SubscriptionBuiltinTopicData & topicdata) +{ + ddstopicdata.key <<= topicdata.key; + ddstopicdata.participant_key <<= topicdata.participant_key; + ddstopicdata.topic_name = topicdata.topic_name; + ddstopicdata.type_name = topicdata.type_name; + + ddstopicdata.durability <<= topicdata.durability; + ddstopicdata.deadline <<= topicdata.deadline; + ddstopicdata.latency_budget <<= topicdata.latency_budget; + ddstopicdata.liveliness <<= topicdata.liveliness; + ddstopicdata.reliability <<= topicdata.reliability; + ddstopicdata.ownership <<= topicdata.ownership; + ddstopicdata.destination_order <<= topicdata.destination_order; + ddstopicdata.user_data <<= topicdata.user_data; + ddstopicdata.time_based_filter <<= topicdata.time_based_filter; + + ddstopicdata.presentation <<= topicdata.presentation; + ddstopicdata.partition <<= topicdata.partition; + ddstopicdata.topic_data <<= topicdata.topic_data; + ddstopicdata.group_data <<= topicdata.group_data; +} + +inline void +operator<<= (::DDS_SubscriptionBuiltinTopicData & ddstopicdata, const ::DDS::SubscriptionBuiltinTopicData & topicdata) +{ + ddstopicdata.key <<= topicdata.key; + ddstopicdata.participant_key <<= topicdata.participant_key; + ddstopicdata.topic_name = CORBA::string_dup (topicdata.topic_name); + ddstopicdata.type_name = CORBA::string_dup (topicdata.type_name); + + ddstopicdata.durability <<= topicdata.durability; + ddstopicdata.deadline <<= topicdata.deadline; + ddstopicdata.latency_budget <<= topicdata.latency_budget; + ddstopicdata.liveliness <<= topicdata.liveliness; + ddstopicdata.reliability <<= topicdata.reliability; + ddstopicdata.ownership <<= topicdata.ownership; + ddstopicdata.destination_order <<= topicdata.destination_order; + ddstopicdata.user_data <<= topicdata.user_data; + ddstopicdata.time_based_filter <<= topicdata.time_based_filter; + + ddstopicdata.presentation <<= topicdata.presentation; + ddstopicdata.partition <<= topicdata.partition; + ddstopicdata.topic_data <<= topicdata.topic_data; + ddstopicdata.group_data <<= topicdata.group_data; +} + +#endif + +#endif /* SUBSCRIPTIONBUILTINTOPICDATA_H_ */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SubscriptionMatchedStatus.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SubscriptionMatchedStatus.h new file mode 100644 index 00000000000..a8d02d7a24d --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/SubscriptionMatchedStatus.h @@ -0,0 +1,44 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_SUBSCRIPTIONMATCHEDSTATUS_H +#define DDS4CCM_SUBSCRIPTIONMATCHEDSTATUS_H + +#include "InstanceHandle_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::SubscriptionMatchedStatus DDS_SubscriptionMatchedStatus; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::SubscriptionMatchedStatus &ddsstatus, const ::DDS_SubscriptionMatchedStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.current_count = status.current_count; + ddsstatus.current_count_change = status.current_count_change; + ddsstatus.last_publication_handle <<= status.last_publication_handle; +} + +inline void +operator<<= (::DDS_SubscriptionMatchedStatus &ddsstatus, const ::DDS::SubscriptionMatchedStatus & status) +{ + ddsstatus.total_count = status.total_count; + ddsstatus.total_count_change = status.total_count_change; + ddsstatus.current_count = status.current_count; + ddsstatus.current_count_change = status.current_count_change; + ddsstatus.last_publication_handle <<= status.last_publication_handle; +} + +#endif + +#endif /* DDS4CCM_SUBSCRIPTIONMATCHEDSTATUS_H */ + diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TimeBasedFilterQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TimeBasedFilterQosPolicy.h new file mode 100644 index 00000000000..dfb3f711249 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TimeBasedFilterQosPolicy.h @@ -0,0 +1,34 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_TIMEBASEDFILTERQOSPOLICY_H +#define DDS4CCM_TIMEBASEDFILTERQOSPOLICY_H + +#include "Duration_t.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::TimeBasedFilterQosPolicy DDS_TimeBasedFilterQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::TimeBasedFilterQosPolicy &ddsqos, const ::DDS_TimeBasedFilterQosPolicy & qos) +{ + ddsqos.minimum_separation <<= qos.minimum_separation; +} + +inline void +operator<<= (::DDS_TimeBasedFilterQosPolicy &ddsqos, const ::DDS::TimeBasedFilterQosPolicy & qos) +{ + ddsqos.minimum_separation <<= qos.minimum_separation; +} + +#endif + +#endif /* DDS4CCM_TIMEBASEDFILTERQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/Time_t.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/Time_t.h new file mode 100644 index 00000000000..c9c62c27372 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/Time_t.h @@ -0,0 +1,37 @@ +/** + * @author William R. Otte <wotte@dre.vanderbilt.edu> + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_TIME_T_H +#define DDS4CCM_TIME_T_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::Time_t DDS_Time_t; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::Time_t &ddstime, const ::DDS_Time_t & time) +{ + ddstime.sec = time.sec; + ddstime.nanosec = time.nanosec; +} + +inline void +operator<<= (::DDS_Time_t &ddstime, const ::DDS::Time_t & time) +{ + ddstime.sec = time.sec; + ddstime.nanosec = time.nanosec; +} + +#endif + +#endif /* DDS4CCM_TIME_T_H */ + diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TopicDataQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TopicDataQosPolicy.h new file mode 100644 index 00000000000..394b201ff77 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TopicDataQosPolicy.h @@ -0,0 +1,34 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_TOPICDATAQOSPOLICY_H +#define DDS4CCM_TOPICDATAQOSPOLICY_H + +#include "OctetSeq.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::TopicDataQosPolicy DDS_TopicDataQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::TopicDataQosPolicy &ddsqos, const ::DDS_TopicDataQosPolicy & qos) +{ + ddsqos.value <<= qos.value; +} + +inline void +operator<<= (::DDS_TopicDataQosPolicy &ddsqos, const ::DDS::TopicDataQosPolicy & qos) +{ + ddsqos.value <<= qos.value; +} + +#endif + +#endif /* DDS4CCM_TOPICDATAQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TopicQos.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TopicQos.h new file mode 100644 index 00000000000..1cbc53d2b4b --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TopicQos.h @@ -0,0 +1,71 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_TOPICQOS_H +#define DDS4CCM_TOPICQOS_H + +#include "TopicDataQosPolicy.h" +#include "DurabilityQosPolicy.h" +#include "DurabilityServiceQosPolicy.h" +#include "DeadlineQosPolicy.h" +#include "LatencyBudgetQosPolicy.h" +#include "LivelinessQosPolicy.h" +#include "ReliabilityQosPolicy.h" +#include "DestinationOrderQosPolicy.h" +#include "HistoryQosPolicy.h" +#include "ResourceLimitsQosPolicy.h" +#include "TransportPriorityQosPolicy.h" +#include "LifespanQosPolicy.h" +#include "OwnershipQosPolicy.h" + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::TopicQos DDS_TopicQos; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::TopicQos &ddsqos, const ::DDS_TopicQos & qos) +{ + ddsqos.topic_data <<= qos.topic_data; + ddsqos.durability <<= qos.durability; + ddsqos.durability_service <<= qos.durability_service; + ddsqos.deadline <<= qos.deadline; + ddsqos.latency_budget <<= qos.latency_budget; + ddsqos.liveliness <<= qos.liveliness; + ddsqos.reliability <<= qos.reliability; + ddsqos.destination_order <<= qos.destination_order; + ddsqos.history <<= qos.history; + ddsqos.resource_limits <<= qos.resource_limits; + ddsqos.transport_priority <<= qos.transport_priority; + ddsqos.lifespan <<= qos.lifespan; + ddsqos.ownership <<= qos.ownership; +} + +inline void +operator<<= (::DDS_TopicQos &ddsqos, const ::DDS::TopicQos & qos) +{ + ddsqos.topic_data <<= qos.topic_data; + ddsqos.durability <<= qos.durability; + ddsqos.durability_service <<= qos.durability_service; + ddsqos.deadline <<= qos.deadline; + ddsqos.latency_budget <<= qos.latency_budget; + ddsqos.liveliness <<= qos.liveliness; + ddsqos.reliability <<= qos.reliability; + ddsqos.destination_order <<= qos.destination_order; + ddsqos.history <<= qos.history; + ddsqos.resource_limits <<= qos.resource_limits; + ddsqos.transport_priority <<= qos.transport_priority; + ddsqos.lifespan <<= qos.lifespan; + ddsqos.ownership <<= qos.ownership; +} + +#endif + +#endif /* DDS4CCM_TOPICQOS_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TransportPriorityQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TransportPriorityQosPolicy.h new file mode 100644 index 00000000000..3116b5f5bb5 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/TransportPriorityQosPolicy.h @@ -0,0 +1,33 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_TRANSPORTPRIOTITYQOSPOLICY_H +#define DDS4CCM_TRANSPORTPRIOTITYQOSPOLICY_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::TransportPriorityQosPolicy DDS_TransportPriorityQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::TransportPriorityQosPolicy &ddsqos, const ::DDS_TransportPriorityQosPolicy & qos) +{ + ddsqos.value = qos.value; +} + +inline void +operator<<= (::DDS_TransportPriorityQosPolicy &ddsqos, const ::DDS::TransportPriorityQosPolicy & qos) +{ + ddsqos.value = qos.value; +} + +#endif + +#endif /* DDS4CCM_TRANSPORTPRIOTITYQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/UserDataQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/UserDataQosPolicy.h new file mode 100644 index 00000000000..9e4dc792d5d --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/UserDataQosPolicy.h @@ -0,0 +1,34 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_USERDATAQOSPOLICY_H +#define DDS4CCM_USERDATAQOSPOLICY_H + +#include "OctetSeq.h" +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::UserDataQosPolicy DDS_UserDataQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::UserDataQosPolicy &ddsqos, const ::DDS_UserDataQosPolicy & qos) +{ + ddsqos.value <<= qos.value; +} + +inline void +operator<<= (::DDS_UserDataQosPolicy &ddsqos, const ::DDS::UserDataQosPolicy & qos) +{ + ddsqos.value <<= qos.value; +} + +#endif + +#endif /* DDS4CCM_USERDATAQOSPOLICY_H */ diff --git a/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/WriterDataLifecycleQosPolicy.h b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/WriterDataLifecycleQosPolicy.h new file mode 100644 index 00000000000..6cecbb95c45 --- /dev/null +++ b/modules/CIAO/connectors/dds4ccm/impl/dds/ndds/WriterDataLifecycleQosPolicy.h @@ -0,0 +1,33 @@ +/** + * @author Johnny Willemsen <jwillemsen@remedy.nl> + * + * $Id$ + * + * Wrapper facade for NDDS. + */ + +#ifndef DDS4CCM_WRITERDATALIFECYCLEQOSPOLICY_H +#define DDS4CCM_WRITERDATALIFECYCLEQOSPOLICY_H + +#include "dds4ccm/impl/dds4ccm_conf.h" + +#if (CIAO_DDS4CCM_OPENDDS==1) +typedef ::DDS::WriterDataLifecycleQosPolicy DDS_WriterDataLifecycleQosPolicy; +#endif + +#if (CIAO_DDS4CCM_NDDS==1) +inline void +operator<<= (::DDS::WriterDataLifecycleQosPolicy &ddsqos, const ::DDS_WriterDataLifecycleQosPolicy & qos) +{ + ddsqos.autodispose_unregistered_instances = qos.autodispose_unregistered_instances; +} + +inline void +operator<<= (::DDS_WriterDataLifecycleQosPolicy &ddsqos, const ::DDS::WriterDataLifecycleQosPolicy & qos) +{ + ddsqos.autodispose_unregistered_instances = qos.autodispose_unregistered_instances; +} + +#endif + +#endif /* DDS4CCM_WRITERDATALIFECYCLEQOSPOLICY_H */ |