blob: 27d67cdddad731f2b1e78ed1c691617a8e56e7a1 (
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
|
// $Id$
#include "client_interceptor.h"
#include "HelloC.h"
#include "ace/Log_Msg.h"
extern const ACE_TCHAR *server2_ior;
extern CORBA::ORB_var orb;
const IOP::ServiceId service_id = 0xdeadbeef;
int isRecursive = 0;
extern Demo::HelloWorld_var server1_shutdownObj;
Echo_Client_Request_Interceptor::
Echo_Client_Request_Interceptor ()
: myname_ ("Echo_Client_Interceptor")
{
}
Echo_Client_Request_Interceptor::~Echo_Client_Request_Interceptor (void)
{
}
char *
Echo_Client_Request_Interceptor::name (void)
{
return CORBA::string_dup (this->myname_);
}
void
Echo_Client_Request_Interceptor::destroy (void)
{
}
void
Echo_Client_Request_Interceptor::send_poll (
PortableInterceptor::ClientRequestInfo_ptr)
{
// Do Nothing
}
void
Echo_Client_Request_Interceptor::send_request (
PortableInterceptor::ClientRequestInfo_ptr ri)
{
CORBA::String_var operation = ri->operation ();
if (ACE_OS::strcmp (operation.in (), "shutdown") == 0) {
return;
}
//send to another
isRecursive ++ ;
if (isRecursive%2 == 1 )
{
if (isRecursive == 3) {
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t)Echo_Client_Request_Interceptor::send_request(%d) ")
ACE_TEXT ("shutdown server 1 now. \n"), isRecursive));
server1_shutdownObj->shutdown();
}
CORBA::Object_var helloObj = orb->string_to_object(server2_ior);
Demo::HelloWorld_var hello = Demo::HelloWorld::_narrow(helloObj.in ());
if (CORBA::is_nil(hello.in ())) {
ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%P|%t)Echo_Client_Request_Interceptor::send_request(%d) ")
ACE_TEXT ("hello reference is nil.\n"), isRecursive));
}
else {
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t)Echo_Client_Request_Interceptor::send_request(%d) ")
ACE_TEXT ("call server2 HelloWorld::sayHello() \n"), isRecursive));
const char* pMsg = " server2 say Hello";
hello->sayHello(pMsg) ;
}
}
}
void
Echo_Client_Request_Interceptor::receive_reply (
PortableInterceptor::ClientRequestInfo_ptr)
{
}
void
Echo_Client_Request_Interceptor::receive_other (
PortableInterceptor::ClientRequestInfo_ptr)
{
}
void
Echo_Client_Request_Interceptor::receive_exception (
PortableInterceptor::ClientRequestInfo_ptr)
{
}
|
