summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2010-06-29 13:11:57 +0000
committerJohnny Willemsen <jwillemsen@remedy.nl>2010-06-29 13:11:57 +0000
commitb38209befc51f797c74fe9afc180d40063e8a208 (patch)
tree60a26ba2099a30fb6502404c07a405fa3dcadf15
parent41f70459381183a8c87ae786624595c1d4003b10 (diff)
downloadATCD-b38209befc51f797c74fe9afc180d40063e8a208.tar.gz
Tue Jun 29 13:09:53 UTC 2010 Johnny Willemsen <jwillemsen@remedy.nl>
* DAnCE/tests/NodeManager-NodeApplicationManager/NodeManager-NodeApplicationManager.mpc: Fixed nmake warning * connectors/dds4ccm/impl/Publisher_T.cpp: * connectors/dds4ccm/impl/Subscriber_T.cpp: Cleanup code
-rw-r--r--CIAO/ChangeLog9
-rw-r--r--CIAO/DAnCE/tests/NodeManager-NodeApplicationManager/NodeManager-NodeApplicationManager.mpc3
-rw-r--r--CIAO/connectors/dds4ccm/impl/Publisher_T.cpp68
-rw-r--r--CIAO/connectors/dds4ccm/impl/Subscriber_T.cpp66
4 files changed, 10 insertions, 136 deletions
diff --git a/CIAO/ChangeLog b/CIAO/ChangeLog
index bb6d4568588..70668aaf7a8 100644
--- a/CIAO/ChangeLog
+++ b/CIAO/ChangeLog
@@ -1,3 +1,12 @@
+Tue Jun 29 13:09:53 UTC 2010 Johnny Willemsen <jwillemsen@remedy.nl>
+
+ * DAnCE/tests/NodeManager-NodeApplicationManager/NodeManager-NodeApplicationManager.mpc:
+ Fixed nmake warning
+
+ * connectors/dds4ccm/impl/Publisher_T.cpp:
+ * connectors/dds4ccm/impl/Subscriber_T.cpp:
+ Cleanup code
+
Tue Jun 29 12:42:04 UTC 2010 Marijke Hengstmengel <mhengstmengel@remedy.nl>
* connectors/ami4ccm/tutorials/Hello/Tutorial/01_general.html
diff --git a/CIAO/DAnCE/tests/NodeManager-NodeApplicationManager/NodeManager-NodeApplicationManager.mpc b/CIAO/DAnCE/tests/NodeManager-NodeApplicationManager/NodeManager-NodeApplicationManager.mpc
index 6e10cfaf57e..bc18cab6dd2 100644
--- a/CIAO/DAnCE/tests/NodeManager-NodeApplicationManager/NodeManager-NodeApplicationManager.mpc
+++ b/CIAO/DAnCE/tests/NodeManager-NodeApplicationManager/NodeManager-NodeApplicationManager.mpc
@@ -1,8 +1,7 @@
// $Id$
-project : dance_exe, dance_nodemanager_stub, dance_logger {
+project : dance, dance_nodemanager_stub, dance_logger {
exename = NodeManagerNodeApplicationManagerTest
- exeout = .
Source_Files {
test.cpp
diff --git a/CIAO/connectors/dds4ccm/impl/Publisher_T.cpp b/CIAO/connectors/dds4ccm/impl/Publisher_T.cpp
index 1c27e29736c..51d17bb6d56 100644
--- a/CIAO/connectors/dds4ccm/impl/Publisher_T.cpp
+++ b/CIAO/connectors/dds4ccm/impl/Publisher_T.cpp
@@ -44,7 +44,6 @@ namespace CIAO
{
DDS4CCM_TRACE ("CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::create_datawriter");
-#if (CIAO_DDS4CCM_NDDS==1)
ACE_UNUSED_ARG (qos);
Topic_type * topic = dynamic_cast < Topic_type * > (a_topic);
@@ -86,12 +85,6 @@ namespace CIAO
ccm_dds_dw->enable ();
return retval._retn ();
-#else
- return this->impl ()->create_datawriter (a_topic,
- qos,
- a_listener,
- mask);
-#endif
}
#if (CIAO_DDS4CCM_NDDS==1)
@@ -162,7 +155,6 @@ namespace CIAO
{
DDS4CCM_TRACE ("CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::delete_datawriter");
-#if (CIAO_DDS4CCM_NDDS==1)
DataWriter_type *top = dynamic_cast< DataWriter_type * > (a_datawriter);
if (top == 0)
@@ -194,9 +186,6 @@ namespace CIAO
}
return retval;
-#else
- return this->impl ()->delete_datawriter (a_datawriter);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -204,17 +193,10 @@ namespace CIAO
CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::lookup_datawriter (const char * impl_name)
{
::DDS::DataWriter_var retval = ::DDS::DataWriter::_nil ();
-#if (CIAO_DDS4CCM_NDDS==1)
DDSDataWriter* dw = this->impl ()->lookup_datawriter (impl_name);
ACE_NEW_THROW_EX (retval,
DataWriter_type (dw),
CORBA::NO_MEMORY ());
-#else
- ::DDS::DataWriter_var dw = this->impl ()->lookup_datawriter (impl_name);
- ACE_NEW_THROW_EX (retval,
- DataWriter_type (dw.in ()),
- CORBA::NO_MEMORY ());
-#endif
return retval._retn ();
}
@@ -230,13 +212,9 @@ namespace CIAO
CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::set_qos (const ::DDS::PublisherQos & qos)
{
DDS4CCM_TRACE ("CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::set_qos");
-#if (CIAO_DDS4CCM_NDDS==1)
::DDS_PublisherQos ccm_dds_qos;
ccm_dds_qos <<= qos;
return this->impl ()->set_qos (ccm_dds_qos);
-#else
- return this->impl ()->set_qos (qos);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -244,16 +222,12 @@ namespace CIAO
CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_qos (::DDS::PublisherQos & qos)
{
DDS4CCM_TRACE ("CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_qos");
-#if (CIAO_DDS4CCM_NDDS==1)
::DDS_PublisherQos ccm_dds_qos;
ccm_dds_qos <<= qos;
::DDS::ReturnCode_t retcode = this->impl()->
get_qos (ccm_dds_qos);
qos <<= ccm_dds_qos;
return retcode;
-#else
- return this->impl ()->get_qos (qos);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -263,7 +237,6 @@ namespace CIAO
{
DDS4CCM_TRACE ("CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::set_listener");
-#if (CIAO_DDS4CCM_NDDS==1)
PublisherListener_type * ccm_dds_impl_list = 0;
if (! ::CORBA::is_nil (a_listener))
{
@@ -272,9 +245,6 @@ namespace CIAO
CORBA::NO_MEMORY ());
}
return this->impl ()->set_listener (ccm_dds_impl_list, mask);
-#else
- return this->impl ()->set_listener (a_listener, mask);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -283,7 +253,6 @@ namespace CIAO
{
DDS4CCM_TRACE ("CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_listener");
-#if (CIAO_DDS4CCM_NDDS==1)
DDSPublisherListener *ccm_dds_pub_list = this->impl ()->get_listener ();
PublisherListener_type * list_proxy =
dynamic_cast <PublisherListener_type *> (ccm_dds_pub_list);
@@ -295,9 +264,6 @@ namespace CIAO
return ::DDS::PublisherListener::_nil ();
}
return list_proxy->get_publisher_listener ();
-#else
- return this->impl ()->get_listener ();
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -333,13 +299,9 @@ namespace CIAO
CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::wait_for_acknowledgments (
const ::DDS::Duration_t & max_wait)
{
-#if (CIAO_DDS4CCM_NDDS==1)
DDS_Duration_t ccm_dds_dds_duration;
ccm_dds_dds_duration <<= max_wait;
return this->impl ()->wait_for_acknowledgments (ccm_dds_dds_duration);
-#else
- return this->impl ()->wait_for_acknowledgments (max_wait);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -348,17 +310,10 @@ namespace CIAO
{
DDS4CCM_TRACE ("CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_participant");
::DDS::DomainParticipant_var retval = ::DDS::DomainParticipant::_nil ();
-#if (CIAO_DDS4CCM_NDDS==1)
DDSDomainParticipant* p = this->impl ()->get_participant ();
ACE_NEW_THROW_EX (retval,
DomainParticipant_type (p),
CORBA::NO_MEMORY ());
-#else
- ::DDS::DomainParticipant_var p = this->impl ()->get_participant ();
- ACE_NEW_THROW_EX (retval,
- DomainParticipant_type (p.in ()),
- CORBA::NO_MEMORY ());
-#endif
return retval._retn ();
}
@@ -367,13 +322,9 @@ namespace CIAO
CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::set_default_datawriter_qos (const ::DDS::DataWriterQos & qos)
{
DDS4CCM_TRACE ("CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::set_default_datawriter_qos");
-#if (CIAO_DDS4CCM_NDDS==1)
::DDS_DataWriterQos ccm_dds_qos;
ccm_dds_qos <<= qos;
return this->impl()->set_default_datawriter_qos (ccm_dds_qos);
-#else
- return this->impl()->set_default_datawriter_qos (qos);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -381,15 +332,11 @@ namespace CIAO
CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_default_datawriter_qos (::DDS::DataWriterQos & qos)
{
DDS4CCM_TRACE ("CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_default_datawriter_qos");
-#if (CIAO_DDS4CCM_NDDS==1)
::DDS_DataWriterQos ccm_dds_qos;
::DDS::ReturnCode_t retcode =
this->impl()->get_default_datawriter_qos (ccm_dds_qos);
qos <<= ccm_dds_qos;
return retcode;
-#else
- return this->impl()->get_default_datawriter_qos (qos);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -398,7 +345,6 @@ namespace CIAO
const ::DDS::TopicQos & a_impl_qos)
{
DDS4CCM_TRACE ("CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::copy_from_topic_qos");
-#if (CIAO_DDS4CCM_NDDS==1)
::DDS_DataWriterQos ccm_dds_qos;
::DDS_TopicQos ccm_dds_topic_qos;
@@ -408,9 +354,6 @@ namespace CIAO
this->impl()->copy_from_topic_qos (ccm_dds_qos, ccm_dds_topic_qos);
a_dataimpl_qos <<= ccm_dds_qos;
return retcode;
-#else
- return this->impl()->copy_from_topic_qos (a_dataimpl_qos, a_impl_qos);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -425,17 +368,10 @@ namespace CIAO
CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_statuscondition (void)
{
::DDS::StatusCondition_var retval = ::DDS::StatusCondition::_nil ();
-#if (CIAO_DDS4CCM_NDDS==1)
DDSStatusCondition* sc = this->impl ()->get_statuscondition ();
ACE_NEW_THROW_EX (retval,
CCM_DDS_StatusCondition_i (sc),
CORBA::NO_MEMORY ());
-#else
- ::DDS::StatusCondition_var sc = this->impl ()->get_statuscondition ();
- ACE_NEW_THROW_EX (retval,
- CCM_DDS_StatusCondition_i (sc.in ()),
- CORBA::NO_MEMORY ());
-#endif
return retval._retn ();
}
@@ -450,14 +386,10 @@ namespace CIAO
::DDS::InstanceHandle_t
CCM_DDS_Publisher_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_instance_handle (void)
{
-#if (CIAO_DDS4CCM_NDDS==1)
::DDS_InstanceHandle_t const rtihandle = this->impl ()->get_instance_handle ();
::DDS::InstanceHandle_t handle;
handle <<= rtihandle;
return handle;
-#else
- return this->impl ()->get_instance_handle ();
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
diff --git a/CIAO/connectors/dds4ccm/impl/Subscriber_T.cpp b/CIAO/connectors/dds4ccm/impl/Subscriber_T.cpp
index 3a2ba2e84c7..567d22a5799 100644
--- a/CIAO/connectors/dds4ccm/impl/Subscriber_T.cpp
+++ b/CIAO/connectors/dds4ccm/impl/Subscriber_T.cpp
@@ -47,7 +47,6 @@ namespace CIAO
CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_statuscondition (void)
{
::DDS::StatusCondition_var retval = ::DDS::StatusCondition::_nil ();
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
DDSStatusCondition* sc = this->impl ()->get_statuscondition ();
if (sc)
{
@@ -55,15 +54,6 @@ namespace CIAO
CCM_DDS_StatusCondition_i (sc),
CORBA::NO_MEMORY ());
}
-#else
- ::DDS::StatusCondition_var sc = this->impl ()->get_statuscondition ();
- if (! ::CORBA::is_nil (sc.in ()))
- {
- ACE_NEW_THROW_EX (retval,
- CCM_DDS_StatusCondition_i (sc.in ()),
- CORBA::NO_MEMORY ());
- }
-#endif
return retval._retn ();
}
@@ -78,14 +68,10 @@ namespace CIAO
::DDS::InstanceHandle_t
CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_instance_handle (void)
{
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
::DDS_InstanceHandle_t const rtihandle = this->impl ()->get_instance_handle ();
::DDS::InstanceHandle_t handle;
handle <<= rtihandle;
return handle;
-#else
- return this->impl ()->get_instance_handle ();
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -96,19 +82,12 @@ namespace CIAO
::DDS::StatusMask mask,
const ::DDS::DataReaderQos & qos)
{
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
ACE_UNUSED_ARG (qos);
DDS_DataReaderQos ccm_dds_qos = DDS_DATAREADER_QOS_DEFAULT;
return this->impl ()->create_datareader (topic,
ccm_dds_qos,
ccm_dds_drl,
mask);
-#else
- return this->impl ()->create_datareader (topic,
- qos,
- ccm_dds_drl,
- mask);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -119,19 +98,12 @@ namespace CIAO
::DDS::StatusMask mask,
const ::DDS::DataReaderQos & qos)
{
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
ACE_UNUSED_ARG (qos);
DDS_DataReaderQos ccm_dds_qos = DDS_DATAREADER_QOS_DEFAULT;
return this->impl ()->create_datareader (topic,
ccm_dds_qos,
ccm_dds_drl,
mask);
-#else
- return this->impl ()->create_datareader (topic,
- qos,
- ccm_dds_drl,
- mask);
-#endif
}
#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
@@ -380,7 +352,6 @@ namespace CIAO
::DDS::InstanceStateMask instance_states)
{
CIAO_TRACE ("CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::set_qos");
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
::DDSDataReaderSeq dds_readers;
::DDS_ReturnCode_t retcode =
@@ -401,12 +372,6 @@ namespace CIAO
}
}
return retcode;
-#else
- return this->impl ()->get_datareaders (readers,
- sample_states,
- view_states,
- instance_states);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -422,13 +387,9 @@ namespace CIAO
const ::DDS::SubscriberQos & qos)
{
CIAO_TRACE ("CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::set_qos");
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
::DDS_SubscriberQos ccm_dds_qos;
ccm_dds_qos <<= qos;
return this->impl ()->get_qos (ccm_dds_qos);
-#else
- return this->impl ()->set_qos (qos);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -437,14 +398,10 @@ namespace CIAO
::DDS::SubscriberQos & qos)
{
CIAO_TRACE ("CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_qos");
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
::DDS_SubscriberQos ccm_dds_qos;
::DDS::ReturnCode_t retcode = this->impl ()->get_qos (ccm_dds_qos);
qos <<= ccm_dds_qos;
return retcode;
-#else
- return this->impl ()->get_qos (qos);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -502,7 +459,6 @@ namespace CIAO
CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_participant (void)
{
::DDS::DomainParticipant_var retval = ::DDS::DomainParticipant::_nil ();
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
DDSDomainParticipant* p = this->impl ()->get_participant ();
if (p)
{
@@ -510,15 +466,6 @@ namespace CIAO
DomainParticipant_type (p),
CORBA::NO_MEMORY ());
}
-#else
- ::DDS::DomainParticipant_var p = this->impl ()->get_participant ();
- if (! ::CORBA::is_nil (p.in))
- {
- ACE_NEW_THROW_EX (retval,
- CCM_DDS_DomainParticipant_T (p.in ()),
- CORBA::NO_MEMORY ());
- }
-#endif
return retval._retn ();
}
@@ -528,13 +475,9 @@ namespace CIAO
const ::DDS::DataReaderQos & qos)
{
CIAO_TRACE ("CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::set_default_datareader_qos");
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
::DDS_DataReaderQos ccm_dds_qos;
ccm_dds_qos <<= qos;
return this->impl ()->set_default_datareader_qos (ccm_dds_qos);
-#else
- return this->impl ()->set_default_datareader_qos (qos);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -543,14 +486,10 @@ namespace CIAO
::DDS::DataReaderQos & qos)
{
CIAO_TRACE ("CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::get_default_datareader_qos");
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
::DDS_DataReaderQos ccm_dds_qos;
::DDS::ReturnCode_t retcode = this->impl ()->get_default_datareader_qos (ccm_dds_qos);
qos <<= ccm_dds_qos;
return retcode;
-#else
- return this->impl ()->get_default_datareader_qos (qos);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
@@ -560,7 +499,6 @@ namespace CIAO
const ::DDS::TopicQos & a_impl_qos)
{
DDS4CCM_TRACE ("CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::copy_from_topic_qos");
-#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
::DDS_DataReaderQos ccm_dds_qos;
::DDS_TopicQos ccm_dds_topic_qos;
@@ -571,10 +509,6 @@ namespace CIAO
ccm_dds_topic_qos);
a_datareader_qos <<= ccm_dds_qos;
return retcode;
-#else
- return this->impl()->copy_from_topic_qos (a_datareader_qos,
- a_impl_qos);
-#endif
}
template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>