dotcloud/docker

Method Cluster.Init has 96 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *Cluster) Init(req types.InitRequest) (string, error) {
    c.controlMutex.Lock()
    defer c.controlMutex.Unlock()
    if c.nr != nil {
        if req.ForceNewCluster {

Method Daemon.handleContainerExit has 96 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) handleContainerExit(c *container.Container, e *libcontainerdtypes.EventInfo) error {
    var exitStatus container.ExitStatus
    c.Lock()

    cfg := daemon.config()

Method Daemon.connectToNetwork has 96 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) connectToNetwork(ctx context.Context, cfg *config.Config, ctr *container.Container, idOrName string, endpointConfig *network.EndpointSettings, updateSettings bool) (retErr error) {
    containerName := strings.TrimPrefix(ctr.Name, "/")
    ctx, span := otel.Tracer("").Start(ctx, "daemon.connectToNetwork", trace.WithAttributes(
        attribute.String("container.ID", ctr.ID),
        attribute.String("container.name", containerName),

driver has 25 methods (exceeds 20 allowed). Consider refactoring.

Open

type driver struct {
    config            configuration
    natChain          *iptables.ChainInfo
    filterChain       *iptables.ChainInfo
    isolationChain1   *iptables.ChainInfo

cnmNetworkAllocator has 25 methods (exceeds 20 allowed). Consider refactoring.

Open

type cnmNetworkAllocator struct {
    // The plugin getter instance used to get network and IPAM driver plugins.
    pg plugingetter.PluginGetter

    // The driver registry for all internal and external IPAM drivers.

containerConfig has 25 methods (exceeds 20 allowed). Consider refactoring.

Open

type containerConfig struct {
    task                *api.Task
    networksAttachments map[string]*api.NetworkAttachment
}

Method task.Exec has 95 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (t *task) Exec(ctx context.Context, processID string, spec *specs.Process, withStdin bool, attachStdio libcontainerdtypes.StdioCallback) (_ libcontainerdtypes.Process, retErr error) {
    hcsContainer, err := t.getHCSContainer()
    if err != nil {
        return nil, err
    }

Method client.newStdioPipes has 95 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *client) newStdioPipes(fifos *cio.FIFOSet) (_ *stdioPipes, err error) {
    p := &stdioPipes{}
    if fifos.Stdin != "" {
        c.logger.WithField("stdin", fifos.Stdin).Debug("listen")
        l, err := winio.ListenPipe(fifos.Stdin, nil)

Method Daemon.foldFilter has 95 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) foldFilter(ctx context.Context, view *container.View, config *containertypes.ListOptions) (*listContext, error) {
    psFilters := config.Filters

    var filtExited []int

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

Open

            if os.Getenv("DOCKER_SERVICE_PREFER_OFFLINE_IMAGE") != "1" && queryRegistry {
                digestImage, err := c.imageWithDigestString(ctx, ctnr.Image, authConfig)
                if err != nil {
                    log.G(ctx).Warnf("unable to pin image %s to digest: %s", ctnr.Image, err.Error())
                    // warning in the client response should be concise

• Read up
  Read up

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

Open

            if os.Getenv("DOCKER_SERVICE_PREFER_OFFLINE_IMAGE") != "1" && queryRegistry {
                digestImage, err := c.imageWithDigestString(ctx, newCtnr.Image, authConfig)
                if err != nil {
                    log.G(ctx).Warnf("unable to pin image %s to digest: %s", newCtnr.Image, err.Error())
                    // warning in the client response should be concise

• Read up
  Read up

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

Open

package client // import "github.com/docker/docker/client"

import (
    "context"
    "encoding/json"

• Read up
  Read up

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

Open

package client // import "github.com/docker/docker/client"

import (
    "context"
    "encoding/json"

• Read up
  Read up

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

Open

        case 2:
            if wireType != 2 {
                return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
            }
            var byteLen int

• Read up
  Read up

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

Open

        case 7:
            if wireType != 2 {
                return fmt.Errorf("proto: wrong wireType = %d for field Value", wireType)
            }
            var byteLen int

• Read up
  Read up

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

Open

        case 3:
            if wireType != 2 {
                return fmt.Errorf("proto: wrong wireType = %d for field Line", wireType)
            }
            var byteLen int

• Read up
  Read up

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

Open

        case 1:
            if wireType != 2 {
                return fmt.Errorf("proto: wrong wireType = %d for field Payload", wireType)
            }
            var byteLen int

• Read up
  Read up

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

Open

        case 5:
            if wireType != 2 {
                return fmt.Errorf("proto: wrong wireType = %d for field Payload", wireType)
            }
            var byteLen int

• Read up
  Read up

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

Open

        if opt, ok := ep.generic[netlabel.PortMap]; ok {
            pblist := []types.PortBinding{}

            for i := 0; i < len(opt.([]interface{})); i++ {
                pb := types.PortBinding{}

• Read up
  Read up

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

Open

        if opt, ok := ep.generic[netlabel.ExposedPorts]; ok {
            tplist := []types.TransportPort{}

            for i := 0; i < len(opt.([]interface{})); i++ {
                tp := types.TransportPort{}

• Read up
  Read up