From mboxrd@z Thu Jan 1 00:00:00 1970 Received: from atuin.qyliss.net (localhost [IPv6:::1]) by atuin.qyliss.net (Postfix) with ESMTP id 3B6BA1A63E; Fri, 07 Nov 2025 19:02:36 +0000 (UTC) Received: by atuin.qyliss.net (Postfix, from userid 993) id E33E61A55D; Fri, 07 Nov 2025 19:02:21 +0000 (UTC) X-Spam-Checker-Version: SpamAssassin 4.0.1 (2024-03-26) on atuin.qyliss.net X-Spam-Level: X-Spam-Status: No, score=-0.1 required=3.0 tests=DKIM_SIGNED,DKIM_VALID, DKIM_VALID_AU,DMARC_PASS,FREEMAIL_FROM,RCVD_IN_DNSWL_NONE, SPF_HELO_NONE autolearn=unavailable autolearn_force=no version=4.0.1 Received: from mail-yx1-xb12d.google.com (mail-yx1-xb12d.google.com [IPv6:2607:f8b0:4864:20::b12d]) by atuin.qyliss.net (Postfix) with ESMTPS id 4890C1A5BA for ; Fri, 07 Nov 2025 19:02:03 +0000 (UTC) Received: by mail-yx1-xb12d.google.com with SMTP id 956f58d0204a3-63fbed0f71aso951492d50.0 for ; Fri, 07 Nov 2025 11:02:02 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20230601; t=1762542120; x=1763146920; darn=spectrum-os.org; h=cc:to:in-reply-to:references:message-id:content-transfer-encoding :mime-version:subject:date:from:from:to:cc:subject:date:message-id :reply-to; bh=WVxhgCUBokUz1RFCyaoSflbsPOeSesbTCmkdq+gNpyM=; b=QcXLJiH+Zxo1ZMnp+Gi7OtU79wweg0GhwZAIm205SxGSpS9ucw0qxidsdktcqvpg11 CJ9GXTi1kK0tvw2XOzIRqpqQLA4MAQDPjajSBJrHfontCaZHeX9ydov61L28MYDYeUMt aXnJy/UiMXTD7KKUZjN9LgBxapfwyrdFgkCb9dCrZAxFGlNhwemR9Uakl9/qfiB3qwYD /vDio7IMAQXWfBL2Wc8h6cAgOdrPT0/oQcaGthpc2WodA4jngOc68fTRyWgzwF2QLu4r lepCbyfZWget2Rz+jBIFaQQhZwyjIMbCYZ6LdIUlmU9YBrEIZ4A/a+CGo+/StHCK05JM rImA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1762542120; x=1763146920; h=cc:to:in-reply-to:references:message-id:content-transfer-encoding :mime-version:subject:date:from:x-gm-gg:x-gm-message-state:from:to :cc:subject:date:message-id:reply-to; bh=WVxhgCUBokUz1RFCyaoSflbsPOeSesbTCmkdq+gNpyM=; b=pognZq6Md7Yk2M6uOEYS1cqAE8VPnwQ/xMC72VG5r2ZEYuMbPURvS58Tre746NcN5U FehmpmGOhGEFSfcBslThnCyLrCgR5brj5H4yBDeoksT+og3M2f1RWZIjF3xRSFkHZYeB RyUcQ+V8FT4n/J/Bu1hOpVUmwOlufs0oOpQYI9+8gt+Y65kS/Th59I6Y1d0XK/uKCdne B9QfTN6OG5KHqG5H/1ajH01xjdhKNnczSyknv5JQaeDH79Mog68h3gjUwSR2oTaSbqcK DV+UqaLN3/ZBPophVyVZ39rZD2iKvj1dsghsJ8ZNzowo9bfn8RgKbMD8GDVCSUXw0sxx nT5Q== X-Gm-Message-State: AOJu0YwAtHpdjvu99X+m9iXVEdpCVwpGTHjf7GtLYBWMfBhchX/kRnjH Hl38ZPvrIq6Nb9rh9sH1OhzqVeNw3qbLB8TLJ9lGpZ4PCKnejPrhvJ3HNbUD5g== X-Gm-Gg: ASbGncvpMgJHGM54wA6cS5DTr+8BM8DGGu3tWu3Mg5kMzrmSU8JlAR3k64CLnzmGBqq Op8v16FlwMDboCldWpToWinGi5u1oNdjjGP5eD3DGnONDbUA7sjjHiuH3TFajVpMAaC+f4Z2agR 1B119zcu7iJtrQXSksns4Lzjhp98bFMk4GhxPOXpmwiYAMPBdmOY6bi785+R+DCaNB2b9Q5o23M dPbbYowSu2JzNbeARcPC3HGfuw/4jgNYPvRKDSMUWNt0PdY7pVZ+cUc+8BV/1jQsGdYmNGp8bMb WxfR7YKuc1C7zgZoHezYwTDC8hDEDUWGLwNVRy6+HOjwclCTJDNYDDo9NcndrCik28rVS7R5zlM AL5LeNFkLrODmtUfy6/ReGToJfh2xqB3JZjyN+dPL2zRCw619Ghluv8UZmvWq+4mlhfHPDqptaM Wjgz3fsFZ4eFGw8fmPrPTlx1lpJUOoahXIrP+lUfiUx4DSqPaVVasgvW+EpVEJmSXETQi0vV/GQ cTJDvcgNuKn9wvu25OPNpLm X-Google-Smtp-Source: AGHT+IHDeLnme1h34ltELin0WliH07uiWK8aDXGLod94IueiPylHDB5+ZO86D4TkukB4t+OVPFOhsg== X-Received: by 2002:a05:690e:160f:b0:640:c0e4:bd89 with SMTP id 956f58d0204a3-640d452b7edmr110060d50.10.1762542120383; Fri, 07 Nov 2025 11:02:00 -0800 (PST) Received: from localhost.localdomain (h96-60-249-169.cncrtn.broadband.dynamic.tds.net. [96.60.249.169]) by smtp.gmail.com with UTF8SMTPSA id 956f58d0204a3-640b5ca403asm2043581d50.8.2025.11.07.11.01.59 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Fri, 07 Nov 2025 11:01:59 -0800 (PST) From: Demi Marie Obenour Date: Fri, 07 Nov 2025 14:00:58 -0500 Subject: [PATCH v6 1/2] tools: Add adapter tool for services using sd_notify MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: 7bit Message-Id: <20251107-udev-v6-1-176246281424@gmail.com> References: <20251107-udev-v6-0-176246281424@gmail.com> In-Reply-To: <20251107-udev-v6-0-176246281424@gmail.com> To: Spectrum OS Development X-Mailer: b4 0.14.3 X-Developer-Signature: v=1; a=ed25519-sha256; t=1762542057; l=6031; i=demiobenour@gmail.com; s=20250729; h=from:subject:message-id; bh=ZQ6+gwzBHDR/w9c8KWF1RyZ0rTH+tg9u/sUMdVCd3IY=; b=zwySK5A6xModKj7IB369jHIiGMe8s5vK1lJRa4C6mTLGxSrXqq9uxcRUMyDeGBZSrjOZm5LHd Do10Mp+nRdRBAijBqcCh/i7SWo8RCgJR4o8O82jUoOcdttOIgJwVvns X-Developer-Key: i=demiobenour@gmail.com; a=ed25519; pk=X57Q4/YQDj9t4SBeKaDwvXYKB6quZJVx/DE2Ly2out0= Message-ID-Hash: TCWHFBNIAUFA2G7PFBAX6INZTEOA6LOJ X-Message-ID-Hash: TCWHFBNIAUFA2G7PFBAX6INZTEOA6LOJ X-MailFrom: demiobenour@gmail.com X-Mailman-Rule-Misses: dmarc-mitigation; no-senders; approved; emergency; loop; banned-address; member-moderation; header-match-devel.spectrum-os.org-0; header-match-devel.spectrum-os.org-1; header-match-devel.spectrum-os.org-2; header-match-devel.spectrum-os.org-3; header-match-devel.spectrum-os.org-4; nonmember-moderation; administrivia; implicit-dest; max-recipients; max-size; news-moderation; no-subject; digests; suspicious-header CC: Demi Marie Obenour , Alyssa Ross X-Mailman-Version: 3.3.9 Precedence: list List-Id: Patches and low-level development discussion Archived-At: List-Archive: List-Help: List-Owner: List-Post: List-Subscribe: List-Unsubscribe: This adapts programs using sd_notify for use with s6 readiness notification. stdin and stdout are hard-coded for simplicity. Signed-off-by: Demi Marie Obenour --- systemd readiness notification has two strict advantages over the s6 version: 1. It allows reliable reloading. 2. It allows providing a status message that the service manager can show in status output. s6 would actually benefit from both of these features. --- Changes since v4: - Use CC0 for the trivial Meson file. - Use -D_GNU_SOURCE instead of #define _GNU_SOURCE 1. - Use a global variable for the iovec. - Use ISC license for the C code in case s6 wants to use it. - Remove unneeded MSG_DONTWAIT. - Remove unneeded check for EAGAIN and EWOULDBLOCK when poll() has already indicated that the file descriptor is ready. Changes since v1: - Hard-code file descriptors. - Run wrapper as background process. - Massively reduce code size. - Use // instead of /* */ for comments. - Check that the notification FD is a pipe and that the listening socket is a socket. - Rely on s6-ipc-socketbinder to create the listening socket. - Do not unlink the listening socket. Signed-off-by: Demi Marie Obenour --- tools/default.nix | 1 + tools/meson.build | 1 + tools/sd-notify-adapter/meson.build | 4 ++ tools/sd-notify-adapter/sd-notify-adapter.c | 107 ++++++++++++++++++++++++++++ 4 files changed, 113 insertions(+) diff --git a/tools/default.nix b/tools/default.nix index 398f57038d3f9fdec47b72850755e289f225f339..36a9a8c84de9f83e31981d3d47fab27e98f6ae5a 100644 --- a/tools/default.nix +++ b/tools/default.nix @@ -76,6 +76,7 @@ stdenv.mkDerivation (finalAttrs: { ./lsvm ./start-vmm ./subprojects + ./sd-notify-adapter ] ++ lib.optionals driverSupport [ ./xdp-forwarder ])); diff --git a/tools/meson.build b/tools/meson.build index 186008dbc9dd2b63adbce7475c375fb0de5c2c6a..5d0ae81042fd3d77646594500f32cb1d48a6af0c 100644 --- a/tools/meson.build +++ b/tools/meson.build @@ -27,6 +27,7 @@ if get_option('host') subdir('lsvm') subdir('start-vmm') + subdir('sd-notify-adapter') endif if get_option('app') diff --git a/tools/sd-notify-adapter/meson.build b/tools/sd-notify-adapter/meson.build new file mode 100644 index 0000000000000000000000000000000000000000..906fbde673105fd65436b34802f1bcc74e9f823e --- /dev/null +++ b/tools/sd-notify-adapter/meson.build @@ -0,0 +1,4 @@ +# SPDX-License-Identifier: CC0-1.0 +# SPDX-FileCopyrightText: 2025 Demi Marie Obenour + +executable('sd-notify-adapter', 'sd-notify-adapter.c', c_args : ['-D_GNU_SOURCE'], install: true) diff --git a/tools/sd-notify-adapter/sd-notify-adapter.c b/tools/sd-notify-adapter/sd-notify-adapter.c new file mode 100644 index 0000000000000000000000000000000000000000..734f018da605e4359d3fa6422a01effbd9e878ea --- /dev/null +++ b/tools/sd-notify-adapter/sd-notify-adapter.c @@ -0,0 +1,107 @@ +// SPDX-License-Identifier: ISC +// SPDX-FileCopyrightText: 2025 Demi Marie Obenour + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include +#include +#include +#include +#include +#include +#include + +#define ARRAY_SIZE(s) (sizeof(s)/sizeof(s[0])) + +enum { + socket_fd, + notification_fd, +}; + +struct iovec msg; + +#define READY "READY=1" +#define READY_SIZE (sizeof(READY) - 1) + +static void process_notification(void) +{ + ssize_t first_recv_size = recv(socket_fd, msg.iov_base, msg.iov_len, + MSG_TRUNC | MSG_PEEK); + if (first_recv_size == -1) { + if (errno == EINTR) + return; // signal caught + err(EXIT_FAILURE, "recv from notification socket"); + } + size_t size = (size_t)first_recv_size; + if (size == 0) + return; // avoid arithmetic on NULL pointer + if (size > msg.iov_len) { + msg.iov_base = realloc(msg.iov_base, size); + if (msg.iov_base == NULL) + err(EXIT_FAILURE, "allocation failure"); + msg.iov_len = size; + } + ssize_t second_recv_size = recv(socket_fd, msg.iov_base, msg.iov_len, + MSG_CMSG_CLOEXEC | MSG_TRUNC); + if (second_recv_size == -1) { + if (errno == EINTR) + return; + err(EXIT_FAILURE, "recv from notification socket"); + } + assert(first_recv_size == second_recv_size); + for (char *next, *cursor = msg.iov_base, *end = cursor + size; + cursor != NULL; cursor = (next == NULL ? NULL : next + 1)) { + next = memchr(cursor, '\n', (size_t)(end - cursor)); + size_t message_size = (size_t)((next == NULL ? end : next) - cursor); + if (message_size == READY_SIZE && + memcmp(cursor, READY, READY_SIZE) == 0) { + ssize_t write_size = write(notification_fd, "\n", 1); + if (write_size != 1) + err(EXIT_FAILURE, "writing to notification descriptor"); + exit(0); + } + } +} + +int main(int argc, char **) +{ + if (argc != 1) + errx(EXIT_FAILURE, "stdin is listening socket, stdout is notification pipe"); + for (;;) { + struct pollfd p[] = { + { + .fd = socket_fd, + .events = POLLIN, + .revents = 0, + }, + { + .fd = notification_fd, + .events = 0, + .revents = 0, + }, + }; + int r = poll(p, ARRAY_SIZE(p), -1); + if (r < 0) { + if (errno == EINTR) + continue; + err(EXIT_FAILURE, "poll"); + } + if (p[0].revents) { + if (p[0].revents & POLLERR) + errx(EXIT_FAILURE, "unexpected POLLERR"); + if (p[0].revents & POLLIN) + process_notification(); + } + if (p[1].revents) + errx(EXIT_FAILURE, "s6 closed its pipe before the child was ready"); + } +} -- 2.51.2