diff options
Diffstat (limited to 'ACE/examples/APG/Streams/CommandStream.cpp')
-rw-r--r-- | ACE/examples/APG/Streams/CommandStream.cpp | 97 |
1 files changed, 0 insertions, 97 deletions
diff --git a/ACE/examples/APG/Streams/CommandStream.cpp b/ACE/examples/APG/Streams/CommandStream.cpp deleted file mode 100644 index def3f123d77..00000000000 --- a/ACE/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 |