Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ require (
k8s.io/client-go v11.0.1-0.20190805182717-6502b5e7b1b5+incompatible
k8s.io/cloud-provider v0.24.1
k8s.io/component-base v0.24.1
k8s.io/klog/v2 v2.100.1
k8s.io/klog/v2 v2.120.1
k8s.io/mount-utils v0.29.0-alpha.2
k8s.io/utils v0.0.0-20230726121419-3b25d923346b
sigs.k8s.io/boskos v0.0.0-20220711194915-6cb8a6fb2dd1
Expand All @@ -50,7 +50,7 @@ require (
github.com/emicklei/go-restful v2.9.5+incompatible // indirect
github.com/felixge/httpsnoop v1.0.4 // indirect
github.com/fsnotify/fsnotify v1.5.4 // indirect
github.com/go-logr/logr v1.3.0 // indirect
github.com/go-logr/logr v1.4.1 // indirect
github.com/go-logr/stdr v1.2.2 // indirect
github.com/go-openapi/jsonpointer v0.20.0 // indirect
github.com/go-openapi/jsonreference v0.19.6 // indirect
Expand Down
8 changes: 4 additions & 4 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -1065,8 +1065,8 @@ github.com/go-logr/logr v0.2.0/go.mod h1:z6/tIYblkpsD+a4lm/fGIIU9mZ+XfAiaFtq7xTg
github.com/go-logr/logr v0.4.0/go.mod h1:z6/tIYblkpsD+a4lm/fGIIU9mZ+XfAiaFtq7xTgseGU=
github.com/go-logr/logr v1.2.0/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
github.com/go-logr/logr v1.3.0 h1:2y3SDp0ZXuc6/cjLSZ+Q3ir+QB9T/iG5yYRXqsagWSY=
github.com/go-logr/logr v1.3.0/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
github.com/go-logr/logr v1.4.1 h1:pKouT5E8xu9zeFC39JXRDukb6JFQPXM5p5I91188VAQ=
github.com/go-logr/logr v1.4.1/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
github.com/go-logr/zapr v0.1.0/go.mod h1:tabnROwaDl0UNxkVeFRbY8bwB37GwRv0P8lg6aAiEnk=
Expand Down Expand Up @@ -3321,8 +3321,8 @@ k8s.io/klog/v2 v2.0.0/go.mod h1:PBfzABfn139FHAV07az/IF9Wp1bkk3vpT2XSJ76fSDE=
k8s.io/klog/v2 v2.2.0/go.mod h1:Od+F08eJP+W3HUb4pSrPpgp9DGU4GzlpG/TmITuYh/Y=
k8s.io/klog/v2 v2.8.0/go.mod h1:hy9LJ/NvuK+iVyP4Ehqva4HxZG/oXyIS3n3Jmire4Ec=
k8s.io/klog/v2 v2.60.1/go.mod h1:y1WjHnz7Dj687irZUWR/WLkLc5N1YHtjLdmgWjndZn0=
k8s.io/klog/v2 v2.100.1 h1:7WCHKK6K8fNhTqfBhISHQ97KrnJNFZMcQvKp7gP/tmg=
k8s.io/klog/v2 v2.100.1/go.mod h1:y1WjHnz7Dj687irZUWR/WLkLc5N1YHtjLdmgWjndZn0=
k8s.io/klog/v2 v2.120.1 h1:QXU6cPEOIslTGvZaXvFWiP9VKyeet3sawzTOvdXb4Vw=
k8s.io/klog/v2 v2.120.1/go.mod h1:3Jpz1GvMt720eyJH1ckRHK1EDfpxISzJ7I9OYgaDtPE=
k8s.io/kube-openapi v0.0.0-20180731170545-e3762e86a74c/go.mod h1:BXM9ceUBTj2QnfH2MK1odQs778ajze1RxcmP6S8RVVc=
k8s.io/kube-openapi v0.0.0-20190228160746-b3a7cee44a30/go.mod h1:BXM9ceUBTj2QnfH2MK1odQs778ajze1RxcmP6S8RVVc=
k8s.io/kube-openapi v0.0.0-20190816220812-743ec37842bf/go.mod h1:1TqjTSzOxsLGIKfj0lK8EeCP7K1iUG65v09OM0/WG5E=
Expand Down
4 changes: 2 additions & 2 deletions pkg/gce-pd-csi-driver/node.go
Original file line number Diff line number Diff line change
Expand Up @@ -397,9 +397,9 @@ func (ns *GCENodeServer) NodeUnstageVolume(ctx context.Context, req *csi.NodeUns
klog.Errorf("Failed to find device path for volume %s. Device may not be detached cleanly (error is ignored and unstaging is continuing): %v", volumeID, err.Error())
} else {
if devFsPath, err := filepath.EvalSymlinks(devicePath); err != nil {
klog.Warningf("filepath.EvalSymlinks(%q) failed when trying to disable device: %w (ignored, unstaging continues)", devicePath, err)
klog.Warningf("filepath.EvalSymlinks(%q) failed when trying to disable device: %v (ignored, unstaging continues)", devicePath, err)
} else if err := ns.DeviceUtils.DisableDevice(devFsPath); err != nil {
klog.Warningf("Failed to disabled device %s (aka %s) for volume %s. Device may not be detached cleanly (ignored, unstaging continues): %w", devicePath, devFsPath, volumeID, err)
klog.Warningf("Failed to disabled device %s (aka %s) for volume %s. Device may not be detached cleanly (ignored, unstaging continues): %v", devicePath, devFsPath, volumeID, err)
}
}

Expand Down
6 changes: 3 additions & 3 deletions test/e2e/tests/multi_zone_e2e_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -296,7 +296,7 @@ func testAttachAndMount(volID string, volName string, instance *remote.InstanceI
// Detach Disk
err = client.ControllerUnpublishVolume(volID, instance.GetNodeID())
if err != nil {
klog.Errorf("Failed to detach disk: %w", err)
klog.Errorf("Failed to detach disk: %v", err)
}
}

Expand All @@ -317,12 +317,12 @@ func testAttachAndMount(volID string, volName string, instance *remote.InstanceI
// Unstage Disk
err = client.NodeUnstageVolume(volID, stageDir)
if err != nil {
klog.Errorf("Failed to unstage volume: %w", err)
klog.Errorf("Failed to unstage volume: %v", err)
}
fp := filepath.Join("/tmp/", volName)
err = testutils.RmAll(instance, fp)
if err != nil {
klog.Errorf("Failed to rm file path %s: %w", fp, err)
klog.Errorf("Failed to rm file path %s: %v", fp, err)
}

detach()
Expand Down
24 changes: 12 additions & 12 deletions test/e2e/tests/resize_e2e_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Detach Disk
err = client.ControllerUnpublishVolume(volume.VolumeId, instance.GetNodeID())
if err != nil {
klog.Errorf("Failed to detach disk: %w", err)
klog.Errorf("Failed to detach disk: %v", err)
}
}()

Expand All @@ -87,12 +87,12 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Unstage Disk
err = client.NodeUnstageVolume(volume.VolumeId, stageDir)
if err != nil {
klog.Errorf("Failed to unstage volume: %w", err)
klog.Errorf("Failed to unstage volume: %v", err)
}
fp := filepath.Join("/tmp/", volName)
err = testutils.RmAll(instance, fp)
if err != nil {
klog.Errorf("Failed to rm file path %s: %w", fp, err)
klog.Errorf("Failed to rm file path %s: %v", fp, err)
}
}()

Expand All @@ -105,7 +105,7 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Unmount Disk
err = client.NodeUnpublishVolume(volume.VolumeId, publishDir)
if err != nil {
klog.Errorf("NodeUnpublishVolume failed with error: %w", err)
klog.Errorf("NodeUnpublishVolume failed with error: %v", err)
}
}()

