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

Open

func GetHostPartIP(ip net.IP, mask net.IPMask) (net.IP, error) {
    // Find the effective starting of address and mask
    is, ms, err := compareIPMask(ip, mask)
    if err != nil {
        return nil, fmt.Errorf("cannot compute host portion ip address because %s", err)

• Read up
  Read up

Similar blocks of code found in 3 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 3 locations. Consider refactoring.

Open

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

import (
    "context"
    "encoding/json"

• Read up
  Read up

Method LayerUploadManager.makeUploadFunc has 57 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (lum *LayerUploadManager) makeUploadFunc(descriptor UploadDescriptor) doFunc {
    return func(progressChan chan<- progress.Progress, start <-chan struct{}, inactive chan<- struct{}) transfer {
        u := &uploadTransfer{
            transfer: newTransfer(),
        }

Method Sandbox.clearNetworkResources has 57 lines of code (exceeds 50 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)

Method Resolver.setupIPTable has 57 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (r *Resolver) setupIPTable() error {
    if r.err != nil {
        return r.err
    }
    laddr := r.conn.LocalAddr().String()

Function updateNodeKey has 57 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func updateNodeKey(lIP, aIP, rIP net.IP, idxs []*spi, curKeys []*key, newIdx, priIdx, delIdx int) []*spi {
    log.G(context.TODO()).Debugf("Updating keys for node: %s (%d,%d,%d)", rIP, newIdx, priIdx, delIdx)

    spis := idxs
    log.G(context.TODO()).Debugf("Current: %v", spis)

Method ImageService.getPushDescriptor has 57 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (i *ImageService) getPushDescriptor(ctx context.Context, img containerdimages.Image, platform *ocispec.Platform) (ocispec.Descriptor, error) {
    pm := i.matchRequestedOrDefault(platforms.OnlyStrict, platform)

    anyMissing := false

Function GetTimestamp has 57 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func GetTimestamp(value string, reference time.Time) (string, error) {
    if d, err := time.ParseDuration(value); value != "0" && err == nil {
        return strconv.FormatInt(reference.Add(-d).Unix(), 10), nil
    }

Method Cluster.resolveSystemAddr has 57 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *Cluster) resolveSystemAddr() (net.IP, error) {
    // Use the system's only device IP address, or fail if there are
    // multiple addresses to choose from.
    interfaces, err := nlwrap.LinkList()
    if err != nil {

Method Cluster.AttachNetwork has 57 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *Cluster) AttachNetwork(target string, containerID string, addresses []string) (*network.NetworkingConfig, error) {
    aKey := attacherKey(target, containerID)
    c.mu.Lock()
    state := c.currentNodeState()
    if state.swarmNode == nil || state.swarmNode.Agent() == nil {

Method Cluster.Join has 57 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *Cluster) Join(req types.JoinRequest) error {
    c.controlMutex.Lock()
    defer c.controlMutex.Unlock()
    c.mu.Lock()
    if c.nr != nil {

Method Daemon.ContainerStats has 57 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) ContainerStats(ctx context.Context, prefixOrName string, config *backend.ContainerStatsConfig) error {
    ctr, err := daemon.GetContainer(prefixOrName)
    if err != nil {
        return err
    }

Function ffjsonWriteJSONBytesAsString has 57 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ffjsonWriteJSONBytesAsString(buf *bytes.Buffer, s []byte) {
    const hex = "0123456789abcdef"

    buf.WriteByte('"')
    start := 0

Function StartProxy has 13 return statements (exceeds 4 allowed).

Open

func StartProxy(pb types.PortBinding,
    proxyPath string,
    listenSock *os.File,
) (stop func() error, retErr error) {
    if proxyPath == "" {

Method driver.CreateEndpoint has 13 return statements (exceeds 4 allowed).

Open

func (d *driver) CreateEndpoint(ctx context.Context, nid, eid string, ifInfo driverapi.InterfaceInfo, epOptions map[string]interface{}) error {
    ctx, span := otel.Tracer("").Start(ctx, fmt.Sprintf("libnetwork.drivers.windows_%s.CreateEndpoint", d.name), trace.WithAttributes(
        attribute.String("nid", nid),
        attribute.String("eid", eid)))
    defer span.End()

Method Root.validateOpts has a Cognitive Complexity of 26 (exceeds 20 allowed). Consider refactoring.

Open

func (r *Root) validateOpts(opts map[string]string) error {
    if len(opts) == 0 {
        return nil
    }
    for opt := range opts {

• Read up
  Read up

Method containerRouter.postContainerExecStart has a Cognitive Complexity of 26 (exceeds 20 allowed). Consider refactoring.

Open

func (s *containerRouter) postContainerExecStart(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
    if err := httputils.ParseForm(r); err != nil {
        return err
    }

• Read up
  Read up

Method task.Exec has a Cognitive Complexity of 26 (exceeds 20 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
    }

• Read up
  Read up

Method Daemon.ContainerLogs has 13 return statements (exceeds 4 allowed).

Open

func (daemon *Daemon) ContainerLogs(ctx context.Context, containerName string, config *containertypes.LogsOptions) (messages <-chan *backend.LogMessage, isTTY bool, retErr error) {
    ctx, span := tracing.StartSpan(ctx, "daemon.ContainerLogs")
    defer func() {
        span.SetStatus(retErr)
        span.End()