From aec4853498cb3a9fd76a7bd038fb7b4305f91adf Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Thu, 30 Jun 2022 22:20:47 +0200 Subject: [PATCH 01/18] libnetwork: ipvlan: clean up some consts Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/ipvlan/ipvlan.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/libnetwork/drivers/ipvlan/ipvlan.go b/libnetwork/drivers/ipvlan/ipvlan.go index 63600e6820..8a301a8851 100644 --- a/libnetwork/drivers/ipvlan/ipvlan.go +++ b/libnetwork/drivers/ipvlan/ipvlan.go @@ -18,10 +18,10 @@ const ( containerVethPrefix = "eth" vethPrefix = "veth" - ipvlanType = "ipvlan" // driver type name - parentOpt = "parent" // parent interface -o parent - driverModeOpt = ipvlanType + "_mode" // mode -o ipvlan_mode - driverFlagOpt = ipvlanType + "_flag" // flag -o ipvlan_flag + ipvlanType = "ipvlan" // driver type name + parentOpt = "parent" // parent interface -o parent + driverModeOpt = "ipvlan_mode" // mode -o ipvlan_mode + driverFlagOpt = "ipvlan_flag" // flag -o ipvlan_flag modeL2 = "l2" // ipvlan L2 mode (default) modeL3 = "l3" // ipvlan L3 mode From 9fba1514d2bcb9a191ebb49fcee334d32296d5de Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Thu, 30 Jun 2022 22:21:05 +0200 Subject: [PATCH 02/18] libnetwork: macvlan: clean up some consts Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/macvlan/macvlan.go | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/libnetwork/drivers/macvlan/macvlan.go b/libnetwork/drivers/macvlan/macvlan.go index 030323c6a0..119c885393 100644 --- a/libnetwork/drivers/macvlan/macvlan.go +++ b/libnetwork/drivers/macvlan/macvlan.go @@ -17,17 +17,15 @@ const ( vethLen = 7 containerVethPrefix = "eth" vethPrefix = "veth" - macvlanType = "macvlan" // driver type name - modePrivate = "private" // macvlan mode private - modeVepa = "vepa" // macvlan mode vepa - modeBridge = "bridge" // macvlan mode bridge - modePassthru = "passthru" // macvlan mode passthrough - parentOpt = "parent" // parent interface -o parent - modeOpt = "_mode" // macvlan mode ux opt suffix + macvlanType = "macvlan" // driver type name + modePrivate = "private" // macvlan mode private + modeVepa = "vepa" // macvlan mode vepa + modeBridge = "bridge" // macvlan mode bridge + modePassthru = "passthru" // macvlan mode passthrough + parentOpt = "parent" // parent interface -o parent + driverModeOpt = "macvlan_mode" // macvlan mode ux opt suffix ) -var driverModeOpt = macvlanType + modeOpt // mode --option macvlan_mode - type endpointTable map[string]*endpoint type networkTable map[string]*network From d3e3d434824553c3c997be5d6f17668c1048bf10 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 09:13:38 +0200 Subject: [PATCH 03/18] libnetwork: ipvlan: use single ipSubnet type Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/ipvlan/ipvlan_joinleave.go | 28 ++++++------------- libnetwork/drivers/ipvlan/ipvlan_network.go | 4 +-- libnetwork/drivers/ipvlan/ipvlan_store.go | 11 ++------ 3 files changed, 13 insertions(+), 30 deletions(-) diff --git a/libnetwork/drivers/ipvlan/ipvlan_joinleave.go b/libnetwork/drivers/ipvlan/ipvlan_joinleave.go index de143db4b4..360c62fe26 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_joinleave.go +++ b/libnetwork/drivers/ipvlan/ipvlan_joinleave.go @@ -171,29 +171,17 @@ func ifaceGateway(dfNet string) (*staticRoute, error) { } // getSubnetforIPv4 returns the ipv4 subnet to which the given IP belongs -func (n *network) getSubnetforIPv4(ip *net.IPNet) *ipv4Subnet { - for _, s := range n.config.Ipv4Subnets { - _, snet, err := net.ParseCIDR(s.SubnetIP) - if err != nil { - return nil - } - // first check if the mask lengths are the same - i, _ := snet.Mask.Size() - j, _ := ip.Mask.Size() - if i != j { - continue - } - if snet.Contains(ip.IP) { - return s - } - } - - return nil +func (n *network) getSubnetforIPv4(ip *net.IPNet) *ipSubnet { + return getSubnetForIP(ip, n.config.Ipv4Subnets) } // getSubnetforIPv6 returns the ipv6 subnet to which the given IP belongs -func (n *network) getSubnetforIPv6(ip *net.IPNet) *ipv6Subnet { - for _, s := range n.config.Ipv6Subnets { +func (n *network) getSubnetforIPv6(ip *net.IPNet) *ipSubnet { + return getSubnetForIP(ip, n.config.Ipv6Subnets) +} + +func getSubnetForIP(ip *net.IPNet, subnets []*ipSubnet) *ipSubnet { + for _, s := range subnets { _, snet, err := net.ParseCIDR(s.SubnetIP) if err != nil { return nil diff --git a/libnetwork/drivers/ipvlan/ipvlan_network.go b/libnetwork/drivers/ipvlan/ipvlan_network.go index d1d7fd071c..b4875250a7 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_network.go +++ b/libnetwork/drivers/ipvlan/ipvlan_network.go @@ -260,7 +260,7 @@ func (config *configuration) fromOptions(labels map[string]string) error { func (config *configuration) processIPAM(id string, ipamV4Data, ipamV6Data []driverapi.IPAMData) error { if len(ipamV4Data) > 0 { for _, ipd := range ipamV4Data { - s := &ipv4Subnet{ + s := &ipSubnet{ SubnetIP: ipd.Pool.String(), GwIP: ipd.Gateway.String(), } @@ -269,7 +269,7 @@ func (config *configuration) processIPAM(id string, ipamV4Data, ipamV6Data []dri } if len(ipamV6Data) > 0 { for _, ipd := range ipamV6Data { - s := &ipv6Subnet{ + s := &ipSubnet{ SubnetIP: ipd.Pool.String(), GwIP: ipd.Gateway.String(), } diff --git a/libnetwork/drivers/ipvlan/ipvlan_store.go b/libnetwork/drivers/ipvlan/ipvlan_store.go index ec6dd5cecd..cb8eafce2b 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_store.go +++ b/libnetwork/drivers/ipvlan/ipvlan_store.go @@ -32,16 +32,11 @@ type configuration struct { IpvlanMode string IpvlanFlag string CreatedSlaveLink bool - Ipv4Subnets []*ipv4Subnet - Ipv6Subnets []*ipv6Subnet + Ipv4Subnets []*ipSubnet + Ipv6Subnets []*ipSubnet } -type ipv4Subnet struct { - SubnetIP string - GwIP string -} - -type ipv6Subnet struct { +type ipSubnet struct { SubnetIP string GwIP string } From afeb4c7a6e34016cf8962fa43d7dbbd398e61aed Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 09:21:22 +0200 Subject: [PATCH 04/18] libnetwork: macvlan: use single ipSubnet type Signed-off-by: Sebastiaan van Stijn --- .../drivers/macvlan/macvlan_joinleave.go | 31 ++++++------------- libnetwork/drivers/macvlan/macvlan_network.go | 4 +-- libnetwork/drivers/macvlan/macvlan_store.go | 11 ++----- 3 files changed, 15 insertions(+), 31 deletions(-) diff --git a/libnetwork/drivers/macvlan/macvlan_joinleave.go b/libnetwork/drivers/macvlan/macvlan_joinleave.go index 69f083328b..647a7fae75 100644 --- a/libnetwork/drivers/macvlan/macvlan_joinleave.go +++ b/libnetwork/drivers/macvlan/macvlan_joinleave.go @@ -94,6 +94,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, if err := d.storeUpdate(ep); err != nil { return fmt.Errorf("failed to save macvlan endpoint %.7s to store: %v", ep.id, err) } + return nil } @@ -115,30 +116,18 @@ func (d *driver) Leave(nid, eid string) error { return nil } -// getSubnetforIP returns the ipv4 subnet to which the given IP belongs -func (n *network) getSubnetforIPv4(ip *net.IPNet) *ipv4Subnet { - for _, s := range n.config.Ipv4Subnets { - _, snet, err := net.ParseCIDR(s.SubnetIP) - if err != nil { - return nil - } - // first check if the mask lengths are the same - i, _ := snet.Mask.Size() - j, _ := ip.Mask.Size() - if i != j { - continue - } - if snet.Contains(ip.IP) { - return s - } - } - - return nil +// getSubnetforIPv4 returns the ipv4 subnet to which the given IP belongs +func (n *network) getSubnetforIPv4(ip *net.IPNet) *ipSubnet { + return getSubnetForIP(ip, n.config.Ipv4Subnets) } // getSubnetforIPv6 returns the ipv6 subnet to which the given IP belongs -func (n *network) getSubnetforIPv6(ip *net.IPNet) *ipv6Subnet { - for _, s := range n.config.Ipv6Subnets { +func (n *network) getSubnetforIPv6(ip *net.IPNet) *ipSubnet { + return getSubnetForIP(ip, n.config.Ipv6Subnets) +} + +func getSubnetForIP(ip *net.IPNet, subnets []*ipSubnet) *ipSubnet { + for _, s := range subnets { _, snet, err := net.ParseCIDR(s.SubnetIP) if err != nil { return nil diff --git a/libnetwork/drivers/macvlan/macvlan_network.go b/libnetwork/drivers/macvlan/macvlan_network.go index 943e90df85..e6872cd68f 100644 --- a/libnetwork/drivers/macvlan/macvlan_network.go +++ b/libnetwork/drivers/macvlan/macvlan_network.go @@ -241,7 +241,7 @@ func (config *configuration) fromOptions(labels map[string]string) error { func (config *configuration) processIPAM(id string, ipamV4Data, ipamV6Data []driverapi.IPAMData) error { if len(ipamV4Data) > 0 { for _, ipd := range ipamV4Data { - s := &ipv4Subnet{ + s := &ipSubnet{ SubnetIP: ipd.Pool.String(), GwIP: ipd.Gateway.String(), } @@ -250,7 +250,7 @@ func (config *configuration) processIPAM(id string, ipamV4Data, ipamV6Data []dri } if len(ipamV6Data) > 0 { for _, ipd := range ipamV6Data { - s := &ipv6Subnet{ + s := &ipSubnet{ SubnetIP: ipd.Pool.String(), GwIP: ipd.Gateway.String(), } diff --git a/libnetwork/drivers/macvlan/macvlan_store.go b/libnetwork/drivers/macvlan/macvlan_store.go index 5cc04eac8e..7dbc0d428e 100644 --- a/libnetwork/drivers/macvlan/macvlan_store.go +++ b/libnetwork/drivers/macvlan/macvlan_store.go @@ -31,16 +31,11 @@ type configuration struct { Parent string MacvlanMode string CreatedSlaveLink bool - Ipv4Subnets []*ipv4Subnet - Ipv6Subnets []*ipv6Subnet + Ipv4Subnets []*ipSubnet + Ipv6Subnets []*ipSubnet } -type ipv4Subnet struct { - SubnetIP string - GwIP string -} - -type ipv6Subnet struct { +type ipSubnet struct { SubnetIP string GwIP string } From a893540b667c302ae3267d3968628b19f8aca4ec Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 09:37:30 +0200 Subject: [PATCH 05/18] libnetwork: ipvlan: set network ID as part of parseNetworkOptions Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/ipvlan/ipvlan_network.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libnetwork/drivers/ipvlan/ipvlan_network.go b/libnetwork/drivers/ipvlan/ipvlan_network.go index b4875250a7..3357745512 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_network.go +++ b/libnetwork/drivers/ipvlan/ipvlan_network.go @@ -38,7 +38,6 @@ func (d *driver) CreateNetwork(nid string, option map[string]interface{}, nInfo if err != nil { return err } - config.ID = nid err = config.processIPAM(nid, ipV4Data, ipV6Data) if err != nil { return err @@ -212,6 +211,7 @@ func parseNetworkOptions(id string, option options.Generic) (*configuration, err config.Internal = true } } + config.ID = id return config, nil } From 8d067bbdb47270ecfc32e62944a6c68e984ce9a8 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 10:30:57 +0200 Subject: [PATCH 06/18] libnetwork: ipvlan: processIPAM(): remove unused arg and error return Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/ipvlan/ipvlan_network.go | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/libnetwork/drivers/ipvlan/ipvlan_network.go b/libnetwork/drivers/ipvlan/ipvlan_network.go index 3357745512..85db29734d 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_network.go +++ b/libnetwork/drivers/ipvlan/ipvlan_network.go @@ -38,10 +38,8 @@ func (d *driver) CreateNetwork(nid string, option map[string]interface{}, nInfo if err != nil { return err } - err = config.processIPAM(nid, ipV4Data, ipV6Data) - if err != nil { - return err - } + config.processIPAM(ipV4Data, ipV6Data) + // verify the ipvlan mode from -o ipvlan_mode option switch config.IpvlanMode { case "", modeL2: @@ -257,7 +255,7 @@ func (config *configuration) fromOptions(labels map[string]string) error { } // processIPAM parses v4 and v6 IP information and binds it to the network configuration -func (config *configuration) processIPAM(id string, ipamV4Data, ipamV6Data []driverapi.IPAMData) error { +func (config *configuration) processIPAM(ipamV4Data, ipamV6Data []driverapi.IPAMData) { if len(ipamV4Data) > 0 { for _, ipd := range ipamV4Data { s := &ipSubnet{ @@ -276,5 +274,4 @@ func (config *configuration) processIPAM(id string, ipamV4Data, ipamV6Data []dri config.Ipv6Subnets = append(config.Ipv6Subnets, s) } } - return nil } From 35cba9b1c967f053c5955a77bb2156ef04b83763 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 10:32:39 +0200 Subject: [PATCH 07/18] libnetwork: ipvlan: processIPAM(): simplify Remove redundant checks and intermediate variables. Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/ipvlan/ipvlan_network.go | 26 ++++++++------------- 1 file changed, 10 insertions(+), 16 deletions(-) diff --git a/libnetwork/drivers/ipvlan/ipvlan_network.go b/libnetwork/drivers/ipvlan/ipvlan_network.go index 85db29734d..a7ae9c8b62 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_network.go +++ b/libnetwork/drivers/ipvlan/ipvlan_network.go @@ -256,22 +256,16 @@ func (config *configuration) fromOptions(labels map[string]string) error { // processIPAM parses v4 and v6 IP information and binds it to the network configuration func (config *configuration) processIPAM(ipamV4Data, ipamV6Data []driverapi.IPAMData) { - if len(ipamV4Data) > 0 { - for _, ipd := range ipamV4Data { - s := &ipSubnet{ - SubnetIP: ipd.Pool.String(), - GwIP: ipd.Gateway.String(), - } - config.Ipv4Subnets = append(config.Ipv4Subnets, s) - } + for _, ipd := range ipamV4Data { + config.Ipv4Subnets = append(config.Ipv4Subnets, &ipSubnet{ + SubnetIP: ipd.Pool.String(), + GwIP: ipd.Gateway.String(), + }) } - if len(ipamV6Data) > 0 { - for _, ipd := range ipamV6Data { - s := &ipSubnet{ - SubnetIP: ipd.Pool.String(), - GwIP: ipd.Gateway.String(), - } - config.Ipv6Subnets = append(config.Ipv6Subnets, s) - } + for _, ipd := range ipamV6Data { + config.Ipv6Subnets = append(config.Ipv6Subnets, &ipSubnet{ + SubnetIP: ipd.Pool.String(), + GwIP: ipd.Gateway.String(), + }) } } From 798021af9f7ab8078bd3d93ae0ade666fae3a0a1 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 10:35:12 +0200 Subject: [PATCH 08/18] libnetwork: macvlan: set network ID as part of parseNetworkOptions Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/macvlan/macvlan_network.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/libnetwork/drivers/macvlan/macvlan_network.go b/libnetwork/drivers/macvlan/macvlan_network.go index e6872cd68f..570df0edb8 100644 --- a/libnetwork/drivers/macvlan/macvlan_network.go +++ b/libnetwork/drivers/macvlan/macvlan_network.go @@ -29,7 +29,6 @@ func (d *driver) CreateNetwork(nid string, option map[string]interface{}, nInfo if err != nil { return err } - config.ID = nid err = config.processIPAM(nid, ipV4Data, ipV6Data) if err != nil { return err @@ -193,7 +192,7 @@ func parseNetworkOptions(id string, option options.Generic) (*configuration, err config.Internal = true } } - + config.ID = id return config, nil } From 5d13b384797080e07945a356cf951145881cba31 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 10:37:39 +0200 Subject: [PATCH 09/18] libnetwork: macvlan: processIPAM(): remove unused arg and error return Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/macvlan/macvlan_network.go | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/libnetwork/drivers/macvlan/macvlan_network.go b/libnetwork/drivers/macvlan/macvlan_network.go index 570df0edb8..231d42093c 100644 --- a/libnetwork/drivers/macvlan/macvlan_network.go +++ b/libnetwork/drivers/macvlan/macvlan_network.go @@ -29,10 +29,8 @@ func (d *driver) CreateNetwork(nid string, option map[string]interface{}, nInfo if err != nil { return err } - err = config.processIPAM(nid, ipV4Data, ipV6Data) - if err != nil { - return err - } + config.processIPAM(ipV4Data, ipV6Data) + // verify the macvlan mode from -o macvlan_mode option switch config.MacvlanMode { case "", modeBridge: @@ -237,7 +235,7 @@ func (config *configuration) fromOptions(labels map[string]string) error { } // processIPAM parses v4 and v6 IP information and binds it to the network configuration -func (config *configuration) processIPAM(id string, ipamV4Data, ipamV6Data []driverapi.IPAMData) error { +func (config *configuration) processIPAM(ipamV4Data, ipamV6Data []driverapi.IPAMData) { if len(ipamV4Data) > 0 { for _, ipd := range ipamV4Data { s := &ipSubnet{ @@ -256,6 +254,4 @@ func (config *configuration) processIPAM(id string, ipamV4Data, ipamV6Data []dri config.Ipv6Subnets = append(config.Ipv6Subnets, s) } } - - return nil } From b768d69c04cdf9e7db76b22f6538fc7302f13ab3 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 10:39:49 +0200 Subject: [PATCH 10/18] libnetwork: macvlan: processIPAM(): simplify Remove redundant checks and intermediate variables. Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/macvlan/macvlan_network.go | 26 +++++++------------ 1 file changed, 10 insertions(+), 16 deletions(-) diff --git a/libnetwork/drivers/macvlan/macvlan_network.go b/libnetwork/drivers/macvlan/macvlan_network.go index 231d42093c..bf0b32793a 100644 --- a/libnetwork/drivers/macvlan/macvlan_network.go +++ b/libnetwork/drivers/macvlan/macvlan_network.go @@ -236,22 +236,16 @@ func (config *configuration) fromOptions(labels map[string]string) error { // processIPAM parses v4 and v6 IP information and binds it to the network configuration func (config *configuration) processIPAM(ipamV4Data, ipamV6Data []driverapi.IPAMData) { - if len(ipamV4Data) > 0 { - for _, ipd := range ipamV4Data { - s := &ipSubnet{ - SubnetIP: ipd.Pool.String(), - GwIP: ipd.Gateway.String(), - } - config.Ipv4Subnets = append(config.Ipv4Subnets, s) - } + for _, ipd := range ipamV4Data { + config.Ipv4Subnets = append(config.Ipv4Subnets, &ipSubnet{ + SubnetIP: ipd.Pool.String(), + GwIP: ipd.Gateway.String(), + }) } - if len(ipamV6Data) > 0 { - for _, ipd := range ipamV6Data { - s := &ipSubnet{ - SubnetIP: ipd.Pool.String(), - GwIP: ipd.Gateway.String(), - } - config.Ipv6Subnets = append(config.Ipv6Subnets, s) - } + for _, ipd := range ipamV6Data { + config.Ipv6Subnets = append(config.Ipv6Subnets, &ipSubnet{ + SubnetIP: ipd.Pool.String(), + GwIP: ipd.Gateway.String(), + }) } } From 9f0cb20d9f52af580bb568bc50789196f419a1f3 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 10:50:45 +0200 Subject: [PATCH 11/18] libnetwork: macvlan: move validation into parseNetworkOptions() Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/macvlan/macvlan_network.go | 35 +++++++++---------- 1 file changed, 17 insertions(+), 18 deletions(-) diff --git a/libnetwork/drivers/macvlan/macvlan_network.go b/libnetwork/drivers/macvlan/macvlan_network.go index bf0b32793a..3dfb7e513c 100644 --- a/libnetwork/drivers/macvlan/macvlan_network.go +++ b/libnetwork/drivers/macvlan/macvlan_network.go @@ -31,24 +31,6 @@ func (d *driver) CreateNetwork(nid string, option map[string]interface{}, nInfo } config.processIPAM(ipV4Data, ipV6Data) - // verify the macvlan mode from -o macvlan_mode option - switch config.MacvlanMode { - case "", modeBridge: - // default to macvlan bridge mode if -o macvlan_mode is empty - config.MacvlanMode = modeBridge - case modePrivate: - config.MacvlanMode = modePrivate - case modePassthru: - config.MacvlanMode = modePassthru - case modeVepa: - config.MacvlanMode = modeVepa - default: - return fmt.Errorf("requested macvlan mode '%s' is not valid, 'bridge' mode is the macvlan driver default", config.MacvlanMode) - } - // loopback is not a valid parent link - if config.Parent == "lo" { - return fmt.Errorf("loopback interface is not a valid %s parent link", macvlanType) - } // if parent interface not specified, create a dummy type link to use named dummy+net_id if config.Parent == "" { config.Parent = getDummyName(stringid.TruncateID(config.ID)) @@ -190,6 +172,23 @@ func parseNetworkOptions(id string, option options.Generic) (*configuration, err config.Internal = true } } + + // verify the macvlan mode from -o macvlan_mode option + switch config.MacvlanMode { + case "": + // default to macvlan bridge mode if -o macvlan_mode is empty + config.MacvlanMode = modeBridge + case modeBridge, modePrivate, modePassthru, modeVepa: + // valid option + default: + return nil, fmt.Errorf("requested macvlan mode '%s' is not valid, 'bridge' mode is the macvlan driver default", config.MacvlanMode) + } + + // loopback is not a valid parent link + if config.Parent == "lo" { + return nil, fmt.Errorf("loopback interface is not a valid macvlan parent link") + } + config.ID = id return config, nil } From 4e39cdd9bbbf6600a435200c8f19d57bf6fd31fa Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 10:56:21 +0200 Subject: [PATCH 12/18] libnetwork: ipvlan: move validation into parseNetworkOptions() Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/ipvlan/ipvlan_network.go | 56 ++++++++++----------- 1 file changed, 28 insertions(+), 28 deletions(-) diff --git a/libnetwork/drivers/ipvlan/ipvlan_network.go b/libnetwork/drivers/ipvlan/ipvlan_network.go index a7ae9c8b62..8ac769641a 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_network.go +++ b/libnetwork/drivers/ipvlan/ipvlan_network.go @@ -40,34 +40,6 @@ func (d *driver) CreateNetwork(nid string, option map[string]interface{}, nInfo } config.processIPAM(ipV4Data, ipV6Data) - // verify the ipvlan mode from -o ipvlan_mode option - switch config.IpvlanMode { - case "", modeL2: - // default to ipvlan L2 mode if -o ipvlan_mode is empty - config.IpvlanMode = modeL2 - case modeL3: - config.IpvlanMode = modeL3 - case modeL3S: - config.IpvlanMode = modeL3S - default: - return fmt.Errorf("requested ipvlan mode '%s' is not valid, 'l2' mode is the ipvlan driver default", config.IpvlanMode) - } - // verify the ipvlan flag from -o ipvlan_flag option - switch config.IpvlanFlag { - case "", flagBridge: - // default to bridge if -o ipvlan_flag is empty - config.IpvlanFlag = flagBridge - case flagPrivate: - config.IpvlanFlag = flagPrivate - case flagVepa: - config.IpvlanFlag = flagVepa - default: - return fmt.Errorf("requested ipvlan flag '%s' is not valid, 'bridge' is the ipvlan driver default", config.IpvlanFlag) - } - // loopback is not a valid parent link - if config.Parent == "lo" { - return fmt.Errorf("loopback interface is not a valid %s parent link", ipvlanType) - } // if parent interface not specified, create a dummy type link to use named dummy+net_id if config.Parent == "" { config.Parent = getDummyName(stringid.TruncateID(config.ID)) @@ -209,6 +181,34 @@ func parseNetworkOptions(id string, option options.Generic) (*configuration, err config.Internal = true } } + + // verify the ipvlan mode from -o ipvlan_mode option + switch config.IpvlanMode { + case "": + // default to ipvlan L2 mode if -o ipvlan_mode is empty + config.IpvlanMode = modeL2 + case modeL2, modeL3, modeL3S: + // valid option + default: + return nil, fmt.Errorf("requested ipvlan mode '%s' is not valid, 'l2' mode is the ipvlan driver default", config.IpvlanMode) + } + + // verify the ipvlan flag from -o ipvlan_flag option + switch config.IpvlanFlag { + case "": + // default to bridge if -o ipvlan_flag is empty + config.IpvlanFlag = flagBridge + case flagBridge, flagPrivate, flagVepa: + // valid option + default: + return nil, fmt.Errorf("requested ipvlan flag '%s' is not valid, 'bridge' is the ipvlan driver default", config.IpvlanFlag) + } + + // loopback is not a valid parent link + if config.Parent == "lo" { + return nil, fmt.Errorf("loopback interface is not a valid ipvlan parent link") + } + config.ID = id return config, nil } From 1a1a885423d7775969ba10eb780c21487be3f7e1 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 11:17:10 +0200 Subject: [PATCH 13/18] libnetwork: ipvlan: make configuration.fromOptions a constructor This was effectively a constructor, but through some indirection; make it a regular function, which is a bit more idiomatic. Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/ipvlan/ipvlan_network.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/libnetwork/drivers/ipvlan/ipvlan_network.go b/libnetwork/drivers/ipvlan/ipvlan_network.go index 8ac769641a..b3d5aaeb6e 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_network.go +++ b/libnetwork/drivers/ipvlan/ipvlan_network.go @@ -223,8 +223,7 @@ func parseNetworkGenericOptions(data interface{}) (*configuration, error) { case *configuration: config = opt case map[string]string: - config = &configuration{} - err = config.fromOptions(opt) + return newConfigFromLabels(opt), nil case options.Generic: var opaqueConfig interface{} if opaqueConfig, err = options.GenerateFromModel(opt, config); err == nil { @@ -236,8 +235,9 @@ func parseNetworkGenericOptions(data interface{}) (*configuration, error) { return config, err } -// fromOptions binds the generic options to networkConfiguration to cache -func (config *configuration) fromOptions(labels map[string]string) error { +// newConfigFromLabels creates a new configuration from the given labels. +func newConfigFromLabels(labels map[string]string) *configuration { + config := &configuration{} for label, value := range labels { switch label { case parentOpt: @@ -251,7 +251,8 @@ func (config *configuration) fromOptions(labels map[string]string) error { config.IpvlanFlag = value } } - return nil + + return config } // processIPAM parses v4 and v6 IP information and binds it to the network configuration From 99bde59229b658b4df7140a476bcd91132751cb3 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 11:18:14 +0200 Subject: [PATCH 14/18] libnetwork: ipvlan: cleanup parseNetworkGenericOptions Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/ipvlan/ipvlan_network.go | 17 +++++++---------- 1 file changed, 7 insertions(+), 10 deletions(-) diff --git a/libnetwork/drivers/ipvlan/ipvlan_network.go b/libnetwork/drivers/ipvlan/ipvlan_network.go index b3d5aaeb6e..9ddd29211e 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_network.go +++ b/libnetwork/drivers/ipvlan/ipvlan_network.go @@ -215,24 +215,21 @@ func parseNetworkOptions(id string, option options.Generic) (*configuration, err // parseNetworkGenericOptions parse generic driver docker network options func parseNetworkGenericOptions(data interface{}) (*configuration, error) { - var ( - err error - config *configuration - ) switch opt := data.(type) { case *configuration: - config = opt + return opt, nil case map[string]string: return newConfigFromLabels(opt), nil case options.Generic: - var opaqueConfig interface{} - if opaqueConfig, err = options.GenerateFromModel(opt, config); err == nil { - config = opaqueConfig.(*configuration) + var config *configuration + opaqueConfig, err := options.GenerateFromModel(opt, config) + if err != nil { + return nil, err } + return opaqueConfig.(*configuration), nil default: - err = types.BadRequestErrorf("unrecognized network configuration format: %v", opt) + return nil, types.BadRequestErrorf("unrecognized network configuration format: %v", opt) } - return config, err } // newConfigFromLabels creates a new configuration from the given labels. From 1992190162ffbbb6d8b0598791070d4399210f2e Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 11:20:30 +0200 Subject: [PATCH 15/18] libnetwork: macvlan: make configuration.fromOptions a constructor This was effectively a constructor, but through some indirection; make it a regular function, which is a bit more idiomatic. Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/macvlan/macvlan_network.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/libnetwork/drivers/macvlan/macvlan_network.go b/libnetwork/drivers/macvlan/macvlan_network.go index 3dfb7e513c..398c14e308 100644 --- a/libnetwork/drivers/macvlan/macvlan_network.go +++ b/libnetwork/drivers/macvlan/macvlan_network.go @@ -203,8 +203,7 @@ func parseNetworkGenericOptions(data interface{}) (*configuration, error) { case *configuration: config = opt case map[string]string: - config = &configuration{} - err = config.fromOptions(opt) + return newConfigFromLabels(opt), nil case options.Generic: var opaqueConfig interface{} if opaqueConfig, err = options.GenerateFromModel(opt, config); err == nil { @@ -217,8 +216,9 @@ func parseNetworkGenericOptions(data interface{}) (*configuration, error) { return config, err } -// fromOptions binds the generic options to networkConfiguration to cache -func (config *configuration) fromOptions(labels map[string]string) error { +// newConfigFromLabels creates a new configuration from the given labels. +func newConfigFromLabels(labels map[string]string) *configuration { + config := &configuration{} for label, value := range labels { switch label { case parentOpt: @@ -230,7 +230,7 @@ func (config *configuration) fromOptions(labels map[string]string) error { } } - return nil + return config } // processIPAM parses v4 and v6 IP information and binds it to the network configuration From dddb4d25d2d366efbc3a13b67d86daf286f06efc Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 11:21:42 +0200 Subject: [PATCH 16/18] libnetwork: macvlan: cleanup parseNetworkGenericOptions Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/macvlan/macvlan_network.go | 18 +++++++----------- 1 file changed, 7 insertions(+), 11 deletions(-) diff --git a/libnetwork/drivers/macvlan/macvlan_network.go b/libnetwork/drivers/macvlan/macvlan_network.go index 398c14e308..50f1a086a5 100644 --- a/libnetwork/drivers/macvlan/macvlan_network.go +++ b/libnetwork/drivers/macvlan/macvlan_network.go @@ -195,25 +195,21 @@ func parseNetworkOptions(id string, option options.Generic) (*configuration, err // parseNetworkGenericOptions parses generic driver docker network options func parseNetworkGenericOptions(data interface{}) (*configuration, error) { - var ( - err error - config *configuration - ) switch opt := data.(type) { case *configuration: - config = opt + return opt, nil case map[string]string: return newConfigFromLabels(opt), nil case options.Generic: - var opaqueConfig interface{} - if opaqueConfig, err = options.GenerateFromModel(opt, config); err == nil { - config = opaqueConfig.(*configuration) + var config *configuration + opaqueConfig, err := options.GenerateFromModel(opt, config) + if err != nil { + return nil, err } + return opaqueConfig.(*configuration), nil default: - err = types.BadRequestErrorf("unrecognized network configuration format: %v", opt) + return nil, types.BadRequestErrorf("unrecognized network configuration format: %v", opt) } - - return config, err } // newConfigFromLabels creates a new configuration from the given labels. From aca80d1cda4da98ca8686d58a7c15b41cce96ef6 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 11:30:46 +0200 Subject: [PATCH 17/18] libnetwork: ipvlan: reduce use of const for driver name Inlining the string makes the code more grep'able; renaming the const to "driverName" to reflect the remaining uses of it. Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/ipvlan/ipvlan.go | 6 +++--- libnetwork/drivers/ipvlan/ipvlan_endpoint.go | 6 +++--- libnetwork/drivers/ipvlan/ipvlan_network.go | 9 +++++---- libnetwork/drivers/ipvlan/ipvlan_setup.go | 6 +++--- 4 files changed, 14 insertions(+), 13 deletions(-) diff --git a/libnetwork/drivers/ipvlan/ipvlan.go b/libnetwork/drivers/ipvlan/ipvlan.go index 8a301a8851..c0e3964c2d 100644 --- a/libnetwork/drivers/ipvlan/ipvlan.go +++ b/libnetwork/drivers/ipvlan/ipvlan.go @@ -18,7 +18,7 @@ const ( containerVethPrefix = "eth" vethPrefix = "veth" - ipvlanType = "ipvlan" // driver type name + driverName = "ipvlan" // driver type name parentOpt = "parent" // parent interface -o parent driverModeOpt = "ipvlan_mode" // mode -o ipvlan_mode driverFlagOpt = "ipvlan_flag" // flag -o ipvlan_flag @@ -75,7 +75,7 @@ func Init(dc driverapi.DriverCallback, config map[string]interface{}) error { return err } - return dc.RegisterDriver(ipvlanType, d, c) + return dc.RegisterDriver(driverName, d, c) } func (d *driver) NetworkAllocate(id string, option map[string]string, ipV4Data, ipV6Data []driverapi.IPAMData) (map[string]string, error) { @@ -91,7 +91,7 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro } func (d *driver) Type() string { - return ipvlanType + return driverName } func (d *driver) IsBuiltIn() bool { diff --git a/libnetwork/drivers/ipvlan/ipvlan_endpoint.go b/libnetwork/drivers/ipvlan/ipvlan_endpoint.go index 7d4c42a442..5b9e99769e 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_endpoint.go +++ b/libnetwork/drivers/ipvlan/ipvlan_endpoint.go @@ -27,7 +27,7 @@ func (d *driver) CreateEndpoint(nid, eid string, ifInfo driverapi.InterfaceInfo, return fmt.Errorf("network id %q not found", nid) } if ifInfo.MacAddress() != nil { - return fmt.Errorf("%s interfaces do not support custom mac address assignment", ipvlanType) + return fmt.Errorf("ipvlan interfaces do not support custom mac address assignment") } ep := &endpoint{ id: eid, @@ -42,7 +42,7 @@ func (d *driver) CreateEndpoint(nid, eid string, ifInfo driverapi.InterfaceInfo, if opt, ok := epOptions[netlabel.PortMap]; ok { if _, ok := opt.([]types.PortBinding); ok { if len(opt.([]types.PortBinding)) > 0 { - logrus.Warnf("%s driver does not support port mappings", ipvlanType) + logrus.Warnf("ipvlan driver does not support port mappings") } } } @@ -50,7 +50,7 @@ func (d *driver) CreateEndpoint(nid, eid string, ifInfo driverapi.InterfaceInfo, if opt, ok := epOptions[netlabel.ExposedPorts]; ok { if _, ok := opt.([]types.TransportPort); ok { if len(opt.([]types.TransportPort)) > 0 { - logrus.Warnf("%s driver does not support port exposures", ipvlanType) + logrus.Warnf("ipvlan driver does not support port exposures") } } } diff --git a/libnetwork/drivers/ipvlan/ipvlan_network.go b/libnetwork/drivers/ipvlan/ipvlan_network.go index 9ddd29211e..28bb615fff 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_network.go +++ b/libnetwork/drivers/ipvlan/ipvlan_network.go @@ -22,7 +22,7 @@ func (d *driver) CreateNetwork(nid string, option map[string]interface{}, nInfo defer osl.InitOSContext()() kv, err := kernel.GetKernelVersion() if err != nil { - return fmt.Errorf("Failed to check kernel version for %s driver support: %v", ipvlanType, err) + return fmt.Errorf("failed to check kernel version for ipvlan driver support: %v", err) } // ensure Kernel version is >= v4.2 for ipvlan support if kv.Kernel < ipvlanKernelVer || (kv.Kernel == ipvlanKernelVer && kv.Major < ipvlanMajorVer) { @@ -52,6 +52,7 @@ func (d *driver) CreateNetwork(nid string, option map[string]interface{}, nInfo if foundExisting { return types.InternalMaskableErrorf("restoring existing network %s", config.ID) } + // update persistent db, rollback on fail err = d.storeUpdate(config) if err != nil { @@ -87,7 +88,7 @@ func (d *driver) createNetwork(config *configuration) (bool, error) { } config.CreatedSlaveLink = true - // notify the user in logs they have limited communications + // notify the user in logs that they have limited communications logrus.Debugf("Empty -o parent= flags limit communications to other containers inside of network: %s", config.Parent) } else { @@ -115,7 +116,7 @@ func (d *driver) createNetwork(config *configuration) (bool, error) { return foundExisting, nil } -// DeleteNetwork the network for the specified driver type +// DeleteNetwork deletes the network for the specified driver type func (d *driver) DeleteNetwork(nid string) error { defer osl.InitOSContext()() n := d.network(nid) @@ -164,7 +165,7 @@ func (d *driver) DeleteNetwork(nid string) error { return nil } -// parseNetworkOptions parse docker network options +// parseNetworkOptions parses docker network options func parseNetworkOptions(id string, option options.Generic) (*configuration, error) { var ( err error diff --git a/libnetwork/drivers/ipvlan/ipvlan_setup.go b/libnetwork/drivers/ipvlan/ipvlan_setup.go index 8c162e9ddc..7e8e793485 100644 --- a/libnetwork/drivers/ipvlan/ipvlan_setup.go +++ b/libnetwork/drivers/ipvlan/ipvlan_setup.go @@ -38,7 +38,7 @@ func createIPVlan(containerIfName, parent, ipvlanMode, ipvlanFlag string) (strin // Get the link for the master index (Example: the docker host eth iface) parentLink, err := ns.NlHandle().LinkByName(parent) if err != nil { - return "", fmt.Errorf("error occurred looking up the %s parent iface %s error: %s", ipvlanType, parent, err) + return "", fmt.Errorf("error occurred looking up the ipvlan parent iface %s error: %s", parent, err) } // Create an ipvlan link ipvlan := &netlink.IPVlan{ @@ -51,7 +51,7 @@ func createIPVlan(containerIfName, parent, ipvlanMode, ipvlanFlag string) (strin } if err := ns.NlHandle().LinkAdd(ipvlan); err != nil { // If a user creates a macvlan and ipvlan on same parent, only one slave iface can be active at a time. - return "", fmt.Errorf("failed to create the %s port: %v", ipvlanType, err) + return "", fmt.Errorf("failed to create the ipvlan port: %v", err) } return ipvlan.Attrs().Name, nil @@ -190,7 +190,7 @@ func createDummyLink(dummyName, truncNetID string) error { } parentDummyLink, err := ns.NlHandle().LinkByName(dummyName) if err != nil { - return fmt.Errorf("error occurred looking up the %s parent iface %s error: %s", ipvlanType, dummyName, err) + return fmt.Errorf("error occurred looking up the ipvlan parent iface %s error: %s", dummyName, err) } // bring the new netlink iface up if err := ns.NlHandle().LinkSetUp(parentDummyLink); err != nil { From b1a6d5388dfd54f4a0674eefecb4bb7cdc3f9aed Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Fri, 1 Jul 2022 11:32:46 +0200 Subject: [PATCH 18/18] libnetwork: macvlan: reduce use of const for driver name Inlining the string makes the code more grep'able; renaming the const to "driverName" to reflect the remaining uses of it. Signed-off-by: Sebastiaan van Stijn --- libnetwork/drivers/macvlan/macvlan.go | 6 +++--- libnetwork/drivers/macvlan/macvlan_endpoint.go | 4 ++-- libnetwork/drivers/macvlan/macvlan_network.go | 3 ++- libnetwork/drivers/macvlan/macvlan_setup.go | 6 +++--- 4 files changed, 10 insertions(+), 9 deletions(-) diff --git a/libnetwork/drivers/macvlan/macvlan.go b/libnetwork/drivers/macvlan/macvlan.go index 119c885393..d455affa56 100644 --- a/libnetwork/drivers/macvlan/macvlan.go +++ b/libnetwork/drivers/macvlan/macvlan.go @@ -17,7 +17,7 @@ const ( vethLen = 7 containerVethPrefix = "eth" vethPrefix = "veth" - macvlanType = "macvlan" // driver type name + driverName = "macvlan" // driver type name modePrivate = "private" // macvlan mode private modeVepa = "vepa" // macvlan mode vepa modeBridge = "bridge" // macvlan mode bridge @@ -69,7 +69,7 @@ func Init(dc driverapi.DriverCallback, config map[string]interface{}) error { return err } - return dc.RegisterDriver(macvlanType, d, c) + return dc.RegisterDriver(driverName, d, c) } func (d *driver) NetworkAllocate(id string, option map[string]string, ipV4Data, ipV6Data []driverapi.IPAMData) (map[string]string, error) { @@ -85,7 +85,7 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro } func (d *driver) Type() string { - return macvlanType + return driverName } func (d *driver) IsBuiltIn() bool { diff --git a/libnetwork/drivers/macvlan/macvlan_endpoint.go b/libnetwork/drivers/macvlan/macvlan_endpoint.go index 8d4390f779..dd1cfe1acb 100644 --- a/libnetwork/drivers/macvlan/macvlan_endpoint.go +++ b/libnetwork/drivers/macvlan/macvlan_endpoint.go @@ -47,7 +47,7 @@ func (d *driver) CreateEndpoint(nid, eid string, ifInfo driverapi.InterfaceInfo, if opt, ok := epOptions[netlabel.PortMap]; ok { if _, ok := opt.([]types.PortBinding); ok { if len(opt.([]types.PortBinding)) > 0 { - logrus.Warnf("%s driver does not support port mappings", macvlanType) + logrus.Warnf("macvlan driver does not support port mappings") } } } @@ -55,7 +55,7 @@ func (d *driver) CreateEndpoint(nid, eid string, ifInfo driverapi.InterfaceInfo, if opt, ok := epOptions[netlabel.ExposedPorts]; ok { if _, ok := opt.([]types.TransportPort); ok { if len(opt.([]types.TransportPort)) > 0 { - logrus.Warnf("%s driver does not support port exposures", macvlanType) + logrus.Warnf("macvlan driver does not support port exposures") } } } diff --git a/libnetwork/drivers/macvlan/macvlan_network.go b/libnetwork/drivers/macvlan/macvlan_network.go index 50f1a086a5..2ed8069195 100644 --- a/libnetwork/drivers/macvlan/macvlan_network.go +++ b/libnetwork/drivers/macvlan/macvlan_network.go @@ -78,8 +78,9 @@ func (d *driver) createNetwork(config *configuration) (bool, error) { return false, err } config.CreatedSlaveLink = true + // notify the user in logs that they have limited communications - logrus.Debugf("Empty -o parent= limit communications to other containers inside of network: %s", + logrus.Debugf("Empty -o parent= flags limit communications to other containers inside of network: %s", config.Parent) } else { // if the subinterface parent_iface.vlan_id checks do not pass, return err. diff --git a/libnetwork/drivers/macvlan/macvlan_setup.go b/libnetwork/drivers/macvlan/macvlan_setup.go index 7415a07a27..ec40207d41 100644 --- a/libnetwork/drivers/macvlan/macvlan_setup.go +++ b/libnetwork/drivers/macvlan/macvlan_setup.go @@ -31,7 +31,7 @@ func createMacVlan(containerIfName, parent, macvlanMode string) (string, error) // Get the link for the master index (Example: the docker host eth iface) parentLink, err := ns.NlHandle().LinkByName(parent) if err != nil { - return "", fmt.Errorf("error occurred looking up the %s parent iface %s error: %s", macvlanType, parent, err) + return "", fmt.Errorf("error occurred looking up the macvlan parent iface %s error: %s", parent, err) } // Create a macvlan link macvlan := &netlink.Macvlan{ @@ -43,7 +43,7 @@ func createMacVlan(containerIfName, parent, macvlanMode string) (string, error) } if err := ns.NlHandle().LinkAdd(macvlan); err != nil { // If a user creates a macvlan and ipvlan on same parent, only one slave iface can be active at a time. - return "", fmt.Errorf("failed to create the %s port: %v", macvlanType, err) + return "", fmt.Errorf("failed to create the macvlan port: %v", err) } return macvlan.Attrs().Name, nil @@ -170,7 +170,7 @@ func createDummyLink(dummyName, truncNetID string) error { } parentDummyLink, err := ns.NlHandle().LinkByName(dummyName) if err != nil { - return fmt.Errorf("error occurred looking up the %s parent iface %s error: %s", macvlanType, dummyName, err) + return fmt.Errorf("error occurred looking up the macvlan parent iface %s error: %s", dummyName, err) } // bring the new netlink iface up if err := ns.NlHandle().LinkSetUp(parentDummyLink); err != nil {