Method findRootDevicePathAndNumber

platform/linux_platform.go:1719–1765

()

}

func (p linux) findRootDevicePathAndNumber() (string, int, error) {
	mounts, err := p.diskManager.GetMountsSearcher().SearchMounts()
	if err != nil {
		return "", 0, bosherr.WrapError(err, "Searching mounts")
	}

	for _, mount := range mounts {
		if mount.IsRoot() {
			p.logger.Debug(logTag, "Found root partition: `%s'", mount.PartitionPath)

			stdout, _, _, err := p.cmdRunner.RunCommand("readlink", "-f", mount.PartitionPath)
			if err != nil {
				return "", 0, bosherr.WrapError(err, "Shelling out to readlink")
			}
			rootPartition := strings.Trim(stdout, "\n")
			p.logger.Debug(logTag, "Symlink is: `%s'", rootPartition)

			validNVMeRootPartition := regexp.MustCompile(`^(/dev/[a-z]+\d+n\d+)p(\d+)$`)
			validSCSIRootPartition := regexp.MustCompile(`^/dev/[a-z]+\d$`)

			nvmeMatches := validNVMeRootPartition.FindStringSubmatch(rootPartition)
			isValidSCSIPath := validSCSIRootPartition.MatchString(rootPartition)
			if nvmeMatches == nil && !isValidSCSIPath {
				return "", 0, bosherr.Errorf("Root partition has an invalid name%s", rootPartition)
			}

			var devPath string
			var devNum int
			if nvmeMatches != nil {
				devPath = nvmeMatches[1]
				devNum, err = strconv.Atoi(nvmeMatches[2])
				if err != nil {
					return "", 0, bosherr.WrapError(err, "Parsing NVMe partition number failed")
				}
			} else {
				devPath = rootPartition[:len(rootPartition)-1]
				devNum, err = strconv.Atoi(rootPartition[len(rootPartition)-1:])
				if err != nil {
					return "", 0, bosherr.WrapError(err, "Parsing device number failed")
				}
			}

			return devPath, devNum, nil
		}
	}
	return "", 0, bosherr.Error("Getting root partition device")
}

func (p linux) createEphemeralPartitionsOnRootDevice(desiredSwapSizeInBytes *uint64, labelPrefix string) (string, string, error) {
	p.logger.Info(logTag, "Creating swap & ephemeral partitions on root disk...")