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
|
#include "tao/PI/PICurrent.h"
#if TAO_HAS_INTERCEPTORS == 1
ACE_RCSID (tao,
PICurrent,
"$Id$")
#if !defined (__ACE_INLINE__)
# include "tao/PI/PICurrent.inl"
#endif /* __ACE_INLINE__ */
#include "tao/PI/PICurrent_Impl.h"
#include "tao/ORB_Core.h"
#include "tao/ORB_Core_TSS_Resources.h"
#include "tao/TAO_Server_Request.h"
#include "tao/SystemException.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO::PICurrent::PICurrent (TAO_ORB_Core &orb_core)
: orb_core_ (orb_core),
tss_slot_ (0), // Call initialize() before use.
slot_count_ (0) // Call initialize() before use.
{
}
TAO::PICurrent::~PICurrent (void)
{
}
CORBA::Any *
TAO::PICurrent::get_slot (PortableInterceptor::SlotId identifier
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::InvalidSlot))
{
this->check_validity (identifier ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
return this->tsc ()->get_slot (identifier ACE_ENV_ARG_PARAMETER);
}
void
TAO::PICurrent::set_slot (PortableInterceptor::SlotId identifier,
const CORBA::Any &data
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::InvalidSlot))
{
this->check_validity (identifier ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
this->tsc ()->set_slot (identifier, data ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
namespace
{
extern "C" void CleanUpPICurrent(void *object, void *)
{
delete static_cast<TAO::PICurrent_Impl *> (object);
}
}
TAO::PICurrent_Impl *
TAO::PICurrent::tsc (void)
{
TAO::PICurrent_Impl *impl =
static_cast<TAO::PICurrent_Impl *> (
this->orb_core_.get_tss_resource (this->tss_slot_));
// If this TSS has not yet been set-up, give it it's own PICurrent_Impl.
if (0 == impl)
{
ACE_NEW_THROW_EX (impl,
TAO::PICurrent_Impl,
CORBA::NO_MEMORY (
CORBA::SystemException::_tao_minor_code (
TAO::VMCID,
ENOMEM),
CORBA::COMPLETED_NO));
this->orb_core_.set_tss_resource (this->tss_slot_, impl);
}
return impl;
}
void
TAO::PICurrent::check_validity (const PortableInterceptor::SlotId &identifier
ACE_ENV_ARG_DECL)
{
// If the slot_count is zero, no initialization has been done (if there are
// no slots, then the PICurrent_impl object is not created as there is no
// data to copy).
if (0 == this->slot_count_)
ACE_THROW (CORBA::BAD_INV_ORDER (CORBA::OMGVMCID | 14,
CORBA::COMPLETED_NO));
// No need to acquire a lock for this check. At this point, these
// attributes are read only.
if (identifier >= this->slot_count_)
ACE_THROW (PortableInterceptor::InvalidSlot ());
}
CORBA::ORB_ptr
TAO::PICurrent::_get_orb (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
{
return CORBA::ORB::_duplicate (this->orb_core_.orb ());
}
void
TAO::PICurrent::initialize (PortableInterceptor::SlotId sc
ACE_ENV_ARG_DECL)
{
// Only allow a single initialization; sc is the number of
// allocated PICurrent data slots the end user wants. If 0
// PICurrent is not used, as no data is to be stored.
if ((0 == this->slot_count_) && (0 != sc))
{
// NOTE: This function not only adds the cleanup function
// but ALSO allocates the TSS slot PICurrent is to use.
// It MUST be called BEFORE we attempt to get/set any
// PICurrent slot data.
if (0 != orb_core_.add_tss_cleanup_func (CleanUpPICurrent, this->tss_slot_))
ACE_THROW (CORBA::NO_MEMORY (
CORBA::SystemException::_tao_minor_code (
TAO::VMCID,
ENOMEM),
CORBA::COMPLETED_NO));
this->slot_count_ = sc;
}
}
TAO_END_VERSIONED_NAMESPACE_DECL
#endif /* TAO_HAS_INTERCEPTORS == 1 */
|
