summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/StreamSocket.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2016-06-28 09:10:29 +0200
committerBenoit Foucher <benoit@zeroc.com>2016-06-28 09:10:29 +0200
commit378ae8c05134af0cf5c16811875d713adc654e06 (patch)
tree2656b46db0bc6e0854cc3934913684c9766a4045 /cpp/src/Ice/StreamSocket.cpp
parentIceSSLObjC library now links with IceSSL (diff)
downloadice-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-xcpp/src/Ice/StreamSocket.cpp18
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)
{