dotcloud/docker

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

Open

func (c *Cluster) GetVolume(nameOrID string) (volumetypes.Volume, error) {
    var volume *swarmapi.Volume

    if err := c.lockedManagerAction(func(ctx context.Context, state nodeState) error {
        v, err := getVolume(ctx, state.controlClient, nameOrID)

• Read up
  Read up

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

Open

func dbTableEntriesNumber(ip, port, networkName, tableName string, doneCh chan resultTuple) {
    body, err := httpGet(ip, port, "/gettable?nid="+networkName+"&tname="+tableName)
    if err != nil {
        log.G(context.TODO()).Errorf("tableEntriesNumber %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

package client // import "github.com/docker/docker/client"

import (
    "context"
    "net/url"

• Read up
  Read up

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

Open

package client // import "github.com/docker/docker/client"

import (
    "context"
    "net/url"

• Read up
  Read up

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

Open

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

• Read up
  Read up

Method puller.pullManifestList has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (p *puller) pullManifestList(ctx context.Context, ref reference.Named, mfstList *manifestlist.DeserializedManifestList, pp *ocispec.Platform) (id digest.Digest, manifestListDigest digest.Digest, err error) {
    manifestListDigest, err = schema2ManifestDigest(ref, mfstList)
    if err != nil {
        return "", "", err
    }

Method cnmNetworkAllocator.allocatePools has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (na *cnmNetworkAllocator) allocatePools(n *api.Network) (map[string]string, error) {
    ipam, dName, dOptions, err := na.resolveIPAM(n)
    if err != nil {
        return nil, err
    }

Function normalizeLayersAndHistory has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func normalizeLayersAndHistory(diffs []digest.Digest, history []ocispec.History, ref cache.ImmutableRef) ([]digest.Digest, []ocispec.History) {
    refMeta := getRefMetadata(ref, len(diffs))
    var historyLayers int
    for _, h := range history {
        if !h.EmptyLayer {

Method containerRouter.postContainerExecStart has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method nodeRunner.start has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (n *nodeRunner) start(conf nodeStartConfig) error {
    var control string
    if isWindows {
        control = `\\.\pipe\` + controlSocket
    } else {

Method Daemon.cleanupContainer has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) cleanupContainer(container *container.Container, config backend.ContainerRmConfig) error {
    if container.IsRunning() {
        if !config.ForceRemove {
            if state := container.StateString(); state == "paused" {
                return errdefs.Conflict(fmt.Errorf("cannot remove container %q: container is %s and must be unpaused first", container.Name, state))

Method Daemon.containerExtractToDir has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) containerExtractToDir(container *container.Container, path string, copyUIDGID, noOverwriteDirNonDir bool, content io.Reader) (err error) {
    container.Lock()
    defer container.Unlock()

    // Make sure an online file-system operation is permitted.

Method ImageService.SquashImage has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (i *ImageService) SquashImage(id, parent string) (string, error) {
    var (
        img *image.Image
        err error
    )

Function changes has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func changes(layers []string, rw string, dc deleteChange, sc skipChange) ([]Change, error) {
    var (
        changes     []Change
        changedDirs = make(map[string]struct{})
    )

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

Open

    fPol := &netlink.XfrmPolicy{
        Src:     &net.IPNet{IP: s, Mask: fullMask},
        Dst:     &net.IPNet{IP: d, Mask: fullMask},
        Dir:     netlink.XFRM_DIR_OUT,
        Proto:   syscall.IPPROTO_UDP,

• Read up
  Read up

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

Open

        fSP1 := &netlink.XfrmPolicy{
            Src:     &net.IPNet{IP: s, Mask: fullMask},
            Dst:     &net.IPNet{IP: d, Mask: fullMask},
            Dir:     netlink.XFRM_DIR_OUT,
            Proto:   syscall.IPPROTO_UDP,

• Read up
  Read up

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

Open

func (i *ImageService) CommitBuildStep(ctx context.Context, c backend.CommitConfig) (image.ID, error) {
    ctr := i.containers.Get(c.ContainerID)
    if ctr == nil {
        // TODO: use typed error
        return "", fmt.Errorf("container not found: %s", c.ContainerID)

• Read up
  Read up

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

Open

func (i *ImageService) CommitBuildStep(ctx context.Context, c backend.CommitConfig) (image.ID, error) {
    ctr := i.containers.Get(c.ContainerID)
    if ctr == nil {
        // TODO: use typed error
        return "", errors.Errorf("container not found: %s", c.ContainerID)

• Read up
  Read up

Method LayerDownloadManager.makeDownloadFuncFromDownload has 65 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (ldm *LayerDownloadManager) makeDownloadFuncFromDownload(descriptor DownloadDescriptor, sourceDownload *downloadTransfer, parentDownload *downloadTransfer) doFunc {
    return func(progressChan chan<- progress.Progress, start <-chan struct{}, inactive chan<- struct{}) transfer {
        d := &downloadTransfer{
            transfer:   newTransfer(),
            layerStore: ldm.layerStore,

Method NetworkDB.clusterInit has 65 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (nDB *NetworkDB) clusterInit() error {
    nDB.lastStatsTimestamp = time.Now()
    nDB.lastHealthTimestamp = nDB.lastStatsTimestamp

    config := memberlist.DefaultLANConfig()