From 916abb21d0a6653e0187b91591e492026886b0a4 Mon Sep 17 00:00:00 2001 From: Lennart Poettering Date: Tue, 17 May 2011 19:37:03 +0200 Subject: [PATCH] socket: add POSIX mqueue support --- TODO | 16 +++++--- man/sd_is_fifo.xml | 14 +++++++ man/systemd.socket.xml | 27 ++++++++++++++ src/conf-parser.c | 26 +++++++++++++ src/conf-parser.h | 1 + src/dbus-common.c | 15 ++++++++ src/dbus-common.h | 1 + src/dbus-socket.c | 2 + src/load-fragment.c | 14 +++++++ src/sd-daemon.c | 42 +++++++++++++++++++++ src/sd-daemon.h | 8 ++++ src/socket.c | 84 +++++++++++++++++++++++++++++++++++++++++- src/socket.h | 3 ++ 13 files changed, 245 insertions(+), 8 deletions(-) diff --git a/TODO b/TODO index a26bcbcb..1d6ed5a4 100644 --- a/TODO +++ b/TODO @@ -24,7 +24,16 @@ Features: * add dbus call to convert snapshot ino target -* make use of TIOCVHANGUP +* move nss-myhostname into systemd + +* figure out a standard place to configure timezone name, inform myllynen@redhat.com + +* add dbus call to convert snapshot into target + +* make use of TIOCVHANGUP to revoke access to tty before we spawn a getty on it + +* release VT before we spawn a getty on it to entirely clear scrollback buffer + https://bugzilla.redhat.com/show_bug.cgi?id=701704 * move /selinux to /sys/fs/selinux @@ -32,15 +41,10 @@ Features: * add prefix match to sysctl, tmpfiles, ... -* Add ConditionPathExists= checks to binfmt automount units, to avoid - installing the automount point if the directory does not exist. - * drop /.readahead on bigger upgrades with yum * add inode stat() check to readahead to suppress preloading changed files -* POSIX mqueue support in .socket units - * allow list of pathes in config_parse_condition_path() * introduce dbus calls for enabling/disabling a service diff --git a/man/sd_is_fifo.xml b/man/sd_is_fifo.xml index 0e3f3d03..251f45ce 100644 --- a/man/sd_is_fifo.xml +++ b/man/sd_is_fifo.xml @@ -47,6 +47,7 @@ sd_is_socket sd_is_socket_inet sd_is_socket_unix + sd_is_mq Check the type of a file descriptor @@ -86,6 +87,12 @@ size_t length + + int sd_is_mq + int fd + const char *path + + @@ -136,6 +143,13 @@ address, including the initial 0 byte and set path to the initial 0 byte of the socket address. + + sd_is_mq() may be called to + check whether the specified file descriptor refers to + a POSIX message queue. If the + path parameter is not NULL, it + is checked whether the message queue is bound to the + specified name. diff --git a/man/systemd.socket.xml b/man/systemd.socket.xml index 3ea3154d..22567d48 100644 --- a/man/systemd.socket.xml +++ b/man/systemd.socket.xml @@ -249,6 +249,20 @@ directive above. + + ListenMessageQueue= + Specifies a POSIX + message queue name to listen on. This + expects a valid message queue name + (i.e. beginning with /). Behaviour + otherwise is very similar to the + ListenFIFO= + directive above. On Linux message + queue descriptors are actually file + descriptors and can be inherited + between processes. + + BindIPv6Only= Takes a one of @@ -462,6 +476,19 @@ for details. + + MessageQueueMaxMessages=, + MessageQueueMessageSize= + These two settings + take integer values and control the + mq_maxmsg resp. mq_msgsize field when + creating the message queue. Note that + either none or both of these variables + need to be set. See + mq_setattr3 + for details. + + FreeBind= Takes a boolean diff --git a/src/conf-parser.c b/src/conf-parser.c index a086cf7a..02f740a0 100644 --- a/src/conf-parser.c +++ b/src/conf-parser.c @@ -247,6 +247,32 @@ int config_parse_int( return 0; } +int config_parse_long( + const char *filename, + unsigned line, + const char *section, + const char *lvalue, + int ltype, + const char *rvalue, + void *data, + void *userdata) { + + long *i = data; + int r; + + assert(filename); + assert(lvalue); + assert(rvalue); + assert(data); + + if ((r = safe_atoli(rvalue, i)) < 0) { + log_error("[%s:%u] Failed to parse numeric value: %s", filename, line, rvalue); + return r; + } + + return 0; +} + int config_parse_uint64( const char *filename, unsigned line, diff --git a/src/conf-parser.h b/src/conf-parser.h index 3432695d..51efe007 100644 --- a/src/conf-parser.h +++ b/src/conf-parser.h @@ -47,6 +47,7 @@ int config_parse(const char *filename, FILE *f, const char* const *sections, con /* Generic parsers */ int config_parse_int(const char *filename, unsigned line, const char *section, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata); int config_parse_unsigned(const char *filename, unsigned line, const char *section, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata); +int config_parse_long(const char *filename, unsigned line, const char *section, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata); int config_parse_uint64(const char *filename, unsigned line, const char *section, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata); int config_parse_size(const char *filename, unsigned line, const char *section, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata); int config_parse_bool(const char *filename, unsigned line, const char *section, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata); diff --git a/src/dbus-common.c b/src/dbus-common.c index b23373c5..fe7f84b1 100644 --- a/src/dbus-common.c +++ b/src/dbus-common.c @@ -568,6 +568,21 @@ int bus_property_append_ul(DBusMessageIter *i, const char *property, void *data) return 0; } +int bus_property_append_long(DBusMessageIter *i, const char *property, void *data) { + uint64_t u; + + assert(i); + assert(property); + assert(data); + + u = (int64_t) *(long*) data; + + if (!dbus_message_iter_append_basic(i, DBUS_TYPE_INT64, &u)) + return -ENOMEM; + + return 0; +} + const char *bus_errno_to_dbus(int error) { switch(error) { diff --git a/src/dbus-common.h b/src/dbus-common.h index 729519c5..a88cb13b 100644 --- a/src/dbus-common.h +++ b/src/dbus-common.h @@ -125,6 +125,7 @@ int bus_property_append_uint32(DBusMessageIter *i, const char *property, void *d int bus_property_append_uint64(DBusMessageIter *i, const char *property, void *data); int bus_property_append_size(DBusMessageIter *i, const char *property, void *data); int bus_property_append_ul(DBusMessageIter *i, const char *property, void *data); +int bus_property_append_long(DBusMessageIter *i, const char *property, void *data); #define bus_property_append_int bus_property_append_int32 #define bus_property_append_pid bus_property_append_uint32 diff --git a/src/dbus-socket.c b/src/dbus-socket.c index 88727bbb..3ec78a0f 100644 --- a/src/dbus-socket.c +++ b/src/dbus-socket.c @@ -111,6 +111,8 @@ DBusHandlerResult bus_socket_message_handler(Unit *u, DBusConnection *c, DBusMes { "org.freedesktop.systemd1.Socket", "MaxConnections", bus_property_append_unsigned, "u", &u->socket.max_connections }, { "org.freedesktop.systemd1.Socket", "NConnections", bus_property_append_unsigned, "u", &u->socket.n_connections }, { "org.freedesktop.systemd1.Socket", "NAccepted", bus_property_append_unsigned, "u", &u->socket.n_accepted }, + { "org.freedesktop.systemd1.Socket", "MessageQueueMaxMessages", bus_property_append_long,"t", &u->socket.mq_maxmsg }, + { "org.freedesktop.systemd1.Socket", "MessageQueueMessageSize", bus_property_append_long,"t", &u->socket.mq_msgsize }, { NULL, NULL, NULL, NULL, NULL } }; diff --git a/src/load-fragment.c b/src/load-fragment.c index f8be4dba..7c39d238 100644 --- a/src/load-fragment.c +++ b/src/load-fragment.c @@ -231,6 +231,17 @@ static int config_parse_listen( path_kill_slashes(p->path); + } else if (streq(lvalue, "ListenMessageQueue")) { + + p->type = SOCKET_MQUEUE; + + if (!(p->path = strdup(rvalue))) { + free(p); + return -ENOMEM; + } + + path_kill_slashes(p->path); + } else if (streq(lvalue, "ListenNetlink")) { p->type = SOCKET_SOCKET; @@ -1921,6 +1932,7 @@ static int load_from_path(Unit *u, const char *path) { { "ListenFIFO", config_parse_listen, 0, &u->socket, "Socket" }, { "ListenNetlink", config_parse_listen, 0, &u->socket, "Socket" }, { "ListenSpecial", config_parse_listen, 0, &u->socket, "Socket" }, + { "ListenMessageQueue", config_parse_listen, 0, &u->socket, "Socket" }, { "BindIPv6Only", config_parse_socket_bind, 0, &u->socket, "Socket" }, { "Backlog", config_parse_unsigned, 0, &u->socket.backlog, "Socket" }, { "BindToDevice", config_parse_bindtodevice, 0, &u->socket, "Socket" }, @@ -1943,6 +1955,8 @@ static int load_from_path(Unit *u, const char *path) { { "PipeSize", config_parse_size, 0, &u->socket.pipe_size, "Socket" }, { "FreeBind", config_parse_bool, 0, &u->socket.free_bind, "Socket" }, { "TCPCongestion", config_parse_string, 0, &u->socket.tcp_congestion, "Socket" }, + { "MessageQueueMaxMessages", config_parse_long, 0, &u->socket.mq_maxmsg, "Socket" }, + { "MessageQueueMessageSize", config_parse_long, 0, &u->socket.mq_msgsize, "Socket" }, { "Service", config_parse_socket_service, 0, &u->socket, "Socket" }, EXEC_CONTEXT_CONFIG_ITEMS(u->socket.exec_context, "Socket"), diff --git a/src/sd-daemon.c b/src/sd-daemon.c index 6d1eebff..b30db5d5 100644 --- a/src/sd-daemon.c +++ b/src/sd-daemon.c @@ -41,6 +41,11 @@ #include #include #include +#include + +#if defined(__linux__) +#include +#endif #include "sd-daemon.h" @@ -325,6 +330,43 @@ int sd_is_socket_unix(int fd, int type, int listening, const char *path, size_t return 1; } +int sd_is_mq(int fd, const char *path) { +#if !defined(__linux__) + return 0; +#else + struct mq_attr attr; + + if (fd < 0) + return -EINVAL; + + if (mq_getattr(fd, &attr) < 0) + return -errno; + + if (path) { + char fpath[PATH_MAX]; + struct stat a, b; + + if (path[0] != '/') + return -EINVAL; + + if (fstat(fd, &a) < 0) + return -errno; + + strncpy(stpcpy(fpath, "/dev/mqueue"), path, sizeof(fpath) - 12); + fpath[sizeof(fpath)-1] = 0; + + if (stat(fpath, &b) < 0) + return -errno; + + if (a.st_dev != b.st_dev || + a.st_ino != b.st_ino) + return 0; + } + + return 1; +#endif +} + int sd_notify(int unset_environment, const char *state) { #if defined(DISABLE_SYSTEMD) || !defined(__linux__) || !defined(SOCK_CLOEXEC) return 0; diff --git a/src/sd-daemon.h b/src/sd-daemon.h index 4b853a15..c3d9b6fb 100644 --- a/src/sd-daemon.h +++ b/src/sd-daemon.h @@ -177,6 +177,14 @@ int sd_is_socket_inet(int fd, int family, int type, int listening, uint16_t port */ int sd_is_socket_unix(int fd, int type, int listening, const char *path, size_t length) _sd_hidden_; +/* + Helper call for identifying a passed file descriptor. Returns 1 if + the file descriptor is a POSIX Message Queue of the specified name, + 0 otherwise. If path is NULL a message queue name check is not + done. Returns a negative errno style error code on failure. +*/ +int sd_is_mq(int fd, const char *path) _sd_hidden_; + /* Informs systemd about changed daemon state. This takes a number of newline separated environment-style variable assignments in a diff --git a/src/socket.c b/src/socket.c index 0a18716c..364d3169 100644 --- a/src/socket.c +++ b/src/socket.c @@ -27,6 +27,7 @@ #include #include #include +#include #include "unit.h" #include "socket.h" @@ -248,8 +249,7 @@ static bool socket_needs_mount(Socket *s, const char *prefix) { if (p->type == SOCKET_SOCKET) { if (socket_address_needs_mount(&p->address, prefix)) return true; - } else { - assert(p->type == SOCKET_FIFO || p->type == SOCKET_SPECIAL); + } else if (p->type == SOCKET_FIFO || p->type == SOCKET_SPECIAL) { if (path_startswith(p->path, prefix)) return true; } @@ -468,6 +468,16 @@ static void socket_dump(Unit *u, FILE *f, const char *prefix) { "%sMark: %i\n", prefix, s->mark); + if (s->mq_maxmsg > 0) + fprintf(f, + "%sMessageQueueMaxMessages: %li\n", + prefix, s->mq_maxmsg); + + if (s->mq_msgsize > 0) + fprintf(f, + "%sMessageQueueMessageSize: %li\n", + prefix, s->mq_msgsize); + LIST_FOREACH(port, p, s->ports) { if (p->type == SOCKET_SOCKET) { @@ -484,6 +494,8 @@ static void socket_dump(Unit *u, FILE *f, const char *prefix) { free(k); } else if (p->type == SOCKET_SPECIAL) fprintf(f, "%sListenSpecial: %s\n", prefix, p->path); + else if (p->type == SOCKET_MQUEUE) + fprintf(f, "%sListenMessageQueue: %s\n", prefix, p->path); else fprintf(f, "%sListenFIFO: %s\n", prefix, p->path); } @@ -790,6 +802,66 @@ fail: return r; } +static int mq_address_create( + const char *path, + mode_t mq_mode, + long maxmsg, + long msgsize, + int *_fd) { + + int fd = -1, r = 0; + struct stat st; + mode_t old_mask; + struct mq_attr _attr, *attr = NULL; + + assert(path); + assert(_fd); + + if (maxmsg > 0 && msgsize > 0) { + zero(_attr); + _attr.mq_flags = O_NONBLOCK; + _attr.mq_maxmsg = maxmsg; + _attr.mq_msgsize = msgsize; + attr = &_attr; + } + + /* Enforce the right access mode for the mq */ + old_mask = umask(~ mq_mode); + + /* Include the original umask in our mask */ + umask(~mq_mode | old_mask); + + fd = mq_open(path, O_RDONLY|O_CLOEXEC|O_NONBLOCK|O_CREAT, mq_mode, attr); + umask(old_mask); + + if (fd < 0 && errno != EEXIST) { + r = -errno; + goto fail; + } + + if (fstat(fd, &st) < 0) { + r = -errno; + goto fail; + } + + if ((st.st_mode & 0777) != (mq_mode & ~old_mask) || + st.st_uid != getuid() || + st.st_gid != getgid()) { + + r = -EEXIST; + goto fail; + } + + *_fd = fd; + return 0; + +fail: + if (fd >= 0) + close_nointr_nofail(fd); + + return r; +} + static int socket_open_fds(Socket *s) { SocketPort *p; int r; @@ -850,7 +922,15 @@ static int socket_open_fds(Socket *s) { goto rollback; socket_apply_fifo_options(s, p->fd); + } else if (p->type == SOCKET_MQUEUE) { + if ((r = mq_address_create( + p->path, + s->socket_mode, + s->mq_maxmsg, + s->mq_msgsize, + &p->fd)) < 0) + goto rollback; } else assert_not_reached("Unknown port type"); } diff --git a/src/socket.h b/src/socket.h index b83c34cf..01ea48d6 100644 --- a/src/socket.h +++ b/src/socket.h @@ -59,6 +59,7 @@ typedef enum SocketType { SOCKET_SOCKET, SOCKET_FIFO, SOCKET_SPECIAL, + SOCKET_MQUEUE, _SOCKET_FIFO_MAX, _SOCKET_FIFO_INVALID = -1 } SocketType; @@ -124,6 +125,8 @@ struct Socket { size_t pipe_size; char *bind_to_device; char *tcp_congestion; + long mq_maxmsg; + long mq_msgsize; }; /* Called from the service code when collecting fds */ -- 2.39.5