1 files changed, 65 insertions, 65 deletions

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 + "</br>";

-                    }

-

-                    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 + "</br>";

+                }

+

+                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);

+            }

+        }

+    };  

 };