From 648ee61ae84216d0236e0dbc211addc13b2cfa3a Mon Sep 17 00:00:00 2001 From: Kris Kowal Date: Fri, 6 Jul 2012 11:52:06 -0700 Subject: Expand tabs --- js/helper-classes/RDGE/src/core/script/sockets.js | 130 +++++++++++----------- 1 file changed, 65 insertions(+), 65 deletions(-) (limited to 'js/helper-classes/RDGE/src/core/script/sockets.js') diff --git a/js/helper-classes/RDGE/src/core/script/sockets.js b/js/helper-classes/RDGE/src/core/script/sockets.js index 7d6192d2..e5334280 100755 --- a/js/helper-classes/RDGE/src/core/script/sockets.js +++ b/js/helper-classes/RDGE/src/core/script/sockets.js @@ -112,70 +112,70 @@ RDGE.ConnPoll = function() { */ RDGE.ConnectionPool = funciton(base, startAddr, endAddr, messageHandlerFunc) { - this.start = startAddr; - this.end = endAddr; - this.port = 38951; - this.messageHandler = messageHandlerFunc; - - this.listenSockets = []; - this.connectedSockets = []; - - this.openHandler = null; - this.closeHandler = null; - - this.interval = null; - - this.Init = function (openHandler, closeHandler) { - // empty out lists - this.listenSockets = []; - this.connectedSockets = []; - - this.openHandler = openHandler; - this.closeHandler = closeHandler; - - var len = this.end - this.start; - for (var i = 0; i < len; ++i) { - var url = base + (this.start + i) + ":" + this.port + "/resourcePath"; - var ws = CreateSocket(url, this.listenSockets, this.connectedSockets, this.messageHandler, i, this.openHandler, this.closeHandler); - - this.listenSockets.push(ws); - } - - this.interval = setInterval(ConnPoll, 200); - }; - - this.Shutdown = function () { - if (this.interval != null) { - clearInterval(this.interval); - this.interval = null; - } - var len = this.connectedSockets.length; - for (var i = 0; i < len; ++i) { - // send disconnect message - this.connectedSockets[i].send("type=srv\nmsg=2\n"); ; - } - }; - - this.Close = function (socket) { - socket.rdge_tryDisconnect = true; - }; - - this.Poll = function () { - var len = this.end - this.start; - for (var i = 0; i < len; ++i) { - // re init the sockets to simulate broadcast - if (this.listenSockets[i].readyState == 3/*CLOSING*/ || this.listenSockets[i].readyState == 2/*CLOSING*/ || this.listenSockets[i].rdge_tryDisconnect == true) { - if (this.listenSockets[i].rdge_tryDisconnect) { - document.getElementById("socketConnection").innerHTML += "graceful discon: " + this.listenSockets[i].URL + "
"; - } - - this.listenSockets[i].rdge_tryDisconnect = false; - - var url = base + (this.start + i) + ":" + this.port + "/resourcePath"; - this.listenSockets[i].close(); - this.listenSockets[i] = CreateSocket(url, this.listenSockets, this.connectedSockets, this.messageHandler, i, this.openHandler, this.closeHandler); - } - } - }; + this.start = startAddr; + this.end = endAddr; + this.port = 38951; + this.messageHandler = messageHandlerFunc; + + this.listenSockets = []; + this.connectedSockets = []; + + this.openHandler = null; + this.closeHandler = null; + + this.interval = null; + + this.Init = function (openHandler, closeHandler) { + // empty out lists + this.listenSockets = []; + this.connectedSockets = []; + + this.openHandler = openHandler; + this.closeHandler = closeHandler; + + var len = this.end - this.start; + for (var i = 0; i < len; ++i) { + var url = base + (this.start + i) + ":" + this.port + "/resourcePath"; + var ws = CreateSocket(url, this.listenSockets, this.connectedSockets, this.messageHandler, i, this.openHandler, this.closeHandler); + + this.listenSockets.push(ws); + } + + this.interval = setInterval(ConnPoll, 200); + }; + + this.Shutdown = function () { + if (this.interval != null) { + clearInterval(this.interval); + this.interval = null; + } + var len = this.connectedSockets.length; + for (var i = 0; i < len; ++i) { + // send disconnect message + this.connectedSockets[i].send("type=srv\nmsg=2\n"); ; + } + }; + + this.Close = function (socket) { + socket.rdge_tryDisconnect = true; + }; + + this.Poll = function () { + var len = this.end - this.start; + for (var i = 0; i < len; ++i) { + // re init the sockets to simulate broadcast + if (this.listenSockets[i].readyState == 3/*CLOSING*/ || this.listenSockets[i].readyState == 2/*CLOSING*/ || this.listenSockets[i].rdge_tryDisconnect == true) { + if (this.listenSockets[i].rdge_tryDisconnect) { + document.getElementById("socketConnection").innerHTML += "graceful discon: " + this.listenSockets[i].URL + "
"; + } + + this.listenSockets[i].rdge_tryDisconnect = false; + + var url = base + (this.start + i) + ":" + this.port + "/resourcePath"; + this.listenSockets[i].close(); + this.listenSockets[i] = CreateSocket(url, this.listenSockets, this.connectedSockets, this.messageHandler, i, this.openHandler, this.closeHandler); + } + } + }; }; -- cgit v1.2.3