Skip to content

Commit

Permalink
cephfs: expose FenceControllerServer in driver.go to handle the requests
Browse files Browse the repository at this point in the history
Signed-off-by: Riya Singhal <[email protected]>
  • Loading branch information
riya-singhal31 committed Oct 5, 2023
1 parent bfde4b3 commit 3795dda
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions internal/cephfs/driver.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 3795dda

Please sign in to comment.