summaryrefslogtreecommitdiff
path: root/cpp/src/IcePack/ServerRegistryI.cpp
diff options
context:
space:
mode:
authorMark Spruiell <mes@zeroc.com>2005-10-10 20:51:09 +0000
committerMark Spruiell <mes@zeroc.com>2005-10-10 20:51:09 +0000
commit5c820414d32245f8f23ad323787b72fb94f2782b (patch)
tree7b00c76b0c76606ed30740849b83e65921b8be84 /cpp/src/IcePack/ServerRegistryI.cpp
parentadding IceGrid (diff)
downloadice-5c820414d32245f8f23ad323787b72fb94f2782b.tar.bz2
ice-5c820414d32245f8f23ad323787b72fb94f2782b.tar.xz
ice-5c820414d32245f8f23ad323787b72fb94f2782b.zip
bug 475: remove IcePack
Diffstat (limited to 'cpp/src/IcePack/ServerRegistryI.cpp')
-rw-r--r--cpp/src/IcePack/ServerRegistryI.cpp182
1 files changed, 0 insertions, 182 deletions
diff --git a/cpp/src/IcePack/ServerRegistryI.cpp b/cpp/src/IcePack/ServerRegistryI.cpp
deleted file mode 100644
index 208cf552845..00000000000
--- a/cpp/src/IcePack/ServerRegistryI.cpp
+++ /dev/null
@@ -1,182 +0,0 @@
-// **********************************************************************
-//
-// Copyright (c) 2003-2005 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.
-//
-// **********************************************************************
-
-#include <IcePack/ServerRegistryI.h>
-#include <IcePack/TraceLevels.h>
-#include <Freeze/Initialize.h>
-
-using namespace std;
-using namespace IcePack;
-
-const string ServerRegistryI::_dbName = "serverregistry";
-const string ServerRegistryI::_dbDescriptorName = "serverdescriptors";
-
-ServerRegistryI::ServerRegistryI(const Ice::CommunicatorPtr& communicator, const string& envName,
- const TraceLevelsPtr& traceLevels) :
- _connectionCache(Freeze::createConnection(communicator, envName)),
- _dictCache(_connectionCache, _dbName),
- _dictDescriptorCache(_connectionCache, _dbDescriptorName),
- _traceLevels(traceLevels),
- _envName(envName),
- _communicator(communicator)
-{
-}
-
-void
-ServerRegistryI::add(const string& name,
- const ServerPrx& server,
- const ServerDescriptorPtr& descriptor,
- const Ice::Current& current)
-{
- while(true)
- {
- ServerPrx oldServer;
- try
- {
- oldServer = findByName(name, current);
- oldServer->ice_ping();
- throw ServerExistsException();
- }
- catch(const ServerNotExistException&)
- {
- }
- catch(const Ice::ObjectNotExistException&)
- {
- }
- catch(const Ice::LocalException&)
- {
- throw ServerExistsException();
- }
-
- Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName);
- StringObjectProxyDict dict(connection, _dbName);
- StringServerDescriptorDict dictDescriptor(connection, _dbDescriptorName);
-
- StringObjectProxyDict::iterator p = dict.find(name);
- if(p != dict.end())
- {
- if(oldServer && oldServer != p->second)
- {
- continue;
- }
- }
-
- dict.put(pair<const string, const Ice::ObjectPrx>(name, server));
- dictDescriptor.put(pair<const string, const ServerDescriptorPtr>(name, descriptor));
-
- if(_traceLevels->serverRegistry > 0)
- {
- Ice::Trace out(_traceLevels->logger, _traceLevels->serverRegistryCat);
- out << "added server `" << name << "'";
- }
-
- break;
- }
-}
-
-ServerPrx
-ServerRegistryI::remove(const string& name, const Ice::Current&)
-{
- Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName);
- StringObjectProxyDict dict(connection, _dbName);
- StringServerDescriptorDict dictDescriptor(connection, _dbDescriptorName);
-
- StringObjectProxyDict::iterator p = dict.find(name);
- if(p == dict.end())
- {
- throw ServerNotExistException();
- }
-
- ServerPrx server = ServerPrx::uncheckedCast(p->second);
- dict.erase(p);
- dictDescriptor.erase(name);
-
- if(_traceLevels->serverRegistry > 0)
- {
- Ice::Trace out(_traceLevels->logger, _traceLevels->serverRegistryCat);
- out << "removed server `" << name << "'";
- }
-
- return server;
-}
-
-ServerPrx
-ServerRegistryI::findByName(const string& name, const Ice::Current&)
-{
- Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName);
- StringObjectProxyDict dict(connection, _dbName);
-
- StringObjectProxyDict::iterator p = dict.find(name);
- if(p != dict.end())
- {
- try
- {
- return ServerPrx::checkedCast(p->second);
- }
- catch(const Ice::ObjectNotExistException&)
- {
- dict.erase(p);
- }
- catch(const Ice::LocalException&)
- {
- return ServerPrx::uncheckedCast(p->second);
- }
- }
- throw ServerNotExistException();
-}
-
-ServerDescriptorPtr
-ServerRegistryI::getDescriptor(const string& name, const Ice::Current&)
-{
- Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName);
- StringServerDescriptorDict dictDescriptor(connection, _dbDescriptorName);
-
- StringServerDescriptorDict::iterator p = dictDescriptor.find(name);
- if(p == dictDescriptor.end())
- {
- throw ServerNotExistException();
- }
- return p->second;
-}
-
-Ice::StringSeq
-ServerRegistryI::getAll(const Ice::Current&) const
-{
- Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName);
- StringObjectProxyDict dict(connection, _dbName);
-
- Ice::StringSeq names;
- names.reserve(dict.size());
-
- for(StringObjectProxyDict::iterator p = dict.begin(); p != dict.end(); ++p)
- {
- names.push_back(p->first);
- }
-
- return names;
-}
-
-ServerDescriptorSeq
-ServerRegistryI::getAllDescriptorsOnNode(const string& node, const Ice::Current&) const
-{
- Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName);
- StringServerDescriptorDict dict(connection, _dbDescriptorName);
-
- ServerDescriptorSeq descriptors;
-
- for(StringServerDescriptorDict::iterator p = dict.begin(); p != dict.end(); ++p)
- {
- if(p->second->node == node)
- {
- descriptors.push_back(p->second);
- }
- }
-
- return descriptors;
-}