summaryrefslogtreecommitdiff
path: root/examples/APG/Streams/CommandStream.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/APG/Streams/CommandStream.cpp')
-rw-r--r--examples/APG/Streams/CommandStream.cpp97
1 files changed, 0 insertions, 97 deletions
diff --git a/examples/APG/Streams/CommandStream.cpp b/examples/APG/Streams/CommandStream.cpp
deleted file mode 100644
index def3f123d77..00000000000
--- a/examples/APG/Streams/CommandStream.cpp
+++ /dev/null
@@ -1,97 +0,0 @@
-// $Id$
-
-#include "ace/Log_Msg.h"
-#include "ace/OS_Memory.h"
-#include "CommandStream.h"
-#include "Command.h"
-#include "CommandModule.h"
-#include "CommandTasks.h"
-
-// Gotcha: superclass' open() won't open head/tail modules
-// Gotcha!! Must open the stream before pushing modules!
-
-// Listing 01 code/ch18
-int CommandStream::open (void *arg,
- ACE_Module<ACE_MT_SYNCH> *head,
- ACE_Module<ACE_MT_SYNCH> *tail)
-{
- ACE_TRACE (ACE_TEXT ("CommandStream::open(peer)"));
-
- if (this->inherited::open (arg, head, tail) == -1)
- ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"),
- ACE_TEXT ("Failed to open superclass")),
- -1);
- // Listing 01
-
- // Listing 02 code/ch18
- CommandModule *answerCallModule;
- ACE_NEW_RETURN (answerCallModule,
- AnswerCallModule (this->peer_),
- -1);
-
- CommandModule *retrieveCallerIdModule;
- ACE_NEW_RETURN (retrieveCallerIdModule,
- RetrieveCallerIdModule (this->peer_),
- -1);
-
- CommandModule *playMessageModule;
- ACE_NEW_RETURN (playMessageModule,
- PlayMessageModule (this->peer_),
- -1);
-
- CommandModule *recordMessageModule;
- ACE_NEW_RETURN (recordMessageModule,
- RecordMessageModule (this->peer_),
- -1);
- // Listing 02
-
- // Listing 03 code/ch18
- if (this->push (answerCallModule) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("Failed to push %p\n"),
- answerCallModule->name()),
- -1);
-
- if (this->push (retrieveCallerIdModule) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("Failed to push %p\n"),
- retrieveCallerIdModule->name()),
- -1);
-
- if (this->push (playMessageModule) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("Failed to push %p\n"),
- playMessageModule->name()),
- -1);
-
- if (this->push (recordMessageModule) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("Failed to push %p\n"),
- recordMessageModule->name()),
- -1);
- // Listing 03
- return 0;
-}
-
-// Listing 04 code/ch18
-Command *CommandStream::execute (Command *command)
-{
- ACE_Message_Block *mb;
- ACE_NEW_RETURN (mb, ACE_Message_Block (command), 0);
- if (this->put (mb) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("Fail on put command %d: %p\n"),
- command->command_,
- ACE_TEXT ("")),
- 0);
-
- this->get (mb);
- command = (Command *)mb->data_block ();
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("Command (%d) returns (%d)\n"),
- command->command_,
- command->numeric_result_));
-
- return command;
-}
-// Listing 04