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
|
//$Id$
#include "Invocation_Base.h"
#include "Object.h"
#include "Profile_Transport_Resolver.h"
#include "operation_details.h"
#include "Stub.h"
#include "ORB_Core.h"
//@@ Need to remove when we take care o fthe note below.
#include "corbafwd.h"
#include "Synch_Invocation.h"
#include "Transport.h"
#include "Transport_Mux_Strategy.h"
#include "Messaging_SyncScopeC.h"
ACE_RCSID (tao,
Invocation_Base,
"$Id$")
namespace TAO
{
Invocation_Base::Invocation_Base (CORBA::Object *target,
Argument **args,
int arg_number,
char *operation,
int op_len,
Invocation_Type type,
Invocation_Mode mode)
: target_ (target)
, args_ (args)
, number_args_ (arg_number)
, operation_ (operation)
, op_len_ (op_len)
, type_ (type)
, mode_ (mode)
{
}
void
Invocation_Base::invoke (TAO_Exception_Data *ex_data,
unsigned long ex_count
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
// Should stub object be refcounted here?
TAO_Stub *stub =
this->target_->_stubobj ();
if (stub == 0)
ACE_THROW (CORBA::INTERNAL (
CORBA::SystemException::_tao_minor_code (
TAO_DEFAULT_MINOR_CODE,
EINVAL),
CORBA::COMPLETED_NO));
// @@ Note: We may want somthing like this for FT
/*if (stub->orb_core ()->is_service_invocation ())
return stub->orb_core ()->invoke_services ();
*/
// Initial state
TAO::Invocation_Status status = TAO_INVOKE_START;
TAO_Operation_Details op_details (this->operation_,
this->op_len_,
this->number_args_ != 0,
ex_data,
ex_count);
/*while (status != TAO_INVOKE_SUCCESS ||
status != TAO_INVOKE_FAILURE)
{*/
Profile_Transport_Resolver resolver (stub);
resolver.resolve (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
// Update the request id now that we have a transport
op_details.request_id (resolver.transport ()->tms ()->request_id ());
if (this->type_ == TAO_ONEWAY_INVOCATION)
{
int has_synchronization = 0;
Messaging::SyncScope sync_scope;
stub->orb_core ()->call_sync_scope_hook (stub,
has_synchronization,
sync_scope);
op_details.response_flags (sync_scope);
TAO::Synch_Oneway_Invocation synch (resolver,
op_details);
status =
synch.communicate (this->args_,
this->number_args_
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
else if (this->type_ == TAO_TWOWAY_INVOCATION
&& this->mode_ == TAO_SYNCHRONOUS_INVOCATION)
{
// @@ NOTE:Need to change this to something better. Too many
// hash defines meaning the same thing..
op_details.response_flags (TAO_TWOWAY_RESPONSE_FLAG);
TAO::Synch_Twoway_Invocation synch (resolver,
op_details);
status =
synch.communicate (this->args_,
this->number_args_
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
else if (this->type_ == TAO_TWOWAY_INVOCATION
&& this->mode_ == TAO_ASYNCHRONOUS_CALLBACK_INVOCATION)
{
// Should never get here..
ACE_THROW (CORBA::INTERNAL (
CORBA::SystemException::_tao_minor_code (
TAO_DEFAULT_MINOR_CODE,
EINVAL),
CORBA::COMPLETED_NO));
}
/*}*
}
} // End namespace TAO
|