Expand Down Expand Up @@ -196,7 +196,7 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Detach Disk
err = client.ControllerUnpublishVolume(volume.VolumeId, instance.GetNodeID())
if err != nil {
klog.Errorf("Failed to detach disk: %w", err)
klog.Errorf("Failed to detach disk: %v", err)
}

}()
Expand All @@ -210,12 +210,12 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Unstage Disk
err = client.NodeUnstageVolume(volume.VolumeId, stageDir)
if err != nil {
klog.Errorf("Failed to unstage volume: %w", err)
klog.Errorf("Failed to unstage volume: %v", err)
}
fp := filepath.Join("/tmp/", volName)
err = testutils.RmAll(instance, fp)
if err != nil {
klog.Errorf("Failed to rm file path %s: %w", fp, err)
klog.Errorf("Failed to rm file path %s: %v", fp, err)
}
}()

Expand All @@ -228,7 +228,7 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Unmount Disk
err = client.NodeUnpublishVolume(volume.VolumeId, publishDir)
if err != nil {
klog.Errorf("NodeUnpublishVolume failed with error: %w", err)
klog.Errorf("NodeUnpublishVolume failed with error: %v", err)
}
}()

Expand Down Expand Up @@ -288,7 +288,7 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Detach Disk
err = client.ControllerUnpublishVolume(volume.VolumeId, instance.GetNodeID())
if err != nil {
klog.Errorf("Failed to detach disk: %w", err)
klog.Errorf("Failed to detach disk: %v", err)
}

}()
Expand All @@ -302,12 +302,12 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Unstage Disk
err = client.NodeUnstageVolume(volume.VolumeId, stageDir)
if err != nil {
klog.Errorf("Failed to unstage volume: %w", err)
klog.Errorf("Failed to unstage volume: %v", err)
}
fp := filepath.Join("/tmp/", volName)
err = testutils.RmAll(instance, fp)
if err != nil {
klog.Errorf("Failed to rm file path %s: %w", fp, err)
klog.Errorf("Failed to rm file path %s: %v", fp, err)
}
}()

