docker/swarmkit

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

Open

    case EventUpdateVolume:
        if v.OldVolume != nil {
            return &WatchMessage_Event{Action: WatchActionKindUpdate, Object: &Object{Object: &Object_Volume{Volume: v.Volume}}, OldObject: &Object{Object: &Object_Volume{Volume: v.OldVolume}}}
        } else {
            return &WatchMessage_Event{Action: WatchActionKindUpdate, Object: &Object{Object: &Object_Volume{Volume: v.Volume}}}

• Read up
  Read up

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

Open

    case EventUpdateNode:
        if v.OldNode != nil {
            return &WatchMessage_Event{Action: WatchActionKindUpdate, Object: &Object{Object: &Object_Node{Node: v.Node}}, OldObject: &Object{Object: &Object_Node{Node: v.OldNode}}}
        } else {
            return &WatchMessage_Event{Action: WatchActionKindUpdate, Object: &Object{Object: &Object_Node{Node: v.Node}}}

• Read up
  Read up

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

Open

    case EventUpdateService:
        if v.OldService != nil {
            return &WatchMessage_Event{Action: WatchActionKindUpdate, Object: &Object{Object: &Object_Service{Service: v.Service}}, OldObject: &Object{Object: &Object_Service{Service: v.OldService}}}
        } else {
            return &WatchMessage_Event{Action: WatchActionKindUpdate, Object: &Object{Object: &Object_Service{Service: v.Service}}}

• Read up
  Read up

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

Open

package node

import (
    "fmt"

• Read up
  Read up

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

Open

        for _, taskID := range removeTasks {
            if err := batch.Update(func(tx store.Tx) error {
                t := store.GetTask(tx, taskID)
                if t == nil {
                    return nil

• Read up
  Read up

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

Open

package node

import (
    "fmt"

• Read up
  Read up

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

Open

package node

import (
    "fmt"

• Read up
  Read up

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

Open

    if storeObject.WatchSelectors.CustomPrefix != nil && *storeObject.WatchSelectors.CustomPrefix {
        d.P("func ", ccTypeName, "CheckCustomPrefix(v1, v2 *", ccTypeName, ") bool {")
        d.In()
        // Node is a special case
        if _, hasNoSpec := typesWithNoSpec[*m.Name]; hasNoSpec {

• Read up
  Read up

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

Open

package node

import (
    "fmt"

• Read up
  Read up

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

Open

        for _, taskID := range removeTasks {
            if err := batch.Update(func(tx store.Tx) error {
                t := store.GetTask(tx, taskID)
                if t == nil {
                    return nil

• Read up
  Read up

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

Open

    if flags.Changed("update-order") {
        if spec.Update == nil {
            spec.Update = &api.UpdateConfig{}
        }

• Read up
  Read up

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

Open

    if flags.Changed("rollback-on-failure") {
        if spec.Rollback == nil {
            spec.Rollback = &api.UpdateConfig{}
        }

• Read up
  Read up

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

Open

    if storeObject.WatchSelectors.Custom != nil && *storeObject.WatchSelectors.Custom {
        d.P("func ", ccTypeName, "CheckCustom(v1, v2 *", ccTypeName, ") bool {")
        d.In()
        // Node is a special case
        if _, hasNoSpec := typesWithNoSpec[*m.Name]; hasNoSpec {

• Read up
  Read up

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

Open

package node

import (
    "fmt"

• Read up
  Read up

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

Open

    if flags.Changed("rollback-order") {
        if spec.Rollback == nil {
            spec.Rollback = &api.UpdateConfig{}
        }

• Read up
  Read up

Method Agent.handleSessionMessage has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (a *Agent) handleSessionMessage(ctx context.Context, message *api.SessionMessage, nti *api.NodeTLSInfo) error {
    seen := map[api.Peer]struct{}{}
    for _, manager := range message.Managers {
        if manager.Peer.Addr == "" {
            continue

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

Open

func parseRestart(flags *pflag.FlagSet, spec *api.ServiceSpec) error {
    if spec.Task.Restart == nil {
        // set new service's restart policy as RestartOnAny
        spec.Task.Restart = &api.RestartPolicy{
            Condition: api.RestartOnAny,

Method Resource.MarshalToSizedBuffer has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method ServiceSpec.CopyFrom has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m *ServiceSpec) CopyFrom(src interface{}) {

    o := src.(*ServiceSpec)
    *m = *o
    github_com_moby_swarmkit_v2_api_deepcopy.Copy(&m.Annotations, &o.Annotations)

Method Server.ListServiceStatuses has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *Server) ListServiceStatuses(ctx context.Context, req *api.ListServiceStatusesRequest) (*api.ListServiceStatusesResponse, error) {
    resp := &api.ListServiceStatusesResponse{}
    if req == nil {
        return resp, nil
    }