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
|
// $Id$
#include "Dynamic_Property.h"
TAO_DP_Dispatcher::TAO_DP_Dispatcher(const char* name)
{
}
TAO_DP_Dispatcher::~TAO_DP_Dispatcher (void)
{
for (HANDLER_MAP::iterator handler_iter = this->handlers_.begin ();
handler_iter != this->handlers_.end ();
handler_iter++)
{
CORBA::Boolean delete_me = (*handler_iter).second.second;
if (delete_me)
delete (*handler_iter).second.first;
}
}
void
TAO_DP_Dispatcher::
register_handler(const char* name,
TAO_DP_Evaluation_Handler* handler,
CORBA::Boolean release_on_delete)
{
string prop_name(name);
TAO_DP_Dispatcher::HANDLER_MAP::iterator handlers_iter =
this->handlers_.find(prop_name);
// Set up the handler to receive evaluations for prop_name
if (handlers_iter == this->handlers_.end())
this->handlers_[prop_name] = make_pair (handler, release_on_delete);
}
CosTradingDynamic::DynamicProp*
TAO_DP_Dispatcher::
construct_dynamic_prop (const char* name,
CORBA::TypeCode_ptr returned_type,
const CORBA::Any& extra_info)
{
CosTradingDynamic::DynamicProp* dp_struct = 0;
ACE_NEW_RETURN (dp_struct, CosTradingDynamic::DynamicProp, 0);
TAO_TRY
{
dp_struct->eval_if = this->_this (TAO_TRY_ENV);
TAO_CHECK_ENV;
dp_struct->returned_type =
CORBA::TypeCode::_duplicate (returned_type);
dp_struct->extra_info = extra_info;
}
TAO_CATCHANY
{
return 0;
}
TAO_ENDTRY;
return dp_struct;
}
TAO_DP_Evaluation_Handler*
TAO_DP_Dispatcher::remove_handler(const char* name)
{
string prop_name(name);
TAO_DP_Evaluation_Handler* handler = 0;
HANDLER_MAP::iterator handlers_iter = this->handlers_.find(prop_name);
if (handlers_iter != this->handlers_.end())
{
handler = (*handlers_iter).second.first;
this->handlers_.erase(handlers_iter);
}
return handler;
}
CORBA::Any*
TAO_DP_Dispatcher::evalDP(const char* name,
CORBA::TypeCode_ptr returned_type,
const CORBA::Any& extra_info,
CORBA::Environment& _env)
TAO_THROW_SPEC ((CORBA::SystemException,
CosTradingDynamic::DPEvalFailure))
{
string prop_name(name);
CORBA::Any* result = 0;
HANDLER_MAP::iterator handlers_iter = this->handlers_.find(prop_name);
if (handlers_iter != this->handlers_.end())
{
TAO_DP_Evaluation_Handler* handler = (*handlers_iter).second.first;
result = handler->evalDP (extra_info, returned_type, _env);
TAO_CHECK_ENV_RETURN (_env, result);
if (! returned_type->equal(result->type(), _env))
{
TAO_THROW_RETURN (CosTradingDynamic::DPEvalFailure
(name, returned_type, extra_info),
result);
}
}
else
{
TAO_THROW_RETURN (CosTradingDynamic::DPEvalFailure
(name, returned_type, extra_info),
result);
}
return result;
}
|
