dany/luasocket
1
0
Fork 0
mirror of https://github.com/lunarmodules/luasocket.git synced 2024-12-26 12:28:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

Removed debuging prints.

Browse Source
This commit is contained in:
Diego Nehab 2005-04-20 19:04:47 +00:00
parent 2a00a5ad50
commit 4e3cf63c95
1 changed files with 1 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
samples/forward.lua
View File

@ -72,16 +72,12 @@ end
-- starts a connection in a non-blocking way -- starts a connection in a non-blocking way
function connect(who, host, port) function connect(who, host, port)
who:settimeout(0) who:settimeout(0)
print("trying to connect peer", who, host, port)
local ret, err = who:connect(host, port) local ret, err = who:connect(host, port)
if not ret and err == "timeout" then if not ret and err == "timeout" then
print("got timeout, will wait", who)
wait(who, "output") wait(who, "output")
ret, err = who:connect(host, port) ret, err = who:connect(host, port)
print("connection results arrived", who, ret, err)
end end
if not ret then if not ret then
print("connection failed", who, err)
kick(who) kick(who)
kick(context[who].peer) kick(context[who].peer)
else else
@ -104,7 +100,6 @@ function accept(server)
while true do while true do
-- accept a new connection and start a new coroutine to deal with it -- accept a new connection and start a new coroutine to deal with it
local client = server:accept() local client = server:accept()
print("accepted ", client)
if client then if client then
-- create contexts for client and peer. -- create contexts for client and peer.
local peer, err = socket.tcp() local peer, err = socket.tcp()
@ -139,7 +134,6 @@ end
-- forwards all data arriving to the appropriate peer -- forwards all data arriving to the appropriate peer
function forward(who) function forward(who)
print("starting to foward", who)
who:settimeout(0) who:settimeout(0)
while true do while true do
-- wait until we have something to read -- wait until we have something to read
@ -173,24 +167,8 @@ end
-- what happened, and routing it to wait until something else happens -- what happened, and routing it to wait until something else happens
function go() function go()
while true do while true do
print("will select for reading")
for i,v in ipairs(receiving) do
print(i, v)
end
print("will select for sending")
for i,v in ipairs(sending) do
print(i, v)
end
-- check which sockets are interesting and act on them -- check which sockets are interesting and act on them
readable, writable = socket.select(receiving, sending, 3) readable, writable = socket.select(receiving, sending)
print("was readable")
for i,v in ipairs(readable) do
print(i, v)
end
print("was writable")
for i,v in ipairs(writable) do
print(i, v)
end
-- for all readable connections, resume its thread -- for all readable connections, resume its thread
for _, who in ipairs(readable) do for _, who in ipairs(readable) do
receiving:remove(who) receiving:remove(who)