diff options
author | msmit <msmit@remedy.nl> | 2010-11-15 11:13:57 +0000 |
---|---|---|
committer | msmit <msmit@remedy.nl> | 2010-11-15 11:13:57 +0000 |
commit | 013cae37308c94cb6ae823884c9c7bf8021f4397 (patch) | |
tree | 772f29b9cd49483484c331ab35030b71d394e44c /CIAO/connectors/dds4ccm/impl/ndds | |
parent | 92671a45abac3abdb763755ee75bce7444add78f (diff) | |
download | ATCD-013cae37308c94cb6ae823884c9c7bf8021f4397.tar.gz |
Mon Nov 15 11:12:22 UTC 2010 Marcel Smit <msmit@remedy.nl>
* connectors/dds4ccm/impl/DataReaderListener_T.cpp:
Initialize listening mask to 0.
* connectors/dds4ccm/impl/ndds/DataReader_T.cpp:
No need to re-assign instance state mask, view state mask and
sample mask since they're all unsigned longs.
* connectors/dds4ccm/impl/ndds/DomainParticipantManager.cpp:
don't close down typesupport for now.
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/ndds')
-rw-r--r-- | CIAO/connectors/dds4ccm/impl/ndds/DataReader_T.cpp | 90 | ||||
-rw-r--r-- | CIAO/connectors/dds4ccm/impl/ndds/DomainParticipantManager.cpp | 2 |
2 files changed, 19 insertions, 73 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DataReader_T.cpp b/CIAO/connectors/dds4ccm/impl/ndds/DataReader_T.cpp index 71af90c619c..0ec429a99d3 100644 --- a/CIAO/connectors/dds4ccm/impl/ndds/DataReader_T.cpp +++ b/CIAO/connectors/dds4ccm/impl/ndds/DataReader_T.cpp @@ -107,24 +107,15 @@ namespace CIAO DDS_SampleInfoSeq dds_sample_infos; dds_sample_infos <<= sample_infos; - ::DDS_SampleStateMask dds_sample_states = DDS_ANY_SAMPLE_STATE; - dds_sample_states = sample_states; - - ::DDS_ViewStateMask dds_view_states = DDS_ANY_VIEW_STATE; - dds_view_states = view_states; - - ::DDS_InstanceStateMask dds_instance_states = DDS_ANY_INSTANCE_STATE; - dds_instance_states = instance_states; - typename DDS_TYPE::dds_seq_type dds_data_values; ::DDS::ReturnCode_t const retcode_read = this->rti_entity ()->read (dds_data_values, dds_sample_infos, max_samples, - dds_sample_states, - dds_view_states, - dds_instance_states); + sample_states, + view_states, + instance_states); this->complete_read (dds_data_values, data_values, dds_sample_infos, sample_infos, retcode_read, "read"); @@ -146,24 +137,15 @@ namespace CIAO DDS_SampleInfoSeq dds_sample_infos; dds_sample_infos <<= sample_infos; - ::DDS_SampleStateMask dds_sample_states = DDS_ANY_SAMPLE_STATE; - dds_sample_states = sample_states; - - ::DDS_ViewStateMask dds_view_states = DDS_ANY_VIEW_STATE; - dds_view_states = view_states; - - ::DDS_InstanceStateMask dds_instance_states = DDS_ANY_INSTANCE_STATE; - dds_instance_states = instance_states; - typename DDS_TYPE::dds_seq_type dds_data_values; ::DDS::ReturnCode_t const retcode_take = this->rti_entity ()->take (dds_data_values, dds_sample_infos, max_samples, - dds_sample_states, - dds_view_states, - dds_instance_states); + sample_states, + view_states, + instance_states); this->complete_read (dds_data_values, data_values, dds_sample_infos, sample_infos, @@ -289,15 +271,6 @@ namespace CIAO DDS_SampleInfoSeq dds_sample_infos; dds_sample_infos <<= sample_infos; - ::DDS_SampleStateMask dds_sample_states = DDS_ANY_SAMPLE_STATE; - dds_sample_states = sample_states; - - ::DDS_ViewStateMask dds_view_states = DDS_ANY_VIEW_STATE; - dds_view_states = view_states; - - ::DDS_InstanceStateMask dds_instance_states = DDS_ANY_INSTANCE_STATE; - dds_instance_states = instance_states; - ::DDS_InstanceHandle_t dds_handle = ::DDS_HANDLE_NIL; dds_handle <<= a_handle; @@ -308,9 +281,9 @@ namespace CIAO dds_sample_infos, max_samples, dds_handle, - dds_sample_states, - dds_view_states, - dds_instance_states); + sample_states, + view_states, + instance_states); this->complete_read (dds_data_values, data_values, dds_sample_infos, sample_infos, retcode_read_instance, "read_instance"); @@ -334,15 +307,6 @@ namespace CIAO DDS_SampleInfoSeq dds_sample_infos; dds_sample_infos <<= sample_infos; - ::DDS_SampleStateMask dds_sample_states = DDS_ANY_SAMPLE_STATE; - dds_sample_states = sample_states; - - ::DDS_ViewStateMask dds_view_states = DDS_ANY_VIEW_STATE; - dds_view_states = view_states; - - ::DDS_InstanceStateMask dds_instance_states = DDS_ANY_INSTANCE_STATE; - dds_instance_states = instance_states; - ::DDS_InstanceHandle_t dds_handle = ::DDS_HANDLE_NIL; dds_handle <<= a_handle; @@ -353,9 +317,9 @@ namespace CIAO dds_sample_infos, max_samples, dds_handle, - dds_sample_states, - dds_view_states, - dds_instance_states); + sample_states, + view_states, + instance_states); this->complete_read (dds_data_values, data_values, dds_sample_infos, sample_infos, retcode_take_instance, "take_instance"); @@ -378,15 +342,6 @@ namespace CIAO DDS_SampleInfoSeq dds_sample_infos; dds_sample_infos <<= sample_infos; - ::DDS_SampleStateMask dds_sample_states = DDS_ANY_SAMPLE_STATE; - dds_sample_states = sample_states; - - ::DDS_ViewStateMask dds_view_states = DDS_ANY_VIEW_STATE; - dds_view_states = view_states; - - ::DDS_InstanceStateMask dds_instance_states = DDS_ANY_INSTANCE_STATE; - dds_instance_states = instance_states; - ::DDS_InstanceHandle_t dds_handle = ::DDS_HANDLE_NIL; dds_handle <<= a_handle; @@ -397,9 +352,9 @@ namespace CIAO dds_sample_infos, max_samples, dds_handle, - dds_sample_states, - dds_view_states, - dds_instance_states); + sample_states, + view_states, + instance_states); this->complete_read (dds_data_values, data_values, dds_sample_infos, sample_infos, retcode_read_next_instance, "read_next_instance"); @@ -422,15 +377,6 @@ namespace CIAO DDS_SampleInfoSeq dds_sample_infos; dds_sample_infos <<= sample_infos; - ::DDS_SampleStateMask dds_sample_states = DDS_ANY_SAMPLE_STATE; - dds_sample_states = sample_states; - - ::DDS_ViewStateMask dds_view_states = DDS_ANY_VIEW_STATE; - dds_view_states = view_states; - - ::DDS_InstanceStateMask dds_instance_states = DDS_ANY_INSTANCE_STATE; - dds_instance_states = instance_states; - ::DDS_InstanceHandle_t dds_handle = ::DDS_HANDLE_NIL; dds_handle <<= a_handle; @@ -441,9 +387,9 @@ namespace CIAO dds_sample_infos, max_samples, dds_handle, - dds_sample_states, - dds_view_states, - dds_instance_states); + sample_states, + view_states, + instance_states); this->complete_read (dds_data_values, data_values, dds_sample_infos, sample_infos, retcode_take_next_instance, "take_next_instance"); diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DomainParticipantManager.cpp b/CIAO/connectors/dds4ccm/impl/ndds/DomainParticipantManager.cpp index 87abe7d1ba8..037ad275d20 100644 --- a/CIAO/connectors/dds4ccm/impl/ndds/DomainParticipantManager.cpp +++ b/CIAO/connectors/dds4ccm/impl/ndds/DomainParticipantManager.cpp @@ -126,7 +126,7 @@ namespace CIAO "DomainParticipantManager::~DomainParticipantManager - " "Finalizing DDS\n")); - DDS_TypeSupport_i::close (); + //DDS_TypeSupport_i::close (); DDSDomainParticipantFactory::finalize_instance (); } |