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
|
// -*- C++ -*-
//
// $Id$
#include "SSLIOP_ORBInitializer.h"
ACE_RCSID (TAO_SSLIOP,
SSLIOP_ORBInitializer,
"$Id$")
#include "SSLIOP_Current.h"
#include "SSLIOP_Invocation_Interceptor.h"
#include "orbsvcs/SSLIOPC.h"
#include "tao/Exception.h"
#include "tao/ORBInitInfo.h"
TAO_SSLIOP_ORBInitializer::TAO_SSLIOP_ORBInitializer (int no_protection)
: no_protection_ (no_protection)
{
}
void
TAO_SSLIOP_ORBInitializer::pre_init (
PortableInterceptor::ORBInitInfo_ptr info
TAO_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
TAO_ENV_ARG_DEFN;
// Narrow to a TAO_ORBInitInfo object to get accss to the
// allocate_tss_slot_id() TAO extension.
TAO_ORBInitInfo *tao_info = TAO_ORBInitInfo::_narrow (info,
ACE_TRY_ENV);
ACE_CHECK;
if (tao_info == 0)
{
if (TAO_debug_level > 0)
ACE_ERROR ((LM_ERROR,
"(%P|%t) SSLIOP_ORBInitializer::pre_init:\n"
"(%P|%t) Unable to narrow "
"\"PortableInterceptor::ORBInitInfo_ptr\" to\n"
"(%P|%t) \"TAO_ORBInitInfo *.\"\n"));
ACE_THROW (CORBA::INTERNAL ());
}
// Reserve a TSS slot in the ORB core internal TSS resources for the
// thread-specific portion of SSLIOP::Current.
size_t tss_slot = tao_info->allocate_tss_slot_id (0,
ACE_TRY_ENV);
ACE_CHECK;
CORBA::String_var orb_id = info->orb_id (ACE_TRY_ENV);
ACE_CHECK;
// Create the SSLIOP::Current object.
// Note that a new SSLIOP::Current object is created for each ORB.
// It wouldn't be very used to share security context information
// with another ORB that isn't configured with security, for
// example.
SSLIOP::Current_ptr current = SSLIOP::Current::_nil ();
ACE_NEW_THROW_EX (current,
TAO_SSLIOP_Current (tss_slot, orb_id.in ()),
CORBA::NO_MEMORY (
CORBA_SystemException::_tao_minor_code (
TAO_DEFAULT_MINOR_CODE,
ENOMEM),
CORBA::COMPLETED_NO));
ACE_CHECK;
SSLIOP::Current_var ssliop_current = current;
// Register the SSLIOP::Current object reference with the ORB.
info->register_initial_reference ("SSLIOPCurrent",
ssliop_current.in (),
ACE_TRY_ENV);
ACE_CHECK;
}
void
TAO_SSLIOP_ORBInitializer::post_init (
PortableInterceptor::ORBInitInfo_ptr info
TAO_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
TAO_ENV_ARG_DEFN;
// Note we do not store the SSLIOP::Current as a class member since
// we need to avoid potential problems where the same
// SSLIOP::Current object is shared between ORBs. Each ORB should
// have its own unique SSLIOP::Current object. By obtaining the
// SSLIOP::Current object from the resolve_initial_references()
// mechanism, we are guaranteed that the SSLIOP::Current object is
// specific to the ORB being initialized since a new SSLIOP::Current
// object is registered for each ORB in this ORBInitializer's
// pre_init() method.
CORBA::Object_var obj =
info->resolve_initial_references ("SSLIOPCurrent", ACE_TRY_ENV);
ACE_CHECK;
SSLIOP::Current_var ssliop_current =
SSLIOP::Current::_narrow (obj.in (), ACE_TRY_ENV);
ACE_CHECK;
// Create the SSLIOP secure invocation server request interceptor.
PortableInterceptor::ServerRequestInterceptor_ptr si =
PortableInterceptor::ServerRequestInterceptor::_nil ();
ACE_NEW_THROW_EX (si,
TAO_SSLIOP_Server_Invocation_Interceptor (
ssliop_current.in (),
this->no_protection_),
CORBA::NO_MEMORY (
CORBA_SystemException::_tao_minor_code (
TAO_DEFAULT_MINOR_CODE,
ENOMEM),
CORBA::COMPLETED_NO));
ACE_CHECK;
PortableInterceptor::ServerRequestInterceptor_var si_interceptor =
si;
// Register the SSLIOP secure invocation server request interceptor
// with the ORB.
info->add_server_request_interceptor (si_interceptor.in (),
ACE_TRY_ENV);
ACE_CHECK;
}
|
