AstralTransRocketries/OCEmu
1
0
Fork 0
mirror of https://github.com/zenith391/OCEmu.git synced 2025-09-28 15:34:05 -04:00
Code Issues Packages Projects Releases Wiki Activity

use iterator for pending messages to process messages as they come in

Browse Source
This commit is contained in:
payonel 2015-09-11 21:20:37 -07:00
parent 3be687ef91
commit 62c6e78e91
1 changed files with 32 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/component/modem.lua
View File

@ -228,10 +228,8 @@ function modem_host.processPendingMessages()
end
modem_host.acceptPendingClients()
modem_host.recvPendingMessages()
for _,packet in ipairs(modem_host.messages) do
for _,packet in modem_host.allPendingMessages() do
if packet.type == 'modem_message' then
-- broadcast if no target
if packet.target == 0 then
@ -243,8 +241,6 @@ function modem_host.processPendingMessages()
modem_host.host_shutdown = true
end
end
modem_host.messages = {}
end
function modem_host.acceptPendingClients()
@ -286,12 +282,17 @@ function modem_host.acceptPendingClients()
end
end
function modem_host.recvPendingMessages()
function modem_host.allPendingMessages()
local msgIt = function(...)
if #modem_host.messages > 0 then
return 0, table.remove(modem_host.messages, 1)
end
if modem_host.hosting then
for source, client in pairs(modem_host.clients) do
local packet, err = modem_host.readPacket(client)
if packet then
modem_host.pushMessage(packet)
return 0, packet
elseif err ~= "timeout" then
client:close()
modem_host.clients[source] = nil
@ -301,7 +302,7 @@ function modem_host.recvPendingMessages()
while true do
local packet, err = modem_host.readPacket(modem_host.socket)
if packet then
modem_host.pushMessage(packet)
return 0, packet
else
if err ~= "timeout" then
if not modem_host.host_shutdown then
@ -316,6 +317,9 @@ function modem_host.recvPendingMessages()
end
end
return msgIt, nil, 0
end
function modem_host.createNewMessageBoard()
local why
modem_host.socket, why = socket.bind(modem_host.comms_ip, modem_host.comms_port)