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
|
#include "Iterator_i.h"
#include "orbsvcs/orbsvcs/Log/Log_Constraint_Interpreter.h"
#include "orbsvcs/orbsvcs/Log/Log_Constraint_Visitors.h"
#include "orbsvcs/orbsvcs/DsLogAdminC.h"
ACE_RCSID (Log,
Iterator_i,
"$Id$")
TAO_Iterator_i::TAO_Iterator_i (TAO_LogRecordStore::LOG_RECORD_STORE &store,
CORBA::ULong start,
const char *constraint,
CORBA::ULong max_store_size,
CORBA::ULong max_rec_list_len
)
:iter_ (store),
constraint_ (constraint),
max_store_size_ (max_store_size),
max_rec_list_len_ (max_rec_list_len)
{
// Advance the iterator to the starting point.
for (CORBA::ULong i = 0;
i < start && iter_.advance () != -1;
++i)
{
;
}
}
TAO_Iterator_i::~TAO_Iterator_i (void)
{
// Do nothing
}
void
TAO_Iterator_i::destroy (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
PortableServer::POA_ptr poa = this->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
PortableServer::ObjectId_var oid =
poa->servant_to_id (this
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
// Goodbye cruel world...
// deactivate from the poa.
poa->deactivate_object (oid.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
return;
}
DsLogAdmin::RecordList*
TAO_Iterator_i::get (CORBA::ULong position,
CORBA::ULong how_many
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
DsLogAdmin::InvalidParam))
{
how_many = how_many ? 0 : 1;
if (how_many > this->max_rec_list_len_ - position)
ACE_THROW_RETURN (DsLogAdmin::InvalidParam (), 0);
CORBA::ULong i = 0;
// move the iterator to "position"
for (;
i < position && iter_.advance () != -1;
++i)
{
;
}
// Use an Interpreter to build an expression tree.
TAO_Log_Constraint_Interpreter interpreter (constraint_
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
// Sequentially iterate over all the records and pick the ones that
// meet the constraints.
// Iterate over and populate the list.
TAO_LogRecordStore::LOG_RECORD_HASH_MAP_ENTRY *hash_entry;
DsLogAdmin::RecordList* rec_list;
// Figure out the length of the list.
// Allocate the list of <max_rec_list_len_> length.
ACE_NEW_THROW_EX (rec_list,
DsLogAdmin::RecordList (this->max_rec_list_len_),
CORBA::NO_MEMORY ());
ACE_CHECK_RETURN (0);
CORBA::ULong count = 0;
CORBA::Boolean done = 0;
for ( i = 0;
i < how_many && count < this->max_rec_list_len_;
++i)
{
if (iter_.next (hash_entry) == -1 || iter_.advance () == -1)
{
done = 1;
break;
}
// Use an evaluator.
TAO_Log_Constraint_Visitor visitor (hash_entry->int_id_);
// Does it match the constraint?
if (interpreter.evaluate (visitor) == 1)
{
(*rec_list)[count] = hash_entry->int_id_;
// copy the log record.
count++;
}
}
rec_list->length (count);
if (done == 1)
{
// destroy this object..
this->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (rec_list);
}
return rec_list;
}
|
