Fix build failures

Author: Sneha-at

pkg/common/parameters_test.go

@@ -366,6 +366,7 @@ func TestExtractAndDefaultParameters(t *testing.T) {
 					"key1": "value1",
 					"key2": "value2",
 				},
+				ResourceTags: map[string]string{},
 			},
 			expectDataCacheParams: DataCacheParameters{
 				DataCacheMode: DataCacheModeWriteThrough,
@@ -386,6 +387,7 @@ func TestExtractAndDefaultParameters(t *testing.T) {
 					"key1": "value1",
 					"key2": "value2",
 				},
+				ResourceTags: map[string]string{},
 			},
 			expectDataCacheParams: DataCacheParameters{
 				DataCacheMode: DataCacheModeWriteBack,

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

@@ -119,7 +119,7 @@ func setupCaching(devicePath string, req *csi.NodeStageVolumeRequest, nodeId str
 	if err != nil {
 		return mainDevicePath, fmt.Errorf("lv list error %w: %s", err, info)
 	}
-	klog.Info("=============== Got LVs %s on Volume group %s ============", string(lvList), volumeGroupName)
+	klog.Infof("=============== Got LVs %s on Volume group %s ============", string(lvList), volumeGroupName)
 	if !strings.Contains(string(lvList), mainLvName) {
 		// lvcreate -n main -l 100%PVS cachegroup /dev/sdb
 		klog.V(2).Infof("====== lvcreate main cache layer ======")
@@ -287,7 +287,7 @@ func reduceVolumeGroup(volumeGroupName string, force bool) {
 func RaidLocalSsds() error {
 	isAlreadyRaided, err := isRaided()
 	if err != nil {
-		klog.V(2).Info("======Errored while scanning for available LocalSSDs err:%v; continuing Raiding=======", err)
+		klog.V(2).Infof("======Errored while scanning for available LocalSSDs err:%v; continuing Raiding=======", err)
 	} else if isAlreadyRaided {
 		klog.V(2).Infof("===============Local SSDs are already RAIDed==============")
 		return nil
@@ -331,7 +331,7 @@ func RaidLocalSsds() error {
 	// Validate if Raided successfully
 	isAlreadyRaided, err = isRaided()
 	if err != nil {
-		klog.V(2).Info("======Errored while scanning for available raided LocalSSDs err:%v=======", err)
+		klog.V(2).Infof("======Errored while scanning for available raided LocalSSDs err:%v=======", err)
 	}
 	if !isAlreadyRaided {
 		return fmt.Errorf("failed raiding, raided device not found on scanning")

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

@@ -315,7 +315,7 @@ func (gceCS *GCEControllerServer) CreateVolume(ctx context.Context, req *csi.Cre
 	// Apply Parameters (case-insensitive). We leave validation of
 	// the values to the cloud provider.
 	params, dataCacheParams, err := common.ExtractAndDefaultParameters(req.GetParameters(), gceCS.Driver.name, gceCS.Driver.extraVolumeLabels, gceCS.enableStoragePools, gceCS.enableDataCache, gceCS.Driver.extraTags)
-	klog.V(2).Infof("====== dataCacheParams are %v ======", dataCacheParams, gceCS.Driver.extraTags)
+	klog.V(2).Infof("====== dataCacheParams are %v ======", dataCacheParams)
 	diskTypeForMetric = params.DiskType
 	enableConfidentialCompute = strconv.FormatBool(params.EnableConfidentialCompute)
 	hasStoragePools := len(params.StoragePools) > 0

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

@@ -481,7 +481,7 @@ func (ns *GCENodeServer) NodeUnstageVolume(ctx context.Context, req *csi.NodeUns
 		// LVM PoC Steps
 		klog.V(2).Infof("====== Start LVM PoC NodeUnstageVolume Steps ======")
 		nodeId := ns.MetadataService.GetName()
-		err = cleanupCache(volumeID, nodeId)
+		err := cleanupCache(volumeID, nodeId)
 		if err != nil {
 			klog.Errorf("Failed to cleanup cache: %v", err)
 		}

test/e2e/tests/single_zone_e2e_test.go

@@ -1535,7 +1535,7 @@ var _ = Describe("GCE PD CSI Driver", func() {
 
 		// Stage Disk
 		stageDir := filepath.Join("/tmp/", volName, "stage")
-		err = client.NodeStageExt4Volume(volID, stageDir)
+		err = client.NodeStageExt4Volume(volID, stageDir, false)
 		Expect(err).To(BeNil(), "failed to stage volume: %v", err)
 
 		// Create private bind mount