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
|
// -*- C++ -*-
#include "ace/Log_Msg.h"
ACE_RCSID (ForwardRequest,
Client_Request_Interceptor,
"$Id$")
#include "Current_TestC.h"
#include "Client_Request_Interceptor.h"
#include "Client_ORBInitializer.h"
namespace Test
{
Client_Request_Interceptor::Client_Request_Interceptor (const char *orb_id,
TEST test)
: orb_id_ (CORBA::string_dup (orb_id))
, request_count_ (0)
, requestID_ (1)
, test_ (test)
{
}
CORBA::Long
Client_Request_Interceptor::interceptions (void)
{
return this->request_count_;
}
char *
Client_Request_Interceptor::name (void)
{
return CORBA::string_dup ("Client_Request_Interceptor");
}
void
Client_Request_Interceptor::test_transport_current (const ACE_TCHAR* amethod)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("CRI (%P|%t) Test accessing Transport Current from %s\n"),
amethod));
++this->request_count_;
int tmp = 0;
ACE_TCHAR **argv = 0;
CORBA::ORB_var orb = CORBA::ORB_init (tmp,
argv,
orb_id_.in ());
// Call the test function, which will throw an exception on
// failure
(*this->test_) (orb.in ());
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("CRI (%P|%t) Successfully tested Transport Current from %s\n"),
amethod));
}
void
Client_Request_Interceptor::destroy (void)
{
}
void
Client_Request_Interceptor::send_request (PortableInterceptor::ClientRequestInfo_ptr ri)
{
// Test TC
test_transport_current (ACE_TEXT ("send_request"));
CORBA::Boolean const response_expected =
ri->response_expected ();
// Oneway?
if (response_expected)
ACE_DEBUG ((LM_DEBUG, ACE_TEXT("CRI (%P|%t) Sending a two-way\n")));
else
ACE_DEBUG ((LM_DEBUG, ACE_TEXT("CRI (%P|%t) Sending a one-way\n")));
// Make the context to send the context to the target
IOP::ServiceContext sc;
sc.context_id = Test::Transport::CurrentTest::ContextTag;
// How long can a number really get?
char temp[32];
{
ACE_GUARD (TAO_SYNCH_MUTEX, monitor, this->lock_);
ACE_OS::sprintf (temp, "%ld", this->requestID_);
++this->requestID_;
}
CORBA::ULong string_len = ACE_OS::strlen (temp) + 1;
CORBA::Octet *buf = CORBA::OctetSeq::allocbuf (string_len);
ACE_OS::strcpy (reinterpret_cast <char *> (buf), temp);
sc.context_data.replace (string_len, string_len, buf, 1);
// Add this context to the service context list.
ri->add_request_service_context (sc, 0);
}
void
Client_Request_Interceptor::send_poll (PortableInterceptor::ClientRequestInfo_ptr)
{
test_transport_current (ACE_TEXT ("send_poll"));
}
void
Client_Request_Interceptor::receive_reply (PortableInterceptor::ClientRequestInfo_ptr)
{
test_transport_current (ACE_TEXT ("receive_reply"));
}
void
Client_Request_Interceptor::receive_exception (PortableInterceptor::ClientRequestInfo_ptr)
{
test_transport_current (ACE_TEXT ("receive_exception"));
}
void
Client_Request_Interceptor::receive_other (PortableInterceptor::ClientRequestInfo_ptr)
{
test_transport_current (ACE_TEXT ("receive_other"));
}
}
|
