summaryrefslogtreecommitdiff
path: root/docs/tutorials/011/message_queue.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'docs/tutorials/011/message_queue.cpp')
-rw-r--r--docs/tutorials/011/message_queue.cpp86
1 files changed, 0 insertions, 86 deletions
diff --git a/docs/tutorials/011/message_queue.cpp b/docs/tutorials/011/message_queue.cpp
deleted file mode 100644
index 3c91f7cc66f..00000000000
--- a/docs/tutorials/011/message_queue.cpp
+++ /dev/null
@@ -1,86 +0,0 @@
-// $Id$
-
-/* Most of this is the same as the previous tutorial, so I'll just
- point out the differences. */
-#include "task.h"
-#include "block.h"
-#include "data.h"
-
-
-static int
-run_test (int iterations,
- int threads)
-
-{
- Task task (threads);
-
- if (task.open () == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "open"),
- -1);
-
- ACE_OS::sleep (ACE_Time_Value (1));
-
- int i;
- for (i = 0; i < iterations; ++i)
- {
- /* Construct a Data object that we'll put into the Queue. */
- Data data (i);
-
- /* Create a block large enough for our Data object as well as a
- text message. */
- Block *message;
-
- ACE_NEW_RETURN (message,
- Block (sizeof (data) + 128),
- -1);
-
- /* As before, put a text message into the block. */
- ACE_OS::sprintf (message->wr_ptr (), "This is message %d.", i);
- message->wr_ptr (strlen (message->rd_ptr ()));
-
- *(message->wr_ptr ()) = 0; // Null-terminate the string we just wrote
-
- message->wr_ptr (1); // Move beyond the NULL
-
- /* To copy arbitrary data into a message block, we use the
- copy() method. Since it wants a 'const char*', we have to
- cast our Data pointer.
-
- Note that copy() will advance the wr_ptr() for us. This means
- we don't have to do it ourselves! If you do advance it, it
- will be way beyond what you want. */
- message->copy ((const char *) &data,
- sizeof (data));
-
- if (task.putq (message) == -1)
- break;
- }
-
- Block *message;
- ACE_NEW_RETURN (message,
- Block,
- -1);
- message->msg_type (ACE_Message_Block::MB_HANGUP);
- task.putq (message);
-
- task.wait ();
-
- return 0;
-}
-
-int
-main (int argc, char *argv[])
-{
- int iterations = argc > 1 ? atoi (argv[1]) : 4;
- int threads = argc > 2 ? atoi (argv[2]) : 2;
-
- run_test (iterations,
- threads);
-
- ACE_DEBUG ((LM_DEBUG,
- "(%P|%t) Application exiting\n"));
-
- return 0;
-}