1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
// $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
|
