in pkg/nfs/nfs.go [143:170]
func (n *Driver) Run(testMode bool) {
versionMeta, err := GetVersionYAML(n.name)
if err != nil {
klog.Fatalf("%v", err)
}
klog.V(2).Infof("\nDRIVER INFORMATION:\n-------------------\n%s\n\nStreaming logs below:", versionMeta)
mounter := mount.New("")
if runtime.GOOS == "linux" {
// MounterForceUnmounter is only implemented on Linux now
mounter = mounter.(mount.MounterForceUnmounter)
}
if n.runNodeServer {
n.ns = NewNodeServer(n, mounter)
}
if n.runControllerServer {
n.cs = NewControllerServer(n)
}
s := NewNonBlockingGRPCServer()
s.Start(n.endpoint,
NewDefaultIdentityServer(n),
n.cs,
n.ns,
testMode)
s.Wait()
}