Software / code / prosody-modules
Changeset
2352:3296a09b4e57
misc/systemd: Experimental files for enabling socket activation
| author | Kim Alvefur <zash@zash.se> |
|---|---|
| date | Tue, 08 Nov 2016 00:09:56 +0100 |
| parents | 2351:f8ecb4b248b0 |
| children | 2353:ea97a87c3828 |
| files | misc/systemd/prosody-c2s.socket misc/systemd/prosody-s2s.socket misc/systemd/socket-activation.lua |
| diffstat | 3 files changed, 60 insertions(+), 0 deletions(-) [+] |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/misc/systemd/prosody-c2s.socket Tue Nov 08 00:09:56 2016 +0100 @@ -0,0 +1,9 @@ +[Install] +WantedBy=sockets.target + +[Socket] +ListenStream=0.0.0.0:5222 +ListenStream=5222 +BindIPv6Only=ipv6-only +Accept=false +Service=prosody.service
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/misc/systemd/prosody-s2s.socket Tue Nov 08 00:09:56 2016 +0100 @@ -0,0 +1,9 @@ +[Install] +WantedBy=sockets.target + +[Socket] +ListenStream=0.0.0.0:5269 +ListenStream=5269 +BindIPv6Only=ipv6-only +Accept=false +Service=prosody.service
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/misc/systemd/socket-activation.lua Tue Nov 08 00:09:56 2016 +0100 @@ -0,0 +1,42 @@ +-- Monkeypatch to support socket activation +-- +-- Requires LuaSocket after "agnostic" changes merged +-- +-- To enable: +-- RunScript "socket-activation.lua" + +local socket = require"socket"; +local tcp_serv_mt = debug.getregistry()["tcp{server}"]; +local socket_bind = socket.bind; + +local SD_LISTEN_FDS_START = 3; + +local fds = tonumber(os.getenv"LISTEN_FDS") or 0; + +if fds < SD_LISTEN_FDS_START then return; end + +local servs = {}; + +for i = 1, fds do + local serv = socket.tcp(); + if serv:getfd() >= 0 then + return; -- This won't work, we will leak the old FD + end + debug.setmetatable(serv, tcp_serv_mt); + serv:setfd(SD_LISTEN_FDS_START + i - 1); + local ip, port = serv:getsockname(); + servs [ ip .. ":" .. port ] = serv; +end + +function socket.bind( ip, port, backlog ) + local sock = servs [ ip .. ":" .. port ]; + if sock then + servs [ ip .. ":" .. port ] = nil; + return sock; + end + if next(servs) == nil then + -- my work here is done + socket.bind = socket_bind; + end + return socket_bind( ip, port, backlog ); +end
