docker/docker

Method Daemon.containerStatPath has 5 return statements (exceeds 4 allowed).

Open

func (daemon *Daemon) containerStatPath(container *container.Container, path string) (stat *types.ContainerPathStat, err error) {
    container.Lock()
    defer container.Unlock()

    // Make sure an online file-system operation is permitted.

Method ImageService.manifestMatchesPlatform has 5 return statements (exceeds 4 allowed).

Open

func (i *ImageService) manifestMatchesPlatform(ctx context.Context, img *image.Image, platform ocispec.Platform) (bool, error) {
    ls, err := i.leases.ListResources(ctx, leases.Lease{ID: imageKey(img.ID().String())})
    if err != nil {
        if cerrdefs.IsNotFound(err) {
            return false, nil

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.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 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 parseSubidFile has 5 return statements (exceeds 4 allowed).

Open

func parseSubidFile(path, username string) (ranges, error) {
    var rangeList ranges

    subidFile, err := os.Open(path)
    if err != nil {

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

Open

func doPack(relSrc, root string, options *archive.TarOptions) (io.ReadCloser, error) {
    optionsR, optionsW, err := os.Pipe()
    if err != nil {
        return nil, err
    }

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 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

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

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (pp *volumeDriverProxy) Create(name string, opts map[string]string) (err error) {
    var (
        req volumeDriverProxyCreateRequest
        ret volumeDriverProxyCreateResponse
    )

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (pp *volumeDriverProxy) Get(name string) (volume *proxyVolume, err error) {
    var (
        req volumeDriverProxyGetRequest
        ret volumeDriverProxyGetResponse
    )

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (pp *volumeDriverProxy) Path(name string) (mountpoint string, err error) {
    var (
        req volumeDriverProxyPathRequest
        ret volumeDriverProxyPathResponse
    )

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func doLeaveNetwork(ips []string, args []string) {
    doneCh := make(chan resultTuple, len(ips))
    // check all the nodes
    for _, ip := range ips {
        go leaveNetwork(ip, servicePort, args[0], doneCh)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func doJoinNetwork(ips []string, args []string) {
    doneCh := make(chan resultTuple, len(ips))
    // check all the nodes
    for _, ip := range ips {
        go joinNetwork(ip, servicePort, args[0], doneCh)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (pp *volumeDriverProxy) Unmount(name string, id string) (err error) {
    var (
        req volumeDriverProxyUnmountRequest
        ret volumeDriverProxyUnmountResponse
    )

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    if link, err := d.nlh.LinkByName(ep.srcName); err == nil {
        if err := d.nlh.LinkDel(link); err != nil {
            log.G(context.TODO()).WithError(err).Errorf("Failed to delete interface (%s)'s link on endpoint (%s) delete", ep.srcName, ep.id)
        }
    }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        if link, err := d.nlh.LinkByName(ep.srcName); err == nil {
            if err := d.nlh.LinkDel(link); err != nil {
                log.G(context.TODO()).WithError(err).Errorf("Failed to delete interface (%s)'s link on endpoint (%s) delete", ep.srcName, ep.id)
            }
        }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        nat.Sort(l.Ports, func(ip, jp nat.Port) bool {
            // If the two ports have the same number, tcp takes priority
            // Sort in desc order
            return ip.Int() < jp.Int() || (ip.Int() == jp.Int() && strings.ToLower(ip.Proto()) == "tcp")
        })

• Read up
  Read up