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

Erase backpressure in steps of 1/32th

Browse Source
This commit is contained in:
Alex Hultman
2021-09-20 19:10:43 +02:00
committed by GitHub
parent 34cadcee27
commit 6393f97bfb
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/AsyncSocketData.h
+2 -4
View File
@@ -22,9 +22,6 @@
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;
@@ -38,7 +35,8 @@ struct BackPressure {
} }
void erase(unsigned int length) { void erase(unsigned int length) {
pendingRemoval += length; pendingRemoval += length;
if (pendingRemoval > BACKPRESSURE_MINIMAL_ERASE || !(buffer.length() - pendingRemoval)) { /* Always erase a minimum of 1/32th the current backpressure */
if (pendingRemoval > (buffer.length() >> 5)) {
buffer.erase(0, pendingRemoval); buffer.erase(0, pendingRemoval);
pendingRemoval = 0; pendingRemoval = 0;
} }