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
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
|
// -*- C++ -*-
//=============================================================================
/**
* @file DII_Invocation_Adapter.h
*
* $Id$
*
* @author Balachandran Natarajan <bala@dre.vanderbilt.edu>
*/
//=============================================================================
#ifndef TAO_DII_INVOCATION_ADAPTER_H
#define TAO_DII_INVOCATION_ADAPTER_H
#include /**/ "ace/pre.h"
#include "tao/DynamicInterface/dynamicinterface_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/Invocation_Adapter.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
class ACE_Time_Value;
ACE_END_VERSIONED_NAMESPACE_DECL
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_Operation_Details;
class TAO_Stub;
class TAO_ORB_Core;
class TAO_DII_Deferred_Reply_Dispatcher;
namespace CORBA
{
class Object;
class Environment;
class SystemException;
class ExceptionList;
class Request;
}
namespace TAO
{
class Argument;
class Collocation_Proxy_Broker;
struct Exception_Data;
/**
* @class DII_Invocation_Adapter
*
* @brief Generic interface for the DII invocation object visible
*/
class TAO_DynamicInterface_Export DII_Invocation_Adapter :
public Invocation_Adapter
{
public:
/// The only constructor used by the IDL compiler and onlly way to
/// create this adapter.
/**
*
* @param target Points to the object on which this invocation is
* being invoked.
*
* @param args Array of pointers to the argument list in the
* operation declaration. this includes the return, inout and out
* arguments.
*
* @param arg_number Number of arguments in the above array. This
* is the number of elements in the above array.
*
* @param operation The name of the operation being invoked.
*
* @param ope_len Number of charecters in the operation name. This
* is an optimization which helps us to avoid calling strlen ()
* while creating a message format.
*
* @param cpb The collocation proxy broker for the target if one
* exists.
*
* @param type The operation type which could be a oneway or two
* way operation. this information is availbe in the IDL file.
*
* @param mode Invocation mode. This information is also available
* in the IDL file and in the generated code.
*/
DII_Invocation_Adapter (CORBA::Object *target,
Argument **args,
int arg_number,
const char *operation,
size_t op_len,
CORBA::ExceptionList *exception,
CORBA::Request *r,
Invocation_Mode m = TAO_DII_INVOCATION);
virtual ~DII_Invocation_Adapter (void) {}
protected:
virtual Invocation_Status invoke_twoway (
TAO_Operation_Details &op,
CORBA::Object_var &effective_target,
Profile_Transport_Resolver &r,
ACE_Time_Value *&max_wait_time
ACE_ENV_ARG_DECL);
private:
CORBA::ExceptionList *exception_list_;
CORBA::Request *request_;
private:
/// Dont allow default initializations
DII_Invocation_Adapter (void);
DII_Invocation_Adapter (const DII_Invocation_Adapter &);
DII_Invocation_Adapter & operator= (const DII_Invocation_Adapter &);
};
/**
*
*/
class TAO_DynamicInterface_Export DII_Deferred_Invocation_Adapter
: protected Invocation_Adapter
{
public:
DII_Deferred_Invocation_Adapter (
CORBA::Object *target,
Argument **args,
int arg_number,
const char *operation,
size_t op_len,
Collocation_Proxy_Broker *b,
TAO_ORB_Core *oc,
CORBA::Request *req,
TAO::Invocation_Mode mode = TAO_DII_DEFERRED_INVOCATION);
/// Invoke the target
virtual void invoke (TAO::Exception_Data *ex,
unsigned long ex_count
ACE_ENV_ARG_DECL);
protected:
virtual Invocation_Status invoke_twoway (
TAO_Operation_Details &op,
CORBA::Object_var &effective_target,
Profile_Transport_Resolver &r,
ACE_Time_Value *&max_wait_time
ACE_ENV_ARG_DECL);
private:
CORBA::Request *request_;
/// Reply dispatcher for the current Invocation.
TAO_DII_Deferred_Reply_Dispatcher *rd_;
/// Cache the orb_core
TAO_ORB_Core *orb_core_;
};
} // End namespace TAO
TAO_END_VERSIONED_NAMESPACE_DECL
#include /**/ "ace/post.h"
#endif /*TAO_INVOCATION_ADAPTER_H*/
|
