forks
/
arsd
mirror of https://github.com/adamdruppe/arsd.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #302 from Panke/fix-receivebuffer-length 

fix(http2): increase receivebuffer.length
This commit is contained in:
Adam D. Ruppe 2021-09-18 07:30:46 -04:00 committed by GitHub
parent 010d86b740 c7f063533b
commit 9ce96cfdbd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
http2.d
View File

@ -3540,6 +3540,15 @@ class WebSocket {
public bool lowLevelReceive() { public bool lowLevelReceive() {
if(readyState == CONNECTING) if(readyState == CONNECTING)
throw new Exception("WebSocket not connected when trying to receive. Did you forget to call connect(); ?"); throw new Exception("WebSocket not connected when trying to receive. Did you forget to call connect(); ?");
if (receiveBufferUsedLength == receiveBuffer.length)
{
if (receiveBuffer.length == config.maximumReceiveBufferSize)
throw new Exception("Maximum receive buffer size exhausted");
import std.algorithm : min;
receiveBuffer.length = min(receiveBuffer.length + config.initialReceiveBufferSize,
config.maximumReceiveBufferSize);
}
auto r = socket.receive(receiveBuffer[receiveBufferUsedLength .. $]); auto r = socket.receive(receiveBuffer[receiveBufferUsedLength .. $]);
if(r == 0) if(r == 0)
return false; return false;