Merge pull request #254 from iamniting/partition

feat: filter child block devices also

pkg/internal/block_device.go

@@ -38,6 +38,9 @@ const (
 	// DeviceTypeROM is the device type for ROM devices in lsblk output
 	DeviceTypeROM = "rom"
 
+	// DeviceTypeLVM is the device type for lvm devices in lsblk output
+	DeviceTypeLVM = "lvm"
+
 	// mount string to find if a path is part of kubernetes
 	pluginString = "plugins/kubernetes.io"
 

pkg/vgmanager/filter.go

@@ -76,6 +76,8 @@ var FilterMap = map[string]func(internal.BlockDevice, internal.Executor) (bool,
 			return dev.IsUsableLoopDev(executor)
 		case internal.DeviceTypeROM:
 			return false, nil
+		case internal.DeviceTypeLVM:
+			return false, nil
 		default:
 			return true, nil
 		}

pkg/vgmanager/vgmanager_controller.go

@@ -674,6 +674,16 @@ DeviceLoop:
 		// store device in deviceAgeMap
 		r.deviceAgeMap.storeDeviceAge(blockDevice.KName)
 
+		// check for partitions recursively
+		if blockDevice.HasChildren() {
+			childAvailableDevices, childDelayedDevices, err := r.filterAvailableDevices(blockDevice.Children)
+			if err != nil {
+				return []internal.BlockDevice{}, []internal.BlockDevice{}, err
+			}
+			availableDevices = append(availableDevices, childAvailableDevices...)
+			delayedDevices = append(delayedDevices, childDelayedDevices...)
+		}
+
 		devLogger := r.Log.WithValues("Device.Name", blockDevice.Name)
 		for name, filter := range FilterMap {
 			var valid bool