blob: c2dbebb87a5ca5d44ce504cb4ca174ed13b73b68 (
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
|
// note: This order of header inclusion is required in order to satisfy
// template instantiation rules.
#include "tao/CORBA_methods.h"
#include "tao/AnyTypeCode/NVList.h"
#include "My_DII_Reply_Handler.h"
#include "ace/Log_Msg.h"
#include "tao/AnyTypeCode/Any.h"
My_DII_Reply_Handler::My_DII_Reply_Handler(
TAO_AMH_DSI_Response_Handler_ptr rph,
CORBA::ORB_var orb)
: response_handler_ (TAO_AMH_DSI_Response_Handler::_duplicate(rph)),
orb_ (orb)
{
}
My_DII_Reply_Handler::~My_DII_Reply_Handler()
{
}
void
My_DII_Reply_Handler::handle_response(TAO_InputCDR &incoming)
{
CORBA::NVList_var opList;
if (!CORBA::is_nil (this->response_handler_.in()))
{
int org_byte_order = this->response_handler_->_tao_byte_order ();
try
{
this->orb_->create_list (0, opList.out());
bool lazy_evaluation = true;
opList->_tao_incoming_cdr (incoming,
CORBA::ARG_OUT | CORBA::ARG_INOUT,
lazy_evaluation);
// make sure the response is sent on in the same byte order
// as initially received
this->response_handler_->_tao_byte_order (incoming.byte_order ());
this->response_handler_->invoke_reply (opList.in(),
0 // result
);
}
catch (const CORBA::SystemException &ex)
{
// in this case the response originates locally so we
// need to reset the byte order again
this->response_handler_->_tao_byte_order (org_byte_order);
TAO_AMH_DSI_Exception_Holder h (ex._tao_duplicate());
response_handler_->invoke_excep(&h);
}
catch (...)
{
// in this case the response originates locally so we
// need to reset the byte order again
this->response_handler_->_tao_byte_order (org_byte_order);
ACE_ERROR ((LM_ERROR,
"ERROR: Unknown Exception\n"));
TAO_AMH_DSI_Exception_Holder h (new CORBA::UNKNOWN());
response_handler_->invoke_excep(&h);
}
}
}
void
My_DII_Reply_Handler::handle_excep (TAO_InputCDR &incoming,
CORBA::ULong reply_status)
{
// make sure the response is sent on in the same byte order
// as initially received
this->response_handler_->_tao_byte_order (incoming.byte_order ());
ACE_DEBUG((LM_DEBUG, "calling My_DII_Reply_Handler::handle_excep()\n"));
this->response_handler_->gateway_exception_reply (reply_status, incoming);
}
|
