Method scanner.Scan has 5 return statements (exceeds 4 allowed).

Open

func (s *scanner) Scan(ctx context.Context) bool {
    if s.err != nil {
        return false
    }

Function Zombie has 5 return statements (exceeds 4 allowed).

Open

func Zombie(pid int) (bool, error) {
    if pid < 1 {
        return false, nil
    }
    data, err := os.ReadFile(fmt.Sprintf("/proc/%d/stat", pid))

Method atomicFileWriter.Close has 5 return statements (exceeds 4 allowed).

Open

func (w *atomicFileWriter) Close() (retErr error) {
    defer func() {
        if retErr != nil || w.writeErr != nil {
            os.Remove(w.f.Name())
        }

Method layerStore.initMount has 5 return statements (exceeds 4 allowed).

Open

func (ls *layerStore) initMount(graphID, parent, mountLabel string, initFunc MountInit, storageOpt map[string]string) (string, error) {
    // Use "<graph-id>-init" to maintain compatibility with graph drivers
    // which are expecting this layer with this special name. If all
    // graph drivers can be updated to not rely on knowing about this layer
    // then the initID should be randomly generated.

Function StickRuntimeDirContents has 5 return statements (exceeds 4 allowed).

Open

func StickRuntimeDirContents(files []string) ([]string, error) {
    runtimeDir, err := GetRuntimeDir()
    if err != nil {
        // ignore error if runtimeDir is empty
        return nil, nil

Function toRootless has 5 return statements (exceeds 4 allowed).

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

Method layerStore.ChecksumForGraphID has 5 return statements (exceeds 4 allowed).

Open

func (ls *layerStore) ChecksumForGraphID(id, parent, newTarDataPath string) (diffID DiffID, size int64, err error) {
    rawarchive, err := ls.driver.Diff(id, parent)
    if err != nil {
        return
    }

Function doUnpack has 5 return statements (exceeds 4 allowed).

Open

func doUnpack(decompressedArchive io.Reader, relDest, root string, options *archive.TarOptions) error {
    optionsR, optionsW, err := os.Pipe()
    if err != nil {
        return err
    }

Method Endpoint.deleteServiceInfoFromCluster has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func (ep *Endpoint) deleteServiceInfoFromCluster(sb *Sandbox, fullRemove bool, method string) error {
    if len(ep.dnsNames) == 0 {
        return nil
    }

• Read up
  Read up

Function Join has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func Join(ctx context.Context, path, subpath string) (*SafePath, error) {
    base, subpart, err := evaluatePath(path, subpath)
    if err != nil {
        return nil, err
    }

• Read up
  Read up

Method EndpointRecord.MarshalToSizedBuffer has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func (m *EndpointRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) {
    i := len(dAtA)
    _ = i
    var l int
    _ = l

• Read up
  Read up

Method Sandbox.clearNetworkResources has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func (sb *Sandbox) clearNetworkResources(origEp *Endpoint) error {
    ep := sb.GetEndpoint(origEp.id)
    if ep == nil {
        return fmt.Errorf("could not find the sandbox endpoint data for endpoint %s",
            origEp.id)

• Read up
  Read up

Function programSA has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func programSA(localIP, remoteIP net.IP, spi *spi, k *key, dir int, add bool) (fSA *netlink.XfrmState, rSA *netlink.XfrmState, err error) {
    var (
        action      = "Removing"
        xfrmProgram = ns.NlHandle().XfrmStateDel
    )

• Read up
  Read up

Function parseEndpointOptions has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func parseEndpointOptions(epOptions map[string]interface{}) (*endpointOption, error) {
    if epOptions == nil {
        return nil, nil
    }

• Read up
  Read up

Method driver.NetworkAllocate has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) NetworkAllocate(id string, option map[string]string, ipV4Data, ipV6Data []driverapi.IPAMData) (map[string]string, error) {
    if id == "" {
        return nil, fmt.Errorf("invalid network id for overlay network")
    }

• Read up
  Read up

Method driver.parseNetworkOptions has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) parseNetworkOptions(id string, genericOptions map[string]string) (*networkConfiguration, error) {
    config := &networkConfiguration{Type: d.name}

    for label, value := range genericOptions {
        switch label {

• Read up
  Read up

Function getMountOptions has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func getMountOptions(opts *optsConfig, resolveIP func(string, string) (*net.IPAddr, error)) (mountDevice string, mountOpts string, _ error) {
    if opts.MountDevice == "" {
        return "", "", fmt.Errorf("missing device in volume options")
    }

• Read up
  Read up

Method Builder.dispatchDockerfileWithCancellation has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func (b *Builder) dispatchDockerfileWithCancellation(ctx context.Context, parseResult []instructions.Stage, metaArgs []instructions.ArgCommand, escapeToken rune, source builder.Source) (*dispatchState, error) {
    dispatchRequest := dispatchRequest{}
    buildArgs := NewBuildArgs(b.options.BuildArgs)
    totalCommands := len(metaArgs) + len(parseResult)
    currentCommandIndex := 1

• Read up
  Read up

Function ValidateIPAM has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func ValidateIPAM(ipam *IPAM, enableIPv6 bool) error {
    if ipam == nil {
        return nil
    }

• Read up
  Read up

Method client.extractResourcesFromSpec has a Cognitive Complexity of 21 (exceeds 20 allowed). Consider refactoring.

Open

func (c *client) extractResourcesFromSpec(spec *specs.Spec, configuration *hcsshim.ContainerConfig) {
    if spec.Windows.Resources != nil {
        if spec.Windows.Resources.CPU != nil {
            if spec.Windows.Resources.CPU.Count != nil {
                // This check is being done here rather than in adaptContainerSettings

• Read up
  Read up