Merge pull request #17 from msau42/set-node-server

Correctly set node server in nfs plugin object
This commit is contained in:
Kubernetes Prow Robot 2019-08-15 09:06:35 -07:00 committed by GitHub
commit 48ce196cd8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -68,13 +68,14 @@ func NewNodeServer(n *nfsDriver) *nodeServer {
} }
func (n *nfsDriver) Run() { func (n *nfsDriver) Run() {
n.ns = NewNodeServer(n)
s := NewNonBlockingGRPCServer() s := NewNonBlockingGRPCServer()
s.Start(n.endpoint, s.Start(n.endpoint,
NewDefaultIdentityServer(n), NewDefaultIdentityServer(n),
// NFS plugin has not implemented ControllerServer // NFS plugin has not implemented ControllerServer
// using default controllerserver. // using default controllerserver.
NewControllerServer(n), NewControllerServer(n),
NewNodeServer(n)) n.ns)
s.Wait() s.Wait()
} }