diff options
author | Benoit Foucher <benoit@zeroc.com> | 2016-06-28 09:10:29 +0200 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2016-06-28 09:10:29 +0200 |
commit | 378ae8c05134af0cf5c16811875d713adc654e06 (patch) | |
tree | 2656b46db0bc6e0854cc3934913684c9766a4045 /cpp/src/Ice/StreamSocket.cpp | |
parent | IceSSLObjC library now links with IceSSL (diff) | |
download | ice-378ae8c05134af0cf5c16811875d713adc654e06.tar.bz2 ice-378ae8c05134af0cf5c16811875d713adc654e06.tar.xz ice-378ae8c05134af0cf5c16811875d713adc654e06.zip |
ICE-7204 : Fixed UWP build failure
Diffstat (limited to 'cpp/src/Ice/StreamSocket.cpp')
-rwxr-xr-x | cpp/src/Ice/StreamSocket.cpp | 18 |
1 files changed, 4 insertions, 14 deletions
diff --git a/cpp/src/Ice/StreamSocket.cpp b/cpp/src/Ice/StreamSocket.cpp index 7d186e15dd4..e890be1f829 100755 --- a/cpp/src/Ice/StreamSocket.cpp +++ b/cpp/src/Ice/StreamSocket.cpp @@ -562,13 +562,8 @@ StreamSocket::startWrite(Buffer& buf) assert(!buf.b.empty()); assert(buf.i != buf.b.end()); - size_t packetSize = static_cast<size_t>(buf.b.end() - buf.i); - if(_maxSendPacketSize > 0 && packetSize > _maxSendPacketSize) - { - packetSize = _maxSendPacketSize; - } - assert(packetSize > 0); - _writer->WriteBytes(ref new Array<unsigned char>(&*buf.i, packetSize)); + size_t packetSize = getSendPacketSize(buf.b.end() - buf.i); + _writer->WriteBytes(ref new Array<unsigned char>(&*buf.i, static_cast<unsigned int>(packetSize))); try { queueOperation(SocketOperationWrite, _writer->StoreAsync()); @@ -599,16 +594,11 @@ StreamSocket::finishWrite(Buffer& buf) void StreamSocket::startRead(Buffer& buf) { - size_t packetSize = static_cast<size_t>(buf.b.end() - buf.i); - if(_maxRecvPacketSize > 0 && packetSize > _maxRecvPacketSize) - { - packetSize = _maxRecvPacketSize; - } assert(!buf.b.empty() && buf.i != buf.b.end()); - + size_t packetSize = getRecvPacketSize(buf.b.end() - buf.i); try { - queueOperation(SocketOperationRead, _reader->LoadAsync(packetSize)); + queueOperation(SocketOperationRead, _reader->LoadAsync(static_cast<unsigned int>(packetSize))); } catch(Platform::Exception^ ex) { |