talksik/uWebSockets
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reduce pendingRemoval limit to 32kb

Browse Source
This commit is contained in:
Alex Hultman
2021-09-20 15:01:42 +00:00
parent 069e66b31c
commit 3eefc51c08
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/AsyncSocketData.h
+4 -1
View File
@@ -22,6 +22,9 @@
namespace uWS { namespace uWS {
/* We erase a minimum of 32kb off the front of the backpressure buffer when draining */
const int BACKPRESSURE_MINIMAL_ERASE = 32 * 1024;
struct BackPressure { struct BackPressure {
std::string buffer; std::string buffer;
unsigned int pendingRemoval = 0; unsigned int pendingRemoval = 0;
@@ -35,7 +38,7 @@ struct BackPressure {
} }
void erase(unsigned int length) { void erase(unsigned int length) {
pendingRemoval += length; pendingRemoval += length;
if (pendingRemoval > 1024 * 1024 || !(buffer.length() - pendingRemoval)) { if (pendingRemoval > BACKPRESSURE_MINIMAL_ERASE || !(buffer.length() - pendingRemoval)) {
buffer.erase(0, pendingRemoval); buffer.erase(0, pendingRemoval);
pendingRemoval = 0; pendingRemoval = 0;
} }