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
|
// -*- C++ -*-
//=============================================================================
/**
* @file Server_Main.cpp
*
* $Id$
*
* Implements a generic object that acts as "main" for a CORBA server.
*
* @author Dale Wilson <wilson_d@ociweb.com>
*/
//=============================================================================
#ifndef TAO_UTILS_SERVER_MAIN_T_CPP
#define TAO_UTILS_SERVER_MAIN_T_CPP
#include "Server_Main.h"
ACE_RCSID (Utils,
Server_Main,
"$Id$")
#include "tao/ORB.h"
#include "ace/Argv_Type_Converter.h"
#include "ace/Log_Msg.h"
#include "ace/Time_Value.h"
template <typename SERVANT>
TAO::Utils::Server_Main<SERVANT>::Server_Main (const char * name)
: name_(name)
{
}
template <typename SERVANT>
TAO::Utils::Server_Main<SERVANT>::~Server_Main ()
{
}
template <typename SERVANT>
int
TAO::Utils::Server_Main<SERVANT>::run (int argc, ACE_TCHAR *argv[])
{
int result = 0;
// hide unicode if necessary.
ACE_Argv_Type_Converter command_line (argc, argv);
char ** asciiArgv = command_line.get_ASCII_argv ();
ACE_TRY_NEW_ENV
{
// Initialize the orb
CORBA::ORB_var orb =
CORBA::ORB_init (argc, asciiArgv, name_ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (! CORBA::is_nil(orb.in ()))
{
// create an instance of the servant object and give it a
// chance at the arguments.
SERVANT servant;
result = servant.parse_args (argc, asciiArgv);
if (result == 0)
{
//////////////////////////////////
// let the servant register itself
result = servant.init (orb.in () ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (result == 0)
{
ACE_ERROR ((LM_INFO,
"%T %s (%P|%t) Ready %s\n", name_, servant.identity ()
));
//////////////////////////////////
// Run the event loop for the ORB.
// Initial run to initialize the orb
ACE_Time_Value tv (1,0);
orb->run (tv ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// now run event loop
int quit = 0;
while (result == 0 && ! quit )
{
ACE_Time_Value work_tv (1,0);
orb->perform_work(work_tv ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
quit = servant.idle (result ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
servant.fini (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
orb->shutdown (1 ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_ERROR ((LM_INFO,
"%T %s (%P|%t) Terminated normally. %s\n",
name_,
servant.identity ()
));
}
else
{
ACE_ERROR ((LM_ERROR,
"%T %s (%P|%t) Registration failed: %m\n", name_
));
result = -1;
}
}
else
{
ACE_ERROR ((LM_ERROR,
"%T %s (%P|%t) ORB manager init failed\n", name_
));
result = -1;
}
}
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
name_);
result = -1;
}
ACE_ENDTRY;
return result;
}
#endif //TAO_UTILS_SERVER_MAIN_T_CPP
|
