dotcloud/docker

Method driver.createNetwork has 60 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *driver) createNetwork(config *configuration) (bool, error) {
    foundExisting := false
    networkList := d.getNetworks()
    for _, nw := range networkList {
        if config.Parent == nw.config.Parent {

Method driver.Join has 60 lines of code (exceeds 50 allowed). Consider refactoring.

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,

Method Resolver.forwardExtDNS has 60 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (r *Resolver) forwardExtDNS(ctx context.Context, proto string, remoteAddr net.Addr, query *dns.Msg) *dns.Msg {
    ctx, span := otel.Tracer("").Start(ctx, "resolver.forwardExtDNS")
    defer span.End()

    proxyDNS := r.proxyDNS.Load()

Method controller.Logs has 60 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (r *controller) Logs(ctx context.Context, publisher exec.LogPublisher, options api.LogSubscriptionOptions) error {
    if err := r.checkClosed(); err != nil {
        return err
    }

Method Info.ExtraAttributes has 60 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (info *Info) ExtraAttributes(keyMod func(string) string) (map[string]string, error) {
    extra := make(map[string]string)
    labels, ok := info.Config["labels"]
    if ok && len(labels) > 0 {
        for _, l := range strings.Split(labels, ",") {

Function ensureHTTPServerImage has 60 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ensureHTTPServerImage(t testing.TB) {
    t.Helper()
    var doIt bool
    ensureHTTPServerOnce.Do(func() {
        doIt = true

Method layerStore.CreateRWLayer has 60 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (ls *layerStore) CreateRWLayer(name string, parent ChainID, opts *CreateRWLayerOpts) (_ RWLayer, err error) {
    var (
        storageOpt map[string]string
        initFunc   MountInit
        mountLabel string

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

Open

        case ipcMode.IsContainer():
            ic, err := daemon.getIPCContainer(ipcMode.Container())
            if err != nil {
                return errors.Wrap(err, "failed to join IPC namespace")
            }

• Read up
  Read up

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

Open

    go func() {
        log.G(context.TODO()).Debugf("metrics API listening on %s", l.Addr())
        srv := &http.Server{
            Handler:           mux,
            ReadHeaderTimeout: 5 * time.Minute, // "G112: Potential Slowloris Attack (gosec)"; not a real concern for our use, so setting a long timeout.

• Read up
  Read up

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

Open

    go func() {
        log.G(context.TODO()).Infof("metrics API listening on %s", l.Addr())
        srv := &http.Server{
            Handler:           mux,
            ReadHeaderTimeout: 5 * time.Minute, // "G112: Potential Slowloris Attack (gosec)"; not a real concern for our use, so setting a long timeout.

• Read up
  Read up

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

Open

        case pidMode.IsContainer():
            pc, err := daemon.getPIDContainer(pidMode.Container())
            if err != nil {
                return errors.Wrap(err, "failed to join PID namespace")
            }

• Read up
  Read up

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

Open

        if ok := parentExists(n.config.Parent); ok {
            // only delete the link if it is named the net_id
            if n.config.Parent == getDummyName(nid) {
                err := delDummyLink(n.config.Parent)
                if err != nil {

• Read up
  Read up

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

Open

    if n.config.CreatedSlaveLink && parentExists(n.config.Parent) && d.parentHasSingleUser(n) {
        // only delete the link if it is named the net_id
        if n.config.Parent == getDummyName(nid) {
            err := delDummyLink(n.config.Parent)
            if err != nil {

• Read up
  Read up

Method puller.pullSchema1 has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (p *puller) pullSchema1(ctx context.Context, ref reference.Reference, unverifiedManifest *schema1.SignedManifest, platform *ocispec.Platform) (id digest.Digest, manifestDigest digest.Digest, err error) {
    if platform != nil {
        // Early bath if the requested OS doesn't match that of the configuration.
        // This avoids doing the download, only to potentially fail later.
        if err := image.CheckOS(platform.OS); err != nil {

Function toRootless has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func toRootless(spec *specs.Spec, v2Controllers []string, currentOOMScoreAdj int) error {
    if len(v2Controllers) == 0 {
        if spec.Linux != nil {
            // Remove cgroup settings.
            spec.Linux.Resources = nil

Function fetchTable has 59 lines of code (exceeds 50 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")

Function JobComplete has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func JobComplete(ctx context.Context, client client.CommonAPIClient, service swarmtypes.Service) func(log poll.LogT) poll.Result {
    filter := filters.NewArgs(filters.Arg("service", service.ID))

    var jobIteration swarmtypes.Version
    if service.JobStatus != nil {

Method driver.parseNetworkOptions has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *driver) parseNetworkOptions(id string, genericOptions map[string]string) (*networkConfiguration, error) {
    config := &networkConfiguration{Type: d.name}

    for label, value := range genericOptions {
        switch label {

Function WithDevices has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func WithDevices(daemon *Daemon, c *container.Container) coci.SpecOpts {
    return func(ctx context.Context, _ coci.Client, _ *containers.Container, s *coci.Spec) error {
        // Build lists of devices allowed and created within the container.
        var devs []specs.LinuxDevice
        devPermissions := s.Linux.Resources.Devices

Function TaskFromGRPC has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func TaskFromGRPC(t swarmapi.Task) (types.Task, error) {
    containerStatus := t.Status.GetContainer()
    taskSpec, err := taskSpecFromGRPC(t.Spec)
    if err != nil {
        return types.Task{}, err