diff options
Diffstat (limited to 'cppe/src/IceE/RouterInfo.cpp')
| -rw-r--r-- | cppe/src/IceE/RouterInfo.cpp | 263 |
1 files changed, 0 insertions, 263 deletions
diff --git a/cppe/src/IceE/RouterInfo.cpp b/cppe/src/IceE/RouterInfo.cpp deleted file mode 100644 index 8a864dfbcad..00000000000 --- a/cppe/src/IceE/RouterInfo.cpp +++ /dev/null @@ -1,263 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2007 ZeroC, Inc. All rights reserved. -// -// This copy of Ice-E is licensed to you under the terms described in the -// ICEE_LICENSE file included in this distribution. -// -// ********************************************************************** - -#include <IceE/Config.h> - -#ifdef ICEE_HAS_ROUTER - -#include <IceE/RouterInfo.h> -#include <IceE/Router.h> -#include <IceE/Reference.h> -#include <IceE/LocalException.h> -#include <IceE/Connection.h> // For ice_getConnection()->timeout(). -#include <IceE/Functional.h> - -using namespace std; -using namespace Ice; -using namespace IceInternal; - -IceUtil::Shared* IceInternal::upCast(RouterManager* p) { return p; } -IceUtil::Shared* IceInternal::upCast(RouterInfo* p) { return p; } - -IceInternal::RouterManager::RouterManager() : - _tableHint(_table.end()) -{ -} - -void -IceInternal::RouterManager::destroy() -{ - IceUtil::Mutex::Lock sync(*this); - - for_each(_table.begin(), _table.end(), Ice::secondVoidMemFun<const RouterPrx, RouterInfo>(&RouterInfo::destroy)); - - _table.clear(); - _tableHint = _table.end(); -} - -RouterInfoPtr -IceInternal::RouterManager::get(const RouterPrx& rtr) -{ - if(!rtr) - { - return 0; - } - - RouterPrx router = RouterPrx::uncheckedCast(rtr->ice_router(0)); // The router cannot be routed. - - IceUtil::Mutex::Lock sync(*this); - - map<RouterPrx, RouterInfoPtr>::iterator p = _table.end(); - - if(_tableHint != _table.end()) - { - if(_tableHint->first == router) - { - p = _tableHint; - } - } - - if(p == _table.end()) - { - p = _table.find(router); - } - - if(p == _table.end()) - { - _tableHint = _table.insert(_tableHint, pair<const RouterPrx, RouterInfoPtr>(router, new RouterInfo(router))); - } - else - { - _tableHint = p; - } - - return _tableHint->second; -} - -RouterInfoPtr -IceInternal::RouterManager::erase(const RouterPrx& rtr) -{ - RouterInfoPtr info; - if(rtr) - { - RouterPrx router = RouterPrx::uncheckedCast(rtr->ice_router(0)); // The router cannot be routed. - IceUtil::Mutex::Lock sync(*this); - - map<RouterPrx, RouterInfoPtr>::iterator p = _table.end(); - if(_tableHint != _table.end() && _tableHint->first == router) - { - p = _tableHint; - _tableHint = _table.end(); - } - - if(p == _table.end()) - { - p = _table.find(router); - } - - if(p != _table.end()) - { - info = p->second; - _table.erase(p); - } - } - - return info; -} - -IceInternal::RouterInfo::RouterInfo(const RouterPrx& router) : - _router(router) -{ - assert(_router); -} - -void -IceInternal::RouterInfo::destroy() -{ - IceUtil::Mutex::Lock sync(*this); - - _clientEndpoints.clear(); - _serverEndpoints.clear(); -#ifndef ICEE_PURE_CLIENT - _adapter = 0; -#endif - _identities.clear(); -} - -bool -IceInternal::RouterInfo::operator==(const RouterInfo& rhs) const -{ - return _router == rhs._router; -} - -bool -IceInternal::RouterInfo::operator!=(const RouterInfo& rhs) const -{ - return _router != rhs._router; -} - -bool -IceInternal::RouterInfo::operator<(const RouterInfo& rhs) const -{ - return _router < rhs._router; -} - -RouterPrx -IceInternal::RouterInfo::getRouter() const -{ - // - // No mutex lock necessary, _router is immutable. - // - return _router; -} - -vector<EndpointPtr> -IceInternal::RouterInfo::getClientEndpoints() -{ - IceUtil::Mutex::Lock sync(*this); - - if(_clientEndpoints.size() == 0) // Lazy initialization. - { - ObjectPrx clientProxy = _router->getClientProxy(); - if(!clientProxy) - { - // - // If getClientProxy() return nil, use router endpoints. - // - _clientEndpoints = _router->__reference()->getEndpoints(); - } - else - { - clientProxy = clientProxy->ice_router(0); // The client proxy cannot be routed. - - // - // In order to avoid creating a new connection to the router, - // we must use the same timeout as the already existing - // connection. - // - clientProxy = clientProxy->ice_timeout(_router->ice_getConnection()->timeout()); - - _clientEndpoints = clientProxy->__reference()->getEndpoints(); - } - } - - return _clientEndpoints; -} - -vector<EndpointPtr> -IceInternal::RouterInfo::getServerEndpoints() -{ - IceUtil::Mutex::Lock sync(*this); - - if(_serverEndpoints.size() == 0) // Lazy initialization. - { - ObjectPrx serverProxy = _router->getServerProxy(); - if(!serverProxy) - { - throw NoEndpointException(__FILE__, __LINE__); - } - - serverProxy = serverProxy->ice_router(0); // The server proxy cannot be routed. - - _serverEndpoints = serverProxy->__reference()->getEndpoints(); - } - - return _serverEndpoints; -} - -void -IceInternal::RouterInfo::addProxy(const ObjectPrx& proxy) -{ - assert(proxy); // Must not be called for null proxies. - - IceUtil::Mutex::Lock sync(*this); - - set<Identity>::iterator p = _identities.find(proxy->ice_getIdentity()); - - if(p == _identities.end()) - { - // - // Only add the proxy to the router if it's not already in our local map. - // - ObjectProxySeq proxies; - proxies.push_back(proxy); - ObjectProxySeq evictedProxies = _router->addProxies(proxies); - - // - // If we successfully added the proxy to the router, we add it to our local map. - // - _identities.insert(_identities.begin(), proxy->ice_getIdentity()); - - // - // We also must remove whatever proxies the router evicted. - // - for(ObjectProxySeq::iterator q = evictedProxies.begin(); q != evictedProxies.end(); ++q) - { - _identities.erase((*q)->ice_getIdentity()); - } - } -} - -#ifndef ICEE_PURE_CLIENT -void -IceInternal::RouterInfo::setAdapter(const ObjectAdapterPtr& adapter) -{ - IceUtil::Mutex::Lock sync(*this); - _adapter = adapter; -} - -ObjectAdapterPtr -IceInternal::RouterInfo::getAdapter() const -{ - IceUtil::Mutex::Lock sync(*this); - return _adapter; -} -#endif - -#endif |