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
|
// $Id$
#include "tao/Key_Adapters.h"
#if !defined (__ACE_INLINE__)
# include "tao/Key_Adapters.i"
#endif /* __ACE_INLINE__ */
////////////////////////////////////////////////////////////////////////////////
TAO_Incremental_Key_Generator::TAO_Incremental_Key_Generator (void)
: counter_ (0)
{
}
int
TAO_Incremental_Key_Generator::operator() (PortableServer::ObjectId &id)
{
// Resize to accommodate the counter.
id.length (sizeof this->counter_);
// Add new key data.
ACE_OS::memcpy (id.get_buffer (),
&++this->counter_,
sizeof this->counter_);
// Success.
return 0;
}
////////////////////////////////////////////////////////////////////////////////
u_long
TAO_ObjectId_Hash::operator () (const PortableServer::ObjectId &id) const
{
return ACE::hash_pjw ((const char *) id.get_buffer (),
id.length ());
}
////////////////////////////////////////////////////////////////////////////////
int
TAO_Ignore_Original_Key_Adapter::encode (const PortableServer::ObjectId &original_key,
const ACE_Active_Map_Manager_Key &active_key,
PortableServer::ObjectId &modified_key)
{
// Size of active key.
size_t active_key_size = active_key.size ();
// Resize to accommodate both the original data and the new active key.
modified_key.length (active_key_size);
// Copy active key data into user key.
active_key.encode (modified_key.get_buffer ());
// Success.
return 0;
}
int
TAO_Ignore_Original_Key_Adapter::decode (const PortableServer::ObjectId &modified_key,
ACE_Active_Map_Manager_Key &active_key)
{
// Read off value of index and generation.
active_key.decode (modified_key.get_buffer ());
// Success.
return 0;
}
int
TAO_Ignore_Original_Key_Adapter::decode (const PortableServer::ObjectId &modified_key,
PortableServer::ObjectId &original_key)
{
// Smartly copy all the data; <original_key does not own the data>.
original_key.replace (modified_key.maximum (),
modified_key.length (),
ACE_const_cast (CORBA::Octet *,
modified_key.get_buffer ()),
0);
// Success.
return 0;
}
////////////////////////////////////////////////////////////////////////////////
int
TAO_Preserve_Original_Key_Adapter::encode (const PortableServer::ObjectId &original_key,
const ACE_Active_Map_Manager_Key &active_key,
PortableServer::ObjectId &modified_key)
{
// Size of active key.
size_t active_key_size = active_key.size ();
// Resize to accommodate both the original data and the new active key.
modified_key.length (active_key_size + original_key.length ());
// Copy active key data into user key.
active_key.encode (modified_key.get_buffer ());
// Copy the original key after the active key.
ACE_OS::memcpy (modified_key.get_buffer () + active_key_size,
original_key.get_buffer (),
original_key.length ());
// Success.
return 0;
}
int
TAO_Preserve_Original_Key_Adapter::decode (const PortableServer::ObjectId &modified_key,
ACE_Active_Map_Manager_Key &active_key)
{
// Read off value of index and generation.
active_key.decode (modified_key.get_buffer ());
// Success.
return 0;
}
int
TAO_Preserve_Original_Key_Adapter::decode (const PortableServer::ObjectId &modified_key,
PortableServer::ObjectId &original_key)
{
// Size of active key.
size_t active_key_size = ACE_Active_Map_Manager_Key::size ();
// Smartly copy all the data; <original_key does not own the data>.
original_key.replace (modified_key.maximum () - active_key_size,
modified_key.length () - active_key_size,
ACE_const_cast (CORBA::Octet *,
modified_key.get_buffer ()) + active_key_size,
0);
// Success.
return 0;
}
////////////////////////////////////////////////////////////////////////////////
|
