dotcloud/docker

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

Open

func Register(r driverapi.Registerer, config map[string]interface{}) error {
    d := &driver{
        networks: networkTable{},
    }
    if err := d.initStore(config); err != nil {

• Read up
  Read up

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

Open

func Register(r driverapi.Registerer, config map[string]interface{}) error {
    d := &driver{
        networks: networkTable{},
    }
    if err := d.initStore(config); err != nil {

• Read up
  Read up

Method Manager.Upgrade has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (pm *Manager) Upgrade(ctx context.Context, ref reference.Named, name string, metaHeader http.Header, authConfig *registry.AuthConfig, privileges types.PluginPrivileges, outStream io.Writer) (err error) {

Function New has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

func New(ctx context.Context, rootDir string, cli *containerd.Client, ns string, exitHandler ExitHandler, shim string, shimOpts interface{}) (*Executor, error) {

Method Manager.Upgrade has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (pm *Manager) Upgrade(ctx context.Context, ref reference.Named, name string, metaHeader http.Header, authConfig *registry.AuthConfig, privileges types.PluginPrivileges, outStream io.Writer) error {

Function ReplaceContainer has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

func ReplaceContainer(ctx context.Context, client types.Client, id string, spec *specs.Spec, shim string, runtimeOptions interface{}, opts ...containerd.NewContainerOpts) (types.Container, error) {

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

Open

func (d *Daemon) ListServices(ctx context.Context, t testing.TB) []swarm.Service {
    t.Helper()
    cli := d.NewClientT(t)
    defer cli.Close()

• Read up
  Read up

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

Open

func spExists(sp *netlink.XfrmPolicy) (bool, error) {
    _, err := ns.NlHandle().XfrmPolicyGet(sp)
    switch err {
    case nil:
        return true, nil

• Read up
  Read up

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

Open

func saExists(sa *netlink.XfrmState) (bool, error) {
    _, err := ns.NlHandle().XfrmStateGet(sa)
    switch err {
    case nil:
        return true, nil

• Read up
  Read up

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

Open

func (d *Daemon) ListNodes(ctx context.Context, t testing.TB) []swarm.Node {
    t.Helper()
    cli := d.NewClientT(t)
    defer cli.Close()

• Read up
  Read up

Method Executor.Restore has 8 return statements (exceeds 4 allowed).

Open

func (e *Executor) Restore(id string, stdout, stderr io.WriteCloser) (bool, error) {
    ctx := context.Background()
    p := c8dPlugin{log: log.G(ctx).WithField("plugin", id)}
    ctr, err := e.client.LoadContainer(ctx, id)
    if err != nil {

Method store.Create has 8 return statements (exceeds 4 allowed).

Open

func (is *store) Create(config []byte) (ID, error) {
    var img *Image
    img, err := NewFromJSON(config)
    if err != nil {
        return "", err

Method pushDescriptor.Upload has 8 return statements (exceeds 4 allowed).

Open

func (pd *pushDescriptor) Upload(ctx context.Context, progressOutput progress.Output) (distribution.Descriptor, error) {
    // Skip foreign layers unless this registry allows nondistributable artifacts.
    if !pd.endpoint.AllowNondistributableArtifacts {
        if fs, ok := pd.layer.(distribution.Describable); ok {
            if d := fs.Descriptor(); len(d.URLs) > 0 {

Function setupSeccomp has 8 return statements (exceeds 4 allowed).

Open

func setupSeccomp(config *Seccomp, rs *specs.Spec) (*specs.LinuxSeccomp, error) {
    if config == nil {
        return nil, nil
    }

Method Store.Get has 8 return statements (exceeds 4 allowed).

Open

func (ps *Store) Get(name, capability string, mode int) (plugingetter.CompatPlugin, error) {
    // Lookup using new model.
    if ps != nil {
        p, err := ps.GetV2Plugin(name)
        if err == nil {

Function calcSize has 8 return statements (exceeds 4 allowed).

Open

func calcSize(ctx context.Context, dir string) (int64, error) {
    var size int64
    data := make(map[uint64]struct{})
    err := filepath.Walk(dir, func(d string, fileInfo os.FileInfo, err error) error {
        if err != nil {

Method store.restore has 8 return statements (exceeds 4 allowed).

Open

func (is *store) restore() error {
    // As the code below is run when restoring all images (which can be "many"),
    // constructing the "log.G(ctx).WithFields" is deliberately not "DRY", as the
    // logger is only used for error-cases, and we don't want to do allocations
    // if we don't need it. The "f" type alias is here is just for convenience,

Method Manager.Upgrade has 8 return statements (exceeds 4 allowed).

Open

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

Method ImageCache.GetCache has 8 return statements (exceeds 4 allowed).

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
    }

Method Sandbox.populateNetworkResources has 8 return statements (exceeds 4 allowed).

Open

func (sb *Sandbox) populateNetworkResources(ctx context.Context, ep *Endpoint) error {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.Sandbox.populateNetworkResources", trace.WithAttributes(
        attribute.String("endpoint.Name", ep.Name())))
    defer span.End()