diff options
author | Mark Spruiell <mes@zeroc.com> | 2005-10-10 20:51:09 +0000 |
---|---|---|
committer | Mark Spruiell <mes@zeroc.com> | 2005-10-10 20:51:09 +0000 |
commit | 5c820414d32245f8f23ad323787b72fb94f2782b (patch) | |
tree | 7b00c76b0c76606ed30740849b83e65921b8be84 /cpp/src/IcePack/AdapterRegistryI.cpp | |
parent | adding IceGrid (diff) | |
download | ice-5c820414d32245f8f23ad323787b72fb94f2782b.tar.bz2 ice-5c820414d32245f8f23ad323787b72fb94f2782b.tar.xz ice-5c820414d32245f8f23ad323787b72fb94f2782b.zip |
bug 475: remove IcePack
Diffstat (limited to 'cpp/src/IcePack/AdapterRegistryI.cpp')
-rw-r--r-- | cpp/src/IcePack/AdapterRegistryI.cpp | 143 |
1 files changed, 0 insertions, 143 deletions
diff --git a/cpp/src/IcePack/AdapterRegistryI.cpp b/cpp/src/IcePack/AdapterRegistryI.cpp deleted file mode 100644 index 486d5a2fd1d..00000000000 --- a/cpp/src/IcePack/AdapterRegistryI.cpp +++ /dev/null @@ -1,143 +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/AdapterRegistryI.h> -#include <IcePack/TraceLevels.h> -#include <Freeze/Initialize.h> - -using namespace std; -using namespace IcePack; - -const string AdapterRegistryI::_dbName = "adapterregistry"; - -IcePack::AdapterRegistryI::AdapterRegistryI(const Ice::CommunicatorPtr& communicator, const string& envName, - const TraceLevelsPtr& traceLevels) : - _connectionCache(Freeze::createConnection(communicator, envName)), - _dictCache(_connectionCache, _dbName), - _traceLevels(traceLevels), - _envName(envName), - _communicator(communicator) -{ -} - -void -IcePack::AdapterRegistryI::add(const string& id, const AdapterPrx& adapter, const Ice::Current& current) -{ - while(true) - { - AdapterPrx oldAdapter; - try - { - oldAdapter = findById(id, current); - oldAdapter->ice_ping(); - throw AdapterExistsException(); - } - catch(const AdapterNotExistException&) - { - } - catch(const Ice::ObjectNotExistException&) - { - } - catch(const Ice::LocalException&) - { - throw AdapterExistsException(); - } - - Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName); - StringObjectProxyDict dict(connection, _dbName); - - StringObjectProxyDict::iterator p = dict.find(id); - if(p != dict.end()) - { - if(oldAdapter && oldAdapter != p->second) - { - continue; - } - - p.set(adapter); - - if(_traceLevels->adapterRegistry > 0) - { - Ice::Trace out(_traceLevels->logger, _traceLevels->adapterRegistryCat); - out << "updated adapter `" << id << "'"; - } - } - else - { - dict.put(pair<const string, const Ice::ObjectPrx>(id, adapter)); - - if(_traceLevels->adapterRegistry > 0) - { - Ice::Trace out(_traceLevels->logger, _traceLevels->adapterRegistryCat); - out << "added adapter `" << id << "'"; - } - } - - break; - } -} - -AdapterPrx -IcePack::AdapterRegistryI::remove(const string& id, const AdapterPrx& orig, const Ice::Current&) -{ - Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName); - StringObjectProxyDict dict(connection, _dbName); - - StringObjectProxyDict::iterator p = dict.find(id); - if(p == dict.end()) - { - throw AdapterNotExistException(); - } - - AdapterPrx adapter = AdapterPrx::uncheckedCast(p->second); - if(orig != 0 && orig != adapter) // Only remove if the adapter is equal to the provided proxy (if not null) - { - return 0; - } - dict.erase(p); - - if(_traceLevels->adapterRegistry > 0) - { - Ice::Trace out(_traceLevels->logger, _traceLevels->adapterRegistryCat); - out << "removed adapter `" << id << "'"; - } - - return adapter; -} - -AdapterPrx -IcePack::AdapterRegistryI::findById(const string& id, const Ice::Current&) -{ - Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName); - StringObjectProxyDict dict(connection, _dbName); - - StringObjectProxyDict::iterator p = dict.find(id); - if(p != dict.end()) - { - return AdapterPrx::uncheckedCast(p->second); - } - throw AdapterNotExistException(); -} - -Ice::StringSeq -IcePack::AdapterRegistryI::getAll(const Ice::Current&) const -{ - Freeze::ConnectionPtr connection = Freeze::createConnection(_communicator, _envName); - StringObjectProxyDict dict(connection, _dbName); - - Ice::StringSeq ids; - ids.reserve(dict.size()); - - for(StringObjectProxyDict::iterator p = dict.begin(); p != dict.end(); ++p) - { - ids.push_back(p->first); - } - - return ids; -} |