blob: 1814d83968081a42a1f67ee5b7fd1d6e85318f53 (
plain)
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
|
// $Id$
//========================================================================
//
// = LIBRARY
// TAO/tests/POA/Non_Servant_Upcalls
//
// = FILENAME
// Non_Servant_Upcalls.cpp
//
// = DESCRIPTION
// This program tests the users ability to make calls on a POA
// during non-servant upcalls. In this example, a servant which
// is being destroyed during because of a deactivate_object()
// call, tries to deactivate another object in its destructor.
//
// = AUTHOR
// Irfan Pyarali
//
//=========================================================================
#include "testS.h"
#include "ace/Argv_Type_Converter.h"
// This is to remove "inherits via dominance" warnings from MSVC.
// MSVC is being a little too paranoid.
#if defined (_MSC_VER)
# pragma warning (disable : 4250)
#endif /* _MSC_VER */
class test_i :
public virtual POA_test
{
public:
test_i (test_i *other);
~test_i (void);
test_i *other_;
};
test_i::test_i (test_i *other)
: other_ (other)
{
}
test_i::~test_i (void)
{
ACE_DEBUG ((LM_DEBUG, "(%t) test_i::~test_i\n"));
if (this->other_)
{
ACE_TRY_NEW_ENV
{
PortableServer::POA_var poa = this->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
PortableServer::ObjectId_var id = poa->servant_to_id (this->other_
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_DEBUG ((LM_DEBUG, "(%t) Deactivating other servant\n"));
poa->deactivate_object (id.in ()
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
"test_i::~test_i");
}
ACE_ENDTRY;
}
}
int
ACE_TMAIN (int argc, ACE_TCHAR **argv)
{
ACE_Argv_Type_Converter convert (argc, argv);
ACE_TRY_NEW_ENV
{
// Initialize the ORB first.
CORBA::ORB_var orb = CORBA::ORB_init (convert.get_argc(),
convert.get_ASCII_argv(),
0
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Obtain the RootPOA.
CORBA::Object_var obj =
orb->resolve_initial_references ("RootPOA"
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Get the POA_var object from Object_var.
PortableServer::POA_var root_poa =
PortableServer::POA::_narrow (obj.in ()
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Get the POAManager of the RootPOA.
PortableServer::POAManager_var poa_manager =
root_poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
test_i *servant1 = new test_i (0);
test_i *servant2 = new test_i (servant1);
PortableServer::ObjectId_var id1 =
root_poa->activate_object (servant1
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Give ownership to POA.
servant1->_remove_ref (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
PortableServer::ObjectId_var id2 =
root_poa->activate_object (servant2
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Give ownership to POA.
servant2->_remove_ref (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
root_poa->deactivate_object (id2.in ()
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
root_poa->destroy (1,
1
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Exception caught");
return -1;
}
ACE_ENDTRY;
return 0;
}
|
