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
|
//$Id$
#include "Remote_Invocation.h"
#include "Profile.h"
#include "Profile_Transport_Resolver.h"
#include "target_specification.h"
#include "IOP_IORC.h"
#include "Stub.h"
#include "Transport.h"
ACE_RCSID (tao,
Remote_Invocation,
"$Id$")
namespace TAO
{
Remote_Invocation::Remote_Invocation (Profile_Transport_Resolver &resolver,
TAO_Operation_Details &detail)
: resolver_ (resolver)
, detail_ (detail)
{
}
void
Remote_Invocation::init_target_spec (TAO_Target_Specification &target_spec
ACE_ENV_ARG_DECL)
{
TAO_Profile *pfile =
this->resolver_.profile ();
// Set the target specification mode
switch (pfile->addressing_mode ())
{
case TAO_Target_Specification::Key_Addr:
target_spec.target_specifier (pfile->object_key ());
break;
case TAO_Target_Specification::Profile_Addr:
{
IOP::TaggedProfile *tp =
pfile->create_tagged_profile ();
if (tp)
target_spec.target_specifier (*tp);
}
break;
case TAO_Target_Specification::Reference_Addr:
// We need to call the method seperately. If there is no
// IOP::IOR info, the call would create the info and return the
// index that we need.
CORBA::ULong index = 0;
IOP::IOR *ior_info = 0;
int retval =
this->resolver_.stub ()->create_ior_info (ior_info,
index
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
if (retval == -1)
{
if (TAO_debug_level > 0)
{
ACE_ERROR ((LM_ERROR,
ACE_TEXT ("TAO (%P|%t) Error in finding index for \n")
ACE_TEXT ("IOP::IOR \n")));
}
return;
}
target_spec.target_specifier (*ior_info,
index);
break;
}
}
void
Remote_Invocation::write_header (TAO_Target_Specification &spec,
TAO_OutputCDR &out_stream
ACE_ENV_ARG_DECL)
{
// Send the request for the header
if (this->resolver_.transport ()->generate_request_header (this->detail_,
spec,
out_stream)
== -1)
{
ACE_THROW (CORBA::MARSHAL ());
}
this->resolver_.transport ()->assign_translators (0,
&out_stream);
}
void
Remote_Invocation::marshal_data (Argument **args,
int args_number,
TAO_OutputCDR &out_stream
ACE_ENV_ARG_DECL)
{
for (int i = 0; i != args_number; ++i)
{
if (!((*args[i]).marshal (out_stream)))
ACE_THROW (CORBA::MARSHAL ());
}
}
Invocation_Status
Remote_Invocation::send_message (TAO_OutputCDR &cdr,
short message_semantics
ACE_ENV_ARG_DECL_NOT_USED)
{
int retval =
this->resolver_.transport ()->send_request (
this->resolver_.stub (),
this->resolver_.stub ()->orb_core (),
cdr,
message_semantics,
0);
if (retval != 0)
{
if (TAO_debug_level > 2)
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) Synch_Twoway_Invocation::send_message - ")
ACE_TEXT ("failure while sending message \n")));
// Need to close connections..
return TAO_INVOKE_RESTART;
}
return TAO_INVOKE_SUCCESS;
}
}
|
