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
141
142
143
144
145
146
147
148
149
150
|
#include "tao/DynamicInterface/Server_Request.h"
#include "tao/AnyTypeCode/TypeCode_Constants.h"
#include "tao/AnyTypeCode/NVList.h"
#include "tao/AnyTypeCode/SystemExceptionA.h"
#include "tao/ORB_Core.h"
#include "tao/Thread_Lane_Resources.h"
#include "Roundtrip.h"
Roundtrip::Roundtrip (CORBA::ORB_ptr orb)
: orb_ (CORBA::ORB::_duplicate (orb))
{
}
void
Roundtrip::invoke (CORBA::ServerRequest_ptr request,
TAO_AMH_DSI_Response_Handler_ptr rh)
{
if (ACE_OS::strcmp ("shutdown", request->operation ()) == 0)
{
this->orb_->shutdown (0);
return;
}
else if (ACE_OS::strcmp ("_is_a", request->operation ()) == 0)
{
CORBA::NVList_ptr list;
this->orb_->create_list (0, list);
CORBA::Any type_id;
type_id._tao_set_typecode (CORBA::_tc_string);
list->add_value ("type_id", type_id, CORBA::ARG_IN);
request->arguments (list);
// list still has ownership of the item
CORBA::NamedValue_ptr nv = list->item (0);
const char *arg;
*(nv->value ()) >>= arg;
CORBA::Boolean type_matches = false;
if (ACE_OS::strcmp (arg, "IDL:Test/Roundtrip:1.0") == 0
|| ACE_OS::strcmp (arg, "IDL:omg.org/CORBA/Object:1.0") == 0
|| ACE_OS::strcmp (arg, "") == 0)
type_matches = true;
CORBA::Any result_any;
result_any <<= CORBA::Any::from_boolean (type_matches);
// AMH way of replying
CORBA::NamedValue_var result = 0;
this->orb_->create_named_value (result.out());
*(result->value()) = result_any;
rh->invoke_reply (list, result.in ());
return;
}
else if (ACE_OS::strcmp ("test_method", request->operation ()) == 0)
{
CORBA::NVList_ptr list; // will become property of the arguments list
this->orb_->create_list (0, list);
CORBA::Any send_time;
send_time._tao_set_typecode (CORBA::_tc_ulonglong);
list->add_value ("send_time", send_time, CORBA::ARG_IN);
request->arguments (list);
CORBA::NamedValue_ptr nv = list->item (0);
// AMH way of replying
rh->invoke_reply (list, nv);
return;
}
CORBA::Any bad_operation;
CORBA::BAD_OPERATION exception;
bad_operation <<= exception;
request->set_exception (bad_operation);
}
CORBA::RepositoryId
Roundtrip::_primary_interface (const PortableServer::ObjectId &,
PortableServer::POA_ptr)
{
return CORBA::string_dup ("IDL:Test/Roundtrip:1.0");
}
void
Roundtrip::_dispatch (TAO_ServerRequest &request,
TAO::Portable_Server::Servant_Upcall * /* context */)
{
// No need to do any of this if the client isn't waiting.
if (request.response_expected ())
{
if (!CORBA::is_nil (request.forward_location ()))
{
request.init_reply ();
request.tao_send_reply ();
// No need to invoke in this case.
return;
}
else if (request.sync_with_server ())
{
// The last line before the call to this function
// was an ACE_CHECK_RETURN, so if we're here, we
// know there is no exception so far, and that's all
// a SYNC_WITH_SERVER client request cares about.
request.send_no_exception_reply ();
}
}
// Create DSI request object.
CORBA::ServerRequest *dsi_request = 0;
ACE_NEW (dsi_request,
CORBA::ServerRequest (request));
try
{
TAO_AMH_DSI_Response_Handler_ptr rh_ptr;
ACE_NEW (rh_ptr, TAO_AMH_DSI_Response_Handler(request));
TAO_AMH_DSI_Response_Handler_var rh(rh_ptr);
rh->init (request, 0);
// Delegate to user.
this->invoke (dsi_request, rh.in());
}
catch (const CORBA::Exception& ex)
{
// Only if the client is waiting.
if (request.response_expected () && !request.sync_with_server ())
{
request.tao_send_reply_exception (ex);
}
}
CORBA::release (dsi_request);
}
void
Roundtrip::invoke (CORBA::ServerRequest_ptr)
{
throw CORBA::NO_IMPLEMENT();
}
|
