chillcog/SPT-Server-Build
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed buffering issue on read async spthttplistener

Browse Source
This commit is contained in:
Alex
2025-01-27 18:37:17 +00:00
parent b0e34549ad
commit 79793414d5
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Libraries/Core/Servers/Http/SptHttpListener.cs
+15 -5
View File
@@ -66,21 +66,31 @@ public class SptHttpListener : IHttpListener
compressHeader != "0";
var requestCompressed = req.Method == "PUT" || requestIsCompressed;
var length = req.Headers.ContentLength;
var memory = new Memory<byte>(new byte[(int)length]);
req.Body.ReadAsync(memory).AsTask().Wait();
// reserve some capacity to avoid having the list to resize
var totalRead = new List<byte>(1024 * 32);
// read 8KB at a time
var memory = new Memory<byte>(new byte[100]);
var readTask = req.Body.ReadAsync(memory).AsTask();
readTask.Wait();
while (readTask.Result != 0)
{
totalRead.AddRange(memory.ToArray());
memory = new Memory<byte>(new byte[100]);
readTask = req.Body.ReadAsync(memory).AsTask();
readTask.Wait();
}
string value;
if (requestCompressed)
{
using var uncompressedDataStream = new MemoryStream();
using var compressedDataStream = new MemoryStream(memory.ToArray());
using var compressedDataStream = new MemoryStream(totalRead.ToArray());
using var deflateStream = new ZLibStream(compressedDataStream, CompressionMode.Decompress, true);
deflateStream.CopyTo(uncompressedDataStream);
value = Encoding.UTF8.GetString(uncompressedDataStream.ToArray());
}
else
{
value = Encoding.UTF8.GetString(memory.ToArray());
value = Encoding.UTF8.GetString(totalRead.ToArray());
}
if (!requestIsCompressed) {