Skip to content

Commit

Permalink
util: register group controller server
Browse files Browse the repository at this point in the history
Register group controller server
if its initialized.

Signed-off-by: Madhu Rajanna <madhupr007@gmail.com>
  • Loading branch information
Madhu-1 authored and mergify[bot] committed Feb 9, 2024
1 parent 2af26ca commit 5afc6fd
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions internal/csi-common/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@ type Servers struct {
IS csi.IdentityServer
CS csi.ControllerServer
NS csi.NodeServer
GS csi.GroupControllerServer
}

// NewNonBlockingGRPCServer return non-blocking GRPC.
Expand Down Expand Up @@ -109,6 +110,9 @@ func (s *nonBlockingGRPCServer) serve(endpoint string, srv Servers) {
if srv.NS != nil {
csi.RegisterNodeServer(server, srv.NS)
}
if srv.GS != nil {
csi.RegisterGroupControllerServer(server, srv.GS)
}

log.DefaultLog("Listening for connections on address: %#v", listener.Addr())
err = server.Serve(listener)
Expand Down

0 comments on commit 5afc6fd

Please sign in to comment.