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
130
131
132
133
134
135
136
137
138
139
140
141
|
// **********************************************************************
//
// Copyright (c) 2003-2016 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
#ifndef ICE_GRID_REGISTRYI_H
#define ICE_GRID_REGISTRYI_H
#include <IceUtil/Timer.h>
#include <IceGrid/Registry.h>
#include <IceGrid/Query.h>
#include <IceGrid/Locator.h>
#include <IceGrid/Internal.h>
#include <IceGrid/PlatformInfo.h>
#include <IceGrid/ReplicaSessionManager.h>
#include <IceGrid/PluginFacade.h>
#include <Glacier2/PermissionsVerifierF.h>
#include <IceStorm/Service.h>
namespace IceGrid
{
class Database;
typedef IceUtil::Handle<Database> DatabasePtr;
class WellKnownObjectsManager;
typedef IceUtil::Handle<WellKnownObjectsManager> WellKnownObjectsManagerPtr;
class TraceLevels;
typedef IceUtil::Handle<TraceLevels> TraceLevelsPtr;
class ReapThread;
typedef IceUtil::Handle<ReapThread> ReapThreadPtr;
class SessionServantManager;
typedef IceUtil::Handle<SessionServantManager> SessionServantManagerPtr;
class ClientSessionFactory;
typedef IceUtil::Handle<ClientSessionFactory> ClientSessionFactoryPtr;
class AdminSessionFactory;
typedef IceUtil::Handle<AdminSessionFactory> AdminSessionFactoryPtr;
std::string getInstanceName(const Ice::CommunicatorPtr&);
class RegistryI : public Registry
{
public:
RegistryI(const Ice::CommunicatorPtr&, const TraceLevelsPtr&, bool, bool, const std::string&, const std::string&);
~RegistryI();
bool start();
bool startImpl();
void stop();
virtual SessionPrx createSession(const std::string&, const std::string&, const Ice::Current&);
virtual AdminSessionPrx createAdminSession(const std::string&, const std::string&, const Ice::Current&);
virtual SessionPrx createSessionFromSecureConnection(const Ice::Current&);
virtual AdminSessionPrx createAdminSessionFromSecureConnection(const Ice::Current&);
virtual int getSessionTimeout(const Ice::Current& = Ice::Current()) const;
virtual int getACMTimeout(const Ice::Current& = Ice::Current()) const;
std::string getName() const;
RegistryInfo getInfo() const;
void waitForShutdown();
virtual void shutdown();
std::string getServerAdminCategory() const { return _instanceName + "-RegistryServerAdminRouter"; }
std::string getNodeAdminCategory() const { return _instanceName + "-RegistryNodeAdminRouter"; }
std::string getReplicaAdminCategory() const { return _instanceName + "-RegistryReplicaAdminRouter"; }
Ice::ObjectPrx createAdminCallbackProxy(const Ice::Identity&) const;
const Ice::ObjectAdapterPtr& getRegistryAdapter() { return _registryAdapter; }
Ice::LocatorPrx getLocator();
private:
void setupLocatorRegistry();
LocatorPrx setupLocator(const RegistryPrx&, const QueryPrx&);
QueryPrx setupQuery();
RegistryPrx setupRegistry();
InternalRegistryPrx setupInternalRegistry();
bool setupUserAccountMapper();
Ice::ObjectAdapterPtr setupClientSessionFactory(const LocatorPrx&);
Ice::ObjectAdapterPtr setupAdminSessionFactory(const Ice::ObjectPtr&, const Ice::ObjectPtr&,
const Ice::ObjectPtr&, const LocatorPrx&);
Glacier2::PermissionsVerifierPrx getPermissionsVerifier(const LocatorPrx&, const std::string&);
Glacier2::SSLPermissionsVerifierPrx getSSLPermissionsVerifier(const LocatorPrx&, const std::string&);
Glacier2::SSLInfo getSSLInfo(const Ice::ConnectionPtr&, std::string&);
NodePrxSeq registerReplicas(const InternalRegistryPrx&, const NodePrxSeq&);
void registerNodes(const InternalRegistryPrx&, const NodePrxSeq&);
const Ice::CommunicatorPtr _communicator;
const TraceLevelsPtr _traceLevels;
const bool _nowarn;
const bool _readonly;
const std::string _initFromReplica;
const std::string _collocatedNodeName;
DatabasePtr _database;
Ice::ObjectAdapterPtr _clientAdapter;
Ice::ObjectAdapterPtr _serverAdapter;
Ice::ObjectAdapterPtr _registryAdapter;
WellKnownObjectsManagerPtr _wellKnownObjects;
std::string _instanceName;
bool _master;
std::string _replicaName;
ReapThreadPtr _reaper;
IceUtil::TimerPtr _timer;
SessionServantManagerPtr _servantManager;
int _sessionTimeout;
IceUtil::UniquePtr<ReplicaSessionManager> _session;
mutable PlatformInfo _platform;
ClientSessionFactoryPtr _clientSessionFactory;
Glacier2::PermissionsVerifierPrx _clientVerifier;
Glacier2::SSLPermissionsVerifierPrx _sslClientVerifier;
AdminSessionFactoryPtr _adminSessionFactory;
Glacier2::PermissionsVerifierPrx _adminVerifier;
Glacier2::SSLPermissionsVerifierPrx _sslAdminVerifier;
IceStormInternal::ServicePtr _iceStorm;
};
typedef IceUtil::Handle<RegistryI> RegistryIPtr;
}
#endif
|
