intel userspace cni 适配 Kubevirt

func createVhostPort(sock_dir string, sock_name string, client bool, bridge_name string) (string, error) {
	var err error
	type_str := "type=dpdkvhostuser"
	if client {
		type_str = "type=dpdkvhostuserclient"
	}
	// COMMAND: ovs-vsctl add-port <bridge_name> <sock_name> -- set Interface <sock_name> type=<dpdkvhostuser|dpdkvhostuserclient>
	cmd := "ovs-vsctl"
	args := []string{"add-port", bridge_name, sock_name, "--", "set", "Interface", sock_name, type_str}

	if client == true {
		socketarg := "options:vhost-server-path=" + sock_dir		if sock_dir[len(sock_dir)-1] != '/' {
			socketarg += "/"
		}
		socketarg += sock_name
		logging.Debugf("Additional string: %s", socketarg)

		args = append(args, socketarg)
	}
	if _, err = execCommand(cmd, args); err != nil {
		return "", err	}
	if client == false {
		// Determine the location OvS uses for Sockets. Default location can be
		// overwritten with environmental variable: OVS_SOCKDIR
		ovs_socket_dir, ok := os.LookupEnv("OVS_SOCKDIR")
		if ok == false {
			ovs_socket_dir = defaultOvSSocketDir		}
		// Move socket to defined dir for easier mounting
		err = os.Rename(ovs_socket_dir+sock_name, sock_dir+sock_name)
		if err != nil {
			logging.Errorf("Rename ERROR: %v", err)
			err = nil
			//deleteVhostPort(sock_name, bridge_name)
		}
	}
	return sock_name, err}language-go复制代码

const (
    ...
	volMntKeySharedDir      = "shared-dir"
	DefaultHostkubeletPodBaseDir  = "/var/lib/kubelet/pods/"
	DefaultHostEmptyDirVolumeName = "volumes/kubernetes.io~empty-dir/")func GetPodVolumeMountHostSharedDir(pod *v1.Pod) (string, error) {
	var hostSharedDir string
	logging.Verbosef("GetPodVolumeMountSharedDir: type=%T Volumes=%v", pod.Spec.Volumes, pod.Spec.Volumes)
	if len(pod.Spec.Volumes) == 0 {
		return hostSharedDir, &NoSharedDirProvidedError{"Error: No Volumes. Need \"shared-dir\" in podSpec \"Volumes\""}
	}

	for _, volumeMount := range pod.Spec.Volumes {
		if volumeMount.Name == volMntKeySharedDir {
			if volumeMount.HostPath != nil {
				hostSharedDir = volumeMount.HostPath.Path			} else if volumeMount.EmptyDir != nil {
				hostSharedDir = DefaultHostkubeletPodBaseDir + string(pod.UID) + "/" + DefaultHostEmptyDirVolumeName + volMntKeySharedDir			} else {
				return hostSharedDir, &NoSharedDirProvidedError{"Error: Volume is invalid"}
			}
			break
		}
	}
	if len(hostSharedDir) == 0 {
		return hostSharedDir, &NoSharedDirProvidedError{"Error: No shared-dir. Need \"shared-dir\" in podSpec \"Volumes\""}
	}
	return hostSharedDir, nil}language-go复制代码

const (
	defaultBridge               = "br0"
	DefaultHostVhostuserBaseDir = "/var/lib/vhost_sockets/")func getShortSharedDir(sharedDir string) string {
	// sun_path for unix domain socket has a array size of 108
	// When the sharedDir path length greater than 89 (108 - 19)
	// 19 is the possible vhostuser socke file name length "/abcdefghijkl-net99" (1 + 12 + 1 + 3 + 2)
	if len(sharedDir) >= 89 && strings.Contains(sharedDir, "empty-dir") {
		// Format - /var/lib/kubelet/pods/<podID>/volumes/kubernetes.io~empty-dir/shared-dir
		parts := strings.Split(sharedDir, "/")
		podID := parts[5]
		newSharedDir := DefaultHostVhostuserBaseDir + podID
		logging.Infof("getShortSharedDir: Short shared directory: %s", newSharedDir)
		return newSharedDir	}
	return sharedDir}func createSharedDir(sharedDir, oldSharedDir string) error {
	var err error

	_, err = os.Stat(sharedDir)
	if os.IsNotExist(err) {
		err = os.MkdirAll(sharedDir, 0750)
		if err != nil {
			logging.Errorf("createSharedDir: Failed to create dir (%s): %v", sharedDir, err)
			return err		}

		if strings.Contains(sharedDir, DefaultHostVhostuserBaseDir) {
			logging.Debugf("createSharedDir: Mount from %s to %s", oldSharedDir, sharedDir)
			err = unix.Mount(oldSharedDir, sharedDir, "", unix.MS_BIND, "")
			if err != nil {
				logging.Errorf("createSharedDir: Failed to bind mout: %s", err)
				return err			}
		}
		return nil

	}
	return err}language-go复制代码

func setSharedDirGroup(sharedDir string, group string) error {
	groupInfo, err := user.LookupGroup(group)
	if err != nil {
		return err	}

	logging.Debugf("setSharedDirGroup: group %s's gid is %s", group, groupInfo.Gid)
	gid, err := strconv.Atoi(groupInfo.Gid)
	if err != nil {
		return err	}

	err = os.Chown(DefaultHostVhostuserBaseDir, -1, gid)
	if err != nil {
		return err	}

	err = os.Chown(sharedDir, -1, gid)
	if err != nil {
		return err	}
	return nil}func addLocalDeviceVhost(conf *types.NetConf, args *skel.CmdArgs, actualSharedDir string, data *OvsSavedData) error {
	...
	group := conf.HostConf.VhostConf.Group	if group != "" {
		err = setSharedDirGroup(sharedDir, group)
		if err != nil {
			logging.Errorf("addLocalDeviceVhost: Failed to set shared dir group: %v", err)
			return err		}
	}
	...}language-go