blob: 11876b31acb551c88dfccf94e2c6a41ea5aa76b4 (
plain)
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
|
// -*- C++ -*-
// ===================================================================
/**
* @file PICurrent_Impl.h
*
* $Id$
*
* @author Ossama Othman <ossama@dre.vanderbilt.edu>
*/
// ===================================================================
#ifndef TAO_PI_CURRENT_IMPL_H
#define TAO_PI_CURRENT_IMPL_H
#include /**/ "ace/pre.h"
#include "tao/PI/pi_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/orbconf.h"
#if TAO_HAS_INTERCEPTORS == 1
#include "tao/PI/PICurrentC.h"
#include "tao/AnyTypeCode/Any.h"
#include "ace/Array_Base.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
/// Forward declarations.
class TAO_ORB_Core;
namespace TAO
{
/**
* @class PICurrent_Impl
*
* @brief Implementation of the PortableInterceptor::Current
* interface.
*
* This class implements both the "request scope current" and the
* "thread scope current" objects as required by Portable
* Interceptors.
*/
class TAO_PI_Export PICurrent_Impl
{
public:
/// Constructor.
PICurrent_Impl (void);
/// Destructor.
~PICurrent_Impl (void);
/// Retrieve information stored in the slot table at the given
/// SlotId.
CORBA::Any *get_slot (PortableInterceptor::SlotId identifier
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::InvalidSlot));
/// Set information in the slot table at the given SlotId.
void set_slot (PortableInterceptor::SlotId identifier,
const CORBA::Any & data
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::InvalidSlot));
/// Logically/Lazy (shallow) copy the given object's slot table.
void take_lazy_copy (PICurrent_Impl *p);
private:
/// Force this object to convert from a logical (referenced)
/// copy, to a physical (or deep, actual) copy.
void convert_from_lazy_to_real_copy ();
/// Set the callback PICurrent_Impl object that will be notified
/// of this object's impending destruction or change.
/// Set to 0 to clear. (NOTE Only handles a SINGLE object at
/// at time, does NOT warn previous callback that this has
/// been changed.)
void set_callback_for_impending_change (PICurrent_Impl *p);
/// Typedef for the underyling "slot table."
typedef ACE_Array_Base<CORBA::Any> Table;
/// Return a reference to the slot table currently associated
/// with this PICurrent_Impl object.
/**
* @return Logically copied slot table if available, otherwise
* underlying slot table.
*/
Table & current_slot_table ();
/// Prevent copying through the copy constructor and the assignment
/// operator.
//@{
PICurrent_Impl (const PICurrent_Impl &);
void operator= (const PICurrent_Impl &);
//@}
private:
/// Array of CORBA::Anys that is the underlying "slot table."
Table slot_table_;
/// Access to logical copy from a PICurrent_Impl in another
/// scope, i.e. either the request scope or the thread scope.
PICurrent_Impl *lazy_copy_;
/// PICurrent_Impl object that will be notified of this object's
/// impending destruction or change to its slot_table_. This is
/// the PICurrent_Impl that has access to our slot_table_ via its
/// lazy_copy_ pointer. As necessary this allows that object's
/// convert_from_lazy_to_real_copy() to be called.
PICurrent_Impl *impending_change_callback_;
};
}
TAO_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
# include "tao/PI/PICurrent_Impl.inl"
#endif /* __ACE_INLINE__ */
#endif /* TAO_HAS_INTERCEPTORS == 1 */
#include /**/ "ace/post.h"
#endif /* TAO_PI_CURRENT_IMPL_H */
|
