1 files changed, 83 insertions, 0 deletions
diff --git a/modules/CIAO/connectors/dds4ccm/impl/ndds/ReadCondition.cpp b/modules/CIAO/connectors/dds4ccm/impl/ndds/ReadCondition.cpp
new file mode 100644
index 00000000000..5ae5382892a
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/impl/ndds/ReadCondition.cpp
@@ -0,0 +1,83 @@
+// $Id$
+
+#include "ReadCondition.h"
+#include "DataReader.h"
+
+namespace CIAO
+{
+  namespace DDS4CCM
+  {
+    namespace RTI
+    {
+      // Implementation skeleton constructor
+      RTI_ReadCondition_i::RTI_ReadCondition_i (void)
+        : impl_ (0)
+      {
+      }
+
+      // Implementation skeleton destructor
+      RTI_ReadCondition_i::~RTI_ReadCondition_i (void)
+      {
+      }
+
+      ::CORBA::Boolean
+      RTI_ReadCondition_i::get_trigger_value (void)
+      {
+        return this->impl ()->get_trigger_value ();
+      }
+
+      ::DDS::SampleStateMask
+      RTI_ReadCondition_i::get_sample_state_mask (void)
+      {
+        return this->impl ()->get_sample_state_mask ();
+      }
+
+      ::DDS::ViewStateMask
+      RTI_ReadCondition_i::get_view_state_mask (void)
+      {
+        return this->impl ()->get_view_state_mask ();
+      }
+
+      ::DDS::InstanceStateMask
+      RTI_ReadCondition_i::get_instance_state_mask (void)
+      {
+        return this->impl ()->get_instance_state_mask ();
+      }
+
+      ::DDS::DataReader_ptr
+      RTI_ReadCondition_i::get_datareader (void)
+      {
+        DDSDataReader* rd = this->impl ()->get_datareader ();
+        ::DDS::DataReader_var retval = new RTI_DataReader_i ();
+        RTI_DataReader_i *rti_dr = dynamic_cast < RTI_DataReader_i *>(retval.in ());
+        rti_dr->set_impl (rd);
+
+        return retval._retn ();
+      }
+
+      DDSReadCondition *
+      RTI_ReadCondition_i::get_impl (void)
+      {
+        return this->impl_;
+      }
+
+      void
+      RTI_ReadCondition_i::set_impl (DDSReadCondition * rc)
+      {
+        this->impl_ = rc;
+      }
+
+      DDSReadCondition *
+      RTI_ReadCondition_i::impl (void)
+      {
+        if (!this->impl_)
+          {
+            throw ::CORBA::BAD_INV_ORDER ();
+          }
+        return this->impl_;
+      }
+
+    }
+  }
+}
+