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

Open

func main() {
    ipPtr := flag.String("ip", "127.0.0.1", "ip address")
    portPtr := flag.Int("port", 2000, "port")
    networkPtr := flag.String("net", "", "target network")
    tablePtr := flag.String("t", "", "table to process <sd/overlay>")

Method driver.DiscoverNew has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *driver) DiscoverNew(dType discoverapi.DiscoveryType, data interface{}) error {
    switch dType {
    case discoverapi.NodeDiscovery:
        nodeData, ok := data.(discoverapi.NodeDiscoveryData)
        if !ok {

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

Open

func dispatchRun(ctx context.Context, d dispatchRequest, c *instructions.RunCommand) error {
    if err := image.CheckOS(d.state.operatingSystem); err != nil {
        return err
    }

Method ImageService.GetImageAndReleasableLayer has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (i *ImageService) GetImageAndReleasableLayer(ctx context.Context, refOrID string, opts backend.GetImageAndLayerOptions) (builder.Image, builder.ROLayer, error) {
    if refOrID == "" { // FROM scratch
        if runtime.GOOS == "windows" {
            return nil, nil, fmt.Errorf(`"FROM scratch" is not supported on Windows`)
        }

Method Daemon.containerArchivePath has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (daemon *Daemon) containerArchivePath(container *container.Container, path string) (content io.ReadCloser, stat *containertypes.PathStat, err error) {
    container.Lock()

    defer func() {
        if err != nil {

Method ImageService.CommitImage has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (i *ImageService) CommitImage(ctx context.Context, c backend.CommitConfig) (image.ID, error) {
    if err := ctx.Err(); err != nil {
        return "", err
    }

Method JSONProgress.String has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (p *JSONProgress) String() string {
    var (
        width       = p.width()
        pbBox       string
        numbersBox  string

Method Manager.Push has 11 return statements (exceeds 4 allowed).

Open

func (pm *Manager) Push(ctx context.Context, name string, metaHeader http.Header, authConfig *registry.AuthConfig, outStream io.Writer) error {
    p, err := pm.config.Store.GetV2Plugin(name)
    if err != nil {
        return err
    }

Function Push has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func Push(ctx context.Context, ref reference.Named, config *ImagePushConfig) error {
    // FIXME: Allow to interrupt current push when new push of same image is done.

    // Resolve the Repository name from fqn to RepositoryInfo
    repoInfo, err := config.RegistryService.ResolveRepository(ref)

• Read up
  Read up

Method ImageCache.GetCache has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (ic *ImageCache) GetCache(parentID string, cfg *containertypes.Config, platform ocispec.Platform) (string, error) {
    imgID, err := ic.localImageCache.GetCache(parentID, cfg, platform)
    if err != nil {
        return "", err
    }

• Read up
  Read up

Function SwitchRoot has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func SwitchRoot(path string) error {
    if mounted, _ := mountinfo.Mounted(path); !mounted {
        if err := mount.Mount(path, path, "bind", "rbind,rw"); err != nil {
            return realChroot(path)
        }

• Read up
  Read up

Method Allocator.RequestPool has 11 return statements (exceeds 4 allowed).

Open

func (a *Allocator) RequestPool(req ipamapi.PoolRequest) (ipamapi.AllocatedPool, error) {
    log.G(context.TODO()).Debugf("RequestPool: %+v", req)

    parseErr := func(err error) error {
        return types.InternalErrorf("failed to parse pool request for address space %q pool %q subpool %q: %v", req.AddressSpace, req.Pool, req.SubPool, err)

Method Sandbox.delete has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (sb *Sandbox) delete(ctx context.Context, force bool) error {
    sb.mu.Lock()
    if sb.inDelete {
        sb.mu.Unlock()
        return types.ForbiddenErrorf("another sandbox delete in progress")

• Read up
  Read up

Function skipAgent has 11 return statements (exceeds 4 allowed).

Open

func skipAgent(dAtA []byte) (n int, err error) {
    l := len(dAtA)
    iNdEx := 0
    depth := 0
    for iNdEx < l {

Function skipOverlay has 11 return statements (exceeds 4 allowed).

Open

func skipOverlay(dAtA []byte) (n int, err error) {
    l := len(dAtA)
    iNdEx := 0
    depth := 0
    for iNdEx < l {

Function skipNetworkdb has 11 return statements (exceeds 4 allowed).

Open

func skipNetworkdb(dAtA []byte) (n int, err error) {
    l := len(dAtA)
    iNdEx := 0
    depth := 0
    for iNdEx < l {

Method driver.link has 11 return statements (exceeds 4 allowed).

Open

func (d *driver) link(network *bridgeNetwork, endpoint *bridgeEndpoint, enable bool) (retErr error) {
    cc := endpoint.containerConfig
    ec := endpoint.extConnConfig
    if cc == nil || ec == nil || (len(cc.ParentEndpoints) == 0 && len(cc.ChildEndpoints) == 0) {
        // nothing to do

Method driver.deleteNetwork has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) deleteNetwork(nid string) error {
    var err error

    // Get network handler and remove it from driver
    d.Lock()

• Read up
  Read up

Method cnmNetworkAllocator.allocateNetworkIPs has a Cognitive Complexity of 25 (exceeds 20 allowed). Consider refactoring.

Open

func (na *cnmNetworkAllocator) allocateNetworkIPs(nAttach *api.NetworkAttachment) error {
    var ip *net.IPNet
    var opts map[string]string

    ipam, _, _, err := na.resolveIPAM(nAttach.Network)

• Read up
  Read up

Method bridgeNetwork.setupIPTables has 11 return statements (exceeds 4 allowed).

Open

func (n *bridgeNetwork) setupIPTables(ipVersion iptables.IPVersion, maskedAddr *net.IPNet, config *networkConfiguration, i *bridgeInterface) error {
    var err error

    d := n.driver
    d.Lock()