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
|
#include "tao/Strategies/SHMIOP_Factory.h"
#if defined (TAO_HAS_SHMIOP) && (TAO_HAS_SHMIOP != 0)
#include "tao/Strategies/SHMIOP_Acceptor.h"
#include "tao/Strategies/SHMIOP_Connector.h"
#include "tao/ORB_Constants.h"
#include "ace/Arg_Shifter.h"
#include "ace/Argv_Type_Converter.h"
#include "ace/OS_NS_strings.h"
ACE_RCSID (Strategies,
SHMIOP_Factory,
"$Id$")
static const char prefix_[] = "shmiop";
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO_SHMIOP_Protocol_Factory::TAO_SHMIOP_Protocol_Factory (void)
: TAO_Protocol_Factory (TAO_TAG_SHMEM_PROFILE),
mmap_prefix_ (0),
min_bytes_ (10*1024) // @@ Nanbor, remove this magic number!!
{
}
TAO_SHMIOP_Protocol_Factory::~TAO_SHMIOP_Protocol_Factory (void)
{
delete [] this->mmap_prefix_;
}
int
TAO_SHMIOP_Protocol_Factory::match_prefix (const ACE_CString &prefix)
{
// Check for the proper prefix for this protocol.
return (ACE_OS::strcasecmp (prefix.c_str (), ::prefix_) == 0);
}
const char *
TAO_SHMIOP_Protocol_Factory::prefix (void) const
{
return ::prefix_;
}
char
TAO_SHMIOP_Protocol_Factory::options_delimiter (void) const
{
return '/';
}
TAO_Acceptor *
TAO_SHMIOP_Protocol_Factory::make_acceptor (void)
{
TAO_SHMIOP_Acceptor *acceptor = 0;
ACE_NEW_RETURN (acceptor,
TAO_SHMIOP_Acceptor,
0);
acceptor->set_mmap_options (this->mmap_prefix_,
this->min_bytes_);
return acceptor;
}
int
TAO_SHMIOP_Protocol_Factory::init (int argc,
ACE_TCHAR* argv[])
{
// Copy command line parameter not to use original as well as type conversion.
ACE_Argv_Type_Converter command_line(argc, argv);
ACE_Arg_Shifter arg_shifter (command_line.get_argc(), command_line.get_TCHAR_argv());
while (arg_shifter.is_anything_left ())
{
const ACE_TCHAR *current_arg = 0;
if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT("-MMAPFileSize"))))
{
this->min_bytes_ = ACE_OS::atoi (current_arg);
arg_shifter.consume_arg ();
}
else if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT("-MMAPFilePrefix"))))
{
this->mmap_prefix_ = ACE::strnew (current_arg);
arg_shifter.consume_arg ();
}
else
// Any arguments that don't match are ignored so that the
// caller can still use them.
arg_shifter.ignore_arg ();
}
return 0;
}
TAO_Connector *
TAO_SHMIOP_Protocol_Factory::make_connector (void)
{
TAO_Connector *connector = 0;
ACE_NEW_RETURN (connector,
TAO_SHMIOP_Connector,
0);
return connector;
}
int
TAO_SHMIOP_Protocol_Factory::requires_explicit_endpoint (void) const
{
return 1;
}
TAO_END_VERSIONED_NAMESPACE_DECL
ACE_STATIC_SVC_DEFINE (TAO_SHMIOP_Protocol_Factory,
ACE_TEXT ("SHMIOP_Factory"),
ACE_SVC_OBJ_T,
&ACE_SVC_NAME (TAO_SHMIOP_Protocol_Factory),
ACE_Service_Type::DELETE_THIS |
ACE_Service_Type::DELETE_OBJ,
0)
ACE_FACTORY_DEFINE (TAO_Strategies, TAO_SHMIOP_Protocol_Factory)
#endif /* TAO_HAS_SHMIOP && TAO_HAS_SHMIOP != 0 */
|
