File bridge_linux.go has 1238 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package bridge

import (
    "context"
    "fmt"

Method driver.CreateEndpoint has a Cognitive Complexity of 47 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) CreateEndpoint(ctx context.Context, nid, eid string, ifInfo driverapi.InterfaceInfo, _ map[string]interface{}) error {
    if ifInfo == nil {
        return errors.New("invalid interface info passed")
    }

• Read up
  Read up

Method driver.CreateEndpoint has 138 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *driver) CreateEndpoint(ctx context.Context, nid, eid string, ifInfo driverapi.InterfaceInfo, _ map[string]interface{}) error {
    if ifInfo == nil {
        return errors.New("invalid interface info passed")
    }

Method driver.link has a Cognitive Complexity of 43 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) link(network *bridgeNetwork, endpoint *bridgeEndpoint, enable bool) (retErr error) {
    cc := endpoint.containerConfig
    ec := endpoint.extConnConfig
    if cc == nil || ec == nil || (len(cc.ParentEndpoints) == 0 && len(cc.ChildEndpoints) == 0) {
        // nothing to do

• Read up
  Read up

Method networkConfiguration.fromLabels has a Cognitive Complexity of 36 (exceeds 20 allowed). Consider refactoring.

Open

func (c *networkConfiguration) fromLabels(labels map[string]string) error {
    var err error
    for label, value := range labels {
        switch label {
        case BridgeName:

• Read up
  Read up

driver has 24 methods (exceeds 20 allowed). Consider refactoring.

Open

type driver struct {
    config            configuration
    natChain          *iptables.ChainInfo
    filterChain       *iptables.ChainInfo
    isolationChain1   *iptables.ChainInfo

Method driver.configure has 78 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *driver) configure(option map[string]interface{}) error {
    var (
        config            configuration
        err               error
        natChain          *iptables.ChainInfo

Method driver.createNetwork has 76 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *driver) createNetwork(config *networkConfiguration) (err error) {
    // Initialize handle when needed
    d.Lock()
    if d.nlh == nil {
        d.nlh = ns.NlHandle()

Method driver.CreateEndpoint has 21 return statements (exceeds 4 allowed).

Open

func (d *driver) CreateEndpoint(ctx context.Context, nid, eid string, ifInfo driverapi.InterfaceInfo, _ map[string]interface{}) error {
    if ifInfo == nil {
        return errors.New("invalid interface info passed")
    }

Method driver.link has 62 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *driver) link(network *bridgeNetwork, endpoint *bridgeEndpoint, enable bool) (retErr error) {
    cc := endpoint.containerConfig
    ec := endpoint.extConnConfig
    if cc == nil || ec == nil || (len(cc.ParentEndpoints) == 0 && len(cc.ChildEndpoints) == 0) {
        // nothing to do

Method driver.configure has a Cognitive Complexity of 27 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) configure(option map[string]interface{}) error {
    var (
        config            configuration
        err               error
        natChain          *iptables.ChainInfo

• Read up
  Read up

Method networkConfiguration.fromLabels has 12 return statements (exceeds 4 allowed).

Open

func (c *networkConfiguration) fromLabels(labels map[string]string) error {
    var err error
    for label, value := range labels {
        switch label {
        case BridgeName:

Method networkConfiguration.fromLabels has 54 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *networkConfiguration) fromLabels(labels map[string]string) error {
    var err error
    for label, value := range labels {
        switch label {
        case BridgeName:

Method driver.deleteNetwork has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) deleteNetwork(nid string) error {
    var err error

    // Get network handler and remove it from driver
    d.Lock()

• Read up
  Read up

Method driver.link has 11 return statements (exceeds 4 allowed).

Open

func (d *driver) link(network *bridgeNetwork, endpoint *bridgeEndpoint, enable bool) (retErr error) {
    cc := endpoint.containerConfig
    ec := endpoint.extConnConfig
    if cc == nil || ec == nil || (len(cc.ParentEndpoints) == 0 && len(cc.ChildEndpoints) == 0) {
        // nothing to do

Method driver.Join has 8 return statements (exceeds 4 allowed).

Open

func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.drivers.bridge.Join", trace.WithAttributes(
        attribute.String("nid", nid),
        attribute.String("eid", eid),
        attribute.String("sboxKey", sboxKey)))

Method driver.ProgramExternalConnectivity has 8 return statements (exceeds 4 allowed).

Open

func (d *driver) ProgramExternalConnectivity(ctx context.Context, nid, eid string, options map[string]interface{}) error {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.drivers.bridge.ProgramExternalConnectivity", trace.WithAttributes(
        attribute.String("nid", nid),
        attribute.String("eid", eid)))
    defer span.End()

Method driver.CreateNetwork has 8 return statements (exceeds 4 allowed).

Open

func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {
    if len(ipV4Data) == 0 || ipV4Data[0].Pool.String() == "0.0.0.0/0" {
        return types.InvalidParameterErrorf("ipv4 pool is empty")
    }
    // Sanity checks

Method networkConfiguration.Validate has 7 return statements (exceeds 4 allowed).

Open

func (c *networkConfiguration) Validate() error {
    if c.Mtu < 0 {
        return ErrInvalidMtu(c.Mtu)
    }

Method driver.EndpointOperInfo has 6 return statements (exceeds 4 allowed).

Open

func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, error) {
    // Get the network handler and make sure it exists
    d.Lock()
    n, ok := d.networks[nid]
    d.Unlock()

Method driver.DeleteEndpoint has 6 return statements (exceeds 4 allowed).

Open

func (d *driver) DeleteEndpoint(nid, eid string) error {
    var err error

    // Get the network handler and make sure it exists
    d.Lock()

Method driver.Join has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

Method driver.Leave has 5 return statements (exceeds 4 allowed).

Open

func (d *driver) Leave(nid, eid string) error {
    network, err := d.getNetwork(nid)
    if err != nil {
        return types.InternalMaskableErrorf("%s", err)
    }

Method driver.createNetwork has a Cognitive Complexity of 22 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) createNetwork(config *networkConfiguration) (err error) {
    // Initialize handle when needed
    d.Lock()
    if d.nlh == nil {
        d.nlh = ns.NlHandle()

• Read up
  Read up

Method driver.RevokeExternalConnectivity has 5 return statements (exceeds 4 allowed).

Open

func (d *driver) RevokeExternalConnectivity(nid, eid string) error {
    network, err := d.getNetwork(nid)
    if err != nil {
        return err
    }

Method networkConfiguration.Conflicts has 5 return statements (exceeds 4 allowed).

Open

func (c *networkConfiguration) Conflicts(o *networkConfiguration) error {
    if o == nil {
        return errors.New("same configuration")
    }

Method driver.createNetwork has 5 return statements (exceeds 4 allowed).

Open

func (d *driver) createNetwork(config *networkConfiguration) (err error) {
    // Initialize handle when needed
    d.Lock()
    if d.nlh == nil {
        d.nlh = ns.NlHandle()

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            iptables.OnReloaded(func() {
                log.G(context.TODO()).Debugf("Recreating ip6tables chains on firewall reload")
                if _, _, _, _, err := setupIPChains(config, iptables.IPv6); err != nil {
                    log.G(context.TODO()).WithError(err).Error("Error reloading ip6tables chains")
                }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        iptables.OnReloaded(func() {
            log.G(context.TODO()).Debugf("Recreating iptables chains on firewall reload")
            if _, _, _, _, err := setupIPChains(config, iptables.IPv4); err != nil {
                log.G(context.TODO()).WithError(err).Error("Error reloading iptables chains")
            }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    if link, err := d.nlh.LinkByName(ep.srcName); err == nil {
        if err := d.nlh.LinkDel(link); err != nil {
            log.G(context.TODO()).WithError(err).Errorf("Failed to delete interface (%s)'s link on endpoint (%s) delete", ep.srcName, ep.id)
        }
    }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        if link, err := d.nlh.LinkByName(ep.srcName); err == nil {
            if err := d.nlh.LinkDel(link); err != nil {
                log.G(context.TODO()).WithError(err).Errorf("Failed to delete interface (%s)'s link on endpoint (%s) delete", ep.srcName, ep.id)
            }
        }

• Read up
  Read up