Merge pull request #408 from fredkan/v1.1.1-local-nodeserver-update

update local nodeserver

pkg/local/nodeserver.go

@@ -109,18 +109,25 @@ func NewNodeServer(d *csicommon.CSIDriver, dName, nodeID string) csi.NodeServer
 		log.Fatalf("Error building kubernetes clientset: %s", err.Error())
 	}
 
-	// local volume daemon
-	// GRPC server to provide volume manage
-	go server.Start()
+	mounter := k8smount.New("")
+	serviceType := os.Getenv(utils.ServiceType)
+	if len(serviceType) == 0 || serviceType == "" {
+		serviceType = utils.PluginService
+	}
 
-	// pv handler
-	// watch pv/pvc annotations and provide volume manage
-	go generator.VolumeHandler()
+	if serviceType == utils.PluginService {
+		// local volume daemon
+		// GRPC server to provide volume manage
+		go server.Start()
 
-	mounter := k8smount.New("")
-	// maintain pmem node
-	if types.GlobalConfigVar.PmemEnable {
-		manager.MaintainPMEM(types.GlobalConfigVar.PmemType, mounter)
+		// pv handler
+		// watch pv/pvc annotations and provide volume manage
+		go generator.VolumeHandler()
+
+		// maintain pmem node
+		if types.GlobalConfigVar.PmemEnable {
+			manager.MaintainPMEM(types.GlobalConfigVar.PmemType, mounter)
+		}
 	}
 
 	return &nodeServer{