summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/impl/ndds
diff options
context:
space:
mode:
authormsmit <msmit@remedy.nl>2010-11-15 11:13:57 +0000
committermsmit <msmit@remedy.nl>2010-11-15 11:13:57 +0000
commit013cae37308c94cb6ae823884c9c7bf8021f4397 (patch)
tree772f29b9cd49483484c331ab35030b71d394e44c /CIAO/connectors/dds4ccm/impl/ndds
parent92671a45abac3abdb763755ee75bce7444add78f (diff)
downloadATCD-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.cpp90
-rw-r--r--CIAO/connectors/dds4ccm/impl/ndds/DomainParticipantManager.cpp2
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 ();
}