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
|
// This may look like C, but it's really -*- C++ -*-
// $Id$
//=================================================================================
//
// = LIBRARY
// TAO/examples/POA/On_Demand_Loading
//
// = FILENAME
// Servant_Activator.h
//
// = DESCRIPTION
// Defines a <ServantActivator_i> class, which activates a servant by
// obtaining it and associates it with an object on-demand.
//
// = AUTHOR
// Kirthika Parameswaran <kirthika@cs.wustl.edu>
//
//==================================================================================
#include "ace/OS.h"
#ifndef SERVANT_ACTIVATOR_H
#define SERVANT_ACTIVATOR_H
#include "tao/corba.h"
#include "ace/DLL.h"
class ServantActivator_i : public POA_PortableServer::ServantActivator
{
//= TITLE
// Servant Activator for the MyFoo servant.
//
//= DESCRIPTION
// This class associates an unassociated servant with an object in
// the POA Active Object Map.
public:
typedef PortableServer::Servant
(*SERVANT_FACTORY) (const PortableServer::ObjectId &oid,
PortableServer::POA_ptr poa,
CORBA::ORB_ptr orb);
// This typedef is used to typecast the void* obtained when finding
// a symbol in the dll. Invoking the function pointer obtained would
// get a servant.
typedef void
(*SERVANT_GARBAGE_COLLECTOR) (const PortableServer::ObjectId &oid,
PortableServer::POA_ptr,
PortableServer::Servant servant);
// This typedef is used to obtain the garbage_collection_function symbol
// in the dll. Invoking the function pointer obtained would then destroy
// the servant.
ServantActivator_i (CORBA::ORB_ptr orb,
const char *dllname,
const char *factory_function,
const char *garbage_collection_function);
// Initialization.
virtual PortableServer::Servant incarnate (const PortableServer::ObjectId &oid,
PortableServer::POA_ptr poa,
CORBA::Environment &ACE_TRY_ENV);
// This method is invoked by a POA with USE_SERVANT_MANAGER and
// RETAIN policies, whenever it receives a request for a
// MyFooServant object that is not currently active. When an servant
// pointer corresponding to objectId is not found in the Active
// Object Map, the POA hands over the job of obtaining the servant
// to the Servant Manager. Depending upon whether the POA is created
// with RETAIN or NON_RETAIN as the servant_retention policy, the
// Servant Activator or the Servant Locator interface is invoked
// respectively.
virtual void etherealize (const PortableServer::ObjectId &oid,
PortableServer::POA_ptr adapter,
PortableServer::Servant servant,
CORBA::Boolean cleanup_in_progress,
CORBA::Boolean remaining_activations,
CORBA::Environment &ACE_TRY_ENV);
// This method is invoked whenever a MyFooServant for a MyFoo object
// is deactivated. This occurs when the POA is destroyed or the
// Object is deactivated. When the POA is getting destroyed, it
// needs to deactivate every object in the Active Object Map and on
// that call the ServantActivator invokes this method which will
// destroy the servant associated with the object.
private:
ACE_DLL dll_;
// The ACE_DLL object which performs the task of loading the dll
// and accessing it.
SERVANT_FACTORY servant_supplier_;
// The function pointer of factory_function type.
SERVANT_GARBAGE_COLLECTOR servant_garbage_collector_;
// The function pointer of garbage_collection_function type.
CORBA::ORB_var orb_;
// A reference to the ORB.
};
#endif /* SERVANT_ACTIVATOR_H */
|
