diff options
author | Benoit Foucher <benoit@zeroc.com> | 2012-10-26 11:04:37 +0200 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2012-10-26 11:04:37 +0200 |
commit | 16c6179e7ca9a0fcfbe0ccd2320c2f3af1ab68fa (patch) | |
tree | ed1d3bf97e2c3210bdca93722d91a70a1c9ba7fe /cpp/src | |
parent | Renamed MetricsAdmin facet name to Metrics (diff) | |
download | ice-16c6179e7ca9a0fcfbe0ccd2320c2f3af1ab68fa.tar.bz2 ice-16c6179e7ca9a0fcfbe0ccd2320c2f3af1ab68fa.tar.xz ice-16c6179e7ca9a0fcfbe0ccd2320c2f3af1ab68fa.zip |
Fixed bug in communicator flush batch requests, also fixed C++ SSL issue where ice_connectionId wouldn't work
Diffstat (limited to 'cpp/src')
-rw-r--r-- | cpp/src/Ice/OutgoingAsync.cpp | 15 | ||||
-rw-r--r-- | cpp/src/IceSSL/EndpointI.h | 1 |
2 files changed, 11 insertions, 5 deletions
diff --git a/cpp/src/Ice/OutgoingAsync.cpp b/cpp/src/Ice/OutgoingAsync.cpp index 126fa243ddc..5dd2238944f 100644 --- a/cpp/src/Ice/OutgoingAsync.cpp +++ b/cpp/src/Ice/OutgoingAsync.cpp @@ -1043,7 +1043,6 @@ IceInternal::CommunicatorBatchOutgoingAsync::flushConnection(const ConnectionIPt using BatchOutgoingAsync::__sent; #endif - virtual void __finished(const Ice::LocalException& ex, bool) { _remoteObserver.failed(ex.ice_name()); @@ -1067,10 +1066,18 @@ IceInternal::CommunicatorBatchOutgoingAsync::flushConnection(const ConnectionIPt ++_useCount; } - AsyncStatus status = con->flushAsyncBatchRequests(new BatchOutgoingAsyncI(this, _instance, _observer)); - if(!(status & AsyncStatusSent)) + try { - _sentSynchronously = false; + AsyncStatus status = con->flushAsyncBatchRequests(new BatchOutgoingAsyncI(this, _instance, _observer)); + if(!(status & AsyncStatusSent)) + { + _sentSynchronously = false; + } + } + catch(const Ice::LocalException&) + { + check(false); + throw; } } diff --git a/cpp/src/IceSSL/EndpointI.h b/cpp/src/IceSSL/EndpointI.h index 0115fb71fbb..4eec180dfa8 100644 --- a/cpp/src/IceSSL/EndpointI.h +++ b/cpp/src/IceSSL/EndpointI.h @@ -65,7 +65,6 @@ private: const std::string _host; const Ice::Int _port; const Ice::Int _timeout; - const std::string _connectionId; const bool _compress; }; |