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

net.server_epoll: Support hooking signals via signalfd

Browse source 
Handling signal events the same way as all other events makes sense and
seems safer than the signal handling just jumping around in C and
messing with Lua states.
This commit is contained in:
Kim Alvefur 2024-02-24 00:20:35 +01:00
parent 54f76b97d2
commit 49c296360d
1 changed files with 15 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

15
net/server_epoll.lua
View file

@ -29,6 +29,7 @@ local new_id = require "prosody.util.id".short;
local xpcall = require "prosody.util.xpcall".xpcall; local xpcall = require "prosody.util.xpcall".xpcall;
local sslconfig = require "prosody.util.sslconfig"; local sslconfig = require "prosody.util.sslconfig";
local tls_impl = require "prosody.net.tls_luasec"; local tls_impl = require "prosody.net.tls_luasec";
local have_signal, signal = pcall(require, "prosody.util.signal");
local poller = require "prosody.util.poll" local poller = require "prosody.util.poll"
local EEXIST = poller.EEXIST; local EEXIST = poller.EEXIST;
@ -1143,6 +1144,19 @@ local function loop(once)
return quitting; return quitting;
end end
local hook_signal;
if have_signal and signal.signalfd then
local function dispatch(self)
return self:on("signal", signal.signalfd_read(self:getfd()));
end
function hook_signal(signum, cb)
local watch = watchfd(signal.signalfd(signum), dispatch);
watch.listeners = { onsignal = cb };
return watch;
end
end
return { return {
get_backend = function () return "epoll"; end; get_backend = function () return "epoll"; end;
addserver = addserver; addserver = addserver;
@ -1168,6 +1182,7 @@ return {
set_config = function (newconfig) set_config = function (newconfig)
cfg = setmetatable(newconfig, default_config); cfg = setmetatable(newconfig, default_config);
end; end;
hook_signal = hook_signal;
tls_builder = function(basedir) tls_builder = function(basedir)
return sslconfig._new(tls_impl.new_context, basedir) return sslconfig._new(tls_impl.new_context, basedir)