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
|
// $Id$
#include "tao/DII_Reply_Dispatcher.h"
ACE_RCSID(tao, DII_Reply_Dispatcher, "$Id$")
#if (TAO_HAS_MINIMUM_CORBA == 0)
#include "tao/Pluggable.h"
#include "tao/Environment.h"
#include "tao/GIOP_Message_State.h"
#include "tao/Request.h"
#include "tao/debug.h"
#if !defined (__ACE_INLINE__)
#include "tao/DII_Reply_Dispatcher.i"
#endif /* __ACE_INLINE__ */
// Constructor.
TAO_DII_Deferred_Reply_Dispatcher::TAO_DII_Deferred_Reply_Dispatcher (const CORBA::Request_ptr req)
: req_ (req),
transport_ (0)
{
}
// Destructor.
TAO_DII_Deferred_Reply_Dispatcher::~TAO_DII_Deferred_Reply_Dispatcher (void)
{
if (this->transport_ != 0)
this->transport_->idle_after_reply ();
}
// Dispatch the reply.
int
TAO_DII_Deferred_Reply_Dispatcher::dispatch_reply (
CORBA::ULong reply_status,
const TAO_GIOP_Version & /*version*/,
IOP::ServiceContextList &reply_ctx,
TAO_GIOP_Message_State *message_state
)
{
this->reply_status_ = reply_status;
//this->version_ = version;
this->message_state_ = message_state;
// Steal the buffer, that way we don't do any unnecesary copies of
// this data.
CORBA::ULong max = reply_ctx.maximum ();
CORBA::ULong len = reply_ctx.length ();
IOP::ServiceContext* context_list = reply_ctx.get_buffer (1);
this->reply_service_info_.replace (max, len, context_list, 1);
if (TAO_debug_level >= 4)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P | %t):TAO_Asynch_Reply_Dispatcher::dispatch_reply:\n")));
}
ACE_TRY_NEW_ENV
{
// Call the Request back and send the reply data.
this->req_->handle_response (this->message_state_->cdr,
reply_status,
ACE_TRY_ENV);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
if (TAO_debug_level >= 4)
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
"Exception during reply handler");
}
ACE_ENDTRY;
// This was dynamically allocated. Now the job is done. Commit
// suicide here.
delete this;
return 1;
}
TAO_GIOP_Message_State *
TAO_DII_Deferred_Reply_Dispatcher::message_state (void)
{
return this->message_state_;
}
void
TAO_DII_Deferred_Reply_Dispatcher::dispatcher_bound (TAO_Transport*)
{
}
void
TAO_DII_Deferred_Reply_Dispatcher::connection_closed (void)
{
ACE_TRY_NEW_ENV
{
// Generate a fake exception....
CORBA::COMM_FAILURE comm_failure (0, CORBA::COMPLETED_MAYBE);
TAO_OutputCDR out_cdr;
comm_failure._tao_encode (out_cdr, ACE_TRY_ENV);
ACE_TRY_CHECK;
// Turn into an output CDR
TAO_InputCDR cdr (out_cdr);
this->req_->handle_response (cdr,
TAO_PLUGGABLE_MESSAGE_SYSTEM_EXCEPTION,
ACE_TRY_ENV);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
if (TAO_debug_level >= 4)
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
"DII_Deferred_Reply_Dispacher::connection_closed");
}
ACE_ENDTRY;
}
#endif /* TAO_HAS_MINIMUM_CORBA */
|
