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
|
// ============================================================================
//
// = LIBRARY
// tests
//
// = DESCRIPTION
// This test exercises ACE_Service_Config assembling a stream.
//
// = AUTHOR
// Steve Huston <shuston@riverace.com>
//
// ============================================================================
#include "test_config.h"
#include "ace/Log_Msg.h"
#include "ace/Module.h"
#include "ace/Service_Config.h"
#include "ace/Task.h"
/*
* The Decrypter service is static and is configured into a stream
* dynamically.
*
* NOTE! This code is here, and it will trip up while being loaded. If
* "static Decrypter" is inserted into the .conf file's module list, this
* test will barf. This is arguably a weird test, but I don't know any
* reason it should not work; however, this behavior has never been tested
* and may not have ever worked... but if someone is feeling ambitious,
* please go ahead and make this work. I'm out of time and energy.
* -Steve Huston
*/
class Static_Task : public ACE_Task<ACE_SYNCH>
{
public:
int open (void *) override
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("opening %s\n"),
this->name () ? this->name () : ACE_TEXT ("Static_Task")));
return 0;
}
int close (u_long) override
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("closing %s\n"),
this->name () ? this->name () : ACE_TEXT ("Static_Task")));
return 0;
}
int init (int, ACE_TCHAR *[]) override
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("initializing %s\n"),
this->name () ? this->name () : ACE_TEXT ("Static_Task")));
return 0;
}
int fini () override
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("finalizing %s\n"),
this->name () ? this->name () : ACE_TEXT ("Static_Task")));
return 0;
}
};
class Decrypter : public ACE_Service_Object, public ACE_Module<ACE_SYNCH, ACE_System_Time_Policy>
{
public:
Decrypter ()
: ACE_Module<ACE_SYNCH, ACE_System_Time_Policy> (
ACE_TEXT ("Decrypter"),
&writer_, &reader_,
0,
M_DELETE_NONE) // Tasks are members; don't delete
{}
ACE_ALLOC_HOOK_DECLARE;
private:
Static_Task writer_;
Static_Task reader_;
};
ACE_FACTORY_DEFINE (ACE_Local_Service, Decrypter)
ACE_STATIC_SVC_DEFINE (Decrypter_Descriptor,
ACE_TEXT ("Decrypter"),
ACE_MODULE_T,
&ACE_SVC_NAME (Decrypter),
(ACE_Service_Type::DELETE_THIS |
ACE_Service_Type::DELETE_OBJ),
1)
ACE_STATIC_SVC_REQUIRE (Decrypter_Descriptor)
ACE_ALLOC_HOOK_DEFINE(Decrypter);
int
run_main (int, ACE_TCHAR *argv[])
{
ACE_START_TEST (ACE_TEXT ("Service_Config_Stream_Test"));
ACE_STATIC_SVC_REGISTER (Decrypter);
// If you want to try the static module in the stream test (comments at
// the top of this file) it needs the -y in the argv list which enables
// static services. Otherwise it's not really needed. Same with the
// 'false' 4th arg to open() below - it allows static services.
ACE_TCHAR *_argv[5] = { argv[0],
const_cast<ACE_TCHAR*> (ACE_TEXT ("-d")),
const_cast<ACE_TCHAR*> (ACE_TEXT ("-y")),
const_cast<ACE_TCHAR*> (ACE_TEXT ("-f")),
const_cast<ACE_TCHAR*>
(ACE_TEXT ("Service_Config_Stream_Test.conf")) };
int status;
if ((status = ACE_Service_Config::open (5,
_argv,
ACE_DEFAULT_LOGGER_KEY,
false,
true /*ignore def svc.conf*/)) == -1)
ACE_ERROR ((LM_ERROR,
ACE_TEXT ("%p\n"),
ACE_TEXT ("open"),
1));
ACE_END_TEST;
return status;
}
|
