From f098ebef83642e89e32296f4448cce7ae9437f73 Mon Sep 17 00:00:00 2001 From: Marc Laukien Date: Tue, 29 Jun 2004 18:28:25 +0000 Subject: fixes --- cpp/src/Ice/ConnectionFactory.cpp | 56 ++++++++++++++++++++++++++------------- 1 file changed, 38 insertions(+), 18 deletions(-) (limited to 'cpp/src/Ice/ConnectionFactory.cpp') diff --git a/cpp/src/Ice/ConnectionFactory.cpp b/cpp/src/Ice/ConnectionFactory.cpp index 231632a6fcc..49eeb55a08c 100644 --- a/cpp/src/Ice/ConnectionFactory.cpp +++ b/cpp/src/Ice/ConnectionFactory.cpp @@ -126,13 +126,12 @@ IceInternal::OutgoingConnectionFactory::create(const vector& endpts // // Modify endpoints with overrides. // - DefaultsAndOverridesPtr defaultsAndOverrides = _instance->defaultsAndOverrides(); vector::iterator q; for(q = endpoints.begin(); q != endpoints.end(); ++q) { - if(defaultsAndOverrides->overrideTimeout) + if(_instance->defaultsAndOverrides()->overrideTimeout) { - *q = (*q)->timeout(defaultsAndOverrides->overrideTimeoutValue); + *q = (*q)->timeout(_instance->defaultsAndOverrides()->overrideTimeoutValue); } // @@ -164,7 +163,15 @@ IceInternal::OutgoingConnectionFactory::create(const vector& endpts // if(!pr.first->second->isDestroyed()) { - compress = (*r)->compress(); + if(_instance->defaultsAndOverrides()->overrideCompress) + { + compress = _instance->defaultsAndOverrides()->overrideCompressValue; + } + else + { + compress = (*r)->compress(); + } + return pr.first->second; } @@ -222,7 +229,15 @@ IceInternal::OutgoingConnectionFactory::create(const vector& endpts // if(!pr.first->second->isDestroyed()) { - compress = (*r)->compress(); + if(_instance->defaultsAndOverrides()->overrideCompress) + { + compress = _instance->defaultsAndOverrides()->overrideCompressValue; + } + else + { + compress = (*r)->compress(); + } + return pr.first->second; } @@ -258,10 +273,9 @@ IceInternal::OutgoingConnectionFactory::create(const vector& endpts assert(connector); Int timeout; - DefaultsAndOverridesPtr defaultsAndOverrides = _instance->defaultsAndOverrides(); - if(defaultsAndOverrides->overrideConnectTimeout) + if(_instance->defaultsAndOverrides()->overrideConnectTimeout) { - timeout = defaultsAndOverrides->overrideConnectTimeoutValue; + timeout = _instance->defaultsAndOverrides()->overrideConnectTimeoutValue; } // It is not necessary to check for overrideTimeout, // the endpoint has already been modified with this @@ -276,7 +290,14 @@ IceInternal::OutgoingConnectionFactory::create(const vector& endpts } connection = new Connection(_instance, transceiver, endpoint, 0); connection->validate(); - compress = (*r)->compress(); + if(_instance->defaultsAndOverrides()->overrideCompress) + { + compress = _instance->defaultsAndOverrides()->overrideCompressValue; + } + else + { + compress = (*r)->compress(); + } break; } catch(const LocalException& ex) @@ -362,7 +383,6 @@ IceInternal::OutgoingConnectionFactory::setRouter(const RouterPrx& router) // ObjectPrx proxy = routerInfo->getClientProxy(); ObjectAdapterPtr adapter = routerInfo->getAdapter(); - DefaultsAndOverridesPtr defaultsAndOverrides = _instance->defaultsAndOverrides(); vector::const_iterator p; for(p = proxy->__reference()->endpoints.begin(); p != proxy->__reference()->endpoints.end(); ++p) { @@ -371,9 +391,9 @@ IceInternal::OutgoingConnectionFactory::setRouter(const RouterPrx& router) // // Modify endpoints with overrides. // - if(defaultsAndOverrides->overrideTimeout) + if(_instance->defaultsAndOverrides()->overrideTimeout) { - endpoint = endpoint->timeout(defaultsAndOverrides->overrideTimeoutValue); + endpoint = endpoint->timeout(_instance->defaultsAndOverrides()->overrideTimeoutValue); } // @@ -763,16 +783,16 @@ IceInternal::IncomingConnectionFactory::IncomingConnectionFactory(const Instance _warn(_instance->properties()->getPropertyAsInt("Ice.Warn.Connections") > 0), _state(StateHolding) { - DefaultsAndOverridesPtr defaultsAndOverrides = _instance->defaultsAndOverrides(); - - if(defaultsAndOverrides->overrideTimeout) + if(_instance->defaultsAndOverrides()->overrideTimeout) { - const_cast(_endpoint) = _endpoint->timeout(defaultsAndOverrides->overrideTimeoutValue); + const_cast(_endpoint) = + _endpoint->timeout(_instance->defaultsAndOverrides()->overrideTimeoutValue); } - if(defaultsAndOverrides->overrideCompress) + if(_instance->defaultsAndOverrides()->overrideCompress) { - const_cast(_endpoint) = _endpoint->compress(defaultsAndOverrides->overrideCompressValue); + const_cast(_endpoint) = + _endpoint->compress(_instance->defaultsAndOverrides()->overrideCompressValue); } const_cast(_transceiver) = _endpoint->serverTransceiver(const_cast(_endpoint)); -- cgit v1.2.3