dotcloud/docker

Function installCommonConfigFlags has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func installCommonConfigFlags(conf *config.Config, flags *pflag.FlagSet) {
    var (
        allowNonDistributable = opts.NewNamedListOptsRef("allow-nondistributable-artifacts", &conf.AllowNondistributableArtifacts, registry.ValidateIndexName)
        registryMirrors       = opts.NewNamedListOptsRef("registry-mirrors", &conf.Mirrors, registry.ValidateMirror)
        insecureRegistries    = opts.NewNamedListOptsRef("insecure-registries", &conf.InsecureRegistries, registry.ValidateIndexName)

Method imageRouter.getImagesJSON has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method process.reap has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (p *process) reap() {
    logger := p.ctr.client.logger.WithFields(log.Fields{
        "container": p.ctr.id,
        "process":   p.id,
    })

Method container.createIO has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *container) createIO(fifos *cio.FIFOSet, stdinCloseSync chan containerd.Process, attachStdio libcontainerdtypes.StdioCallback) (cio.IO, error) {
    var (
        io  *cio.DirectIO
        err error
    )

Method PluginSpec.MarshalToSizedBuffer has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m *PluginSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) {
    i := len(dAtA)
    _ = i
    var l int
    _ = l

Method follow.Do has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (fl *follow) Do(ctx context.Context, f *os.File, read logPos) {
    fl.log = log.G(ctx).WithFields(log.Fields{
        "module": "logger",
        "file":   f.Name(),
    })

Method logStream.collectBatch has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (l *logStream) collectBatch(created chan bool) {
    // Wait for the logstream/group to be created
    <-created
    flushInterval := l.forceFlushInterval
    if flushInterval <= 0 {

Function ServiceFromGRPC has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ServiceFromGRPC(s swarmapi.Service) (types.Service, error) {
    curSpec, err := serviceSpecFromGRPC(&s.Spec)
    if err != nil {
        return types.Service{}, err
    }

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

Open

func New(name string, config Options) (Driver, error) {
    ctx := context.TODO()
    if name != "" {
        log.G(ctx).Infof("[graphdriver] trying configured driver: %s", name)
        if err := checkRemoved(name); err != nil {

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 LTime", wireType)
            }
            m.LTime = 0

• 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 LTime", wireType)
            }
            m.LTime = 0

• 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 LTime", wireType)
            }
            m.LTime = 0

• 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 LTime", wireType)
            }
            m.LTime = 0

• 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 LTime", wireType)
            }
            m.LTime = 0

• 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 LTime", wireType)
            }
            m.LTime = 0

• Read up
  Read up

Function detectManifestBlobMediaType has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func detectManifestBlobMediaType(dt []byte) (string, error) {
    var mfst struct {
        MediaType string          `json:"mediaType"`
        Manifests json.RawMessage `json:"manifests"` // oci index, manifest list
        Config    json.RawMessage `json:"config"`    // schema2 Manifest

Function Go has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func Go(flags int, setupfn func() error, fn func()) error {
    started := make(chan error)

    maskedFlags := flags
    for f := range reversibleSetnsFlags {

Method Cluster.Info has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *Cluster) Info(ctx context.Context) types.Info {
    info := types.Info{
        NodeAddr: c.GetAdvertiseAddress(),
    }
    c.mu.RLock()

Function MergeSwarmSpecToGRPC has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func MergeSwarmSpecToGRPC(s types.Spec, spec swarmapi.ClusterSpec) (swarmapi.ClusterSpec, error) {
    // We take the initSpec (either created from scratch, or returned by swarmkit),
    // and will only change the value if the one taken from types.Spec is not nil or 0.
    // In other words, if the value taken from types.Spec is nil or 0, we will maintain the status quo.
    if s.Annotations.Name != "" {

Method Daemon.ContainerInspectCurrent has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) ContainerInspectCurrent(ctx context.Context, name string, size bool) (*containertypes.InspectResponse, error) {
    ctr, err := daemon.GetContainer(name)
    if err != nil {
        return nil, err
    }