diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2006-05-05 12:08:20 +0000 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2006-05-05 12:08:20 +0000 |
| commit | 18f9a9bed9a763f4d902bdc859cc1b2731679d58 (patch) | |
| tree | 0ee9bd8702b9e604d8e5a5102a5d001f3baf4ec4 /cpp/src/IceGrid/AdapterCache.cpp | |
| parent | More changes wrt string conversion (diff) | |
| download | ice-18f9a9bed9a763f4d902bdc859cc1b2731679d58.tar.bz2 ice-18f9a9bed9a763f4d902bdc859cc1b2731679d58.tar.xz ice-18f9a9bed9a763f4d902bdc859cc1b2731679d58.zip | |
Removed session based locator, refactored allocation code.
Diffstat (limited to 'cpp/src/IceGrid/AdapterCache.cpp')
| -rw-r--r-- | cpp/src/IceGrid/AdapterCache.cpp | 35 |
1 files changed, 5 insertions, 30 deletions
diff --git a/cpp/src/IceGrid/AdapterCache.cpp b/cpp/src/IceGrid/AdapterCache.cpp index 8e1fbdd0d48..8eae5e3fac4 100644 --- a/cpp/src/IceGrid/AdapterCache.cpp +++ b/cpp/src/IceGrid/AdapterCache.cpp @@ -202,27 +202,13 @@ ServerAdapterEntry::ServerAdapterEntry(AdapterCache& cache, } vector<pair<string, AdapterPrx> > -ServerAdapterEntry::getProxies(int& nReplicas, const SessionIPtr&) +ServerAdapterEntry::getProxies(int& nReplicas) { vector<pair<string, AdapterPrx> > adapters; try { nReplicas = 1; - // - // TODO: Remove this code if we really don't want to check the - // session for allocatable adapters. - // -// if(allocatable()) -// { -// if(session == getSession()) -// { -// adapters.push_back(make_pair(_id, getProxy())); -// } -// } -// else -// { - adapters.push_back(make_pair(_id, getProxy())); -// } + adapters.push_back(make_pair(_id, getProxy())); } catch(const NodeUnreachableException&) { @@ -292,7 +278,7 @@ ServerAdapterEntry::getServer() const return _server; } -bool +void ServerAdapterEntry::allocated(const SessionIPtr& session) { TraceLevelsPtr traceLevels = _cache.getTraceLevels(); @@ -301,7 +287,6 @@ ServerAdapterEntry::allocated(const SessionIPtr& session) Ice::Trace out(traceLevels->logger, traceLevels->adapterCat); out << "adapter `" << _id << "' allocated by `" << session->getUserId() << "' (" << _count << ")"; } - return true; } void @@ -384,7 +369,7 @@ ReplicaGroupEntry::update(const LoadBalancingPolicyPtr& policy) } vector<pair<string, AdapterPrx> > -ReplicaGroupEntry::getProxies(int& nReplicas, const SessionIPtr& session) +ReplicaGroupEntry::getProxies(int& nReplicas) { ReplicaSeq replicas; bool adaptive = false; @@ -448,17 +433,7 @@ ReplicaGroupEntry::getProxies(int& nReplicas, const SessionIPtr& session) { try { - if(p->second->allocatable()) - { - if(session == p->second->getSession()) - { - adapters.push_back(make_pair(p->first, p->second->getProxy())); - } - } - else - { - adapters.push_back(make_pair(p->first, p->second->getProxy())); - } + adapters.push_back(make_pair(p->first, p->second->getProxy())); } catch(AdapterNotExistException&) { |