crabapples
/
websockify
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added mechanism to ensure data send in case that websocket.bufferedAmount > api.maxBufferedAmount

This commit is contained in:
Daniel 2015-03-24 12:17:22 +02:00
parent 63209f84ca
commit e67a8c4908
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
include/websock.js
View File

@ -65,7 +65,8 @@ var api = {}, // Public API
'error' : function() {}
},
test_mode = false;
test_mode = false,
sendDataFromQueueTimer = -1;
//
@ -209,9 +210,20 @@ function flush() {
// overridable for testing
function send(arr) {
var dataSentOk;
//Util.Debug(">> send_array: " + arr);
sQ = sQ.concat(arr);
return flush();
dataSentOk = flush();
if (dataSentOk === false && sendDataFromQueueTimer === -1) {
sendDataFromQueueTimer = setInterval(function () {
dataSentOk = flush();
if (dataSentOk === true) {
clearInterval(sendDataFromQueueTimer);
sendDataFromQueueTimer = -1;
}
}, 100);
}
return dataSentOk;
}
function send_string(str) {