Method Daemon.ContainerRename has a Cognitive Complexity of 56 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) ContainerRename(oldName, newName string) (retErr error) {
    if oldName == "" || newName == "" {
        return errdefs.InvalidParameter(errors.New("Neither old nor new names may be empty"))
    }

• Read up
  Read up

File backend_linux.go has 676 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package plugin // import "github.com/docker/docker/plugin"

import (
    "archive/tar"
    "bytes"

Function attemptBindHostPorts has a Cognitive Complexity of 55 (exceeds 20 allowed). Consider refactoring.

Open

func attemptBindHostPorts(
    ctx context.Context,
    cfg []portBindingReq,
    proto string,
    hostPortStart, hostPortEnd uint16,

• Read up
  Read up

Method Cluster.resolveSystemAddrViaSubnetCheck has a Cognitive Complexity of 55 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Cluster) resolveSystemAddrViaSubnetCheck() (net.IP, error) {
    // Use the system's only IP address, or fail if there are
    // multiple addresses to choose from. Skip interfaces which
    // are managed by docker via subnet check.
    interfaces, err := net.Interfaces()

• Read up
  Read up

Method Daemon.buildSandboxOptions has a Cognitive Complexity of 55 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) buildSandboxOptions(cfg *config.Config, ctr *container.Container) ([]libnetwork.SandboxOption, error) {
    var sboxOptions []libnetwork.SandboxOption
    sboxOptions = append(sboxOptions, libnetwork.OptionHostname(ctr.Config.Hostname), libnetwork.OptionDomainname(ctr.Config.Domainname))

    if ctr.HostConfig.NetworkMode.IsHost() {

• Read up
  Read up

Function ServiceSpecToGRPC has 175 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ServiceSpecToGRPC(s types.ServiceSpec) (swarmapi.ServiceSpec, error) {
    name := s.Name
    if name == "" {
        name = namesgenerator.GetRandomName(0)
    }

File port_mapping_linux.go has 664 lines of code (exceeds 500 allowed). Consider refactoring.

Open

// FIXME(thaJeztah): remove once we are a module; the go:build directive prevents go from downgrading language version to go1.16:
//go:build go1.21

package bridge

Method Reader.TestFollow has 173 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (tr Reader) TestFollow(t *testing.T) {
    // Reader sends all logs and closes after logger is closed
    // - Starting from empty log (like run)
    for i, tail := range []int{-1, 0, 1, 42} {
        i, tail := i, tail

Method puller.pullSchema2Layers has a Cognitive Complexity of 54 (exceeds 20 allowed). Consider refactoring.

Open

func (p *puller) pullSchema2Layers(ctx context.Context, target distribution.Descriptor, layers []distribution.Descriptor, platform *ocispec.Platform) (id digest.Digest, err error) {
    if _, err := p.config.ImageStore.Get(ctx, target.Digest); err == nil {
        // If the image already exists locally, no need to pull
        // anything.
        return target.Digest, nil

• Read up
  Read up

Function skipAgent has a Cognitive Complexity of 54 (exceeds 20 allowed). Consider refactoring.

Open

func skipAgent(dAtA []byte) (n int, err error) {
    l := len(dAtA)
    iNdEx := 0
    depth := 0
    for iNdEx < l {

• Read up
  Read up

Function skipOverlay has a Cognitive Complexity of 54 (exceeds 20 allowed). Consider refactoring.

Open

func skipOverlay(dAtA []byte) (n int, err error) {
    l := len(dAtA)
    iNdEx := 0
    depth := 0
    for iNdEx < l {

• Read up
  Read up

Function skipNetworkdb has a Cognitive Complexity of 54 (exceeds 20 allowed). Consider refactoring.

Open

func skipNetworkdb(dAtA []byte) (n int, err error) {
    l := len(dAtA)
    iNdEx := 0
    depth := 0
    for iNdEx < l {

• Read up
  Read up

Function skipEntry has a Cognitive Complexity of 54 (exceeds 20 allowed). Consider refactoring.

Open

func skipEntry(dAtA []byte) (n int, err error) {
    l := len(dAtA)
    iNdEx := 0
    depth := 0
    for iNdEx < l {

• Read up
  Read up

Function skipPlugin has a Cognitive Complexity of 54 (exceeds 20 allowed). Consider refactoring.

Open

func skipPlugin(dAtA []byte) (n int, err error) {
    l := len(dAtA)
    iNdEx := 0
    depth := 0
    for iNdEx < l {

• Read up
  Read up

Function setupLabelFilter has a Cognitive Complexity of 54 (exceeds 20 allowed). Consider refactoring.

Open

func setupLabelFilter(ctx context.Context, store content.Store, fltrs filters.Args) (func(image images.Image) bool, error) {
    type labelCheck struct {
        key        string
        value      string
        onlyExists bool

• Read up
  Read up

File cloudwatchlogs.go has 663 lines of code (exceeds 500 allowed). Consider refactoring.

Open

// Package awslogs provides the logdriver for forwarding container logs to Amazon CloudWatch Logs
package awslogs // import "github.com/docker/docker/daemon/logger/awslogs"

import (
    "context"

File ndbClient.go has 662 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package dbclient

import (
    "context"
    "fmt"

Method Config.CopyStreams has a Cognitive Complexity of 53 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Config) CopyStreams(ctx context.Context, cfg *AttachConfig) <-chan error {
    var group errgroup.Group

    // Connect stdin of container to the attach stdin stream.
    if cfg.Stdin != nil {

• Read up
  Read up

Method ImageService.Images has a Cognitive Complexity of 53 (exceeds 20 allowed). Consider refactoring.

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
    }

• Read up
  Read up

Method Controller.NewNetwork has 167 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *Controller) NewNetwork(networkType, name string, id string, options ...NetworkOption) (_ *Network, retErr error) {
    if id != "" {
        c.networkLocker.Lock(id)
        defer c.networkLocker.Unlock(id) //nolint:errcheck