From d972cffe5a221cc585e2edfdd1d3514eab51271c Mon Sep 17 00:00:00 2001 From: Ophestra Date: Mon, 23 Mar 2026 15:16:21 +0900 Subject: internal/netlink: make full response available The previous API makes it impossible to retrieve remaining messages in the current iteration. Signed-off-by: Ophestra --- internal/netlink/rtnl.go | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) (limited to 'internal/netlink/rtnl.go') diff --git a/internal/netlink/rtnl.go b/internal/netlink/rtnl.go index 1ed463b6..e6585bf8 100644 --- a/internal/netlink/rtnl.go +++ b/internal/netlink/rtnl.go @@ -18,23 +18,23 @@ func DialRoute() (*RouteConn, error) { } // rtnlConsume consumes a message from rtnetlink. -func rtnlConsume(msg *syscall.NetlinkMessage) error { - switch msg.Header.Type { - case syscall.NLMSG_DONE: - return Complete{} +func rtnlConsume(resp []syscall.NetlinkMessage) error { + for i := range resp { + switch resp[i].Header.Type { + case syscall.NLMSG_DONE: + return Complete{} - case syscall.NLMSG_ERROR: - if e := As[syscall.NlMsgerr](msg.Data); e != nil { - if e.Error == 0 { - return Complete{} + case syscall.NLMSG_ERROR: + if e := As[syscall.NlMsgerr](resp[i].Data); e != nil { + if e.Error == 0 { + return Complete{} + } + return syscall.Errno(-e.Error) } - return syscall.Errno(-e.Error) + return syscall.EBADE } - return syscall.EBADE - - default: - return nil } + return nil } // InAddr is equivalent to struct in_addr. -- cgit v1.3.1