diff options
Diffstat (limited to 'CIAO/tests/DDS/Publisher/publisher.cpp')
| -rw-r--r-- | CIAO/tests/DDS/Publisher/publisher.cpp | 32 |
1 files changed, 17 insertions, 15 deletions
diff --git a/CIAO/tests/DDS/Publisher/publisher.cpp b/CIAO/tests/DDS/Publisher/publisher.cpp index a14c8780e4f..6f412c89fd1 100644 --- a/CIAO/tests/DDS/Publisher/publisher.cpp +++ b/CIAO/tests/DDS/Publisher/publisher.cpp @@ -19,8 +19,8 @@ const OpenDDS::DCPS::TransportIdType TRANSPORT_IMPL_ID = 1; // constants for Stock Ddstopicr domain Id, types, and topic DDS::DomainId_t DDSTOPIC_DOMAIN_ID = 467; -const char* DDSTOPIC_TYPE = "DDS Test"; -const char* DDSTEST_TOPIC = "DDSTopic"; +const char* DDSTOPIC_TYPE = "DDSTopic"; +const char* DDSTEST_TOPIC = "DDSTopic Data"; int main (int argc, char *argv[]) { @@ -131,21 +131,23 @@ int main (int argc, char *argv[]) { // Publish... ACE_Time_Value wait_time( 1, 0 ); - for ( int i = 0; i < 8; ++i ) { - DDSTopic ddstopic; - ddstopic.id = CORBA::string_dup("Asynch Message"); - ddstopic.sequence_number = i; - - cout << "Writing Ddstopicr, count " << i << endl; - - DDS::ReturnCode_t ret = ddstopic_dw->write(ddstopic, topic_handle); - if (ret != DDS::RETCODE_OK) { - ACE_ERROR ((LM_ERROR, ACE_TEXT("(%P|%t)ERROR: topic write returned %d.\n"), ret)); + long i = 0; + while(true) + { + DDSTopic ddstopic; + ddstopic.id = CORBA::string_dup("Asynch Message"); + ddstopic.sequence_number = i++; + + cout << "Writing DDSTopic [" << i << "]" << endl; + + DDS::ReturnCode_t ret = ddstopic_dw->write(ddstopic, topic_handle); + if (ret != DDS::RETCODE_OK) { + ACE_ERROR ((LM_ERROR, ACE_TEXT("(%P|%t)ERROR: topic write returned %d.\n"), ret)); + } + + ACE_OS::sleep( wait_time ); } - ACE_OS::sleep( wait_time ); - } - } catch (CORBA::Exception& e) { cerr << "Exception caught in main.cpp:" << endl << e << endl; |