docker/swarmkit

Function ParseAddSecret has 54 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ParseAddSecret(cmd *cobra.Command, spec *api.ServiceSpec, flagName string) error {
    flags := cmd.Flags()

    if flags.Changed(flagName) {
        secrets, err := flags.GetStringSlice(flagName)

Function ParseAddConfig has 54 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ParseAddConfig(cmd *cobra.Command, spec *api.ServiceSpec, flagName string) error {
    flags := cmd.Flags()

    if flags.Changed(flagName) {
        configs, err := flags.GetStringSlice(flagName)

Method NetworkAttachment.MarshalToSizedBuffer has 54 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method Dispatcher.markNodesUnknown has 54 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *Dispatcher) markNodesUnknown(ctx context.Context) error {
    log := log.G(ctx).WithField("method", "(*Dispatcher).markNodesUnknown")
    var nodes []*api.Node
    var err error
    d.store.View(func(tx store.ReadTx) {

Method Allocator.allocateNode has 54 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (a *Allocator) allocateNode(ctx context.Context, node *api.Node, existingAddressesOnly bool, networks []*api.Network) bool {
    var allocated bool

    nc := a.netCtx

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

Open

    if len(m.Hosts) > 0 {
        for iNdEx := len(m.Hosts) - 1; iNdEx >= 0; iNdEx-- {
            i -= len(m.Hosts[iNdEx])
            copy(dAtA[i:], m.Hosts[iNdEx])
            i = encodeVarintSpecs(dAtA, i, uint64(len(m.Hosts[iNdEx])))

• Read up
  Read up

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

Open

    if len(m.CapabilityAdd) > 0 {
        for iNdEx := len(m.CapabilityAdd) - 1; iNdEx >= 0; iNdEx-- {
            i -= len(m.CapabilityAdd[iNdEx])
            copy(dAtA[i:], m.CapabilityAdd[iNdEx])
            i = encodeVarintSpecs(dAtA, i, uint64(len(m.CapabilityAdd[iNdEx])))

• Read up
  Read up

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

Open

    if len(m.CapabilityDrop) > 0 {
        for iNdEx := len(m.CapabilityDrop) - 1; iNdEx >= 0; iNdEx-- {
            i -= len(m.CapabilityDrop[iNdEx])
            copy(dAtA[i:], m.CapabilityDrop[iNdEx])
            i = encodeVarintSpecs(dAtA, i, uint64(len(m.CapabilityDrop[iNdEx])))

• Read up
  Read up

Method LogMessage.MarshalToSizedBuffer has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method TaskSpec.CopyFrom has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

    o := src.(*TaskSpec)
    *m = *o
    if o.Resources != nil {

Method Scheduler.scheduleNTasksOnNodes has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *Scheduler) scheduleNTasksOnNodes(ctx context.Context, n int, taskGroup map[string]*api.Task, nodes []NodeInfo, schedulingDecisions map[string]schedulingDecision, nodeLess func(a *NodeInfo, b *NodeInfo) bool) int {
    tasksScheduled := 0
    failedConstraints := make(map[int]bool) // key is index in nodes slice
    nodeIter := 0
    nodeCount := len(nodes)

Method Server.ListResources has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *Server) ListResources(ctx context.Context, request *api.ListResourcesRequest) (*api.ListResourcesResponse, error) {
    var (
        resources     []*api.Resource
        respResources []*api.Resource
        err           error

Method Deallocator.Run has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (deallocator *Deallocator) Run(ctx context.Context) error {
    var (
        allServices []*api.Service
        allNetworks []*api.Network
    )

Method Node.triggerSnapshot has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (n *Node) triggerSnapshot(ctx context.Context, raftConfig api.RaftConfig) {
    snapshot := api.Snapshot{Version: api.Snapshot_V0}
    for _, member := range n.cluster.Members() {
        snapshot.Membership.Members = append(snapshot.Membership.Members,
            &api.RaftMember{

Function init has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func init() {
    register(ObjectStoreConfig{
        Table: &memdb.TableSchema{
            Name: tableResource,
            Indexes: map[string]*memdb.IndexSchema{

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

Open

    if flags.Changed("cpu-limit") {
        if spec.Task.Resources == nil {
            spec.Task.Resources = &api.ResourceRequirements{}
        }
        if spec.Task.Resources.Limits == nil {

• Read up
  Read up

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

Open

    if flags.Changed("memory-reservation") {
        if spec.Task.Resources == nil {
            spec.Task.Resources = &api.ResourceRequirements{}
        }
        if spec.Task.Resources.Reservations == nil {

• Read up
  Read up

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

Open

    if flags.Changed("memory-limit") {
        if spec.Task.Resources == nil {
            spec.Task.Resources = &api.ResourceRequirements{}
        }
        if spec.Task.Resources.Limits == nil {

• Read up
  Read up

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

Open

    suite.NoError(s.Update(func(tx store.Tx) error {
        t6 := &api.Task{
            ID: "testTaskID6",
            Status: api.TaskStatus{
                State: api.TaskStateNew,

• Read up
  Read up

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

Open

func (m *SelectBySlot) Size() (n int) {
    if m == nil {
        return 0
    }
    var l int

• Read up
  Read up