Function cleanupNetwork

pkg/cmd/container/kill.go:130–202

cleanupNetwork removes cni network setup, specifically the forwards

(ctx context.Context, container containerd.Container, globalOpts types.GlobalCommandOptions)

// cleanupNetwork removes cni network setup, specifically the forwards
func cleanupNetwork(ctx context.Context, container containerd.Container, globalOpts types.GlobalCommandOptions) error {
	return rootlessutil.WithDetachedNetNSIfAny(func() error {
		// retrieve current active port mappings
		dataStore, err := clientutil.DataStore(globalOpts.DataRoot, globalOpts.Address)
		if err != nil {
			return err
		}
		containerLabels, err := container.Labels(ctx)
		if err != nil {
			return err
		}
		ports, err := portutil.LoadPortMappings(dataStore, globalOpts.Namespace, container.ID(), containerLabels)
		if err != nil {
			return fmt.Errorf("no oci spec: %q", err)
		}
		portMappings := []cni.NamespaceOpts{
			cni.WithCapabilityPortMap(ports),
		}

		// retrieve info to get cni instance
		spec, err := container.Spec(ctx)
		if err != nil {
			return err
		}
		networksJSON := spec.Annotations[labels.Networks]
		var networks []string
		if err := json.Unmarshal([]byte(networksJSON), &networks); err != nil {
			log.G(ctx).WithError(err).WithField("container", container.ID()).Infof("unable to retrieve networking information for that container")
			return nil
		}
		netType, err := nettype.Detect(networks)
		if err != nil {
			return err
		}

		switch netType {
		case nettype.Host, nettype.None, nettype.Container, nettype.Namespace:
			// NOP
		case nettype.CNI:
			e, err := netutil.NewCNIEnv(globalOpts.CNIPath, globalOpts.CNINetConfPath, netutil.WithNamespace(globalOpts.Namespace), netutil.WithDefaultNetwork(globalOpts.BridgeIP))
			if err != nil {
				return err
			}
			cniOpts := []cni.Opt{
				cni.WithPluginDir([]string{globalOpts.CNIPath}),
			}
			var netw *netutil.NetworkConfig
			for _, netstr := range networks {
				if netw, err = e.NetworkByNameOrID(netstr); err != nil {
					return err
				}
				cniOpts = append(cniOpts, cni.WithConfListBytes(netw.Bytes))
			}
			cniObj, err := cni.New(cniOpts...)
			if err != nil {
				return err
			}