git-svn-id: svn+ssh://mecka.net/home/svn/dds@3 c30cbac5-9f56-4f76-8ed5-5c34e48a65ae

3 files changed, 2 insertions, 9 deletions

diff --git a/dds_io_sub/DataReaderListener.cpp b/dds_io_sub/DataReaderListener.cpp
index c110174..c39dcf9 100644
--- a/dds_io_sub/DataReaderListener.cpp
+++ b/dds_io_sub/DataReaderListener.cpp
@@ -11,7 +11,6 @@ using namespace IOTest;
 
 // Implementation skeleton constructor
 DataReaderListenerImpl::DataReaderListenerImpl()
-  : num_reads_(0)
 {
 }
 
@@ -23,7 +22,6 @@ DataReaderListenerImpl::~DataReaderListenerImpl ()
 void DataReaderListenerImpl::on_data_available(DDS::DataReader_ptr reader)
   throw (CORBA::SystemException)
 {
-  num_reads_ ++;
 
   try {
     ::IOTest::PortDataReader_var port_dr = ::IOTest::PortDataReader::_narrow(reader);
diff --git a/dds_io_sub/DataReaderListener.h b/dds_io_sub/DataReaderListener.h
index 355e2cd..26f94ed 100644
--- a/dds_io_sub/DataReaderListener.h
+++ b/dds_io_sub/DataReaderListener.h
@@ -62,14 +62,11 @@ public:
   )
   throw (CORBA::SystemException);
 
-  long num_reads() const {
-    return num_reads_;
-  }
 
 private:
   DIASIO io;
   DDS::DataReader_var reader_;
-  long                  num_reads_;
+
 };
 
 #endif /* DATAREADER_LISTENER_IMPL  */
diff --git a/dds_io_sub/dds_io_sub.cpp b/dds_io_sub/dds_io_sub.cpp
index 6cdaabd..ae153b4 100644
--- a/dds_io_sub/dds_io_sub.cpp
+++ b/dds_io_sub/dds_io_sub.cpp
@@ -187,9 +187,7 @@ int main (int argc, char *argv[])
         exit(1);
       }
 
-
-      int expected = 10;
-      while ( listener_servant.num_reads() < expected) {
+      while(1) {
         ACE_OS::sleep (1);
       }