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
|
#include "ServantLocator.h"
ACE_RCSID (ServantLocator,
ServantLocator,
"$Id$")
#include "test_i.h"
extern CORBA::Boolean receive_request_service_contexts_called;
extern CORBA::Boolean ending_interception_point_called;
ServantLocator::ServantLocator (CORBA::ORB_ptr orb)
: error_status_ (false),
orb_ (CORBA::ORB::_duplicate (orb)),
servant_ ()
{
}
ServantLocator::~ServantLocator (void)
{
}
PortableServer::Servant
ServantLocator::preinvoke (
const PortableServer::ObjectId & /* oid */,
PortableServer::POA_ptr /* adapter */,
const char * operation,
PortableServer::ServantLocator::Cookie & /* the_cookie */)
{
if (ACE_OS::strcmp (operation, "shutdown") != 0)
{
if (receive_request_service_contexts_called == 0)
{
error_status_ = true;
ACE_ERROR ((LM_ERROR,
"PortableInterceptor::ServerRequestInterceptor:: "
"receive_request_service_contexts() not called\n"
"prior to "
"PortableServer::ServantLocator::preinvoke().\n"));
throw CORBA::INTERNAL ();
}
if (this->servant_.in () == 0)
{
test_i * servant;
ACE_NEW_THROW_EX (servant,
test_i (this->orb_.in ()),
CORBA::NO_MEMORY ());
this->servant_ = servant;
}
}
return this->servant_.in ();
}
void
ServantLocator::postinvoke (
const PortableServer::ObjectId & /* oid */,
PortableServer::POA_ptr /* adapter */,
const char * operation,
PortableServer::ServantLocator::Cookie /* the_cookie */,
PortableServer::Servant /* the_servant */)
{
if (ACE_OS::strcmp (operation, "shutdown") != 0)
{
// Ending interception points should be called after postinvoke().
if (::ending_interception_point_called != 0)
{
error_status_ = true;
ACE_ERROR ((LM_ERROR,
"ERROR: PortableInterceptor::ServerRequestInterceptor"
"\n"
"ERROR: ending interception point incorrectly "
"called prior to\n"
"ERROR: "
"PortableServer::ServantLocator::postinvoke().\n"));
throw CORBA::INTERNAL ();
}
}
}
|
