cephfs: expose FenceControllerServer in driver.go to handle the requests

Signed-off-by: Riya Singhal <[email protected]>
ceph · Oct 24, 2023 · 1fc9678 · 1fc9678
1 parent 74dfb7b
commit 1fc9678
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/internal/cephfs/driver.go b/internal/cephfs/driver.go
@@ -197,6 +197,11 @@ func (fs *Driver) setupCSIAddonsServer(conf *util.Config) error {
 	is := casceph.NewIdentityServer(conf)
 	fs.cas.RegisterService(is)
 
+	if conf.IsControllerServer {
+		fcs := casceph.NewFenceControllerServer()
+		fs.cas.RegisterService(fcs)
+	}
+
 	// start the server, this does not block, it runs a new go-routine
 	err = fs.cas.Start()
 	if err != nil {

diff --git a/internal/csi-addons/cephfs/network_fence_test.go b/internal/csi-addons/cephfs/network_fence_test.go
@@ -20,9 +20,8 @@ import (
 	"context"
 	"testing"
 
-	"github.com/stretchr/testify/assert"
-
 	"github.com/csi-addons/spec/lib/go/fence"
+	"github.com/stretchr/testify/assert"
 )
 
 // TestFenceClusterNetwork is a minimal test for the FenceClusterNetwork()