Added forcecephkernelclient as startup parameter to force enabling ceph

Signed-off-by: Stefan Haas <shaas@suse.com>

pkg/cephfs/driver.go

@@ -95,7 +95,7 @@ func (fs *Driver) Run(conf *util.Config, cachePersister util.CachePersister) {
 	// Configuration
 	PluginFolder = conf.PluginPath
 
-	if err := loadAvailableMounters(); err != nil {
+	if err := loadAvailableMounters(conf); err != nil {
 		klog.Fatalf("cephfs: failed to load ceph mounters: %v", err)
 	}
 

pkg/cephfs/volumemounter.go

@@ -49,7 +49,7 @@ var (
 
 // Load available ceph mounters installed on system into availableMounters
 // Called from driver.go's Run()
-func loadAvailableMounters() error {
+func loadAvailableMounters(conf *util.Config) error {
 	// #nosec
 	fuseMounterProbe := exec.Command("ceph-fuse", "--version")
 	// #nosec
@@ -70,7 +70,8 @@ func loadAvailableMounters() error {
 		if err != nil {
 			return err
 		}
-		if majorVers > 4 || (majorVers >= 4 && minorVers >= 17) {
+
+		if conf.ForceKernelCephFS || majorVers > 4 || (majorVers >= 4 && minorVers >= 17) {
 			klog.Infof("loaded mounter: %s", volumeMounterKernel)
 			availableMounters = append(availableMounters, volumeMounterKernel)
 		} else {

pkg/util/util.go

@@ -97,9 +97,13 @@ type Config struct {
 
 	IsControllerServer bool // if set to true start provisoner server
 	IsNodeServer       bool // if set to true start node server
+
 	// rbd related flag
 	Containerized bool // whether run as containerized
 
+	// cephfs related flags
+	ForceKernelCephFS bool // force to use the ceph kernel client even if the kernel is < 4.17
+
 }
 
 // CreatePersistanceStorage creates storage path and initializes new cache