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++ -*-
//
// $Id$
#include "tao/Environment.h"
#include "tao/SystemException.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
ACE_INLINE ACE_Lock &
TAO_POA_Manager::lock (void)
{
return this->lock_;
}
ACE_INLINE void
TAO_POA_Manager::activate (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableServer::POAManager::AdapterInactive))
{
// Lock access to the POAManager for the duration of this transaction
TAO_OBJECT_ADAPTER_GUARD;
this->activate_i (ACE_ENV_SINGLE_ARG_PARAMETER);
}
#if (TAO_HAS_MINIMUM_POA == 0)
ACE_INLINE void
TAO_POA_Manager::hold_requests (CORBA::Boolean wait_for_completion
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableServer::POAManager::AdapterInactive))
{
// Lock access to the POAManager for the duration of this transaction
TAO_OBJECT_ADAPTER_GUARD;
this->hold_requests_i (wait_for_completion ACE_ENV_ARG_PARAMETER);
}
ACE_INLINE void
TAO_POA_Manager::discard_requests (CORBA::Boolean wait_for_completion
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableServer::POAManager::AdapterInactive))
{
// Lock access to the POAManager for the duration of this transaction
TAO_OBJECT_ADAPTER_GUARD;
this->discard_requests_i (wait_for_completion ACE_ENV_ARG_PARAMETER);
}
ACE_INLINE void
TAO_POA_Manager::deactivate (CORBA::Boolean etherealize_objects,
CORBA::Boolean wait_for_completion
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableServer::POAManager::AdapterInactive))
{
// Lock access to the POAManager for the duration of this transaction
TAO_OBJECT_ADAPTER_GUARD;
this->deactivate_i (etherealize_objects,
wait_for_completion
ACE_ENV_ARG_PARAMETER);
}
#endif /* TAO_HAS_MINIMUM_POA == 0 */
ACE_INLINE PortableServer::POAManager::State
TAO_POA_Manager::get_state_i (void)
ACE_THROW_SPEC ((CORBA::SystemException))
{
return this->state_;
}
ACE_INLINE PortableServer::POAManager::State
TAO_POA_Manager::get_state (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
// Lock access to the POAManager for the duration of this transaction
TAO_OBJECT_ADAPTER_GUARD_RETURN (this->state_);
return this->get_state_i ();
}
ACE_INLINE char*
TAO_POA_Manager::generate_manager_id (void) const
{
// The AdapterManagerId must be unique across all Adapter Managers
// (e.g. POAManagers) within a given process. To avoid locking
// overhead, the address of the POAManager object is used as the
// AdapterManagerId. This guarantees that the AdapterManagerId is
// unique.
//
// For 64-bit platforms, only the lower 32 bits are used. Hopefully
// that will be enough to ensure uniqueness.
// This is basically the same trick used in
// TAO_GIOP_Invocation::generate_request_id(). However, no right
// shifting of 64 bit addresses is performed since the
// TAO_POA_Manager object is not large enough to allow that trick.
CORBA::Long id = 0;
// Note that we reinterpret_cast to an "unsigned long" instead of
// CORBA::ULong since we need to first cast to an integer large
// enough to hold an address to avoid compile-time warnings on some
// 64-bit platforms.
if (sizeof (this) == 4) // 32 bit address
id = reinterpret_cast <ptrdiff_t> (this);
else if (sizeof (this) == 8) // 64 bit address -- use lower 32 bits
id = reinterpret_cast <ptrdiff_t> (this) & 0xFFFFFFFFu;
// @@ If we ever hit a platform where neither of the above cases are
// satisfied, we're up the creek!
// else
// // Fallback on an atomically incremented variable specific to the
// // ORB, or perhaps specific to the process.
// id = ...GENERATE_ID_ATOMICALLY...; // Fallback
char* buf = new char [25];
ACE_OS::sprintf (buf, "POAManager%d", id);
return buf;
}
ACE_INLINE
CORBA::PolicyList& TAO_POA_Manager::get_policies ()
{
return this->policies_;
}
TAO_END_VERSIONED_NAMESPACE_DECL
|
