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
|
// $Id$
#include "tao/tao_internals.h"
#include "ace/Service_Config.h"
#include "ace/Service_Repository.h"
#include "tao/default_server.h"
#include "tao/default_client.h"
int TAO_Internal::service_open_count_ = 0;
int
TAO_Internal::fake_service_entries_i (void)
{
#if defined (TAO_PLATFORM_SVC_CONF_FILE_NOTSUP)
#define FAKE_SVC_ENTRY(svcname, svctype, argc, argv) \
do \
{ \
ACE_Service_Object *obj = _make_##svctype (); \
obj->init (argc, argv); \
ACE_Service_Repository::instance()->insert \
(new ACE_Service_Type (svcname,\
new ACE_Service_Object_Type\
(obj, svcname, \
(ACE_Service_Type::DELETE_OBJ \
| ACE_Service_Type::DELETE_THIS)), \
0, 1));\
}\
while (0) //;
char *rfactory_args[] = { "-ORBresources", "global" };
FAKE_SVC_ENTRY ("Resource_Factory",
TAO_Resource_Factory,
sizeof rfactory_args / sizeof rfactory_args[0],
rfactory_args);
char *client_args[] = { 0 };
FAKE_SVC_ENTRY ("Client_Strategy_Factory",
TAO_Default_Client_Strategy_Factory,
0,
client_args);
char* server_args[] = {
"-ORBconcurrency", "reactive",
"-ORBdemuxstrategy", "dynamic", "-ORBtablesize", "128" };
FAKE_SVC_ENTRY ("Server_Strategy_Factory",
TAO_Default_Server_Strategy_Factory,
sizeof server_args / sizeof server_args[0],
server_args);
#endif /* TAO_PLATFORM_SVC_CONF_FILE_NOTSUP */
return 0;
}
int
TAO_Internal::open_services (int& argc, char** argv)
{
ACE_MT (ACE_GUARD_RETURN (ACE_SYNCH_RECURSIVE_MUTEX, guard, *ACE_Static_Object_Lock::instance (), -1));
if (TAO_Internal::service_open_count_++ == 0)
{
#if defined (TAO_PLATFORM_SVC_CONF_FILE_NOTSUP)
ACE_UNUSED_ARG (argc);
ACE_UNUSED_ARG (argv);
return fake_service_entries_i ();
#else
return ACE_Service_Config::open (argc, argv);
#endif /* TAO_PLATFORM_SVC_CONF_FILE_NOTSUP */
}
else
return 0;
}
TAO_Internal::TAO_Internal (void)
{
}
int
TAO_Internal::close_services (void)
{
ACE_MT (ACE_GUARD_RETURN (ACE_SYNCH_RECURSIVE_MUTEX, guard, *ACE_Static_Object_Lock::instance (), -1));
if (service_open_count_ == 0)
return -1;
if (--service_open_count_ == 0)
return ACE_Service_Config::close ();
return 0;
}
|
