Forward error to user

Signed-off-by: Lehner Florian <[email protected]>

attributeTcMsg.go

@@ -355,11 +355,19 @@ func extractActStats(data []byte, stats *ActionStats) error {
 }
 
 func extractClsact(data []byte) error {
-	return fmt.Errorf("extractClsact()\t%v", data)
+	// Clsact is parameterless - so we expect to options
+	if len(data) != 0 {
+		return fmt.Errorf("extractClsact()\t%v", data)
+	}
+	return nil
 }
 
 func extractIngress(data []byte) error {
-	return fmt.Errorf("extractIngress()\t%v", data)
+	// Ingress is parameterless - so we expect to options
+	if len(data) != 0 {
+		return fmt.Errorf("extractIngress()\t%v", data)
+	}
+	return nil
 }
 
 const (

tc.go

@@ -4,6 +4,7 @@ package tc
 
 import (
 	"encoding/binary"
+	"fmt"
 	"unsafe"
 
 	"github.com/mdlayher/netlink"
@@ -95,7 +96,9 @@ func (tc *Tc) action(action int, flags netlink.HeaderFlags, info *Object, opts [
 	}
 
 	for _, msg := range msgs {
-		_ = msg
+		if msg.Header.Type == netlink.Error {
+			return fmt.Errorf("could not process query: %v", err)
+		}
 	}
 
 	return nil