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
|
// @(#)request.cpp 1.6 95/09/24
// Copyright 1994-1995 by Sun Microsystems Inc.
// All Rights Reserved
//
// Implementation of Dynamic Invocation Interface
#include "tao/corba.h"
// {77420085-F276-11ce-9598-0000C07CA898}
DEFINE_GUID (IID_CORBA_Request,
0x77420085, 0xf276, 0x11ce, 0x95, 0x98, 0x0, 0x0, 0xc0, 0x7c, 0xa8, 0x98);
ULONG __stdcall
CORBA_Request::AddRef (void)
{
ACE_MT (ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, guard, lock_, 0));
return refcount_++;
}
ULONG __stdcall
CORBA_Request::Release (void)
{
{
ACE_MT (ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, mon, this->lock_, 0));
ACE_ASSERT (this != 0);
if (--refcount_ != 0)
return refcount_;
}
delete this;
return 0;
}
HRESULT __stdcall
CORBA_Request::QueryInterface (REFIID riid,
void **ppv)
{
*ppv = 0;
if (IID_CORBA_Request == riid || IID_IUnknown == riid)
*ppv = this;
if (*ppv == 0)
return ResultFromScode (E_NOINTERFACE);
(void) AddRef ();
return NOERROR;
}
// Reference counting for DII Request object
void
CORBA::release (CORBA::Request_ptr req)
{
if (req)
req->Release ();
}
CORBA::Boolean
CORBA::is_nil (CORBA::Request_ptr req)
{
return (CORBA::Boolean) req == 0;
}
// DII Request class implementation
CORBA_Request::CORBA_Request (CORBA::Object_ptr obj,
const CORBA::Char *op,
CORBA::NVList_ptr args,
CORBA::NamedValue_ptr result,
CORBA::Flags flags)
: args_ (args),
result_ (result),
flags_ (flags),
refcount_ (1)
{
target_ = CORBA::Object::_duplicate (obj);
opname_ = CORBA::string_copy (op);
}
CORBA_Request::CORBA_Request (CORBA::Object_ptr obj,
const CORBA::Char *op)
: flags_ (0),
refcount_ (1)
{
target_ = CORBA::Object::_duplicate (obj);
opname_ = CORBA::string_copy (op);
args_ = new CORBA::NVList;
result_ = new CORBA::NamedValue;
result_->AddRef();
}
CORBA_Request::~CORBA_Request (void)
{
assert (refcount_ == 0);
CORBA::release (target_);
CORBA::string_free ((CORBA::String) opname_);
CORBA::release (args_);
CORBA::release (result_);
}
// The public DII interfaces: normal and oneway calls.
//
// NOTE that using DII, programmers can get the special behaviour of
// discarding the response for normal calls. This doesn't change the
// semantics of any OMG-IDL interface, it just streamlines control
// flow in some exotic situations.
void
CORBA_Request::invoke (void)
{
STUB_Object *stub;
if (target_->QueryInterface (IID_STUB_Object,
(void **) &stub) != NOERROR)
{
env_.exception (new CORBA::DATA_CONVERSION (CORBA::COMPLETED_NO));
return;
}
stub->do_dynamic_call ((char *) opname_,
CORBA::B_TRUE,
args_,
result_,
flags_,
exceptions_,
env_);
stub->Release ();
}
void
CORBA_Request::send_oneway (void)
{
STUB_Object *stub;
if (target_->QueryInterface (IID_STUB_Object,
(void **) &stub) != NOERROR)
{
env_.exception (new CORBA::DATA_CONVERSION (CORBA::COMPLETED_NO));
return;
}
stub->do_dynamic_call ((char *) opname_,
CORBA::B_TRUE,
args_,
result_,
flags_,
exceptions_,
env_);
stub->Release ();
}
|
