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
|
// -*- C++ -*-
// $Id$
#include "tao/TransportCurrent/TC_IIOPC.h"
#include "tao/TransportCurrent/TCC.h"
#include "Current_Test_Impl.h"
Current_Test_Impl::Current_Test_Impl (CORBA::ORB_ptr orb,
PortableServer::POA_ptr poa,
int do_collocated_calls)
: orb_ (CORBA::ORB::_duplicate (orb))
, poa_ (PortableServer::POA::_duplicate (poa))
, do_collocated_calls_ (do_collocated_calls)
{
}
Current_Test_Impl::~Current_Test_Impl (void)
{
}
::CORBA::Long
Current_Test_Impl::self_test (void)
{
return 0;
}
void
Current_Test_Impl::test_transport_current (void)
{
if (TAO_debug_level > 2) {
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) server - Testing access to IIOP Transport Current ...\n")));
}
CORBA::Object_var tcobject =
this->orb_->resolve_initial_references ("TAO::Transport::IIOP::Current");
TAO::Transport::IIOP::Current_var tc =
TAO::Transport::IIOP::Current::_narrow (tcobject.in ());
if (CORBA::is_nil (tc.in()))
{
ACE_ERROR ((LM_ERROR,
ACE_TEXT ("Unable to narrow down to TAO::Transport::IIOP::Current\n")));
throw CORBA::INTERNAL ();
}
CORBA::String_var rhost (tc->remote_host ());
CORBA::String_var lhost (tc->local_host ());
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) server - [%s:%d] -> [%s:%d]\n"),
rhost.in (), tc->remote_port (),
lhost.in (), tc->local_port ()));
if (TAO_debug_level > 2) {
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) server - Successfully accessed IIOP Transport Current\n")));
}
}
void
Current_Test_Impl::invoked_by_client (void)
{
if (TAO_debug_level >= 1) {
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) server - Test method invoked by client.\n")));
}
this->test_transport_current ();
if (this->do_collocated_calls_)
{
CORBA::Object_var selfobject =
poa_->servant_to_reference (this);
Test::Transport::CurrentTest_var self =
Test::Transport::CurrentTest::_narrow (selfobject.in ());
if (TAO_debug_level >= 1) {
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) server - Making a collocated invocation to invoked_during_upcall().\n")));
}
self->invoked_during_upcall ();
}
else
{
if (TAO_debug_level >= 1)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) server - skipping collocated calls\n")));
}
}
}
void
Current_Test_Impl::invoked_during_upcall (void)
{
if (TAO_debug_level > 2) {
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) server - Test method invoked ")
ACE_TEXT ("by the server during upcall.\n")));
}
}
void
Current_Test_Impl::shutdown (void)
{
if (TAO_debug_level > 2) {
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) server - shutting down.\n")));
}
this->orb_->shutdown (0);
}
|
