summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAlexey Lebedeff <alebedev@mirantis.com>2016-03-16 15:37:34 +0300
committerAlexey Lebedeff <alebedev@mirantis.com>2016-03-16 15:37:34 +0300
commitdad0d3573b547dd601408a8feac56fb025c2347d (patch)
treee281795ec0407f89382088eb4b784e16176a610e /src
parentdf0965b4a69f8191bba7d213d82ef2edf0d09b77 (diff)
downloadrabbitmq-server-git-dad0d3573b547dd601408a8feac56fb025c2347d.tar.gz
Support abstract unix socket for systemd notify
Diffstat (limited to 'src')
-rw-r--r--src/rabbit.erl7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl
index d3e0dcc632..98d2d5db91 100644
--- a/src/rabbit.erl
+++ b/src/rabbit.erl
@@ -340,10 +340,15 @@ sd_notify_socat() ->
false
end.
+socat_socket_arg("@" ++ AbstractUnixSocket) ->
+ "abstract-sendto:" ++ AbstractUnixSocket;
+socat_socket_arg(UnixSocket) ->
+ "unix-sendto:" ++ UnixSocket.
+
sd_open_port() ->
open_port(
{spawn_executable, os:find_executable("socat")},
- [{args, ["unix-sendto:" ++ os:getenv("NOTIFY_SOCKET"), "STDIO"]},
+ [{args, [socat_socket_arg(os:getenv("NOTIFY_SOCKET")), "STDIO"]},
use_stdio, out]).
sd_notify_socat(Unit) ->