dotcloud/docker

Method Plugin.Set has 63 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

    if p.PluginObj.Enabled {

Function newProxy has 63 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func newProxy(config ProxyConfig) (p Proxy, err error) {
    ipv := ipv4
    if config.HostIP.To4() == nil {
        ipv = ipv6
    }

Method Daemon.ContainerAttach has 63 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) ContainerAttach(prefixOrName string, req *backend.ContainerAttachConfig) error {
    keys := []byte{}
    var err error
    if req.DetachKeys != "" {
        keys, err = term.ToBytes(req.DetachKeys)

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

Open

func IsNetworkNotAvailable(ctx context.Context, c client.NetworkAPIClient, name string) cmp.Comparison {
    return func() cmp.Result {
        networks, err := c.NetworkList(ctx, network.ListOptions{})
        if err != nil {
            return cmp.ResultFromError(err)

• Read up
  Read up

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

Open

func IsNetworkAvailable(ctx context.Context, c client.NetworkAPIClient, name string) cmp.Comparison {
    return func() cmp.Result {
        networks, err := c.NetworkList(ctx, network.ListOptions{})
        if err != nil {
            return cmp.ResultFromError(err)

• Read up
  Read up

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

Open

func IsNetworkAvailable(ctx context.Context, c client.NetworkAPIClient, name string) cmp.Comparison {
    return func() cmp.Result {
        networks, err := c.NetworkList(ctx, network.ListOptions{})
        if err != nil {
            return cmp.ResultFromError(err)

• Read up
  Read up

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

Open

func IsNetworkNotAvailable(ctx context.Context, c client.NetworkAPIClient, name string) cmp.Comparison {
    return func() cmp.Result {
        networks, err := c.NetworkList(ctx, network.ListOptions{})
        if err != nil {
            return cmp.ResultFromError(err)

• Read up
  Read up

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

Open

        if errors.As(err, &apiErr) {
            fields := log.Fields{
                "errorCode":     apiErr.ErrorCode(),
                "message":       apiErr.ErrorMessage(),
                "logGroupName":  l.logGroupName,

• Read up
  Read up

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

Open

        if errors.As(err, &apiErr) {
            fields := log.Fields{
                "errorCode":      apiErr.ErrorCode(),
                "message":        apiErr.ErrorMessage(),
                "logGroupName":   l.logGroupName,

• Read up
  Read up

Method CompoundMessage.Unmarshal has 16 return statements (exceeds 4 allowed).

Open

func (m *CompoundMessage) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx

Method driver.CreateEndpoint has 16 return statements (exceeds 4 allowed).

Open

func (d *driver) CreateEndpoint(ctx context.Context, nid, eid string, ifInfo driverapi.InterfaceInfo, epOptions map[string]interface{}) error {
    var err error
    if err = validateID(nid, eid); err != nil {
        return err
    }

Method containerRouter.postContainersCreate has 16 return statements (exceeds 4 allowed).

Open

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

Method ImageService.ImageDelete has 16 return statements (exceeds 4 allowed).

Open

func (i *ImageService) ImageDelete(ctx context.Context, imageRef string, force, prune bool) (response []imagetypes.DeleteResponse, retErr error) {
    start := time.Now()
    defer func() {
        if retErr == nil {
            dimages.ImageActions.WithValues("delete").UpdateSince(start)

Method Cluster.Init has 16 return statements (exceeds 4 allowed).

Open

func (c *Cluster) Init(req types.InitRequest) (string, error) {
    c.controlMutex.Lock()
    defer c.controlMutex.Unlock()
    if c.nr != nil {
        if req.ForceNewCluster {

Method Daemon.connectToNetwork has 16 return statements (exceeds 4 allowed).

Open

func (daemon *Daemon) connectToNetwork(ctx context.Context, cfg *config.Config, ctr *container.Container, idOrName string, endpointConfig *network.EndpointSettings, updateSettings bool) (retErr error) {
    containerName := strings.TrimPrefix(ctr.Name, "/")
    ctx, span := otel.Tracer("").Start(ctx, "daemon.connectToNetwork", trace.WithAttributes(
        attribute.String("container.ID", ctr.ID),
        attribute.String("container.name", containerName),

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

Open

func networkPeersNumber(ip, port, networkName string, doneCh chan resultTuple) {
    body, err := httpGet(ip, port, "/networkpeers?nid="+networkName)
    if err != nil {
        log.G(context.TODO()).Errorf("networkPeersNumber %s there was an error: %s", ip, err)
        doneCh <- resultTuple{id: ip, result: -1}

• Read up
  Read up

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

Open

func dbQueueLength(ip, port, networkName string, doneCh chan resultTuple) {
    body, err := httpGet(ip, port, "/networkstats?nid="+networkName)
    if err != nil {
        log.G(context.TODO()).Errorf("queueLength %s there was an error: %s", ip, err)
        doneCh <- resultTuple{id: ip, result: -1}

• Read up
  Read up

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

Open

    if !n.config.Internal {
        if len(n.config.Ipv4Subnets) > 0 {
            s := n.getSubnetforIPv4(ep.addr)
            if s == nil {
                return fmt.Errorf("could not find a valid ipv4 subnet for endpoint %s", eid)

• Read up
  Read up

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

Open

    if !n.config.Internal {
        switch n.config.IpvlanMode {
        case modeL3, modeL3S:
            // disable gateway services to add a default gw using dev eth0 only
            jinfo.DisableGatewayService()

• Read up
  Read up

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

Open

func (d *driver) initStore(option map[string]interface{}) error {
    if data, ok := option[netlabel.LocalKVClient]; ok {
        var ok bool
        d.store, ok = data.(*datastore.Store)
        if !ok {

• Read up
  Read up