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
|
// $Id$
/***
* @file RepositoryManager.cpp
*
* @author Stoyan Paunov <spaunov@isis.vanderbilt.edu>
**/
#include "new_RepositoryManager_Impl.h"
#include "ace/OS_NS_stdio.h"
#include "ace/streams.h"
#include "ace/Auto_Ptr.h"
#include "ace/Task.h"
using namespace std;
namespace
{
///name of the file holding the IOR of the RM
const char * rm_ior = "RepositoryManagerDeamon.ior";
///default number of worker threads to run in the multi-threaded RM
const unsigned int nthreads = 3;
}
///Class that implements the service routine of the worker threads
///of the repository manager
class Worker : public ACE_Task_Base
{
// = TITLE
// Run a server thread
//
// = DESCRIPTION
// Use the ACE_Task_Base class to run server threads
//
public:
Worker (CORBA::ORB_ptr orb);
// ctor
virtual int svc (void);
// The thread entry point.
private:
CORBA::ORB_var orb_;
// The orb
};
///Main function
int
ACE_TMAIN (int argc, ACE_TCHAR *argv[])
{
try
{
//init the ORB
CORBA::ORB_var orb = CORBA::ORB_init(argc, argv);
//Get the root POA object
CORBA::Object_var obj = orb->resolve_initial_references ("RootPOA");
//downcast to POA type
PortableServer::POA_var root_poa = PortableServer::POA::_narrow (obj.in ());
//activate the POA manager
PortableServer::POAManager_var mgr = root_poa->the_POAManager ();
mgr->activate ();
//create a servant
CIAO_new_RepositoryManagerDaemon_i* repo = new CIAO_new_RepositoryManagerDaemon_i (orb.in ());
//trasfer ownership to the POA
PortableServer::ServantBase_var distributor_owner_transfer(repo);
//register and implicitly activate servant
CIAO::new_RepositoryManagerDaemon_var RepositoryManagerDeamon = repo->_this ();
//convert the IOR to string
CORBA::String_var ior = orb->object_to_string (RepositoryManagerDeamon.in ());
//output the IOR to a file
FILE* ior_out = ACE_OS::fopen (rm_ior, "w");
if (ior_out == 0)
ACE_ERROR_RETURN ((LM_ERROR,
"Cannot open output file for writing IOR: %s",
rm_ior),
1);
ACE_OS::fprintf (ior_out, "%s", ior.in ());
ACE_OS::fclose (ior_out);
Worker worker (orb.in ());
if (worker.activate (THR_NEW_LWP | THR_JOINABLE,
nthreads) != 0)
ACE_ERROR_RETURN ((LM_ERROR,
"Cannot activate client threads\n"),
1);
worker.thr_mgr ()->wait ();
ACE_DEBUG ((LM_DEBUG, "event loop finished\n"));
//done
return 0;
//Start accepting requests
orb->run ();
//allow objects registered with the POA ot get cleaned-up
root_poa->destroy (1, 1);
//shutdown the orb
orb->shutdown (1);
return 0;
}
catch (CORBA::Exception &ex) {
cerr << "CORBA Exception: " << ex << endl;
return 1;
}
return 0;
}
// ****************************************************************
///Constuctor for the worker class
Worker::Worker (CORBA::ORB_ptr orb)
: orb_ (CORBA::ORB::_duplicate (orb))
{
}
///implementation of the service routine inherited from ACE::Task_Base
int Worker::svc (void)
{
ACE_DECLARE_NEW_CORBA_ENV;
ACE_TRY
{
this->orb_->run (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
}
ACE_ENDTRY;
return 0;
}
|
