Method TableEvent.Unmarshal has 48 return statements (exceeds 4 allowed).

Open

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

Method Controller.sandboxCleanup has a Cognitive Complexity of 43 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Controller) sandboxCleanup(activeSandboxes map[string]interface{}) error {
    sandboxStates, err := c.store.List(&sbState{c: c})
    if err != nil {
        if err == datastore.ErrKeyNotFound {
            // It's normal for no sandboxes to be found. Just bail out.

• Read up
  Read up

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

Function verifyPlatformContainerResources has a Cognitive Complexity of 43 (exceeds 20 allowed). Consider refactoring.

Open

func verifyPlatformContainerResources(resources *containertypes.Resources, isHyperv bool) (warnings []string, err error) {
    fixMemorySwappiness(resources)
    if !isHyperv {
        // The processor resource controls are mutually exclusive on
        // Windows Server Containers, the order of precedence is

• Read up
  Read up

Method tarexporter.Load has 127 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (l *tarexporter) Load(ctx context.Context, inTar io.ReadCloser, outStream io.Writer, quiet bool) (outErr error) {
    ctx, span := tracing.StartSpan(ctx, "tarexport.Load")
    defer span.End()
    defer func() {
        span.SetStatus(outErr)

Method LayerDownloadManager.makeDownloadFunc has 127 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (ldm *LayerDownloadManager) makeDownloadFunc(descriptor DownloadDescriptor, parentLayer layer.ChainID, parentDownload *downloadTransfer) doFunc {
    return func(progressChan chan<- progress.Progress, start <-chan struct{}, inactive chan<- struct{}) transfer {
        d := &downloadTransfer{
            transfer:   newTransfer(),
            layerStore: ldm.layerStore,

File cluster.go has 586 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package networkdb

import (
    "bytes"
    "context"

File builder.go has 585 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package buildkit

import (
    "context"
    "fmt"

Method Daemon.ContainerRename has 126 lines of code (exceeds 50 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"))
    }

Method puller.pullTag has 124 lines of code (exceeds 50 allowed). Consider refactoring.

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 Client.imageBuildOptionsToQuery has 124 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (cli *Client) imageBuildOptionsToQuery(ctx context.Context, options types.ImageBuildOptions) (url.Values, error) {
    query := url.Values{}
    if len(options.Tags) > 0 {
        query["t"] = options.Tags
    }

Method Daemon.fillPlatformInfo has 124 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) fillPlatformInfo(ctx context.Context, v *system.Info, sysInfo *sysinfo.SysInfo, cfg *configStore) error {
    v.CgroupDriver = cgroupDriver(&cfg.Config)
    v.CgroupVersion = "1"
    if sysInfo.CgroupUnified {
        v.CgroupVersion = "2"

Function toRootless has a Cognitive Complexity of 42 (exceeds 20 allowed). Consider refactoring.

Open

func toRootless(spec *specs.Spec, v2Controllers []string, currentOOMScoreAdj int) error {
    if len(v2Controllers) == 0 {
        if spec.Linux != nil {
            // Remove cgroup settings.
            spec.Linux.Resources = nil

• Read up
  Read up

Function newProxy has a Cognitive Complexity of 42 (exceeds 20 allowed). Consider refactoring.

Open

func newProxy(config ProxyConfig) (p Proxy, err error) {
    ipv := ip4
    if config.HostIP.To4() == nil {
        ipv = ip6
    }

• Read up
  Read up

Method cnmNetworkAllocator.IsServiceAllocated has a Cognitive Complexity of 42 (exceeds 20 allowed). Consider refactoring.

Open

func (na *cnmNetworkAllocator) IsServiceAllocated(s *api.Service, flags ...func(*networkallocator.ServiceAllocationOpts)) bool {
    specNetworks := serviceNetworks(s)

    // If endpoint mode is VIP and allocator does not have the
    // service in VIP allocated set then it needs to be allocated.

• Read up
  Read up

Method imageExporterInstance.Export has a Cognitive Complexity of 42 (exceeds 20 allowed). Consider refactoring.

Open

func (e *imageExporterInstance) Export(ctx context.Context, inp *exporter.Source, inlineCache exptypes.InlineCache, sessionID string) (map[string]string, exporter.DescriptorReference, error) {
    if len(inp.Refs) > 1 {
        return nil, nil, fmt.Errorf("exporting multiple references to image store is currently unsupported")
    }

• Read up
  Read up

Function adjustForAPIVersion has a Cognitive Complexity of 42 (exceeds 20 allowed). Consider refactoring.

Open

func adjustForAPIVersion(cliVersion string, service *swarm.ServiceSpec) {
    if cliVersion == "" {
        return
    }
    if versions.LessThan(cliVersion, "1.46") {

• Read up
  Read up

Method ImageService.getSameReferences has a Cognitive Complexity of 42 (exceeds 20 allowed). Consider refactoring.

Open

func (i *ImageService) getSameReferences(ctx context.Context, named reference.Named, imgs []images.Image) ([]images.Image, error) {
    var (
        tag        string
        sameRef    []images.Image
        digestRefs = []images.Image{}

• Read up
  Read up

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

Open

func New(info logger.Info) (logger.Logger, error) {
    hostname, err := info.Hostname()
    if err != nil {
        return nil, fmt.Errorf("%s: cannot access hostname to set source field", driverName)
    }

• Read up
  Read up

Method Daemon.containerAttach has a Cognitive Complexity of 42 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) containerAttach(c *container.Container, cfg *stream.AttachConfig, logs, doStream bool) error {
    if logs {
        logDriver, logCreated, err := daemon.getLogger(c)
        if err != nil {
            return err

• Read up
  Read up