diff --git a/pkg/cloud/devicemanager/manager.go b/pkg/cloud/devicemanager/manager.go index efa4bec15..742d93732 100644 --- a/pkg/cloud/devicemanager/manager.go +++ b/pkg/cloud/devicemanager/manager.go @@ -205,7 +205,7 @@ func (d *deviceManager) release(device *Device) error { return fmt.Errorf("release on device %q assigned to different volume: %q vs %q", device.Path, device.VolumeID, existingVolumeID) } - klog.V(5).Infof("Releasing in-process attachment entry: %v -> volume %s", device, device.VolumeID) + klog.V(5).Infof("Releasing in-process attachment entry: %v -> volume %s", device.Path, device.VolumeID) d.inFlight.Del(nodeID, name) return nil diff --git a/pkg/driver/controller.go b/pkg/driver/controller.go index 13aca1541..e4473bff3 100644 --- a/pkg/driver/controller.go +++ b/pkg/driver/controller.go @@ -342,7 +342,7 @@ func (d *controllerService) CreateSnapshot(ctx context.Context, req *csi.CreateS if snapshot.SourceVolumeID != volumeID { return nil, status.Errorf(codes.AlreadyExists, "Snapshot %s already exists for different volume (%s)", snapshotName, snapshot.SourceVolumeID) } else { - klog.Infof("Snapshot %s of volume %s already exists; nothing to do", snapshotName, volumeID) + klog.V(4).Infof("Snapshot %s of volume %s already exists; nothing to do", snapshotName, volumeID) return newCreateSnapshotResponse(snapshot) } } diff --git a/pkg/driver/identity.go b/pkg/driver/identity.go index 35e37b63c..385207419 100644 --- a/pkg/driver/identity.go +++ b/pkg/driver/identity.go @@ -24,7 +24,7 @@ import ( ) func (d *Driver) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error) { - klog.V(4).Infof("GetPluginInfo: called with args %+v", *req) + klog.V(6).Infof("GetPluginInfo: called with args %+v", *req) resp := &csi.GetPluginInfoResponse{ Name: DriverName, VendorVersion: driverVersion, @@ -34,7 +34,7 @@ func (d *Driver) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoReques } func (d *Driver) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error) { - klog.V(4).Infof("GetPluginCapabilities: called with args %+v", *req) + klog.V(6).Infof("GetPluginCapabilities: called with args %+v", *req) resp := &csi.GetPluginCapabilitiesResponse{ Capabilities: []*csi.PluginCapability{ { diff --git a/pkg/driver/node.go b/pkg/driver/node.go index f8df86c67..921eb8efc 100644 --- a/pkg/driver/node.go +++ b/pkg/driver/node.go @@ -112,7 +112,7 @@ func (d *nodeService) NodeStageVolume(ctx context.Context, req *csi.NodeStageVol return nil, status.Error(codes.Internal, msg) } defer func() { - klog.Infof("NodeStageVolume: volume=%q operation finished", req.GetVolumeId()) + klog.V(4).Infof("NodeStageVolume: volume=%q operation finished", req.GetVolumeId()) d.inFlight.Delete(req) }() @@ -126,7 +126,7 @@ func (d *nodeService) NodeStageVolume(ctx context.Context, req *csi.NodeStageVol return nil, status.Errorf(codes.Internal, "Failed to find device path %s. %v", devicePath, err) } - klog.Infof("NodeStageVolume: find device path %s -> %s", devicePath, source) + klog.V(4).Infof("NodeStageVolume: find device path %s -> %s", devicePath, source) exists, err := d.mounter.ExistsPath(target) if err != nil { @@ -138,7 +138,7 @@ func (d *nodeService) NodeStageVolume(ctx context.Context, req *csi.NodeStageVol // Otherwise we need to create the target directory. if !exists { // If target path does not exist we need to create the directory where volume will be staged - klog.Infof("NodeStageVolume: creating target dir %q", target) + klog.V(4).Infof("NodeStageVolume: creating target dir %q", target) if err = d.mounter.MakeDir(target); err != nil { msg := fmt.Sprintf("could not create target dir %q: %v", target, err) return nil, status.Error(codes.Internal, msg) @@ -156,7 +156,7 @@ func (d *nodeService) NodeStageVolume(ctx context.Context, req *csi.NodeStageVol // If the volume corresponding to the volume_id is already staged to the staging_target_path, // and is identical to the specified volume_capability the Plugin MUST reply 0 OK. if device == source { - klog.Infof("NodeStageVolume: volume=%q already staged", volumeID) + klog.V(4).Infof("NodeStageVolume: volume=%q already staged", volumeID) return &csi.NodeStageVolumeResponse{}, nil } @@ -337,7 +337,7 @@ func (d *nodeService) nodePublishVolumeForBlock(req *csi.NodePublishVolumeReques return status.Errorf(codes.Internal, "Failed to find device path %s. %v", devicePath, err) } - klog.Infof("NodePublishVolume [block]: find device path %s -> %s", devicePath, source) + klog.V(4).Infof("NodePublishVolume [block]: find device path %s -> %s", devicePath, source) globalMountPath := filepath.Dir(target)