fix comments

Author: fengzixu

cmd/hostpathplugin/main.go

@@ -36,7 +36,6 @@ var (
 	ephemeral         = flag.Bool("ephemeral", false, "publish volumes in ephemeral mode even if kubelet did not ask for it (only needed for Kubernetes 1.15)")
 	maxVolumesPerNode = flag.Int64("maxvolumespernode", 0, "limit of volumes per node")
 	showVersion       = flag.Bool("version", false, "Show version.")
-	kubeconfig        = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
 	// Set by the build process
 	version = ""
 )
@@ -59,7 +58,7 @@ func main() {
 }
 
 func handle() {
-	driver, err := hostpath.NewHostPathDriver(*driverName, *nodeID, *endpoint, *ephemeral, *maxVolumesPerNode, version, *kubeconfig)
+	driver, err := hostpath.NewHostPathDriver(*driverName, *nodeID, *endpoint, *ephemeral, *maxVolumesPerNode, version)
 	if err != nil {
 		fmt.Printf("Failed to initialize driver: %s", err.Error())
 		os.Exit(1)

pkg/hostpath/controllerserver.go

@@ -308,7 +308,7 @@ func (cs *controllerServer) ListVolumes(ctx context.Context, req *csi.ListVolume
 	for index := startIdx - 1; index < volumesLength && index < maxLength; index++ {
 		hpVolume = hostPathVolumes[volumeIds[index]]
 		healthy, msg := doHealthCheck(volumeIds[index])
-		glog.V(3).Infof("Healthy state: %+v Volume: %+v", hpVolume.VolName, healthy)
+		glog.V(3).Infof("Healthy state: %s Volume: %t", hpVolume.VolName, healthy)
 		volumeRes.Entries = append(volumeRes.Entries, &csi.ListVolumesResponse_Entry{
 			Volume: &csi.Volume{
 				VolumeId:      hpVolume.VolID,
@@ -335,7 +335,7 @@ func (cs *controllerServer) ControllerGetVolume(ctx context.Context, req *csi.Co
 	}
 
 	healthy, msg := doHealthCheck(req.GetVolumeId())
-	glog.V(3).Infof("Healthy state: %+v Volume: %+v", volume.VolName, healthy)
+	glog.V(3).Infof("Healthy state: %s Volume: %t", volume.VolName, healthy)
 	return &csi.ControllerGetVolumeResponse{
 		Volume: &csi.Volume{
 			VolumeId:      volume.VolID,

pkg/hostpath/healthcheck.go

@@ -57,7 +57,7 @@ func getSourcePath(volumeHandle string) string {
 
 func checkSourcePathExist(volumeHandle string) (bool, error) {
 	sourcePath := getSourcePath(volumeHandle)
-	glog.V(3).Infof("Volume: %+v Source path is: %+v", volumeHandle, sourcePath)
+	glog.V(3).Infof("Volume: %s Source path is: %s", volumeHandle, sourcePath)
 	_, err := os.Stat(sourcePath)
 	if err != nil {
 		if os.IsNotExist(err) {

pkg/hostpath/hostpath.go

@@ -105,7 +105,7 @@ func init() {
 	hostPathVolumeSnapshots = map[string]hostPathSnapshot{}
 }
 
-func NewHostPathDriver(driverName, nodeID, endpoint string, ephemeral bool, maxVolumesPerNode int64, version, kubeconfig string) (*hostPath, error) {
+func NewHostPathDriver(driverName, nodeID, endpoint string, ephemeral bool, maxVolumesPerNode int64, version string) (*hostPath, error) {
 	if driverName == "" {
 		return nil, errors.New("no driver name provided")
 	}