diff options
Diffstat (limited to 'cpp/src/Ice/ProxyFactory.cpp')
| -rw-r--r-- | cpp/src/Ice/ProxyFactory.cpp | 23 |
1 files changed, 5 insertions, 18 deletions
diff --git a/cpp/src/Ice/ProxyFactory.cpp b/cpp/src/Ice/ProxyFactory.cpp index 325f9abe134..b38e281622a 100644 --- a/cpp/src/Ice/ProxyFactory.cpp +++ b/cpp/src/Ice/ProxyFactory.cpp @@ -110,18 +110,15 @@ IceInternal::ProxyFactory::referenceToProxy(const ReferencePtr& ref) const } int -IceInternal::ProxyFactory::checkRetryAfterException(const LocalException& ex, - const ReferencePtr& ref, - bool sleep, - int& cnt) const +IceInternal::ProxyFactory::checkRetryAfterException(const LocalException& ex, const ReferencePtr& ref, int& cnt) const { TraceLevelsPtr traceLevels = _instance->traceLevels(); LoggerPtr logger = _instance->initializationData().logger; // - // We don't retry batch requests because the exception might have caused - // the all the requests batched with the connection to be aborted and we - // want the application to be notified. + // We don't retry batch requests because the exception might have + // caused all the requests batched with the connection to be + // aborted and we want the application to be notified. // if(ref->getMode() == Reference::ModeBatchOneway || ref->getMode() == Reference::ModeBatchDatagram) { @@ -129,7 +126,6 @@ IceInternal::ProxyFactory::checkRetryAfterException(const LocalException& ex, } const ObjectNotExistException* one = dynamic_cast<const ObjectNotExistException*>(&ex); - if(one) { if(ref->getRouterInfo() && one->operation == "ice_add_proxy") @@ -226,8 +222,7 @@ IceInternal::ProxyFactory::checkRetryAfterException(const LocalException& ex, assert(cnt > 0); int interval = -1; - if(cnt == static_cast<int>(_retryIntervals.size() + 1) && - dynamic_cast<const CloseConnectionException*>(&ex)) + if(cnt == static_cast<int>(_retryIntervals.size() + 1) && dynamic_cast<const CloseConnectionException*>(&ex)) { // // A close connection exception is always retried at least once, even if the retry @@ -259,14 +254,6 @@ IceInternal::ProxyFactory::checkRetryAfterException(const LocalException& ex, } out << " because of exception\n" << ex; } - - if(sleep && interval > 0) - { - // - // Sleep before retrying. - // - IceUtil::ThreadControl::sleep(IceUtil::Time::milliSeconds(interval)); - } return interval; } |