go fmt

Author: Hantao (Will) Wang

pkg/gce-pd-csi-driver/node.go

@@ -72,7 +72,7 @@ func (ns *GCENodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePub
 	if volumeCapability == nil {
 		return nil, status.Error(codes.InvalidArgument, "NodePublishVolume Volume Capability must be provided")
 	}
-	
+
 	if acquired := ns.volumeLocks.TryAcquire(volumeID); !acquired {
 		return nil, status.Errorf(codes.Aborted, common.VolumeOperationAlreadyExistsFmt, volumeID)
 	}
@@ -301,7 +301,7 @@ func (ns *GCENodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStage
 	if err != nil {
 		return nil, status.Error(codes.Internal,
 			fmt.Sprintf("Failed to format and mount device from (%q) to (%q) with fstype (%q) and options (%q): %v",
-				devicePath, stagingTargetPath, fstype, options, err))e
+				devicePath, stagingTargetPath, fstype, options, err))
 	}
 
 	return &csi.NodeStageVolumeResponse{}, nil
@@ -320,7 +320,7 @@ func (ns *GCENodeServer) NodeUnstageVolume(ctx context.Context, req *csi.NodeUns
 		return nil, status.Error(codes.InvalidArgument, "NodeUnstageVolume Staging Target Path must be provided")
 	}
 
-	if acquired := ns.volumes.TryAcquire(volumeID); !acquired {
+	if acquired := ns.volumeLocks.TryAcquire(volumeID); !acquired {
 		return nil, status.Error(codes.Aborted, fmt.Sprintf("An operation with the given Volume ID %s already exists", volumeID))
 	}
 	defer ns.volumeLocks.Release(volumeID)