@@ -625,19 +625,24 @@ func bridgeForInterface(intfName, nodeName,
625
625
if err != nil {
626
626
return nil , fmt .Errorf ("gateway accelerated interface %s is not valid: %w" , config .Gateway .GatewayAcceleratedInterface , err )
627
627
}
628
+ gwIntf = config .Gateway .GatewayAcceleratedInterface
628
629
isGWAcclInterface = true
629
630
klog .Infof ("For gateway accelerated interface %s representor: %s" , config .Gateway .GatewayAcceleratedInterface , intfRep )
631
+ } else {
632
+ intfRep , err = getRepresentor (gwIntf )
633
+ if err == nil {
634
+ isGWAcclInterface = true
635
+ }
630
636
}
631
637
632
638
if isGWAcclInterface {
633
- gatewayAcceleratedInterface := config .Gateway .GatewayAcceleratedInterface
634
639
bridgeName , _ , err := util .RunOVSVsctl ("port-to-br" , intfRep )
635
640
if err != nil {
636
641
return nil , fmt .Errorf ("failed to find bridge that has port %s: %w" , intfRep , err )
637
642
}
638
- link , err := util .GetNetLinkOps ().LinkByName (gatewayAcceleratedInterface )
643
+ link , err := util .GetNetLinkOps ().LinkByName (gwIntf )
639
644
if err != nil {
640
- return nil , fmt .Errorf ("failed to get netdevice link for %s: %w" , gatewayAcceleratedInterface , err )
645
+ return nil , fmt .Errorf ("failed to get netdevice link for %s: %w" , gwIntf , err )
641
646
}
642
647
uplinkName , err := util .GetNicName (bridgeName )
643
648
if err != nil {
@@ -646,7 +651,7 @@ func bridgeForInterface(intfName, nodeName,
646
651
res .bridgeName = bridgeName
647
652
res .uplinkName = uplinkName
648
653
res .gwIfaceRep = intfRep
649
- res .gwIface = gatewayAcceleratedInterface
654
+ res .gwIface = gwIntf
650
655
res .macAddress = link .Attrs ().HardwareAddr
651
656
} else if bridgeName , _ , err := util .RunOVSVsctl ("port-to-br" , intfName ); err == nil {
652
657
// This is an OVS bridge's internal port
0 commit comments