From mboxrd@z Thu Jan 1 00:00:00 1970 Authentication-Results: passt.top; dmarc=none (p=none dis=none) header.from=gibson.dropbear.id.au Authentication-Results: passt.top; dkim=pass (2048-bit key; secure) header.d=gibson.dropbear.id.au header.i=@gibson.dropbear.id.au header.a=rsa-sha256 header.s=202602 header.b=Hy14K+rW; dkim-atps=neutral Received: from mail.ozlabs.org (gandalf.ozlabs.org [150.107.74.76]) by passt.top (Postfix) with ESMTPS id 834A15A026E for ; Thu, 19 Mar 2026 07:12:05 +0100 (CET) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gibson.dropbear.id.au; s=202602; t=1773900721; bh=U99EOq0V1SCZAjt+p0LbTVvc+ZZ1jAcsldALS1yMnbg=; h=From:To:Cc:Subject:Date:In-Reply-To:References:From; b=Hy14K+rWuyAlFq7S5iCm7TzEDC84W94Sw7rci+iPauoIPXsSbLgjkN8B2kVZ4L/Rc yWPNoZI0rxUQeNcxKq/4B3a3tz3d4jHRokh/b1/DpH0fYv1PyDsZ5QH7mNwr2at0YB VsupOABRuhKIKaBi/S+a5c/4GYcSGkdzC/KLLaCecxwMMLL+SagW6iS1lG4cIsiE5n 2yw0B0m5xVaPVK9QmcCptm1qUWQO/9fz4roMtsx0E5GKPbExvyKMTuzmxSfVHlmFSD i4DcBrPBwLTTlN3jAOaZnDaJfMH1GvL1jGo8gUFtRwkOaMXXok6NHkjxp+riCURrDE z1wMxXFCWrXRw== Received: by gandalf.ozlabs.org (Postfix, from userid 1007) id 4fbwMP714Yz4wSk; Thu, 19 Mar 2026 17:12:01 +1100 (AEDT) From: David Gibson To: Stefano Brivio , passt-dev@passt.top Subject: [PATCH v2 03/15] serialise: Add helpers for serialising unsigned integers Date: Thu, 19 Mar 2026 17:11:45 +1100 Message-ID: <20260319061157.1983818-4-david@gibson.dropbear.id.au> X-Mailer: git-send-email 2.53.0 In-Reply-To: <20260319061157.1983818-1-david@gibson.dropbear.id.au> References: <20260319061157.1983818-1-david@gibson.dropbear.id.au> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Message-ID-Hash: 35QETEAH52XCPVBGPF45XVXYAHXLRJ7R X-Message-ID-Hash: 35QETEAH52XCPVBGPF45XVXYAHXLRJ7R X-MailFrom: dgibson@gandalf.ozlabs.org X-Mailman-Rule-Misses: dmarc-mitigation; no-senders; approved; emergency; loop; banned-address; member-moderation; nonmember-moderation; administrivia; implicit-dest; max-recipients; max-size; news-moderation; no-subject; digests; suspicious-header CC: David Gibson X-Mailman-Version: 3.3.8 Precedence: list List-Id: Development discussion and patches for passt Archived-At: Archived-At: List-Archive: List-Archive: List-Help: List-Owner: List-Post: List-Subscribe: List-Unsubscribe: Add helpers to serialise/deserialise unsigned integers, handling endian conversion so that the stream format is consistent regardless of host endiannness. Currently we only use this on one place: sending the number of flows during migration. We're going to have more use for this as we add dynamic configuration updates, so these will become more useful. For now we only need a 32-bit version, however define the functions with a macro so we can easily add other integer widths when we need them. Signed-off-by: David Gibson --- flow.c | 10 ++++------ serialise.c | 35 +++++++++++++++++++++++++++++++++++ serialise.h | 7 +++++++ 3 files changed, 46 insertions(+), 6 deletions(-) diff --git a/flow.c b/flow.c index 7d3c5ae6..81333dbc 100644 --- a/flow.c +++ b/flow.c @@ -1135,10 +1135,9 @@ int flow_migrate_source(struct ctx *c, const struct migrate_stage *stage, count++; } - count = htonl(count); - if (sewrite_var(fd, &count)) { + if (sewrite_u32(fd, count)) { rc = errno; - err_perror("Can't send flow count (%u)", ntohl(count)); + err_perror("Can't send flow count (%u)", count); return flow_migrate_source_rollback(c, FLOW_MAX, rc); } @@ -1151,7 +1150,7 @@ int flow_migrate_source(struct ctx *c, const struct migrate_stage *stage, debug("Stop listen()s"); fwd_listen_close(&c->fwd_in); - debug("Sending %u flows", ntohl(count)); + debug("Sending %u flows", count); if (!count) return 0; @@ -1221,10 +1220,9 @@ int flow_migrate_target(struct ctx *c, const struct migrate_stage *stage, (void)stage; - if (seread_var(fd, &count)) + if (seread_u32(fd, &count)) return errno; - count = ntohl(count); debug("Receiving %u flows", count); if (!count) diff --git a/serialise.c b/serialise.c index 68054722..098ae35c 100644 --- a/serialise.c +++ b/serialise.c @@ -13,7 +13,9 @@ */ #include +#include #include +#include #include #include "serialise.h" @@ -86,3 +88,36 @@ int sewrite_buf(int fd, const void *buf, size_t len) } return 0; } + +/** + * seread_uXXX() - Receive a uXXX value from an fd + * @fd: File descriptor to read from + * @valp: Pointer to variable to update with read value + * + * Return: 0 on success, -1 on error + */ +/** + * sewrite_uXXX() - Send a uXXX value to an fd + * @fd: File descriptor to write to + * @val: Value to send + * + * Return: 0 on success, -1 on error + */ +#define SERIALISE_UINT(bits) \ + int seread_u##bits(int fd, uint##bits##_t *val) \ + { \ + uint##bits##_t beval; \ + if (seread_var(fd, &beval) < 0) \ + return -1; \ + *val = be##bits##toh(beval); \ + return 0; \ + } \ + int sewrite_u##bits(int fd, uint##bits##_t val) \ + { \ + uint##bits##_t beval = htobe##bits(val); \ + return sewrite_var(fd, &beval); \ + } + +SERIALISE_UINT(32) + +#undef SERIALISE_UNIT diff --git a/serialise.h b/serialise.h index ec95287f..f2e0aa8d 100644 --- a/serialise.h +++ b/serialise.h @@ -7,6 +7,7 @@ #define SERIALISE_H #include +#include int seread_buf(int fd, void *buf, size_t len); int sewrite_buf(int fd, const void *buf, size_t len); @@ -14,4 +15,10 @@ int sewrite_buf(int fd, const void *buf, size_t len); #define seread_var(fd_, var_) (seread_buf((fd_), (var_), sizeof(*(var_)))) #define sewrite_var(fd_, var_) (sewrite_buf((fd_), (var_), sizeof(*(var_)))) +#define SERIALISE_UINT_DECL(bits) \ + int seread_u##bits(int fd, uint##bits##_t *val); \ + int sewrite_u##bits(int fd, uint##bits##_t val); + +SERIALISE_UINT_DECL(32) + #endif /* _SERIALISE_H */ -- 2.53.0