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
|
// $Id$
#include "tao/corba.h"
#include "tao/IORTable/IORTable.h"
#include "tao/Messaging/Messaging.h"
#include "tao/AnyTypeCode/Any.h"
#include "ace/OS_NS_string.h"
#include "ace/SString.h"
#include "HelloS.h"
namespace Test
{
class Hello_impl: virtual public POA_Test::Hello
{
public:
void say_hello() ACE_THROW_SPEC ((CORBA::SystemException)) { };
};
}
int main(int argc, char* argv[])
{
int status = 0;
CORBA::ORB_var orb = CORBA::ORB::_nil();
ACE_TRY_NEW_ENV
{
// Initialize the ORB
orb =
CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// create Hello object
Test::Hello_impl hello_i;
ACE_TRY_CHECK;
Test::Hello_var hello = hello_i._this ();
ACE_TRY_CHECK;
// give our object a friendly name
CORBA::Object_var iorTableObj =
orb->resolve_initial_references ("IORTable");
ACE_TRY_CHECK;
IORTable::Table_var iorTable
= IORTable::Table::_narrow (iorTableObj.in ());
ACE_TRY_CHECK;
CORBA::String_var ior_string = orb->object_to_string (hello.in ());
ACE_TRY_CHECK;
iorTable->bind("hello", ior_string.in ());
ACE_TRY_CHECK;
ACE_DEBUG ((LM_DEBUG, "Created binding of name 'hello' in IOR table for IOR:\n%s\n", ior_string.in ()));
// Get the root POA
CORBA::Object_var obj_root = orb->resolve_initial_references ("RootPOA");
ACE_TRY_CHECK;
PortableServer::POA_var rootPOA = PortableServer::POA::_narrow (obj_root.in ());
ACE_TRY_CHECK;
// Activate the POA manager
PortableServer::POAManager_var poaManager = rootPOA->the_POAManager ();
ACE_TRY_CHECK;
poaManager->activate ();
ACE_TRY_CHECK;
// try and access the object with its friendly name
ACE_CString full_corbaloc (ior_string.in (), 0, 1);
CORBA::ULong first_slash = full_corbaloc.find ("/", 0);
ACE_CString friendly_corbaloc =
full_corbaloc.substring (0,
first_slash);
friendly_corbaloc += "/hello";
ACE_DEBUG ((LM_DEBUG, "Trying to access object with object ref:\n%s\n", friendly_corbaloc.c_str ()));
CORBA::Object_var obj = orb->string_to_object (friendly_corbaloc.c_str ());
ACE_TRY_CHECK;
TimeBase::TimeT timeout = 10000000;
CORBA::Any timeout_any;
timeout_any <<= timeout;
CORBA::PolicyList policy_list (1);
policy_list.length (1);
policy_list[0] = orb->create_policy (
Messaging::RELATIVE_RT_TIMEOUT_POLICY_TYPE,
timeout_any);
CORBA::Object_var rtt_obj = obj->_set_policy_overrides (
policy_list,
CORBA::SET_OVERRIDE);
policy_list[0]->destroy();
Test::Hello_var hello2 = Test::Hello::_narrow (rtt_obj.in ());
ACE_TRY_CHECK;
if (CORBA::is_nil (hello2.in ()))
{
ACE_ERROR ((LM_ERROR,
"Unable to narrow from "
"corbaloc with policy override\n"));
status = 1;
}
else
{
hello2->say_hello ();
ACE_TRY_CHECK;
ACE_DEBUG ((LM_DEBUG, "Test succeeded !!!\n"));
}
orb->destroy();
ACE_TRY_CHECK;
}
ACE_CATCHANY
{
ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
"Error - test failed - exception caught:");
status = 1;
}
ACE_ENDTRY;
return status;
}
|
