izaya/OC-Minitel
1
0
Fork 0
mirror of https://github.com/ShadowKatStudios/OC-Minitel.git synced 2024-11-23 10:38:05 +11:00
Code Issues Releases Wiki Activity

Added some more connection handling to the bridge

Browse Source
This commit is contained in:
Izaya 2018-04-15 22:21:12 +10:00
parent 90118de6ab
commit 83304aae9c
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
vTunnel/bridge.lua
View File

@ -7,6 +7,8 @@ local port, timeout = tonumber(tArgs[1]) or 4096, tonumber(tArgs[2]) or 60
local clients, coroutines, messages = {}, {}, {} local clients, coroutines, messages = {}, {}, {}
local clientcounter = 1
local function spawn(f) local function spawn(f)
coroutines[#coroutines+1] = coroutine.create(function() coroutines[#coroutines+1] = coroutine.create(function()
pid = #coroutines pid = #coroutines
@ -46,9 +48,10 @@ function socketLoop()
local client,err = server:accept() local client,err = server:accept()
if client then if client then
client:settimeout(0) client:settimeout(0)
clients[#clients+1] = {["conn"]=client,last=os.time(),buffer=""} clients[clientcounter+1] = {["conn"]=client,last=os.time(),buffer=""}
clientcounter = clientcounter + 1
local i,p = client:getsockname() local i,p = client:getsockname()
print("Gained client #"..tostring(#clients)..": "..i..":"..tostring(p)) print("Gained client #"..tostring(clientcounter)..": "..i..":"..tostring(p))
end end
coroutine.yield() coroutine.yield()
end end
@ -63,6 +66,10 @@ function clientLoop()
if s then if s then
client.buffer = client.buffer .. s client.buffer = client.buffer .. s
client.last=os.time() client.last=os.time()
elseif b == "closed" then
print("Client "..tostring(id).." disconnected")
client.conn:close()
clients[id] = nil
end end
if client.buffer:sub(1,3) == "\0\1\0" then if client.buffer:sub(1,3) == "\0\1\0" then
client.buffer=client.buffer:sub(4) client.buffer=client.buffer:sub(4)