dotcloud/docker

Method imageRouter.postImagesPush has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (ir *imageRouter) postImagesPush(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
    metaHeaders := map[string][]string{}
    for k, v := range r.Header {
        if strings.HasPrefix(k, "X-Meta-") {
            metaHeaders[k] = v

Function withCommonOptions has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func withCommonOptions(daemon *Daemon, daemonCfg *dconfig.Config, c *container.Container) coci.SpecOpts {
    return func(ctx context.Context, _ coci.Client, _ *containers.Container, s *coci.Spec) error {
        if c.BaseFS == "" {
            return errors.New("populateCommonSpec: BaseFS of container " + c.ID + " is unexpectedly empty")
        }

Method ImageService.deleteAll has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (i *ImageService) deleteAll(ctx context.Context, imgID image.ID, all []images.Image, c conflictType, prune bool) (records []imagetypes.DeleteResponse, err error) {
    // Workaround for: https://github.com/moby/buildkit/issues/3797
    possiblyDeletedConfigs := map[digest.Digest]struct{}{}
    if len(all) > 0 && i.content != nil {
        handled := map[digest.Digest]struct{}{}

Function New has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func New(info logger.Info) (logger.Logger, error) {
    containerStreamConfig, err := newStreamConfig(info)
    if err != nil {
        return nil, err
    }

Function SwarmFromGRPC has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func SwarmFromGRPC(c swarmapi.Cluster) types.Swarm {
    swarm := types.Swarm{
        ClusterInfo: types.ClusterInfo{
            ID: c.ID,
            Spec: types.Spec{

Function New has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func New(info logger.Info) (logger.Logger, error) {
    // parse gelf address
    address, err := parseAddress(info.Config["gelf-address"])
    if err != nil {
        return nil, err

Method reader.readLogs has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (r *reader) readLogs(ctx context.Context) {
    defer close(r.logWatcher.Msg)

    // Make sure the ready channel is closed in the event of an early
    // return.

Function waitUntilFlushedImpl has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func waitUntilFlushedImpl(s *journald) error {
    if s.readSyncTimeout == 0 {
        return nil
    }

Function toContainerdResources has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func toContainerdResources(resources container.Resources) *libcontainerdtypes.Resources {
    var r libcontainerdtypes.Resources

    if resources.BlkioWeight != 0 {
        r.BlockIO = &specs.LinuxBlockIO{

Method Daemon.containerCopy has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) containerCopy(container *container.Container, resource string) (rc io.ReadCloser, err error) {
    if resource[0] == '/' || resource[0] == '\\' {
        resource = resource[1:]
    }
    container.Lock()

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

Open

        case 4:
            if wireType != 0 {
                return fmt.Errorf("proto: wrong wireType = %d for field Disabled", wireType)
            }
            var v int

• Read up
  Read up

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

Open

        case 9:
            if wireType != 0 {
                return fmt.Errorf("proto: wrong wireType = %d for field ServiceDisabled", wireType)
            }
            var v int

• Read up
  Read up

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

Open

        case 4:
            if wireType != 0 {
                return fmt.Errorf("proto: wrong wireType = %d for field Leaving", wireType)
            }
            var v int

• Read up
  Read up

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

Open

        case 4:
            if wireType != 0 {
                return fmt.Errorf("proto: wrong wireType = %d for field Partial", wireType)
            }
            var v int

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

    case *net.UDPAddr:
        proto = "udp"

        var err error
        allocatedHostPort, err = pm.allocator.RequestPortInRange(hostIP, proto, hostPortStart, hostPortEnd)

• Read up
  Read up

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

Open

    case *net.TCPAddr:
        proto = "tcp"

        var err error
        allocatedHostPort, err = pm.allocator.RequestPortInRange(hostIP, proto, hostPortStart, hostPortEnd)

• Read up
  Read up

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

Open

func (d *driver) storeUpdate(kvObject datastore.KVObject) error {
    if d.store == nil {
        log.G(context.TODO()).Warnf("macvlan store not initialized. kv object %s is not added to the store", datastore.Key(kvObject.Key()...))
        return nil
    }

• Read up
  Read up

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

Open

func (d *driver) storeUpdate(kvObject datastore.KVObject) error {
    if d.store == nil {
        log.G(context.TODO()).Warnf("ipvlan store not initialized. kv object %s is not added to the store", datastore.Key(kvObject.Key()...))
        return nil
    }

• Read up
  Read up