dotcloud/docker

Function buildPortsRelatedCreateEndpointOptions has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func buildPortsRelatedCreateEndpointOptions(c *container.Container, n *libnetwork.Network, sb *libnetwork.Sandbox) ([]libnetwork.EndpointOption, error) {
    // Port-mapping rules belong to the container & applicable only to non-internal networks.
    //
    // TODO(thaJeztah): Look if we can provide a more minimal function for getPortMapInfo, as it does a lot, and we only need the "length".
    if n.Internal() || len(getPortMapInfo(sb)) > 0 {

Function buildIPAMResources has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func buildIPAMResources(nw *libnetwork.Network) networktypes.IPAM {
    var ipamConfig []networktypes.IPAMConfig

    ipamDriver, ipamOptions, ipv4Conf, ipv6Conf := nw.IpamConfig()

Function Parse has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func Parse(filePath string, objName string) (*ParsedPkg, error) {
    fs := token.NewFileSet()
    pkg, err := parser.ParseFile(fs, filePath, nil, parser.AllErrors)
    if err != nil {
        return nil, err

Method Daemon.containerStop has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) containerStop(ctx context.Context, ctr *container.Container, options containertypes.StopOptions) (retErr error) {
    // Cancelling the request should not cancel the stop.
    ctx = context.WithoutCancel(ctx)

    if !ctr.IsRunning() {

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

Open

func (this *PortConfig) String() string {
    if this == nil {
        return "nil"
    }
    s := strings.Join([]string{`&PortConfig{`,

• Read up
  Read up

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

Open

func (this *NetworkEvent) String() string {
    if this == nil {
        return "nil"
    }
    s := strings.Join([]string{`&NetworkEvent{`,

• Read up
  Read up

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

Open

func (this *NetworkEntry) String() string {
    if this == nil {
        return "nil"
    }
    s := strings.Join([]string{`&NetworkEntry{`,

• Read up
  Read up

Method Plugin.Set has 14 return statements (exceeds 4 allowed).

Open

func (p *Plugin) Set(args []string) error {
    p.mu.Lock()
    defer p.mu.Unlock()

    if p.PluginObj.Enabled {

Method driver.Join has 14 return statements (exceeds 4 allowed).

Open

func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.drivers.macvlan.Join", trace.WithAttributes(
        attribute.String("nid", nid),
        attribute.String("eid", eid),
        attribute.String("sboxKey", sboxKey)))

Method client.createWindows has 14 return statements (exceeds 4 allowed).

Open

func (c *client) createWindows(id string, spec *specs.Spec, runtimeOptions interface{}) (*container, error) {
    logger := c.logger.WithField("container", id)
    configuration := &hcsshim.ContainerConfig{
        SystemType:              "Container",
        Name:                    id,

Method ImageService.getPushDescriptor has 14 return statements (exceeds 4 allowed).

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

Method ImageService.resolveAllReferences has 14 return statements (exceeds 4 allowed).

Open

func (i *ImageService) resolveAllReferences(ctx context.Context, refOrID string) (*containerdimages.Image, []containerdimages.Image, error) {
    parsed, err := reference.ParseAnyReference(refOrID)
    if err != nil {
        return nil, nil, errdefs.InvalidParameter(err)
    }

Method ImageService.resolveImage has 14 return statements (exceeds 4 allowed).

Open

func (i *ImageService) resolveImage(ctx context.Context, refOrID string) (containerdimages.Image, error) {
    parsed, err := reference.ParseAnyReference(refOrID)
    if err != nil {
        return containerdimages.Image{}, errdefs.InvalidParameter(err)
    }

Method ImageService.ExportImage has 14 return statements (exceeds 4 allowed).

Open

func (i *ImageService) ExportImage(ctx context.Context, names []string, platform *ocispec.Platform, outStream io.Writer) error {
    pm := i.matchRequestedOrDefault(platforms.OnlyStrict, platform)

    opts := []archive.ExportOpt{
        archive.WithSkipNonDistributableBlobs(),

Method Daemon.openContainerFS has 14 return statements (exceeds 4 allowed).

Open

func (daemon *Daemon) openContainerFS(ctr *container.Container) (_ *containerFSView, retErr error) {
    ctx := context.TODO()

    if err := daemon.Mount(ctr); err != nil {
        return nil, err

Function New has 14 return statements (exceeds 4 allowed).

Open

func New(info logger.Info) (logger.Logger, error) {
    hostname, err := info.Hostname()
    if err != nil {
        return nil, fmt.Errorf("%s: cannot access hostname to set source field", driverName)
    }

Method Daemon.ContainerRename has 14 return statements (exceeds 4 allowed).

Open

func (daemon *Daemon) ContainerRename(oldName, newName string) (retErr error) {
    if oldName == "" || newName == "" {
        return errdefs.InvalidParameter(errors.New("Neither old nor new names may be empty"))
    }

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

Open

func (l *sLM) DeleteResource(ctx context.Context, lease leases.Lease, resource leases.Resource) error {
    if err := l.manager.DeleteResource(ctx, lease, resource); err != nil {
        return err
    }
    if resource.Type == "snapshots/default" {

• Read up
  Read up

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

Open

func (l *sLM) AddResource(ctx context.Context, lease leases.Lease, resource leases.Resource) error {
    if err := l.manager.AddResource(ctx, lease, resource); err != nil {
        return err
    }
    if resource.Type == "snapshots/default" {

• Read up
  Read up

Method pushDescriptor.layerAlreadyExists has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (pd *pushDescriptor) layerAlreadyExists(
    ctx context.Context,
    progressOutput progress.Output,
    diffID layer.DiffID,
    checkOtherRepositories bool,