github/azure-sdk-for-cpp
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix the number of bytes that are read by stream (#203)

Browse Source
This commit is contained in:
Victor Vazquez 2020-06-22 18:24:09 -07:00 committed by GitHub
parent e5e063f88c
commit 90345e090c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
sdk/core/azure-core/src/http/curl/curl.cpp
View File

@ -276,6 +276,9 @@ uint64_t CurlSession::ReadWithOffset(uint8_t* buffer, uint64_t bufferSize, uint6
// Set the max to be written as the size of remaining body size
auto bytesToWrite = std::min<>(bufferSize, remainingBodySize);
// total of bytes read (any from inner buffer plus any from socket)
uint64_t bytesRead = uint64_t();
// If bodyStartInBuffer is set and while innerBufferStart is less than the buffer, it means there
// is still data at innerbuffer for the body that is not yet read
if (this->m_bodyStartInBuffer > 0 && LibcurlReaderSize > innerBufferStart)
@ -311,10 +314,11 @@ uint64_t CurlSession::ReadWithOffset(uint8_t* buffer, uint64_t bufferSize, uint6
// to write
writePosition += innerbufferSize;
bytesToWrite -= innerbufferSize;
bytesRead += innerbufferSize;
}
// read from socket the remaining requested bytes
auto bytesRead = ReadSocketToBuffer(writePosition, (size_t)bytesToWrite);
bytesRead += ReadSocketToBuffer(writePosition, (size_t)bytesToWrite);
if (remainingBodySize - bytesRead == 0)
{
// No more to read from socket