add looplimit

ygopro-server.coffee

@@ -116,6 +116,8 @@ net.createServer (client) ->
       ctos_buffer = Buffer.concat([ctos_buffer, data], ctos_buffer.length + data.length) #buffer的错误使用方式，好孩子不要学
       
       datas = []
+      
+      looplimit = 0
 
       while true
         if ctos_message_length == 0
@@ -148,6 +150,14 @@ net.createServer (client) ->
             ctos_proto = 0
           else
             break
+      
+        looplimit++
+        #log.info(looplimit)
+        if looplimit>800
+          log.info("error ctos")
+          server.end()
+          break
+
       if client.established
         server.write buffer for buffer in datas
       else
@@ -165,6 +175,8 @@ net.createServer (client) ->
 
     #unless ygopro.stoc_follows[stoc_proto] and ygopro.stoc_follows[stoc_proto].synchronous
     client.write data
+    
+    looplimit = 0
 
     while true
       if stoc_message_length == 0
@@ -194,8 +206,15 @@ net.createServer (client) ->
           stoc_proto = 0
         else
           break
-     return
-   return
+      
+      looplimit++
+      #log.info(looplimit)
+      if looplimit>800
+        log.info("error stoc")
+        server.end()
+        break
+    return
+  return
 .listen settings.port, ->
   log.info "server started", settings.ip, settings.port
   return

ygopro-server.js

@@ -126,12 +126,13 @@
     ctos_proto = 0;
     client.pre_establish_buffers = new Array();
     client.on('data', function(data) {
-      var b, buffer, cancel, datas, k, l, len, len1, struct;
+      var b, buffer, cancel, datas, k, l, len, len1, looplimit, struct;
       if (client.is_post_watcher) {
         client.room.watcher.write(data);
       } else {
         ctos_buffer = Buffer.concat([ctos_buffer, data], ctos_buffer.length + data.length);
         datas = [];
+        looplimit = 0;
         while (true) {
           if (ctos_message_length === 0) {
             if (ctos_buffer.length >= 2) {
@@ -171,6 +172,12 @@
               break;
             }
           }
+          looplimit++;
+          if (looplimit > 800) {
+            log.info("error ctos");
+            server.end();
+            break;
+          }
         }
         if (client.established) {
           for (k = 0, len = datas.length; k < len; k++) {
@@ -189,9 +196,10 @@
     stoc_message_length = 0;
     stoc_proto = 0;
     server.on('data', function(data) {
-      var b, stanzas, struct;
+      var b, looplimit, stanzas, struct;
       stoc_buffer = Buffer.concat([stoc_buffer, data], stoc_buffer.length + data.length);
       client.write(data);
+      looplimit = 0;
       while (true) {
         if (stoc_message_length === 0) {
           if (stoc_buffer.length >= 2) {
@@ -224,6 +232,12 @@
             break;
           }
         }
+        looplimit++;
+        if (looplimit > 800) {
+          log.info("error stoc");
+          server.end();
+          break;
+        }
       }
     });
   }).listen(settings.port, function() {