Mirrors/cloudcmd
1
0
Fork 0
mirror of https://github.com/coderaiser/cloudcmd.git synced 2026-01-23 18:55:26 +00:00
Code Issues Projects Releases Wiki Activity

feature(socket) if id in use - reconnect

Browse source
This commit is contained in:
coderaiser 2013-06-30 09:28:32 +00:00
parent cd311d0984
commit cbadd5ee28
2 changed files with 23 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

2
ChangeLog
View file

@ -88,6 +88,8 @@ getJSONfromFileTable.
* feature(socket) add minification and gzip
* feature(socket) if id in use - reconnect
2012.04.22, v0.2.0

34
lib/server/socket.js
View file

@ -38,7 +38,7 @@
* @pServer {Object} started server object
*/
exports.listen = function(pServer){
var lRet, lListen, lConnNum, lConn_func;
var lRet, lListen, lConnNum, lMsg, lConn_func;
if(io){
lListen = io.listen(pServer),
@ -50,17 +50,21 @@
lRet = lListen.sockets.on('connection', function (socket){
++lConnNum;
socket.send('{"stdout":"client connected"}');
log(lConnNum, 'connected');
if(!OnMessageFuncs[lConnNum])
OnMessageFuncs[lConnNum] = onMessage(lConnNum, socket);
lConn_func = OnMessageFuncs[lConnNum];
socket.on('message', lConn_func);
socket.on('disconnect', Util.call(disconnect, lConnNum));
if(!OnMessageFuncs[lConnNum]) {
lMsg = log(lConnNum, 'connected');
socket.send('{"stdout":"' + lMsg + '"}');
OnMessageFuncs[lConnNum] = onMessage(lConnNum, socket);
lConn_func = OnMessageFuncs[lConnNum];
socket.on('message', lConn_func);
socket.on('disconnect', Util.call(disconnect, lConnNum));
} else {
lMsg = log(lConnNum, ' in use. Reconnecting...');
socket.send('{"stdout":"' + lMsg + '"}');
socket.disconnect();
}
});
}
@ -165,14 +169,18 @@
}
function log(pConnNum, pStr, pType){
var lType = ' ';
var lRet, lType = ' ';
if (pStr) {
if (pType)
lType += pType + ':';
Util.log('#' + pConnNum + lType + pStr);
lRet = 'client #' + pConnNum + lType + pStr;
Util.log(lRet);
}
return lRet;
}
})();