diff options
author | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-01-23 23:16:39 +0000 |
---|---|---|
committer | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-01-23 23:16:39 +0000 |
commit | b983862f8e9443fff2939eb6b629afe299837f75 (patch) | |
tree | 443b9d808e53debe85eb85cf78995d5fb45e8349 /tests/Message_Queue_Test.cpp | |
parent | 1ba527bb358117826342453bfb69ea96a9a4ce03 (diff) | |
download | ATCD-poa_end.tar.gz |
This commit was manufactured by cvs2svn to create tag 'poa_end'.poa_end
Diffstat (limited to 'tests/Message_Queue_Test.cpp')
-rw-r--r-- | tests/Message_Queue_Test.cpp | 105 |
1 files changed, 0 insertions, 105 deletions
diff --git a/tests/Message_Queue_Test.cpp b/tests/Message_Queue_Test.cpp deleted file mode 100644 index 6ea1d61b945..00000000000 --- a/tests/Message_Queue_Test.cpp +++ /dev/null @@ -1,105 +0,0 @@ -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// tests -// -// = FILENAME -// Message_Queue_Test.cpp -// -// = DESCRIPTION -// This is a simple test of the ACE_Message_Queue that -// illustrates how to use the forward and reverse iterators. -// -// = AUTHOR -// Irfan Pyarali -// -// ============================================================================ - -#include "test_config.h" -#include "ace/Message_Queue.h" -#include "ace/Synch.h" - -typedef ACE_Message_Queue <ACE_NULL_SYNCH> QUEUE; -typedef ACE_Message_Queue_Iterator <ACE_NULL_SYNCH> ITERATOR; -typedef ACE_Message_Queue_Reverse_Iterator <ACE_NULL_SYNCH> REVERSE_ITERATOR; - -int -main (int, char *[]) -{ - ACE_START_TEST ("Message_Queue_Test"); - - const int ITERATIONS = 5; - char buffer[ITERATIONS][BUFSIZ]; - QUEUE queue (32 * 1024); - int i; - - for (i = 0; i < ITERATIONS; i++) - { - ACE_OS::sprintf (buffer[i], "%d", i+1); - - ACE_Message_Block *entry; - ACE_NEW_RETURN (entry, ACE_Message_Block (buffer[i], sizeof buffer[i]), -1); - - if (queue.is_full ()) - ACE_ERROR_RETURN ((LM_ERROR, - "QUEUE:: the message queue is full on iteration %u!\n", - i+1), - -1); - - if (queue.enqueue (entry) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "QUEUE::enqueue\n"), -1); - } - - ACE_DEBUG ((LM_DEBUG, "\nForward Iterations\n")); - { - ITERATOR iterator (queue); - - for (ACE_Message_Block *entry = 0; - iterator.next (entry) != 0; - iterator.advance ()) - ACE_DEBUG ((LM_DEBUG, "%s\n", entry->base ())); - } - - ACE_DEBUG ((LM_DEBUG, "\nReverse Iterations\n")); - { - REVERSE_ITERATOR iterator (queue); - - for (ACE_Message_Block *entry = 0; - iterator.next (entry) != 0; - iterator.advance ()) - ACE_DEBUG ((LM_DEBUG, "%s\n", entry->base ())); - } - - ACE_DEBUG ((LM_DEBUG, "\nForward Iterations\n")); - { - QUEUE::ITERATOR iterator (queue); - - for (ACE_Message_Block *entry = 0; - iterator.next (entry) != 0; - iterator.advance ()) - ACE_DEBUG ((LM_DEBUG, "%s\n", entry->base ())); - } - - ACE_DEBUG ((LM_DEBUG, "\nReverse Iterations\n")); - { - QUEUE::REVERSE_ITERATOR iterator (queue); - - for (ACE_Message_Block *entry = 0; - iterator.next (entry) != 0; - iterator.advance ()) - ACE_DEBUG ((LM_DEBUG, "%s\n", entry->base ())); - } - - ACE_END_TEST; - return 0; -} - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class ACE_Message_Queue_Iterator<ACE_NULL_SYNCH>; -template class ACE_Message_Queue_Reverse_Iterator<ACE_NULL_SYNCH>; -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate ACE_Message_Queue_Iterator<ACE_NULL_SYNCH> -#pragma instantiate ACE_Message_Queue_Reverse_Iterator<ACE_NULL_SYNCH> -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |