summaryrefslogtreecommitdiff
path: root/cpp/src/IceGrid/RegistryI.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/IceGrid/RegistryI.cpp')
-rw-r--r--cpp/src/IceGrid/RegistryI.cpp59
1 files changed, 23 insertions, 36 deletions
diff --git a/cpp/src/IceGrid/RegistryI.cpp b/cpp/src/IceGrid/RegistryI.cpp
index bbda17c4059..05928bf7bae 100644
--- a/cpp/src/IceGrid/RegistryI.cpp
+++ b/cpp/src/IceGrid/RegistryI.cpp
@@ -238,26 +238,19 @@ RegistryI::start(bool nowarn)
return false;
}
- if(!properties->getProperty("IceGrid.Registry.Admin.Endpoints").empty())
- {
- if(!nowarn)
- {
- Warning out(_communicator->getLogger());
- out << "administrative endpoints `IceGrid.Registry.Admin.Endpoints' enabled";
- }
- }
+ // IceGrid.Registry.SessionManager.Endpoints is optional.
properties->setProperty("Ice.PrintProcessId", "0");
properties->setProperty("Ice.ServerIdleTime", "0");
properties->setProperty("IceGrid.Registry.Client.AdapterId", "");
properties->setProperty("IceGrid.Registry.Server.AdapterId", "");
- properties->setProperty("IceGrid.Registry.Admin.AdapterId", "");
+ properties->setProperty("IceGrid.Registry.SessionManager.AdapterId", "");
properties->setProperty("IceGrid.Registry.Internal.AdapterId", "");
setupThreadPool(properties, "Ice.ThreadPool.Client", 1, 100);
setupThreadPool(properties, "IceGrid.Registry.Client.ThreadPool", 1, 10);
setupThreadPool(properties, "IceGrid.Registry.Server.ThreadPool", 1, 10);
- setupThreadPool(properties, "IceGrid.Registry.Admin.ThreadPool", 1, 10);
+ setupThreadPool(properties, "IceGrid.Registry.SessionManager.ThreadPool", 1, 10);
setupThreadPool(properties, "IceGrid.Registry.Internal.ThreadPool", 1, 100);
_traceLevels = new TraceLevels(properties, _communicator->getLogger(), false);
@@ -339,7 +332,7 @@ RegistryI::start(bool nowarn)
ObjectAdapterPtr serverAdapter = _communicator->createObjectAdapter("IceGrid.Registry.Server");
ObjectAdapterPtr clientAdapter = _communicator->createObjectAdapter("IceGrid.Registry.Client");
- ObjectAdapterPtr adminAdapter = _communicator->createObjectAdapter("IceGrid.Registry.Admin");
+ ObjectAdapterPtr sessionManagerAdapter = _communicator->createObjectAdapter("IceGrid.Registry.SessionManager");
_database->setClientProxy(clientAdapter->createDirectProxy(_communicator->stringToIdentity("dummy")));
_database->setServerProxy(serverAdapter->createDirectProxy(_communicator->stringToIdentity("dummy")));
@@ -348,7 +341,6 @@ RegistryI::start(bool nowarn)
{
LocatorPrx internalLocator = setupLocator(clientAdapter, serverAdapter, registryAdapter);
setupQuery(clientAdapter);
- setupAdmin(adminAdapter);
setupRegistry(clientAdapter);
//
@@ -367,8 +359,8 @@ RegistryI::start(bool nowarn)
_sessionServantLocator = new SessionServantLocatorI(clientAdapter, _instanceName);
clientAdapter->addServantLocator(_sessionServantLocator, "");
- setupClientSessionFactory(registryAdapter, adminAdapter, internalLocator, nowarn);
- setupAdminSessionFactory(registryAdapter, adminAdapter, internalLocator, nowarn);
+ setupClientSessionFactory(registryAdapter, sessionManagerAdapter, internalLocator, nowarn);
+ setupAdminSessionFactory(registryAdapter, sessionManagerAdapter, internalLocator, nowarn);
//
// Register all the replicated well-known objects with all the
@@ -392,7 +384,7 @@ RegistryI::start(bool nowarn)
//
serverAdapter->activate();
clientAdapter->activate();
- adminAdapter->activate();
+ sessionManagerAdapter->activate();
if(!replicaName.empty())
{
@@ -444,15 +436,6 @@ RegistryI::setupQuery(const Ice::ObjectAdapterPtr& clientAdapter)
}
void
-RegistryI::setupAdmin(const Ice::ObjectAdapterPtr& adminAdapter)
-{
- Identity adminId = _communicator->stringToIdentity(_instanceName + "/Admin");
- ObjectPtr admin = new AdminI(_database, this, 0);
- adminAdapter->add(admin, adminId);
- addWellKnownObject(adminAdapter->createProxy(adminId), Admin::ice_staticId());
-}
-
-void
RegistryI::setupRegistry(const Ice::ObjectAdapterPtr& clientAdapter)
{
Identity registryId = _communicator->stringToIdentity(_instanceName + "/Registry");
@@ -516,20 +499,20 @@ RegistryI::setupUserAccountMapper(const Ice::ObjectAdapterPtr& registryAdapter)
void
RegistryI::setupClientSessionFactory(const Ice::ObjectAdapterPtr& registryAdapter,
- const Ice::ObjectAdapterPtr& adminAdapter,
+ const Ice::ObjectAdapterPtr& sessionManagerAdapter,
const Ice::LocatorPrx& locator,
bool nowarn)
{
_waitQueue = new WaitQueue(); // Used for for session allocation timeout.
_waitQueue->start();
- _clientSessionFactory = new ClientSessionFactory(adminAdapter, _database, _waitQueue);
+ _clientSessionFactory = new ClientSessionFactory(sessionManagerAdapter, _database, _waitQueue);
Identity clientSessionMgrId = _communicator->stringToIdentity(_instanceName + "/SessionManager");
- adminAdapter->add(new ClientSessionManagerI(_clientSessionFactory), clientSessionMgrId);
+ sessionManagerAdapter->add(new ClientSessionManagerI(_clientSessionFactory), clientSessionMgrId);
Identity sslClientSessionMgrId = _communicator->stringToIdentity(_instanceName + "/SSLSessionManager");
- adminAdapter->add(new ClientSSLSessionManagerI(_clientSessionFactory), sslClientSessionMgrId);
+ sessionManagerAdapter->add(new ClientSSLSessionManagerI(_clientSessionFactory), sslClientSessionMgrId);
Ice::PropertiesPtr properties = _communicator->getProperties();
@@ -543,23 +526,25 @@ RegistryI::setupClientSessionFactory(const Ice::ObjectAdapterPtr& registryAdapte
properties->getProperty("IceGrid.Registry.SSLPermissionsVerifier"),
nowarn);
- addWellKnownObject(adminAdapter->createProxy(clientSessionMgrId), Glacier2::SessionManager::ice_staticId());
- addWellKnownObject(adminAdapter->createProxy(sslClientSessionMgrId), Glacier2::SSLSessionManager::ice_staticId());
+ addWellKnownObject(sessionManagerAdapter->createProxy(clientSessionMgrId),
+ Glacier2::SessionManager::ice_staticId());
+ addWellKnownObject(sessionManagerAdapter->createProxy(sslClientSessionMgrId),
+ Glacier2::SSLSessionManager::ice_staticId());
}
void
RegistryI::setupAdminSessionFactory(const Ice::ObjectAdapterPtr& registryAdapter,
- const Ice::ObjectAdapterPtr& adminAdapter,
+ const Ice::ObjectAdapterPtr& sessionManagerAdapter,
const Ice::LocatorPrx& locator,
bool nowarn)
{
- _adminSessionFactory = new AdminSessionFactory(adminAdapter, _database, this);
+ _adminSessionFactory = new AdminSessionFactory(sessionManagerAdapter, _database, this);
Identity adminSessionMgrId = _communicator->stringToIdentity(_instanceName + "/AdminSessionManager");
- adminAdapter->add(new AdminSessionManagerI(_adminSessionFactory), adminSessionMgrId);
+ sessionManagerAdapter->add(new AdminSessionManagerI(_adminSessionFactory), adminSessionMgrId);
Identity sslAdmSessionMgrId = _communicator->stringToIdentity(_instanceName + "/AdminSSLSessionManager");
- adminAdapter->add(new AdminSSLSessionManagerI(_adminSessionFactory), sslAdmSessionMgrId);
+ sessionManagerAdapter->add(new AdminSSLSessionManagerI(_adminSessionFactory), sslAdmSessionMgrId);
Ice::PropertiesPtr properties = _communicator->getProperties();
@@ -574,8 +559,10 @@ RegistryI::setupAdminSessionFactory(const Ice::ObjectAdapterPtr& registryAdapter
properties->getProperty("IceGrid.Registry.AdminSSLPermissionsVerifier"),
nowarn);
- addWellKnownObject(adminAdapter->createProxy(adminSessionMgrId), Glacier2::SessionManager::ice_staticId());
- addWellKnownObject(adminAdapter->createProxy(sslAdmSessionMgrId), Glacier2::SSLSessionManager::ice_staticId());
+ addWellKnownObject(sessionManagerAdapter->createProxy(adminSessionMgrId),
+ Glacier2::SessionManager::ice_staticId());
+ addWellKnownObject(sessionManagerAdapter->createProxy(sslAdmSessionMgrId),
+ Glacier2::SSLSessionManager::ice_staticId());
}
void