- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for SetVolumesMountedByNode (0.29 sec)
-
pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go
if addErr != nil { t.Fatalf("AddVolumeNode failed. Expected: <no error> Actual: <%v>", addErr) } // Act asw.SetVolumesMountedByNode(logger, []v1.UniqueVolumeName{generatedVolumeName}, nodeName) asw.SetVolumesMountedByNode(logger, nil, nodeName) attachedVolumes := asw.GetAttachedVolumes() if len(attachedVolumes) != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 66.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world.go
} return volumeName, nil } func (asw *actualStateOfWorld) SetVolumesMountedByNode( logger klog.Logger, volumeNames []v1.UniqueVolumeName, nodeName types.NodeName) { asw.Lock() defer asw.Unlock() asw.inUseVolumes[nodeName] = sets.New(volumeNames...) logger.V(5).Info("SetVolumesMountedByNode volume to the node", "node", klog.KRef("", string(nodeName)), "volumeNames", volumeNames) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 28.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
"Deleted pod %q from volume %q/node %q. Volume should also be deleted but it still exists.", podName, generatedVolumeName, nodeName) } asw.SetVolumesMountedByNode(logger, []v1.UniqueVolumeName{generatedVolumeName}, nodeName) asw.SetVolumesMountedByNode(logger, nil, nodeName) // Assert waitForNewDetacherCallCount(t, 1 /* expectedCallCount */, fakePlugin)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
if err != nil { logger.Error(err, "Failed to mark the volume as attached") continue } } adc.actualStateOfWorld.SetVolumesMountedByNode(logger, node.Status.VolumesInUse, nodeName) adc.addNodeToDswp(node, types.NodeName(node.Name)) } err = adc.processVolumeAttachments(logger) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0)