mirrors/FreeRDP
0
0
Fork 0
mirror of https://github.com/FreeRDP/FreeRDP.git synced 2024-11-24 18:33:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

[core,gateway] eliminate intermediate buffer

Browse Source
This commit is contained in:
akallabeth 2023-06-29 16:28:49 +02:00 committed by akallabeth
parent 4fb7035242
commit 5dcd9fcb8a
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
libfreerdp/core/gateway/http.c
View File

@ -1250,7 +1250,6 @@ HttpResponse* http_response_recv(rdpTls* tls, BOOL readContentLength)
/* Fetch remaining body! */
if ((response->TransferEncoding == TransferEncodingChunked) && readContentLength)
{
char buffer[2048] = { 0 };
http_encoding_chunked_context ctx = { 0 };
ctx.state = ChunkStateLenghHeader;
ctx.nextOffset = 0;
@ -1258,7 +1257,11 @@ HttpResponse* http_response_recv(rdpTls* tls, BOOL readContentLength)
int full_len = 0;
do
{
int status = http_chuncked_read(tls->bio, (BYTE*)buffer, sizeof(buffer), &ctx);
if (!Stream_EnsureRemainingCapacity(response->data, 2048))
goto out_error;
int status = http_chuncked_read(tls->bio, Stream_Pointer(response->data),
Stream_GetRemainingCapacity(response->data), &ctx);
if (status <= 0)
{
if (!BIO_should_retry(tls->bio))
@ -1272,14 +1275,9 @@ HttpResponse* http_response_recv(rdpTls* tls, BOOL readContentLength)
}
else
{
if (!Stream_EnsureRemainingCapacity(response->data, status))
goto out_error;
memcpy(Stream_Pointer(response->data), buffer, status);
Stream_Seek(response->data, (size_t)status);
full_len += status;
}
} while (ctx.state != ChunkStateEnd);
response->BodyLength = full_len;
if (response->BodyLength > 0)