Function New has 10 return statements (exceeds 4 allowed).

Open

func New(info logger.Info) (logger.Logger, error) {
    // parse gelf address
    address, err := parseAddress(info.Config["gelf-address"])
    if err != nil {
        return nil, err

Consider simplifying this complex logical expression.

Open

    if !splunkURL.IsAbs() ||
        (splunkURL.Scheme != "http" && splunkURL.Scheme != "https") ||
        (splunkURL.Path != "" && splunkURL.Path != "/") ||
        splunkURL.RawQuery != "" ||
        splunkURL.Fragment != "" {

Consider simplifying this complex logical expression.

Open

    if path[1] == ':' &&
        ('0' <= c && c <= '9' || 'a' <= c && c <= 'z' ||
            'A' <= c && c <= 'Z') {

Function validateHostConfig has 10 return statements (exceeds 4 allowed).

Open

func validateHostConfig(hostConfig *containertypes.HostConfig) error {
    if hostConfig == nil {
        return nil
    }

Method Daemon.containerExtractToDir has 10 return statements (exceeds 4 allowed).

Open

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

    cfs, err := daemon.openContainerFS(container)

Function New has 10 return statements (exceeds 4 allowed).

Open

func New(name string, config Options) (Driver, error) {
    ctx := context.TODO()
    if name != "" {
        log.G(ctx).Infof("[graphdriver] trying configured driver: %s", name)
        if err := checkRemoved(name); err != nil {

Method Daemon.createNetwork has 10 return statements (exceeds 4 allowed).

Open

func (daemon *Daemon) createNetwork(cfg *config.Config, create networktypes.CreateRequest, id string, agent bool) (*networktypes.CreateResponse, error) {
    if network.IsPredefined(create.Name) {
        return nil, PredefinedNetworkError(create.Name)
    }

Method ImageService.GetImageAndReleasableLayer has 10 return statements (exceeds 4 allowed).

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`)
        }

Function changes has 10 return statements (exceeds 4 allowed).

Open

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

Function Validate has 10 return statements (exceeds 4 allowed).

Open

func Validate(config *Config) error {
    // validate log-level
    if config.LogLevel != "" {
        // FIXME(thaJeztah): find a better way for this; this depends on knowledge of containerd's log package internals.
        // Alternatively: try  log.SetLevel(config.LogLevel), and restore the original level, but this also requires internal knowledge.

Consider simplifying this complex logical expression.

Open

    if oldStat.Mode() != newStat.Mode() ||
        oldStat.UID() != newStat.UID() ||
        oldStat.GID() != newStat.GID() ||
        oldStat.Rdev() != newStat.Rdev() ||
        // Don't look at size or modification time for dirs, its not a good

Method Manager.List has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func (pm *Manager) List(pluginFilters filters.Args) ([]types.Plugin, error) {
    if err := pluginFilters.Validate(acceptedPluginFilterTags); err != nil {
        return nil, err
    }

• Read up
  Read up

Method Manager.Privileges has 9 return statements (exceeds 4 allowed).

Open

func (pm *Manager) Privileges(ctx context.Context, ref reference.Named, metaHeader http.Header, authConfig *registry.AuthConfig) (types.PluginPrivileges, error) {
    var (
        config     types.PluginConfig
        configSeen bool
    )

Function SwitchRoot has 9 return statements (exceeds 4 allowed).

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)
        }

Method Controller.NewSandbox has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Controller) NewSandbox(ctx context.Context, containerID string, options ...SandboxOption) (_ *Sandbox, retErr error) {
    if containerID == "" {
        return nil, types.InvalidParameterErrorf("invalid container ID")
    }

• Read up
  Read up

Function fetchTable has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func fetchTable(ip string, port int, network, tableName string, clusterPeers, networkPeers map[string]string, remediate bool) {
    log.G(context.TODO()).Infof("Fetch %s table and check owners", tableName)
    resp, err := http.Get(fmt.Sprintf(dumpTable, ip, port, network, tableName))
    if err != nil {
        log.G(context.TODO()).WithError(err).Fatalf("Failed fetching endpoint table")

• Read up
  Read up

Method Controller.cleanupLocalEndpoints has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Controller) cleanupLocalEndpoints() error {
    // Get used endpoints
    eps := make(map[string]interface{})
    for _, sb := range c.sandboxes {
        for _, ep := range sb.endpoints {

• Read up
  Read up

Function checkTable has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func checkTable(ctx context.Context, ips []string, port, networkName, tableName string, expectedEntries int, fn func(string, string, string, string, chan resultTuple)) (opTime time.Duration) {
    startTime := time.Now().UnixNano()
    var successTime int64

    // Loop for 2 minutes to guarantee that the result is stable

• Read up
  Read up

Method driver.Join has 9 return statements (exceeds 4 allowed).

Open

func (d *driver) Join(_ context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) (retErr error) {
    join := &api.JoinRequest{
        NetworkID:  nid,
        EndpointID: eid,
        SandboxKey: sboxKey,

Function StartProxy has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func StartProxy(pb types.PortBinding,
    proxyPath string,
    listenSock *os.File,
) (stop func() error, retErr error) {
    if proxyPath == "" {

• Read up
  Read up