diff options
Diffstat (limited to 'tests/Buffer_Stream_Test.cpp')
-rw-r--r-- | tests/Buffer_Stream_Test.cpp | 235 |
1 files changed, 0 insertions, 235 deletions
diff --git a/tests/Buffer_Stream_Test.cpp b/tests/Buffer_Stream_Test.cpp deleted file mode 100644 index 7c903162435..00000000000 --- a/tests/Buffer_Stream_Test.cpp +++ /dev/null @@ -1,235 +0,0 @@ -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// tests -// -// = FILENAME -// Buffer_Stream_Test.cpp -// -// = DESCRIPTION -// This program illustrates an implementation of the classic -// "bounded buffer" program using an ASX STREAM containing two -// Modules. Each ACE_Module contains two Tasks. Each ACE_Task -// contains a ACE_Message_Queue and a pointer to a -// ACE_Thread_Manager. Note how the use of these reusable -// components reduces the reliance on global variables. -// -// = AUTHOR -// Prashant Jain <pjain@cs.wustl.edu> and Doug Schmidt <schmidt@cs.wustl.edu> -// -// ============================================================================ - -#include "test_config.h" -#include "ace/Synch.h" -#include "ace/Stream.h" -#include "ace/Module.h" -#include "ace/Task.h" -#include "ace/OS_NS_time.h" - -ACE_RCSID(tests, Buffer_Stream_Test, "$Id$") - -#if defined (ACE_HAS_THREADS) - -static const char ACE_ALPHABET[] = "abcdefghijklmnopqrstuvwxyz"; - -typedef ACE_Stream<ACE_MT_SYNCH> MT_Stream; -typedef ACE_Module<ACE_MT_SYNCH> MT_Module; -typedef ACE_Task<ACE_MT_SYNCH> MT_Task; - -class Common_Task : public MT_Task - // = TITLE - // Methods that are common to the Supplier and consumer. -{ -public: - Common_Task (void) {} - - // = ACE_Task hooks. - virtual int open (void * = 0); - virtual int close (u_long = 0); -}; - -class Supplier : public Common_Task -// = TITLE -// Define the Supplier interface. -{ -public: - Supplier (void) {} - - virtual int svc (void); - // Read data from stdin and pass to consumer. -}; - -class Consumer : public Common_Task - // = TITLE - // Define the Consumer interface. -{ -public: - Consumer (void) {} - - virtual int put (ACE_Message_Block *mb, ACE_Time_Value *tv = 0); - // Enqueue the message on the ACE_Message_Queue for subsequent - // handling in the svc() method. - - virtual int svc (void); - // Receive message from Supplier and print to stdout. -private: - - ACE_Time_Value timeout_; - // Amount of time to wait for a timeout. -}; - -// Spawn off a new thread. - -int -Common_Task::open (void *) -{ - if (this->activate (THR_NEW_LWP | THR_DETACHED) == -1) - ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("spawn")), -1); - return 0; -} - -int -Common_Task::close (u_long exit_status) -{ - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("(%t) thread is exiting with status %d in module %s\n"), - exit_status, - this->name ())); - - // Can do anything here that is required when a thread exits, e.g., - // storing thread-specific information in some other storage - // location, etc. - return 0; -} - -// The Supplier reads data from the stdin stream, creates a message, -// and then queues the message in the message list, where it is -// removed by the consumer thread. A 0-sized message is enqueued when -// there is no more data to read. The consumer uses this as a flag to -// know when to exit. - -int -Supplier::svc (void) -{ - ACE_Message_Block *mb; - - // Send one message for each letter of the alphabet, then send an empty - // message to mark the end. - for (const char *c = ACE_ALPHABET; *c != '\0'; c++) - { - // Allocate a new message. - char d[2]; - d[0] = *c; - d[1] = '\0'; - - ACE_NEW_RETURN (mb, - ACE_Message_Block (2), - -1); - ACE_OS::strcpy (mb->wr_ptr (), d); - - mb->wr_ptr (2); - - if (this->put_next (mb) == -1) - ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"), - ACE_TEXT ("put_next"))); - } - - ACE_NEW_RETURN(mb, ACE_Message_Block, -1); - if (this->put_next (mb) == -1) - ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"), ACE_TEXT ("put_next"))); - - return 0; -} - -int -Consumer::put (ACE_Message_Block *mb, ACE_Time_Value *tv) -{ - // Simply enqueue the Message_Block into the end of the queue. - return this->putq (mb, tv); -} - -// The consumer dequeues a message from the ACE_Message_Queue, writes -// the message to the stderr stream, and deletes the message. The -// Consumer sends a 0-sized message to inform the consumer to stop -// reading and exit. - -int -Consumer::svc (void) -{ - ACE_Message_Block *mb = 0; - int result; - const char *c = ACE_ALPHABET; - char *output; - - // Keep looping, reading a message out of the queue, until we - // timeout or get a message with a length == 0, which signals us to - // quit. - - for (;;) - { - this->timeout_.sec (ACE_OS::time (0) + 4); // Wait for upto 4 seconds - - result = this->getq (mb, &this->timeout_); - - if (result == -1) - break; - - size_t length = mb->length (); - - if (length > 0) - { - output = mb->rd_ptr (); - ACE_ASSERT (*c == output[0]); - c++; - } - mb->release (); - - if (length == 0) - break; - } - -#if !defined (ACE_HAS_WINCE) - ACE_ASSERT (result == 0 || errno == EWOULDBLOCK); -#endif /* ! ACE_HAS_WINCE */ - return 0; -} - -#endif /* ACE_HAS_THREADS */ - -// Main driver function. - -int -run_main (int, ACE_TCHAR *[]) -{ - ACE_START_TEST (ACE_TEXT ("Buffer_Stream_Test")); - -#if defined (ACE_HAS_THREADS) - // Control hierachically-related active objects. - MT_Stream stream; - MT_Module *cm; - MT_Module *sm; - - // Allocate the Consumer and Supplier modules. - ACE_NEW_RETURN (cm, MT_Module (ACE_TEXT ("Consumer"), new Consumer), -1); - ACE_NEW_RETURN (sm, MT_Module (ACE_TEXT ("Supplier"), new Supplier), -1); - - // Create Supplier and Consumer Modules and push them onto the - // Stream. All processing is performed in the Stream. - - if (stream.push (cm) == -1) - ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("push")), 1); - else if (stream.push (sm) == -1) - ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("push")), 1); - - // Barrier synchronization: wait for the threads to exit, then exit - // ourselves. - ACE_Thread_Manager::instance ()->wait (); -#else - ACE_ERROR ((LM_INFO, - ACE_TEXT ("threads not supported on this platform\n"))); -#endif /* ACE_HAS_THREADS */ - ACE_END_TEST; - return 0; -} |