Commit ab667bc0 authored by mercury233's avatar mercury233

update timeout

parent 477dacf5
...@@ -607,7 +607,7 @@ net.createServer (client) -> ...@@ -607,7 +607,7 @@ net.createServer (client) ->
server = new net.Socket() server = new net.Socket()
client.server = server client.server = server
client.setTimeout(300000) #5分钟 client.setTimeout(2000) #连接前超时2秒
# 释放处理 # 释放处理
client.on 'close', (had_error) -> client.on 'close', (had_error) ->
...@@ -668,7 +668,7 @@ net.createServer (client) -> ...@@ -668,7 +668,7 @@ net.createServer (client) ->
client.destroy() client.destroy()
return return
if ROOM_bad_ip[client.ip] > 5 if ROOM_bad_ip[client.ip] > 5 or ROOM_connected_ip[client.ip] > 10
log.info 'BAD IP', client.ip log.info 'BAD IP', client.ip
client.destroy() client.destroy()
return return
...@@ -970,6 +970,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server)-> ...@@ -970,6 +970,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server)->
ygopro.stoc_die(client, room.error) ygopro.stoc_die(client, room.error)
else else
#client.room = room #client.room = room
client.setTimeout(300000) #连接后超时5分钟
client.rid = _.indexOf(ROOM_all, room) client.rid = _.indexOf(ROOM_all, room)
room.connect(client) room.connect(client)
return return
...@@ -1065,7 +1066,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server)-> ...@@ -1065,7 +1066,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server)->
ygopro.stoc_die(client, room.error) ygopro.stoc_die(client, room.error)
else if room.started else if room.started
if settings.modules.enable_halfway_watch if settings.modules.enable_halfway_watch
#client.room = room client.setTimeout(300000) #连接后超时5分钟
client.rid = _.indexOf(ROOM_all, room) client.rid = _.indexOf(ROOM_all, room)
client.is_post_watcher = true client.is_post_watcher = true
ygopro.stoc_send_chat_to_room(room, "#{client.name} 加入了观战") ygopro.stoc_send_chat_to_room(room, "#{client.name} 加入了观战")
...@@ -1076,7 +1077,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server)-> ...@@ -1076,7 +1077,7 @@ ygopro.ctos_follow 'JOIN_GAME', false, (buffer, info, client, server)->
else else
ygopro.stoc_die(client, "决斗已开始,不允许观战") ygopro.stoc_die(client, "决斗已开始,不允许观战")
else else
#client.room = room client.setTimeout(300000) #连接后超时5分钟
client.rid = _.indexOf(ROOM_all, room) client.rid = _.indexOf(ROOM_all, room)
room.connect(client) room.connect(client)
return return
......
...@@ -800,7 +800,7 @@ ...@@ -800,7 +800,7 @@
ROOM_connected_ip[client.ip] = connect_count; ROOM_connected_ip[client.ip] = connect_count;
server = new net.Socket(); server = new net.Socket();
client.server = server; client.server = server;
client.setTimeout(300000); client.setTimeout(2000);
client.on('close', function(had_error) { client.on('close', function(had_error) {
var room; var room;
room = ROOM_all[client.rid]; room = ROOM_all[client.rid];
...@@ -866,7 +866,7 @@ ...@@ -866,7 +866,7 @@
client.destroy(); client.destroy();
} }
}); });
if (ROOM_bad_ip[client.ip] > 5) { if (ROOM_bad_ip[client.ip] > 5 || ROOM_connected_ip[client.ip] > 10) {
log.info('BAD IP', client.ip); log.info('BAD IP', client.ip);
client.destroy(); client.destroy();
return; return;
...@@ -1187,6 +1187,7 @@ ...@@ -1187,6 +1187,7 @@
} else if (room.error) { } else if (room.error) {
ygopro.stoc_die(client, room.error); ygopro.stoc_die(client, room.error);
} else { } else {
client.setTimeout(300000);
client.rid = _.indexOf(ROOM_all, room); client.rid = _.indexOf(ROOM_all, room);
room.connect(client); room.connect(client);
} }
...@@ -1284,6 +1285,7 @@ ...@@ -1284,6 +1285,7 @@
ygopro.stoc_die(client, room.error); ygopro.stoc_die(client, room.error);
} else if (room.started) { } else if (room.started) {
if (settings.modules.enable_halfway_watch) { if (settings.modules.enable_halfway_watch) {
client.setTimeout(300000);
client.rid = _.indexOf(ROOM_all, room); client.rid = _.indexOf(ROOM_all, room);
client.is_post_watcher = true; client.is_post_watcher = true;
ygopro.stoc_send_chat_to_room(room, client.name + " 加入了观战"); ygopro.stoc_send_chat_to_room(room, client.name + " 加入了观战");
...@@ -1298,6 +1300,7 @@ ...@@ -1298,6 +1300,7 @@
ygopro.stoc_die(client, "决斗已开始,不允许观战"); ygopro.stoc_die(client, "决斗已开始,不允许观战");
} }
} else { } else {
client.setTimeout(300000);
client.rid = _.indexOf(ROOM_all, room); client.rid = _.indexOf(ROOM_all, room);
room.connect(client); room.connect(client);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment