mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-04 21:57:45 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

mod_net_multiplex: Silence luacheck warnings

Browse source
This commit is contained in:
Kim Alvefur 2018-10-10 21:56:47 +02:00
parent 9c1bbd8313
commit 044da0478a
1 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

12
plugins/mod_net_multiplex.lua
View file

@ -18,7 +18,7 @@ end
module:hook("service-added", function (event) add_service(event.service); end); module:hook("service-added", function (event) add_service(event.service); end);
module:hook("service-removed", function (event) available_services[event.service] = nil; end); module:hook("service-removed", function (event) available_services[event.service] = nil; end);
for service_name, services in pairs(portmanager.get_registered_services()) do for _, services in pairs(portmanager.get_registered_services()) do
for _, service in ipairs(services) do for _, service in ipairs(services) do
add_service(service); add_service(service);
end end
@ -38,11 +38,11 @@ function listener.onincoming(conn, data)
for service, multiplex_pattern in pairs(available_services) do for service, multiplex_pattern in pairs(available_services) do
if buf:match(multiplex_pattern) then if buf:match(multiplex_pattern) then
module:log("debug", "Routing incoming connection to %s", service.name); module:log("debug", "Routing incoming connection to %s", service.name);
local listener = service.listener; local next_listener = service.listener;
conn:setlistener(listener); conn:setlistener(next_listener);
local onconnect = listener.onconnect; local onconnect = next_listener.onconnect;
if onconnect then onconnect(conn) end if onconnect then onconnect(conn) end
return listener.onincoming(conn, buf); return next_listener.onincoming(conn, buf);
end end
end end
if #buf > max_buffer_len then -- Give up if #buf > max_buffer_len then -- Give up
@ -52,7 +52,7 @@ function listener.onincoming(conn, data)
end end
end end
function listener.ondisconnect(conn, err) function listener.ondisconnect(conn)
buffers[conn] = nil; -- warn if no buffer? buffers[conn] = nil; -- warn if no buffer?
end end