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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
#include "Service_Config_Stream_DLL.h"
#include "ace/Service_Repository.h"
#include "ace/Service_Types.h"
int
Test_Task::open (void *)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("opening %s\n"),
this->name () ? this->name () : ACE_TEXT ("task")));
return 0;
}
int
Test_Task::close (u_long)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("closing %s\n"),
this->name () ? this->name () : ACE_TEXT ("task")));
return 0;
}
int
Test_Task::init (int, ACE_TCHAR *[])
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("initializing %s\n"),
this->name () ? this->name () : ACE_TEXT ("task")));
return 0;
}
int
Test_Task::fini ()
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("finalizing %s\n"),
this->name () ? this->name () : ACE_TEXT ("task")));
return 0;
}
// Factories used to control configuration.
ACE_FACTORY_DECLARE (Service_Config_Stream_DLL, Test_Task)
ACE_FACTORY_DEFINE (Service_Config_Stream_DLL, Test_Task)
// Dynamically linked functions used to control configuration.
extern "C" Service_Config_Stream_DLL_Export MT_Stream *make_stream ();
extern "C" Service_Config_Stream_DLL_Export MT_Module *make_da ();
extern "C" Service_Config_Stream_DLL_Export MT_Module *make_ea ();
extern "C" Service_Config_Stream_DLL_Export MT_Module *make_mr ();
extern "C" Service_Config_Stream_DLL_Export MT_Module *make_close ();
MT_Stream *
make_stream ()
{
return new MT_Stream;
}
MT_Module *
make_da ()
{
return new MT_Module (ACE_TEXT ("Device_Adapter"),
new Test_Task, new Test_Task);
}
MT_Module *
make_ea ()
{
return new MT_Module (ACE_TEXT ("Event_Analyzer"),
new Test_Task, new Test_Task);
}
MT_Module *
make_mr ()
{
return new MT_Module (ACE_TEXT ("Multicast_Router"),
new Test_Task, new Test_Task);
}
MT_Module *
make_close ()
{
return new MT_Module (ACE_TEXT ("Close_Test_Module"),
new Test_Task, new Test_Task);
}
// Task to verify the order and operation of the stream assembly
// Command line args give the stream name (to look it up) and the names
// of the tasks that should be there, from head to tail.
ACE_FACTORY_DECLARE (Service_Config_Stream_DLL, Stream_Order_Test)
ACE_FACTORY_DEFINE (Service_Config_Stream_DLL, Stream_Order_Test)
int
Stream_Order_Test::init (int argc, ACE_TCHAR *argv[])
{
if (argc < 1)
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT ("Stream_Order_Test needs at least 1 arg\n")),
-1);
const ACE_Service_Type *st = 0;
if (ACE_Service_Repository::instance ()->find (argv[0], &st, false) == -1)
ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("Cannot find %s\n"), argv[0]), -1);
const ACE_Service_Type_Impl *st_impl = st->type ();
MT_Stream *str = reinterpret_cast<MT_Stream *>(st_impl->object ());
MT_Module *m = 0;
if (-1 == str->top (m))
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT ("Cannot get module %p\n"),
ACE_TEXT ("top")),
-1);
// Walk down the stream and compare module names. Note we start from the
// top, i.e., the last module pushed.
bool error = false;
for (int i = 1; i < argc; ++i)
{
if (m == 0)
{
ACE_ERROR ((LM_ERROR,
ACE_TEXT ("Ran out of modules at layer %d\n"),
i));
continue;
}
if (ACE_OS::strcmp (argv[i], m->name ()) != 0)
{
ACE_ERROR ((LM_ERROR,
ACE_TEXT ("Layer %d: expected module %s, found %s\n"),
i,
argv[i], m->name ()));
error = true;
}
else
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("Layer %d: found module %s, correct\n"),
i,
m->name ()));
m = m->next ();
}
return error ? -1 : 0;
}
|
