[PATCH v3 12/18] malloc: fix mp message alignment
David Marchand
david.marchand at redhat.com
Tue Jul 8 14:28:16 CEST 2025
Content (param[]) of received multiprocess messages are aligned with
a 4 bytes constraint.
Before patch:
struct mp_msg_internal {
int type; /* 0 4 */
struct rte_mp_msg {
char name[64]; /* 4 64 */
/* --- cacheline 1 boundary (64 bytes) was 4 bytes ago --- */
int len_param; /* 68 4 */
int num_fds; /* 72 4 */
/* typedef uint8_t -> __uint8_t */ unsigned char param[256]; /* 76 256 */
/* --- cacheline 5 boundary (320 bytes) was 12 bytes ago --- */
int fds[253]; /* 332 1012 */
} msg; /* 4 1340 */
/* size: 1344, cachelines: 21, members: 2 */
};
This results in many unaligned accesses for multiprocess malloc requests.
Examples:
../lib/eal/common/malloc_mp.c:308:32: runtime error:
member access within misaligned address 0x7f7b35df4684 for type
'const struct malloc_mp_req', which requires 8 byte alignment
../lib/eal/common/malloc_mp.c:158:9: runtime error:
member access within misaligned address 0x7f36a535bb5c for type
'const struct malloc_mp_req', which requires 8 byte alignment
../lib/eal/common/malloc_mp.c:171:8: runtime error:
member access within misaligned address 0x7f4ba65f296c for type
'struct malloc_mp_req', which requires 8 byte alignment
Signed-off-by: David Marchand <david.marchand at redhat.com>
---
lib/eal/common/eal_common_proc.c | 2 +-
lib/eal/common/malloc_mp.c | 18 +++++++++---------
2 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/lib/eal/common/eal_common_proc.c b/lib/eal/common/eal_common_proc.c
index 0dea787e38..3846c7178d 100644
--- a/lib/eal/common/eal_common_proc.c
+++ b/lib/eal/common/eal_common_proc.c
@@ -62,7 +62,7 @@ enum mp_type {
struct mp_msg_internal {
int type;
- struct rte_mp_msg msg;
+ alignas(8) struct rte_mp_msg msg;
};
struct async_request_param {
diff --git a/lib/eal/common/malloc_mp.c b/lib/eal/common/malloc_mp.c
index 9765277f5d..000c7f6b47 100644
--- a/lib/eal/common/malloc_mp.c
+++ b/lib/eal/common/malloc_mp.c
@@ -148,7 +148,7 @@ get_unique_id(void)
static int
handle_sync(const struct rte_mp_msg *msg, const void *peer)
{
- struct rte_mp_msg reply;
+ alignas(8) struct rte_mp_msg reply;
const struct malloc_mp_req *req =
(const struct malloc_mp_req *)msg->param;
struct malloc_mp_req *resp =
@@ -330,7 +330,7 @@ handle_request(const struct rte_mp_msg *msg, const void *peer __rte_unused)
}
if (ret != 0) {
- struct rte_mp_msg resp_msg;
+ alignas(8) struct rte_mp_msg resp_msg;
struct malloc_mp_req *resp =
(struct malloc_mp_req *)resp_msg.param;
@@ -351,7 +351,7 @@ handle_request(const struct rte_mp_msg *msg, const void *peer __rte_unused)
/* we did not modify the request */
free(entry);
} else {
- struct rte_mp_msg sr_msg;
+ alignas(8) struct rte_mp_msg sr_msg;
struct malloc_mp_req *sr =
(struct malloc_mp_req *)sr_msg.param;
struct timespec ts;
@@ -444,7 +444,7 @@ handle_sync_response(const struct rte_mp_msg *request,
}
if (entry->user_req.t == REQ_TYPE_FREE) {
- struct rte_mp_msg msg;
+ alignas(8) struct rte_mp_msg msg;
struct malloc_mp_req *resp = (struct malloc_mp_req *)msg.param;
memset(&msg, 0, sizeof(msg));
@@ -465,7 +465,7 @@ handle_sync_response(const struct rte_mp_msg *request,
} else if (entry->user_req.t == REQ_TYPE_ALLOC &&
result == REQ_RESULT_SUCCESS) {
struct malloc_heap *heap = entry->alloc_state.heap;
- struct rte_mp_msg msg;
+ alignas(8) struct rte_mp_msg msg;
struct malloc_mp_req *resp =
(struct malloc_mp_req *)msg.param;
@@ -489,7 +489,7 @@ handle_sync_response(const struct rte_mp_msg *request,
free(entry);
} else if (entry->user_req.t == REQ_TYPE_ALLOC &&
result == REQ_RESULT_FAIL) {
- struct rte_mp_msg rb_msg;
+ alignas(8) struct rte_mp_msg rb_msg;
struct malloc_mp_req *rb =
(struct malloc_mp_req *)rb_msg.param;
struct timespec ts;
@@ -551,7 +551,7 @@ static int
handle_rollback_response(const struct rte_mp_msg *request,
const struct rte_mp_reply *reply __rte_unused)
{
- struct rte_mp_msg msg;
+ alignas(8) struct rte_mp_msg msg;
struct malloc_mp_req *resp = (struct malloc_mp_req *)msg.param;
const struct malloc_mp_req *mpreq =
(const struct malloc_mp_req *)request->param;
@@ -628,7 +628,7 @@ handle_response(const struct rte_mp_msg *msg, const void *peer __rte_unused)
int
request_sync(void)
{
- struct rte_mp_msg msg;
+ alignas(8) struct rte_mp_msg msg;
struct rte_mp_reply reply;
struct malloc_mp_req *req = (struct malloc_mp_req *)msg.param;
struct timespec ts;
@@ -697,7 +697,7 @@ request_sync(void)
int
request_to_primary(struct malloc_mp_req *user_req)
{
- struct rte_mp_msg msg;
+ alignas(8) struct rte_mp_msg msg;
struct malloc_mp_req *msg_req = (struct malloc_mp_req *)msg.param;
struct mp_request *entry;
struct timespec ts;
--
2.50.0
More information about the dev
mailing list