Expand All @@ -320,7 +320,7 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Unmount Disk
err = client.NodeUnpublishVolume(volume.VolumeId, publishDir)
if err != nil {
klog.Errorf("NodeUnpublishVolume failed with error: %w", err)
klog.Errorf("NodeUnpublishVolume failed with error: %v", err)
}
}()

Expand Down
10 changes: 5 additions & 5 deletions test/e2e/tests/setup_e2e_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -122,28 +122,28 @@ func NewTestContext(zone string) *remote.TestContext {

i, err := remote.SetupInstance(*project, *architecture, zone, nodeID, *machineType, *serviceAccount, *imageURL, computeService)
if err != nil {
klog.Fatalf("Failed to setup instance %v: %w", nodeID, err)
klog.Fatalf("Failed to setup instance %v: %v", nodeID, err)
}

err = testutils.MkdirAll(i, "/lib/udev_containerized")
if err != nil {
klog.Fatalf("Failed to make scsi_id containerized directory: %w", err)
klog.Fatalf("Failed to make scsi_id containerized directory: %v", err)
}

err = testutils.CopyFile(i, "/lib/udev/scsi_id", "/lib/udev_containerized/scsi_id")
if err != nil {
klog.Fatalf("Failed to copy scsi_id to containerized directory: %w", err)
klog.Fatalf("Failed to copy scsi_id to containerized directory: %v", err)
}

err = testutils.CopyFile(i, "/lib/udev/google_nvme_id", "/lib/udev_containerized/google_nvme_id")
if err != nil {
klog.Fatalf("Failed to copy google_nvme_id to containerized directory: %w", err)
klog.Fatalf("Failed to copy google_nvme_id to containerized directory: %v", err)
}

klog.Infof("Creating new driver and client for node %s", i.GetName())
tc, err := testutils.GCEClientAndDriverSetup(i, "")
if err != nil {
klog.Fatalf("Failed to set up TestContext for instance %v: %w", i.GetName(), err)
klog.Fatalf("Failed to set up TestContext for instance %v: %v", i.GetName(), err)
}

klog.Infof("Finished creating TestContext for node %s", tc.Instance.GetName())
Expand Down
18 changes: 9 additions & 9 deletions test/e2e/tests/single_zone_e2e_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,7 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Detach Disk
err = client.ControllerUnpublishVolume(volID, instance.GetNodeID())
if err != nil {
klog.Errorf("Failed to detach disk: %w", err)
klog.Errorf("Failed to detach disk: %v", err)
}

}()
Expand Down Expand Up @@ -159,12 +159,12 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Unstage Disk
err = client.NodeUnstageVolume(volID, stageDir)
if err != nil {
klog.Errorf("Failed to unstage volume: %w", err)
klog.Errorf("Failed to unstage volume: %v", err)
}
fp := filepath.Join("/tmp/", volName)
err = testutils.RmAll(instance, fp)
if err != nil {
klog.Errorf("Failed to rm file path %s: %w", fp, err)
klog.Errorf("Failed to rm file path %s: %v", fp, err)
}
}()
})
Expand Down Expand Up @@ -197,7 +197,7 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Detach Disk
err = client.ControllerUnpublishVolume(volID, instance.GetNodeID())
if err != nil {
klog.Errorf("Failed to detach disk: %w", err)
klog.Errorf("Failed to detach disk: %v", err)
}

}()
Expand Down Expand Up @@ -229,12 +229,12 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Unstage Disk
err = client.NodeUnstageVolume(volID, stageDir)
if err != nil {
klog.Errorf("Failed to unstage volume: %w", err)
klog.Errorf("Failed to unstage volume: %v", err)
}
fp := filepath.Join("/tmp/", volName)
err = testutils.RmAll(instance, fp)
if err != nil {
klog.Errorf("Failed to rm file path %s: %w", fp, err)
klog.Errorf("Failed to rm file path %s: %v", fp, err)
}
}()
})
Expand Down Expand Up @@ -1290,15 +1290,15 @@ var _ = Describe("GCE PD CSI Driver", func() {
i, err := remote.SetupInstance(*project, *architecture, zone, nodeID, *machineType, *serviceAccount, *imageURL, computeService)

if err != nil {
klog.Fatalf("Failed to setup instance %v: %w", nodeID, err)
klog.Fatalf("Failed to setup instance %v: %v", nodeID, err)
}

klog.Infof("Creating new driver and client for node %s\n", i.GetName())

// Create new driver and client w/ invalid endpoint
tcInvalid, err := testutils.GCEClientAndDriverSetup(i, "invalid-string")
if err != nil {
klog.Fatalf("Failed to set up Test Context for instance %v: %w", i.GetName(), err)
klog.Fatalf("Failed to set up Test Context for instance %v: %v", i.GetName(), err)
}

_, err = tcInvalid.Client.ListVolumes()
Expand All @@ -1307,7 +1307,7 @@ var _ = Describe("GCE PD CSI Driver", func() {
// Create new driver and client w/ valid, passed-in endpoint
tcValid, err := testutils.GCEClientAndDriverSetup(i, "https://compute.googleapis.com")
if err != nil {
klog.Fatalf("Failed to set up Test Context for instance %v: %w", i.GetName(), err)
klog.Fatalf("Failed to set up Test Context for instance %v: %v", i.GetName(), err)
}
_, err = tcValid.Client.ListVolumes()

Expand Down
8 changes: 4 additions & 4 deletions test/e2e/utils/utils.go
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ func getBoskosProject(resourceType string) *common.Resource {
case <-ticker.C:
p, err := boskos.Acquire(resourceType, "free", "busy")
if err != nil {
klog.Warningf("boskos failed to acquire project: %w", err)
klog.Warningf("boskos failed to acquire project: %v", err)
} else if p == nil {
klog.Warningf("boskos does not have a free %s at the moment", resourceType)
} else {
Expand Down Expand Up @@ -128,17 +128,17 @@ func SetupProwConfig(resourceType string) (project, serviceAccount string) {

c, err := google.DefaultClient(context.Background(), cloudresourcemanager.CloudPlatformScope)
if err != nil {
klog.Fatalf("Failed to get Google Default Client: %w", err)
klog.Fatalf("Failed to get Google Default Client: %v", err)
}

cloudresourcemanagerService, err := cloudresourcemanager.New(c)
if err != nil {
klog.Fatalf("Failed to create new cloudresourcemanager: %w", err)
klog.Fatalf("Failed to create new cloudresourcemanager: %v", err)
}

resp, err := cloudresourcemanagerService.Projects.Get(project).Do()
if err != nil {
klog.Fatalf("Failed to get project %v from Cloud Resource Manager: %w", project, err)
klog.Fatalf("Failed to get project %v from Cloud Resource Manager: %v", project, err)
}

// Default Compute Engine service account
Expand Down
2 changes: 1 addition & 1 deletion test/k8s-integration/filter-junit.go
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ func MergeJUnit(testFilter string, sourceDirectories []string, destination strin
for _, dir := range sourceDirectories {
files, err := os.ReadDir(dir)
if err != nil {
klog.Errorf("Failed to read juint directory %s: %w", dir, err)
klog.Errorf("Failed to read juint directory %s: %v", dir, err)
mergeErrors = append(mergeErrors, err.Error())
continue
}
Expand Down
14 changes: 7 additions & 7 deletions test/k8s-integration/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -217,7 +217,7 @@ func main() {

err := handle()
if err != nil {
klog.Fatalf("Failed to run integration test: %w", err)
klog.Fatalf("Failed to run integration test: %v", err)
}
}

Expand Down Expand Up @@ -274,7 +274,7 @@ func handle() error {
defer func() {
err = setEnvProject(string(oldProject))
if err != nil {
klog.Errorf("failed to set project environment to %s: %w", oldProject, err.Error())
klog.Errorf("failed to set project environment to %s: %v", oldProject, err.Error())
}
}()
project = newproject
Expand All @@ -300,7 +300,7 @@ func handle() error {
if *teardownCluster {
err := deleteImage(*stagingImage, testParams.stagingVersion)
if err != nil {
klog.Errorf("failed to delete image: %w", err)
klog.Errorf("failed to delete image: %v", err)
}
}
}()
Expand All @@ -325,7 +325,7 @@ func handle() error {
return fmt.Errorf("failed to build Kubernetes: %v", err.Error())
}
} else {
klog.Info("Fetching precompiled Kubernetes artifacts for %s/%s", *platform, *arch)
klog.Infof("Fetching precompiled Kubernetes artifacts for %s/%s", *platform, *arch)
if err := downloadKubernetesRelease(testParams.k8sSourceDir, *kubeVersion, *platform, *arch); err != nil {
return fmt.Errorf("failed to download Kubernetes release: %v", err.Error())
}
Expand Down Expand Up @@ -382,12 +382,12 @@ func handle() error {
case "gce":
err := clusterDownGCE(testParams.k8sSourceDir)
if err != nil {
klog.Errorf("failed to cluster down: %w", err)
klog.Errorf("failed to cluster down: %v", err)
}
case "gke":
err := clusterDownGKE(*gceZone, *gceRegion)
if err != nil {
klog.Errorf("failed to cluster down: %w", err)
klog.Errorf("failed to cluster down: %v", err)
}
default:
klog.Errorf("deployment-strategy must be set to 'gce' or 'gke', but is: %s", testParams.deploymentStrategy)
Expand Down Expand Up @@ -441,7 +441,7 @@ func handle() error {
if *teardownDriver {
defer func() {
if teardownErr := deleteDriver(testParams, *deployOverlayName); teardownErr != nil {
klog.Errorf("failed to delete driver: %w", teardownErr)
klog.Errorf("failed to delete driver: %v", teardownErr)
}
}()
}
Expand Down
Loading