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
145
146
147
148
149
150
151
152
153
154
155
156
157
158
|
// $Id$
#include "Naming_Service.h"
#include "ace/Get_Opt.h"
#include "ace/Argv_Type_Converter.h"
ACE_RCSID(Naming_Service, Naming_Service, "$Id$")
// Default Constructor.
TAO_Naming_Service::TAO_Naming_Service (void)
: time_ (0)
{
}
// Constructor taking command-line arguments.
TAO_Naming_Service::TAO_Naming_Service (int argc,
ACE_TCHAR* argv[])
: time_ (0)
{
this->init (argc, argv);
}
// Initialize the state of the TAO_Naming_Service object
int
TAO_Naming_Service::init (int argc,
ACE_TCHAR* argv[])
{
int result;
ACE_DECLARE_NEW_CORBA_ENV;
ACE_TRY
{
// Copy command line parameter.
ACE_Argv_Type_Converter command_line(argc, argv);
// Initialize the ORB
this->orb_ =
CORBA::ORB_init (command_line.get_argc(), command_line.get_ASCII_argv(), 0 ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Parse the args for '-t' option. If '-t' option is passed, do
// the needful and then remove the option from the list of
// arguments.
this->parse_args (command_line.get_argc(), command_line.get_TCHAR_argv());
// This function call initializes the naming service and returns
// '-1' in case of an exception.
result = this->my_naming_server_.init_with_orb (command_line.get_argc(),
command_line.get_TCHAR_argv(),
this->orb_.in ());
if (result == -1)
return result;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "TAO_Naming_Service::init");
return -1;
}
ACE_ENDTRY;
ACE_CHECK_RETURN (-1);
return 0;
}
int
TAO_Naming_Service::parse_args (int &argc,
ACE_TCHAR* argv[])
{
ACE_Get_Opt get_opts (argc, argv, ACE_LIB_TEXT("-t:"));
int c;
while ((c = get_opts ()) != -1)
{
switch (c)
{
case 't':
{
int time = ACE_OS::atoi (get_opts.opt_arg ());
if (time >= 0)
this->time_ = time;
// Remove the option '-t' from argv []
// to avoid any confusion that might result.
for (int i = get_opts.opt_ind (); i != argc; ++i)
argv [i-2 ] = argv [i];
// Decrement the value of argc to reflect the removal
// of '-t' option.
argc = argc - 2;
break;
}
case '?':
default:
// Don't do anything. The TAO_Naming_Server::parse_args ()
// takes care of indicating an error in case of error.
break;
}
}
return 0;
}
// Run the ORB event loop.
int
TAO_Naming_Service::run (ACE_ENV_SINGLE_ARG_DECL)
{
if (time_ == 0)
{
this->orb_->run (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
}
else
{
ACE_Time_Value tv (time_);
this->orb_->run (tv ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
}
return 0;
}
void
TAO_Naming_Service::shutdown (ACE_ENV_SINGLE_ARG_DECL)
{
this->orb_->shutdown (0 ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
int
TAO_Naming_Service::fini (void)
{
ACE_DECLARE_NEW_CORBA_ENV;
this->my_naming_server_.fini();
ACE_TRY
{
// destroy implies shutdown
this->orb_->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "TAO_Naming_Service::fini");
return -1;
}
ACE_ENDTRY;
return 0;
}
// Destructor.
TAO_Naming_Service::~TAO_Naming_Service (void)
{
// Destructor
}
|
