diff options
Diffstat (limited to 'cpp/src/IceGrid/LocatorI.cpp')
| -rw-r--r-- | cpp/src/IceGrid/LocatorI.cpp | 414 |
1 files changed, 207 insertions, 207 deletions
diff --git a/cpp/src/IceGrid/LocatorI.cpp b/cpp/src/IceGrid/LocatorI.cpp index 58cd8503f7a..9158def55ff 100644 --- a/cpp/src/IceGrid/LocatorI.cpp +++ b/cpp/src/IceGrid/LocatorI.cpp @@ -27,19 +27,19 @@ class AMI_Adapter_getDirectProxyI : public AMI_Adapter_getDirectProxy public: AMI_Adapter_getDirectProxyI(const LocatorIPtr& locator, const string& id, const LocatorAdapterInfo& adapter) : - _locator(locator), _id(id), _adapter(adapter) + _locator(locator), _id(id), _adapter(adapter) { } virtual void ice_response(const ::Ice::ObjectPrx& obj) { - assert(obj); - _locator->getDirectProxyCallback(_adapter.proxy->ice_getIdentity(), obj); + assert(obj); + _locator->getDirectProxyCallback(_adapter.proxy->ice_getIdentity(), obj); } virtual void ice_exception(const ::Ice::Exception& ex) { - _locator->getDirectProxyException(_adapter, _id, ex); + _locator->getDirectProxyException(_adapter, _id, ex); } private: @@ -54,18 +54,18 @@ class AMI_Adapter_activateI : public AMI_Adapter_activate public: AMI_Adapter_activateI(const LocatorIPtr& locator, const string& id, const LocatorAdapterInfo& adapter) : - _locator(locator), _id(id), _adapter(adapter) + _locator(locator), _id(id), _adapter(adapter) { } virtual void ice_response(const ::Ice::ObjectPrx& obj) { - _locator->getDirectProxyCallback(_adapter.proxy->ice_getIdentity(), obj); + _locator->getDirectProxyCallback(_adapter.proxy->ice_getIdentity(), obj); } virtual void ice_exception(const ::Ice::Exception& ex) { - _locator->getDirectProxyException(_adapter, _id, ex); + _locator->getDirectProxyException(_adapter, _id, ex); } private: @@ -84,66 +84,66 @@ class AMD_Locator_findAdapterByIdI : public Ice::AMD_Locator_findAdapterById public: AMD_Locator_findAdapterByIdI(const Ice::AMD_Locator_findObjectByIdPtr& cb, const Ice::ObjectPrx& obj) : - _cb(cb), - _obj(obj) + _cb(cb), + _obj(obj) { } virtual void ice_response(const ::Ice::ObjectPrx& obj) { - // - // If the adapter dummy direct proxy is not null, return a - // proxy containing the identity we were looking for and the - // endpoints of the adapter. - // - // If null, return the proxy registered with the object - // registry. - // - if(obj) - { - _cb->ice_response(obj->ice_identity(_obj->ice_getIdentity())); - } - else - { - _cb->ice_response(_obj); - } + // + // If the adapter dummy direct proxy is not null, return a + // proxy containing the identity we were looking for and the + // endpoints of the adapter. + // + // If null, return the proxy registered with the object + // registry. + // + if(obj) + { + _cb->ice_response(obj->ice_identity(_obj->ice_getIdentity())); + } + else + { + _cb->ice_response(_obj); + } } virtual void ice_exception(const ::Ice::Exception& ex) { - try - { - ex.ice_throw(); - } - catch(Ice::AdapterNotFoundException&) - { - // - // We couldn't find the adapter, we ignore and return the - // original proxy containing the adapter id. - // - _cb->ice_response(_obj); - return; - } - catch(const Ice::Exception& ex) - { - // - // Rethrow unexpected exception. - // - _cb->ice_exception(ex); - return; - } - - assert(false); + try + { + ex.ice_throw(); + } + catch(Ice::AdapterNotFoundException&) + { + // + // We couldn't find the adapter, we ignore and return the + // original proxy containing the adapter id. + // + _cb->ice_response(_obj); + return; + } + catch(const Ice::Exception& ex) + { + // + // Rethrow unexpected exception. + // + _cb->ice_exception(ex); + return; + } + + assert(false); } virtual void ice_exception(const std::exception& ex) { - _cb->ice_exception(ex); + _cb->ice_exception(ex); } virtual void ice_exception() { - _cb->ice_exception(); + _cb->ice_exception(); } private: @@ -155,12 +155,12 @@ private: } LocatorI::Request::Request(const Ice::AMD_Locator_findAdapterByIdPtr& amdCB, - const LocatorIPtr& locator, - const string& id, - bool replicaGroup, - const LocatorAdapterInfoSeq& adapters, - int count, - const TraceLevelsPtr& traceLevels) : + const LocatorIPtr& locator, + const string& id, + bool replicaGroup, + const LocatorAdapterInfoSeq& adapters, + int count, + const TraceLevelsPtr& traceLevels) : _amdCB(amdCB), _locator(locator), _id(id), @@ -182,8 +182,8 @@ LocatorI::Request::execute() // if(_adapters.empty()) { - sendResponse(); - return; + sendResponse(); + return; } // @@ -191,24 +191,24 @@ LocatorI::Request::execute() // LocatorAdapterInfoSeq adapters; { - Lock sync(*this); - assert(_count > 0 && _lastAdapter != _adapters.end()); - for(unsigned int i = 0; i < _count; ++i) - { - if(_lastAdapter == _adapters.end()) - { - _count = i; - break; - } - assert(_lastAdapter->proxy); - adapters.push_back(*_lastAdapter); - ++_lastAdapter; - } + Lock sync(*this); + assert(_count > 0 && _lastAdapter != _adapters.end()); + for(unsigned int i = 0; i < _count; ++i) + { + if(_lastAdapter == _adapters.end()) + { + _count = i; + break; + } + assert(_lastAdapter->proxy); + adapters.push_back(*_lastAdapter); + ++_lastAdapter; + } } assert(!adapters.empty()); for(LocatorAdapterInfoSeq::const_iterator p = adapters.begin(); p != adapters.end(); ++p) { - requestAdapter(*p); + requestAdapter(*p); } } @@ -217,32 +217,32 @@ LocatorI::Request::exception(const Ice::Exception& ex) { LocatorAdapterInfo adapter; { - Lock sync(*this); - - if(!_exception.get()) - { - _exception.reset(ex.ice_clone()); - } - - if(_lastAdapter == _adapters.end()) - { - --_count; // Expect one less adapter proxy if there's no more adapters to query. - - // - // If we received all the required proxies, it's time to send the - // answer back to the client. - // - if(_count == _proxies.size()) - { - sendResponse(); - } - return; - } - else - { - adapter = *_lastAdapter; - ++_lastAdapter; - } + Lock sync(*this); + + if(!_exception.get()) + { + _exception.reset(ex.ice_clone()); + } + + if(_lastAdapter == _adapters.end()) + { + --_count; // Expect one less adapter proxy if there's no more adapters to query. + + // + // If we received all the required proxies, it's time to send the + // answer back to the client. + // + if(_count == _proxies.size()) + { + sendResponse(); + } + return; + } + else + { + adapter = *_lastAdapter; + ++_lastAdapter; + } } requestAdapter(adapter); } @@ -261,7 +261,7 @@ LocatorI::Request::response(const Ice::ObjectPrx& proxy) // if(_proxies.size() == _count) { - sendResponse(); + sendResponse(); } } @@ -271,8 +271,8 @@ LocatorI::Request::requestAdapter(const LocatorAdapterInfo& adapter) assert(adapter.proxy); if(_locator->getDirectProxyRequest(this, adapter)) { - AMI_Adapter_getDirectProxyPtr amiCB = new AMI_Adapter_getDirectProxyI(_locator, _id, adapter); - adapter.proxy->getDirectProxy_async(amiCB); + AMI_Adapter_getDirectProxyPtr amiCB = new AMI_Adapter_getDirectProxyI(_locator, _id, adapter); + adapter.proxy->getDirectProxy_async(amiCB); } } @@ -281,45 +281,45 @@ LocatorI::Request::sendResponse() { if(_proxies.size() == 1) { - _amdCB->ice_response(_proxies.back()); + _amdCB->ice_response(_proxies.back()); } else if(_proxies.empty()) { - // - // If there's no proxies, it's either because we couldn't - // contact the adapters or because the replica group has - // no members. - // - assert(_exception.get() || _replicaGroup && _adapters.empty()); - - if(_traceLevels->locator > 0) - { - Ice::Trace out(_traceLevels->logger, _traceLevels->locatorCat); - out << "couldn't resolve " << (_replicaGroup ? "replica group `" : "adapter `") << _id << "' endpoints:\n"; - out << (_exception.get() ? toString(*_exception) : string("replica group is empty")); - } - _amdCB->ice_response(0); + // + // If there's no proxies, it's either because we couldn't + // contact the adapters or because the replica group has + // no members. + // + assert(_exception.get() || _replicaGroup && _adapters.empty()); + + if(_traceLevels->locator > 0) + { + Ice::Trace out(_traceLevels->logger, _traceLevels->locatorCat); + out << "couldn't resolve " << (_replicaGroup ? "replica group `" : "adapter `") << _id << "' endpoints:\n"; + out << (_exception.get() ? toString(*_exception) : string("replica group is empty")); + } + _amdCB->ice_response(0); } else if(_proxies.size() > 1) { - Ice::EndpointSeq endpoints; - endpoints.reserve(_proxies.size()); - for(vector<Ice::ObjectPrx>::const_iterator p = _proxies.begin(); p != _proxies.end(); ++p) - { - Ice::EndpointSeq edpts = (*p)->ice_getEndpoints(); - endpoints.insert(endpoints.end(), edpts.begin(), edpts.end()); - } + Ice::EndpointSeq endpoints; + endpoints.reserve(_proxies.size()); + for(vector<Ice::ObjectPrx>::const_iterator p = _proxies.begin(); p != _proxies.end(); ++p) + { + Ice::EndpointSeq edpts = (*p)->ice_getEndpoints(); + endpoints.insert(endpoints.end(), edpts.begin(), edpts.end()); + } - Ice::ObjectPrx proxy = _locator->getCommunicator()->stringToProxy("dummy:default"); - _amdCB->ice_response(proxy->ice_endpoints(endpoints)); + Ice::ObjectPrx proxy = _locator->getCommunicator()->stringToProxy("dummy:default"); + _amdCB->ice_response(proxy->ice_endpoints(endpoints)); } } LocatorI::LocatorI(const Ice::CommunicatorPtr& communicator, - const DatabasePtr& database, - const Ice::LocatorRegistryPrx& locatorRegistry, - const RegistryPrx& registry, - const QueryPrx& query) : + const DatabasePtr& database, + const Ice::LocatorRegistryPrx& locatorRegistry, + const RegistryPrx& registry, + const QueryPrx& query) : _communicator(communicator), _database(database), _locatorRegistry(locatorRegistry), @@ -334,17 +334,17 @@ LocatorI::LocatorI(const Ice::CommunicatorPtr& communicator, // void LocatorI::findObjectById_async(const Ice::AMD_Locator_findObjectByIdPtr& cb, - const Ice::Identity& id, - const Ice::Current& current) const + const Ice::Identity& id, + const Ice::Current& current) const { Ice::ObjectPrx proxy; try { - proxy = _database->getObjectProxy(id); + proxy = _database->getObjectProxy(id); } catch(const ObjectNotRegisteredException&) { - throw Ice::ObjectNotFoundException(); + throw Ice::ObjectNotFoundException(); } assert(proxy); @@ -358,12 +358,12 @@ LocatorI::findObjectById_async(const Ice::AMD_Locator_findObjectByIdPtr& cb, const string adapterId = proxy->ice_getAdapterId(); if(!adapterId.empty()) { - Ice::AMD_Locator_findAdapterByIdPtr amiCB = new AMD_Locator_findAdapterByIdI(cb, proxy); - findAdapterById_async(amiCB, adapterId, current); + Ice::AMD_Locator_findAdapterByIdPtr amiCB = new AMD_Locator_findAdapterByIdI(cb, proxy); + findAdapterById_async(amiCB, adapterId, current); } else { - cb->ice_response(proxy); + cb->ice_response(proxy); } } @@ -373,54 +373,54 @@ LocatorI::findObjectById_async(const Ice::AMD_Locator_findObjectByIdPtr& cb, // void LocatorI::findAdapterById_async(const Ice::AMD_Locator_findAdapterByIdPtr& cb, - const string& id, - const Ice::Current&) const + const string& id, + const Ice::Current&) const { bool replicaGroup = false; try { - // - // NOTE: getProxies() might throw if the adapter is a server - // adapter and the node is unreachable (it doesn't throw for - // replica groups). - // - int count; - LocatorAdapterInfoSeq adapters; - _database->getAdapter(id)->getLocatorAdapterInfo(adapters, count, replicaGroup); + // + // NOTE: getProxies() might throw if the adapter is a server + // adapter and the node is unreachable (it doesn't throw for + // replica groups). + // + int count; + LocatorAdapterInfoSeq adapters; + _database->getAdapter(id)->getLocatorAdapterInfo(adapters, count, replicaGroup); - LocatorIPtr self = const_cast<LocatorI*>(this); - RequestPtr request = new Request(cb, self, id, replicaGroup, adapters, count, _database->getTraceLevels()); - request->execute(); + LocatorIPtr self = const_cast<LocatorI*>(this); + RequestPtr request = new Request(cb, self, id, replicaGroup, adapters, count, _database->getTraceLevels()); + request->execute(); } catch(const AdapterNotExistException&) { - try - { - cb->ice_response(_database->getAdapterDirectProxy(id)); - } - catch(const AdapterNotExistException&) - { - cb->ice_exception(Ice::AdapterNotFoundException()); - } - return; + try + { + cb->ice_response(_database->getAdapterDirectProxy(id)); + } + catch(const AdapterNotExistException&) + { + cb->ice_exception(Ice::AdapterNotFoundException()); + } + return; } catch(const Ice::Exception& ex) { - const TraceLevelsPtr traceLevels = _database->getTraceLevels(); - if(traceLevels->locator > 0) - { - Ice::Trace out(traceLevels->logger, traceLevels->locatorCat); - if(replicaGroup) - { - out << "couldn't resolve replica group `" << id << "' endpoints:\n" << toString(ex); - } - else - { - out << "couldn't resolve adapter `" << id << "' endpoints:\n" << toString(ex); - } - } - cb->ice_response(0); - return; + const TraceLevelsPtr traceLevels = _database->getTraceLevels(); + if(traceLevels->locator > 0) + { + Ice::Trace out(traceLevels->logger, traceLevels->locatorCat); + if(replicaGroup) + { + out << "couldn't resolve replica group `" << id << "' endpoints:\n" << toString(ex); + } + else + { + out << "couldn't resolve adapter `" << id << "' endpoints:\n" << toString(ex); + } + } + cb->ice_response(0); + return; } } @@ -463,24 +463,24 @@ LocatorI::getDirectProxyException(const LocatorAdapterInfo& adpt, const string& { try { - ex.ice_throw(); + ex.ice_throw(); } catch(const AdapterNotActiveException& ex) { - if(ex.activatable) - { - // - // Activate the adapter if it can be activated on demand. - // - // NOTE: we use a timeout large enough to ensure that the - // activate() call won't timeout if the server hangs in - // deactivation and/or activation. - // - AMI_Adapter_activatePtr amiCB = new AMI_Adapter_activateI(this, id, adpt); - int timeout = adpt.activationTimeout + adpt.deactivationTimeout; - AdapterPrx::uncheckedCast(adpt.proxy->ice_timeout(timeout * 1000))->activate_async(amiCB); - return; - } + if(ex.activatable) + { + // + // Activate the adapter if it can be activated on demand. + // + // NOTE: we use a timeout large enough to ensure that the + // activate() call won't timeout if the server hangs in + // deactivation and/or activation. + // + AMI_Adapter_activatePtr amiCB = new AMI_Adapter_activateI(this, id, adpt); + int timeout = adpt.activationTimeout + adpt.deactivationTimeout; + AdapterPrx::uncheckedCast(adpt.proxy->ice_timeout(timeout * 1000))->activate_async(amiCB); + return; + } } catch(const Ice::Exception&) { @@ -488,16 +488,16 @@ LocatorI::getDirectProxyException(const LocatorAdapterInfo& adpt, const string& PendingRequests requests; { - Lock sync(*this); - PendingRequestsMap::iterator p = _pendingRequests.find(adpt.proxy->ice_getIdentity()); - assert(p != _pendingRequests.end()); - requests.swap(p->second); - _pendingRequests.erase(p); + Lock sync(*this); + PendingRequestsMap::iterator p = _pendingRequests.find(adpt.proxy->ice_getIdentity()); + assert(p != _pendingRequests.end()); + requests.swap(p->second); + _pendingRequests.erase(p); } for(PendingRequests::iterator q = requests.begin(); q != requests.end(); ++q) { - (*q)->exception(ex); + (*q)->exception(ex); } } @@ -506,26 +506,26 @@ LocatorI::getDirectProxyCallback(const Ice::Identity& adapterId, const Ice::Obje { PendingRequests requests; { - Lock sync(*this); - PendingRequestsMap::iterator p = _pendingRequests.find(adapterId); - assert(p != _pendingRequests.end()); - requests.swap(p->second); - _pendingRequests.erase(p); + Lock sync(*this); + PendingRequestsMap::iterator p = _pendingRequests.find(adapterId); + assert(p != _pendingRequests.end()); + requests.swap(p->second); + _pendingRequests.erase(p); } if(proxy) { - for(PendingRequests::const_iterator q = requests.begin(); q != requests.end(); ++q) - { - (*q)->response(proxy); - } + for(PendingRequests::const_iterator q = requests.begin(); q != requests.end(); ++q) + { + (*q)->response(proxy); + } } else { - for(PendingRequests::const_iterator q = requests.begin(); q != requests.end(); ++q) - { - (*q)->exception(AdapterNotActiveException()); - } + for(PendingRequests::const_iterator q = requests.begin(); q != requests.end(); ++q) + { + (*q)->exception(AdapterNotActiveException()); + } } } |