From d86ef31c63190285dda3233b8ee2cb5d381c7686 Mon Sep 17 00:00:00 2001 From: Jose Date: Thu, 7 Aug 2014 01:00:42 +0200 Subject: Windows SSL SChannel implementation & OS X Secure Transport fixes. --- cpp/src/Ice/ConnectionI.cpp | 24 +++++++++++++++++------- 1 file changed, 17 insertions(+), 7 deletions(-) (limited to 'cpp/src/Ice/ConnectionI.cpp') diff --git a/cpp/src/Ice/ConnectionI.cpp b/cpp/src/Ice/ConnectionI.cpp index 22cc069ef08..37afd228ca7 100644 --- a/cpp/src/Ice/ConnectionI.cpp +++ b/cpp/src/Ice/ConnectionI.cpp @@ -1532,12 +1532,19 @@ Ice::ConnectionI::startAsync(SocketOperation operation) } else if(operation & SocketOperationRead) { - if(_observer && !_readHeader) + if(!_hasMoreData) { - _observer.startRead(_readStream); + if(_observer && !_readHeader) + { + _observer.startRead(_readStream); + } + + _transceiver->startRead(_readStream); + } + else + { + _transceiver->getNativeInfo()->completed(IceInternal::SocketOperationRead); } - - _transceiver->startRead(_readStream); } } catch(const Ice::LocalException& ex) @@ -1563,10 +1570,13 @@ Ice::ConnectionI::finishAsync(SocketOperation operation) } else if(operation & SocketOperationRead) { - _transceiver->finishRead(_readStream); - if(_observer && !_readHeader) + if(!_hasMoreData) { - _observer.finishRead(_readStream); + _transceiver->finishRead(_readStream, _hasMoreData); + if(_observer && !_readHeader) + { + _observer.finishRead(_readStream); + } } } } -- cgit v1.2.3