Method RestartManager.ShouldRestart has 5 return statements (exceeds 4 allowed).

Open

func (rm *RestartManager) ShouldRestart(exitCode uint32, hasBeenManuallyStopped bool, executionDuration time.Duration) (bool, chan error, error) {
    if rm.policy.IsNone() {
        return false, nil, nil
    }
    rm.Lock()

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

Open

func retryOnError(err error) error {
    switch v := err.(type) {
    case errcode.Errors:
        if len(v) != 0 {
            return retryOnError(v[0])

Method v2MetadataService.Remove has 5 return statements (exceeds 4 allowed).

Open

func (serv *v2MetadataService) Remove(metadata V2Metadata) error {
    if serv.store == nil {
        // Support a service which has no backend storage, in this case
        // an remove becomes a no-op.
        // TODO: implement in memory storage

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

Open

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

Method tarexporter.loadLayer has 5 return statements (exceeds 4 allowed).

Open

func (l *tarexporter) loadLayer(ctx context.Context, filename string, rootFS image.RootFS, id string, foreignSrc distribution.Descriptor, progressOutput progress.Output) (_ layer.Layer, outErr error) {
    ctx, span := tracing.StartSpan(ctx, "loadLayer")
    span.SetAttributes(tracing.Attribute("image.id", id))
    defer span.End()
    defer func() {

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

Open

func schema2ManifestDigest(ref reference.Named, mfst distribution.Manifest) (digest.Digest, error) {
    _, canonical, err := mfst.Payload()
    if err != nil {
        return "", err
    }

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

Open

func tempMountPoint(sourceFd int) (string, error) {
    var stat unix.Stat_t
    err := unix_noeintr.Fstat(sourceFd, &stat)
    if err != nil {
        return "", errors.Wrap(err, "failed to Fstat mount source fd")

Method LayerDownloadManager.Download has 5 return statements (exceeds 4 allowed).

Open

func (ldm *LayerDownloadManager) Download(ctx context.Context, initialRootFS image.RootFS, layers []DownloadDescriptor, progressOutput progress.Output) (image.RootFS, func(), error) {
    var (
        topLayer       layer.Layer
        topDownload    *downloadTransfer
        watcher        *watcher

Function kubernetesSafeOpen has a Cognitive Complexity of 22 (exceeds 20 allowed). Consider refactoring.

Open

func kubernetesSafeOpen(base, subpath string) (int, error) {
    // syscall.Openat flags used to traverse directories not following symlinks
    const nofollowFlags = unix.O_RDONLY | unix.O_NOFOLLOW
    // flags for getting file descriptor without following the symlink
    const openFDFlags = unix.O_NOFOLLOW | unix.O_PATH

• Read up
  Read up

Function detectManifestBlobMediaType has a Cognitive Complexity of 22 (exceeds 20 allowed). Consider refactoring.

Open

func detectManifestBlobMediaType(dt []byte) (string, error) {
    var mfst struct {
        MediaType string          `json:"mediaType"`
        Manifests json.RawMessage `json:"manifests"` // oci index, manifest list
        Config    json.RawMessage `json:"config"`    // schema2 Manifest

• Read up
  Read up

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

Open

func GetRepositories(ctx context.Context, ref reference.Named, config *ImagePullConfig) ([]distribution.Repository, error) {
    repoInfo, err := config.RegistryService.ResolveRepository(ref)
    if err != nil {
        return nil, errdefs.InvalidParameter(err)
    }

Method puller.pullSchema2Config has 5 return statements (exceeds 4 allowed).

Open

func (p *puller) pullSchema2Config(ctx context.Context, dgst digest.Digest) (configJSON []byte, err error) {
    blobs := p.repo.Blobs(ctx)
    err = retry(ctx, defaultMaxSchemaPullAttempts, defaultSchemaPullBackoff, func(ctx context.Context) (err error) {
        configJSON, err = blobs.Get(ctx, dgst)
        return err

Method PoolsOpt.Set has 5 return statements (exceeds 4 allowed).

Open

func (p *PoolsOpt) Set(value string) error {
    csvReader := csv.NewReader(strings.NewReader(value))
    fields, err := csvReader.Read()
    if err != nil {
        return err

Method Sandbox.updateGateway has 5 return statements (exceeds 4 allowed).

Open

func (sb *Sandbox) updateGateway(ep *Endpoint) error {
    sb.mu.Lock()
    osSbox := sb.osSbox
    sb.mu.Unlock()
    if osSbox == nil {

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

Open

func AddInterfaceFirewalld(intf string) error {
    if !firewalldRunning {
        return nil
    }

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

Open

func getPluginClient(p plugingetter.CompatPlugin) (*plugins.Client, error) {
    if v1, ok := p.(plugingetter.PluginWithV1Client); ok {
        return v1.Client(), nil
    }

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

Open

func Register(r ipamapi.Registerer, pg plugingetter.PluginGetter, lAddrPools, gAddrPools []*ipamutils.NetworkToSplit) error {
    if err := defaultipam.Register(r, lAddrPools, gAddrPools); err != nil {
        return err
    }
    if err := windowsipam.Register(r); err != nil {

Method Allocator.getAddrSpace has 5 return statements (exceeds 4 allowed).

Open

func (a *Allocator) getAddrSpace(as string, v6 bool) (*addrSpace, error) {
    switch as {
    case localAddressSpace:
        if v6 {
            return a.local6, nil

Method Endpoint.UpdateDNSNames has 5 return statements (exceeds 4 allowed).

Open

func (ep *Endpoint) UpdateDNSNames(dnsNames []string) error {
    nw := ep.getNetwork()
    c := nw.getController()
    sb, ok := ep.getSandbox()
    if !ok {

Method Allocator.RequestAddress has 5 return statements (exceeds 4 allowed).

Open

func (a *Allocator) RequestAddress(poolID string, prefAddress net.IP, opts map[string]string) (*net.IPNet, map[string]string, error) {
    log.G(context.TODO()).Debugf("RequestAddress(%s, %v, %v)", poolID, prefAddress, opts)
    k, err := PoolIDFromString(poolID)
    if err != nil {
        return nil, nil, types.InvalidParameterErrorf("invalid pool id: %s", poolID)