Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for SetVolumesMountedByNode (0.29 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top