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
|
#include "orbsvcs/Log/BasicLogFactory_i.h"
ACE_RCSID (Log,
BasicLogFactory_i,
"$Id$")
TAO_BasicLogFactory_i::TAO_BasicLogFactory_i (void)
{
}
TAO_BasicLogFactory_i::~TAO_BasicLogFactory_i (void)
{
}
DsLogAdmin::BasicLogFactory_ptr
TAO_BasicLogFactory_i::activate (PortableServer::POA_ptr poa
ACE_ENV_ARG_DECL)
{
PortableServer::ObjectId_var oid =
poa->activate_object (this
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (DsLogAdmin::BasicLogFactory::_nil ());
CORBA::Object_var obj =
poa->id_to_reference (oid.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (DsLogAdmin::BasicLogFactory::_nil ());
// narrow and store the result..
this->log_mgr_ =
DsLogAdmin::LogMgr::_narrow (obj.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (DsLogAdmin::BasicLogFactory::_nil ());
return DsLogAdmin::BasicLogFactory::_narrow (obj.in ()
ACE_ENV_ARG_PARAMETER);
}
DsLogAdmin::BasicLog_ptr
TAO_BasicLogFactory_i::create (DsLogAdmin::LogFullActionType full_action,
CORBA::ULongLong max_rec_size,
DsLogAdmin::LogId_out id
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
DsLogAdmin::InvalidLogFullAction
))
{
// Get an id for this Log.
this->max_id_++;
DsLogAdmin::BasicLog_ptr basiclog =
this->create_with_id (this->max_id_,
full_action,
max_rec_size
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (DsLogAdmin::BasicLog::_nil ());
// Set the id to return..
id = this->max_id_;
// Store the id in the LogIdList.
CORBA::ULong len = logid_list_.length ();
logid_list_.length (len + 1);
logid_list_[len] = id;
return basiclog;
}
DsLogAdmin::BasicLog_ptr
TAO_BasicLogFactory_i::create_with_id (DsLogAdmin::LogId id,
DsLogAdmin::LogFullActionType full_action,
CORBA::ULongLong max_size
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((
CORBA::SystemException,
DsLogAdmin::LogIdAlreadyExists,
DsLogAdmin::InvalidLogFullAction
))
{
// Make sure the id not used up.
if (hash_map_.find (id) == 0)
ACE_THROW_RETURN (DsLogAdmin::LogIdAlreadyExists (),
DsLogAdmin::BasicLog::_nil ());
DsLogAdmin::BasicLog_var basic_log;
// Object to return.
TAO_BasicLog_i* basic_log_i;
ACE_NEW_THROW_EX (basic_log_i,
TAO_BasicLog_i (*this,
this->log_mgr_.in (),
id,
full_action,
max_size),
CORBA::NO_MEMORY ());
ACE_CHECK_RETURN (DsLogAdmin::BasicLog::_nil ());
PortableServer::ServantBase_var safe_basic_log_i = basic_log_i;
// Transfer ownership to the POA.
basic_log_i->init (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (DsLogAdmin::BasicLog::_nil ());
// Register with the poa
basic_log = basic_log_i->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (DsLogAdmin::BasicLog::_nil ());
// widening a BasicLog_var to a Log_var
DsLogAdmin::Log_var log = DsLogAdmin::BasicLog::_duplicate (basic_log.in ());
// Add to the Hash table..
if (hash_map_.bind (id, log) == -1)
ACE_THROW_RETURN (CORBA::INTERNAL (),
DsLogAdmin::BasicLog::_nil ());
return basic_log._retn ();
}
|
