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")
    }

Function compare has 137 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func compare(a, b *container.Config) bool {
    if a == nil || b == nil {
        return false
    }

Function includeContainerInList has 137 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func includeContainerInList(container *container.Snapshot, filter *listContext) iterationAction {
    // Do not include container if it's in the list before the filter container.
    // Set the filter container to nil to include the rest of containers after this one.
    if filter.beforeFilter != nil {
        if container.ID == filter.beforeFilter.ID {

File image_list.go has 602 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package containerd

import (
    "context"
    "encoding/json"

Method PortConfig.Unmarshal has 136 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m *PortConfig) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx

Function withFetchProgress has a Cognitive Complexity of 45 (exceeds 20 allowed). Consider refactoring.

Open

func withFetchProgress(cs content.Store, out progress.Output, ref reference.Named) images.HandlerFunc {
    return func(ctx context.Context, desc ocispec.Descriptor) ([]ocispec.Descriptor, error) {
        switch desc.MediaType {
        case ocispec.MediaTypeImageManifest, images.MediaTypeDockerSchema2Manifest:
            tn := reference.TagNameOnly(ref)

• Read up
  Read up

Method Daemon.setupMounts has a Cognitive Complexity of 45 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) setupMounts(ctx context.Context, c *container.Container) ([]container.Mount, func(context.Context) error, error) {
    var mounts []container.Mount
    // TODO: tmpfs mounts should be part of Mountpoints
    tmpfsMounts := make(map[string]bool)
    tmpfsMountInfo, err := c.TmpfsMounts()

• Read up
  Read up

Method Daemon.createSpec has a Cognitive Complexity of 45 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) createSpec(ctx context.Context, daemonCfg *configStore, c *container.Container, mounts []container.Mount) (*specs.Spec, error) {
    img, err := daemon.imageService.GetImage(ctx, string(c.ImageID), backend.GetImageOpts{})
    if err != nil {
        return nil, err
    }

• Read up
  Read up

Function UnpackLayer has 135 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func UnpackLayer(dest string, layer io.Reader, options *TarOptions) (size int64, err error) {
    tr := tar.NewReader(layer)
    trBuf := pools.BufioReader32KPool.Get(tr)
    defer pools.BufioReader32KPool.Put(trBuf)

File service.go has 599 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package convert // import "github.com/docker/docker/daemon/cluster/convert"

import (
    "fmt"
    "strings"

Method puller.pullSchema2Layers has 134 lines of code (exceeds 50 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

Method PeerRecord.Unmarshal has 134 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m *PeerRecord) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx

Method Daemon.initNetworkController has 134 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) initNetworkController(daemonCfg *config.Config, activeSandboxes map[string]interface{}) error {
    netOptions, err := daemon.networkOptions(daemonCfg, nil, daemon.id, nil)
    if err != nil {
        return err
    }

Function containerToGRPC has 133 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func containerToGRPC(c *types.ContainerSpec) (*swarmapi.ContainerSpec, error) {
    containerSpec := &swarmapi.ContainerSpec{
        Image:          c.Image,
        Labels:         c.Labels,
        Command:        c.Command,

Method Endpoint.sbJoin has 132 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (ep *Endpoint) sbJoin(ctx context.Context, sb *Sandbox, options ...EndpointOption) (retErr error) {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.sbJoin")
    defer span.End()

    n, err := ep.getNetworkFromStore()

Method NetworkPushPull.Unmarshal has 132 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m *NetworkPushPull) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx

Function FilterNetworks has a Cognitive Complexity of 44 (exceeds 20 allowed). Consider refactoring.

Open

func FilterNetworks(nws []network.Inspect, filter filters.Args) ([]network.Inspect, error) {
    // if filter is empty, return original network list
    if filter.Len() == 0 {
        return nws, nil
    }

• Read up
  Read up

File container.go has 592 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package container // import "github.com/docker/docker/daemon/cluster/executor/container"

import (
    "context"
    "encoding/json"

Method ImageService.pullTag has 130 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (i *ImageService) pullTag(ctx context.Context, ref reference.Named, platform *ocispec.Platform, metaHeaders map[string][]string, authConfig *registrytypes.AuthConfig, out progress.Output) error {
    var opts []containerd.RemoteOpt
    if platform != nil {
        opts = append(opts, containerd.WithPlatform(platforms.Format(*platform)))
    }

Method Daemon.containerStart has 130 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) containerStart(ctx context.Context, daemonCfg *configStore, container *container.Container, checkpoint string, checkpointDir string, resetRestartManager bool) (retErr error) {
    ctx, span := otel.Tracer("").Start(ctx, "daemon.containerStart", trace.WithAttributes(
        attribute.String("container.ID", container.ID),
        attribute.String("container.Name", container.Name)))
    defer span.End()