git: 7ff3b13f12d9 - main - lacp: Sort port map by interface index
- Go to: [ bottom of page ] [ top of archives ] [ this month ]
Date: Mon, 15 Dec 2025 17:09:45 UTC
The branch main has been updated by gallatin:
URL: https://cgit.FreeBSD.org/src/commit/?id=7ff3b13f12d97b7f67f09ecb9141e6dbaa1ad007
commit 7ff3b13f12d97b7f67f09ecb9141e6dbaa1ad007
Author: Andrew Gallatin <gallatin@FreeBSD.org>
AuthorDate: 2025-12-15 16:52:48 +0000
Commit: Andrew Gallatin <gallatin@FreeBSD.org>
CommitDate: 2025-12-15 17:08:59 +0000
lacp: Sort port map by interface index
This makes it easier to reason about system topology, and to
potentially map applications to NIC queues by (ab)using the
mbuf flowid to select egress NIC and queue in a predictable fashion.
Differential Revision: https://reviews.freebsd.org/D54053
Reviewed by: glebius, kbowling
Sponsored by: Netflix
---
sys/net/ieee8023ad_lacp.c | 26 +++++++++++++++++++++++++-
1 file changed, 25 insertions(+), 1 deletion(-)
diff --git a/sys/net/ieee8023ad_lacp.c b/sys/net/ieee8023ad_lacp.c
index 77b5a5d53a67..281d16bc6c05 100644
--- a/sys/net/ieee8023ad_lacp.c
+++ b/sys/net/ieee8023ad_lacp.c
@@ -1036,6 +1036,18 @@ lacp_select_active_aggregator(struct lacp_softc *lsc)
}
}
+static int
+lacp_pm_compare(const void *p1, const void *p2)
+{
+ struct lacp_port *const *a = p1;
+ struct lacp_port *const *b = p2;
+ int left, right;
+
+ left = (*a)->lp_ifp->if_index;
+ right = (*b)->lp_ifp->if_index;
+ return ((left > right) - (left < right));
+}
+
/*
* Updated the inactive portmap array with the new list of ports and
* make it live.
@@ -1079,12 +1091,24 @@ lacp_update_portmap(struct lacp_softc *lsc)
#ifdef NUMA
for (i = 0; i < MAXMEMDOM; i++) {
- if (p->pm_numa[i].count != 0)
+ if (p->pm_numa[i].count != 0) {
p->pm_num_dom++;
+ if (p->pm_numa[i].count > 1) {
+ qsort(&p->pm_numa[i].map[0],
+ p->pm_numa[i].count,
+ sizeof(p->pm_numa[i].map[0]),
+ lacp_pm_compare);
+ }
+ }
}
#endif
speed = lacp_aggregator_bandwidth(la);
}
+
+ if (p->pm_count > 1) {
+ qsort(&p->pm_map[0], p->pm_count,
+ sizeof(p->pm_map[0]), lacp_pm_compare);
+ }
sc->sc_ifp->if_baudrate = speed;
EVENTHANDLER_INVOKE(ifnet_event, sc->sc_ifp,
IFNET_EVENT_UPDATE_BAUDRATE);