Method Daemon.findAndAttachNetwork has 65 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) findAndAttachNetwork(ctr *container.Container, idOrName string, epConfig *networktypes.EndpointSettings) (*libnetwork.Network, *networktypes.NetworkingConfig, error) {
    id := getNetworkID(idOrName, epConfig)

    n, err := daemon.FindNetwork(id)
    if err != nil {

Method pusher.pushTag has a Cognitive Complexity of 28 (exceeds 20 allowed). Consider refactoring.

Open

func (p *pusher) pushTag(ctx context.Context, ref reference.NamedTagged, id digest.Digest) error {
    log.G(ctx).Debugf("Pushing repository: %s", reference.FamiliarString(ref))

    imgConfig, err := p.config.ImageStore.Get(ctx, id)
    if err != nil {

• Read up
  Read up

Method puller.pullTag has 17 return statements (exceeds 4 allowed).

Open

func (p *puller) pullTag(ctx context.Context, ref reference.Named, platform *ocispec.Platform) (tagUpdated bool, err error) {
    var (
        tagOrDigest string // Used for logging/progress only
        dgst        digest.Digest
        mt          string

Method pusher.pushTag has 17 return statements (exceeds 4 allowed).

Open

func (p *pusher) pushTag(ctx context.Context, ref reference.NamedTagged, id digest.Digest) error {
    log.G(ctx).Debugf("Pushing repository: %s", reference.FamiliarString(ref))

    imgConfig, err := p.config.ImageStore.Get(ctx, id)
    if err != nil {

Method Controller.handleEpTableEvent has a Cognitive Complexity of 28 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Controller) handleEpTableEvent(ev events.Event) {
    var (
        nid   string
        eid   string
        value []byte

• Read up
  Read up

Method IPTable.ProgramChain has 17 return statements (exceeds 4 allowed).

Open

func (iptable IPTable) ProgramChain(c *ChainInfo, bridgeName string, hairpinMode, enable bool) error {
    if c.Name == "" {
        return errors.New("could not program chain, missing chain name")
    }

Method PortAllocator.RequestPortsInRange has a Cognitive Complexity of 28 (exceeds 20 allowed). Consider refactoring.

Open

func (p *PortAllocator) RequestPortsInRange(ips []net.IP, proto string, portStart, portEnd int) (int, error) {
    if proto != "tcp" && proto != "udp" && proto != "sctp" {
        return 0, ErrUnknownProtocol
    }

• Read up
  Read up

Method driver.Join has 17 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.overlay.Join", trace.WithAttributes(
        attribute.String("nid", nid),
        attribute.String("eid", eid),
        attribute.String("sboxKey", sboxKey)))

Method linuxParser.validateMountConfigImpl has 17 return statements (exceeds 4 allowed).

Open

func (p *linuxParser) validateMountConfigImpl(mnt *mount.Mount, validateBindSourceExists bool) error {
    if len(mnt.Target) == 0 {
        return &errMountConfig{mnt, errMissingField("Target")}
    }

Method Builder.Build has 17 return statements (exceeds 4 allowed).

Open

func (b *Builder) Build(ctx context.Context, opt backend.BuildConfig) (*builder.Result, error) {
    if len(opt.Options.Outputs) > 1 {
        return nil, errors.Errorf("multiple outputs not supported")
    }

Function ReadCertsDirectory has a Cognitive Complexity of 28 (exceeds 20 allowed). Consider refactoring.

Open

func ReadCertsDirectory(tlsConfig *tls.Config, directory string) error {
    fs, err := os.ReadDir(directory)
    if err != nil && !os.IsNotExist(err) {
        return invalidParam(err)
    }

• Read up
  Read up

Method pushProgress.UpdateProgress has a Cognitive Complexity of 28 (exceeds 20 allowed). Consider refactoring.

Open

func (p *pushProgress) UpdateProgress(ctx context.Context, ongoing *jobs, out progress.Output, start time.Time) error {
    for _, j := range ongoing.Jobs() {
        key := remotes.MakeRefKey(ctx, j)
        id := stringid.TruncateID(j.Digest.Encoded())

• Read up
  Read up

Method ImageService.createDiff has 17 return statements (exceeds 4 allowed).

Open

func (i *ImageService) createDiff(ctx context.Context, name string, sn snapshots.Snapshotter, cs content.Store, comparer diff.Comparer) (*ocispec.Descriptor, digest.Digest, error) {
    info, err := sn.Stat(ctx, name)
    if err != nil {
        return nil, "", err
    }

Method Daemon.killWithSignal has a Cognitive Complexity of 28 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) killWithSignal(container *containerpkg.Container, stopSignal syscall.Signal) error {
    log.G(context.TODO()).WithFields(log.Fields{
        "signal":    int(stopSignal),
        "container": container.ID,
    }).Debugf("sending signal %[1]d (%[1]s) to container", stopSignal)

• Read up
  Read up

Method Daemon.logServiceEvent has a Cognitive Complexity of 28 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) logServiceEvent(action swarmapi.WatchActionKind, service *swarmapi.Service, oldService *swarmapi.Service) {
    attributes := map[string]string{
        "name": service.Spec.Annotations.Name,
    }
    eventTime := eventTimestamp(service.Meta, action)

• Read up
  Read up

Method Daemon.handleContainerExit has a Cognitive Complexity of 28 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) handleContainerExit(c *container.Container, e *libcontainerdtypes.EventInfo) error {
    var exitStatus container.ExitStatus
    c.Lock()

    cfg := daemon.config()

• Read up
  Read up

Function New has a Cognitive Complexity of 28 (exceeds 20 allowed). Consider refactoring.

Open

func New(name string, config Options) (Driver, error) {
    ctx := context.TODO()
    if name != "" {
        log.G(ctx).Infof("[graphdriver] trying configured driver: %s", name)
        if err := checkRemoved(name); err != nil {

• Read up
  Read up

Method Daemon.filterByNameIDMatches has a Cognitive Complexity of 28 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) filterByNameIDMatches(view *container.View, filter *listContext) ([]container.Snapshot, error) {
    idSearch := false
    names := filter.filters.Get("name")
    ids := filter.filters.Get("id")
    if len(names)+len(ids) == 0 {

• Read up
  Read up

Method ImageService.Images has 17 return statements (exceeds 4 allowed).

Open

func (i *ImageService) Images(ctx context.Context, opts imagetypes.ListOptions) ([]*imagetypes.Summary, error) {
    if err := opts.Filters.Validate(acceptedImageFilterTags); err != nil {
        return nil, err
    }

Method tarSum.Read has 17 return statements (exceeds 4 allowed).

Open

func (ts *tarSum) Read(buf []byte) (int, error) {
    if ts.finished {
        return ts.bufWriter.Read(buf)
    }
    if len(ts.bufData) < len(buf) {