Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for RemoveVolumeFromReportAsAttached (0.39 sec)

  1. pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go

    	if err != nil {
    		t.Fatalf("SetDetachRequestTime failed. Expected: <no error> Actual: <%v>", err)
    	}
    	err = asw.RemoveVolumeFromReportAsAttached(generatedVolumeName, nodeName)
    	if err != nil {
    		t.Fatalf("RemoveVolumeFromReportAsAttached failed. Expected: <no error> Actual: <%v>", err)
    	}
    	expectedDetachRequestedTime := asw.GetAttachedVolumes()[0].DetachRequestedTime
    
    	// Act
    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

    	asw.DeleteVolumeNode(volumeName, nodeName)
    }
    
    func (asw *actualStateOfWorld) RemoveVolumeFromReportAsAttached(
    	volumeName v1.UniqueVolumeName, nodeName types.NodeName) error {
    	asw.Lock()
    	defer asw.Unlock()
    	return asw.removeVolumeFromReportAsAttached(volumeName, nodeName)
    }
    
    func (asw *actualStateOfWorld) AddVolumeToReportAsAttached(
    	logger klog.Logger,
    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.go

    			// has the correct volume attachment information.
    			err = rc.actualStateOfWorld.RemoveVolumeFromReportAsAttached(attachedVolume.VolumeName, attachedVolume.NodeName)
    			if err != nil {
    				logger.V(5).Info("RemoveVolumeFromReportAsAttached failed while removing volume from node",
    					"node", klog.KRef("", string(attachedVolume.NodeName)),
    					"volumeName", attachedVolume.VolumeName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 21:02:38 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/cache/actual_state_of_world.go

    func (asw *actualStateOfWorld) AddVolumeToReportAsAttached(logger klog.Logger, volumeName v1.UniqueVolumeName, nodeName types.NodeName) {
    	// no operation for kubelet side
    }
    
    func (asw *actualStateOfWorld) RemoveVolumeFromReportAsAttached(volumeName v1.UniqueVolumeName, nodeName types.NodeName) error {
    	// no operation for kubelet side
    	return nil
    }
    
    func (asw *actualStateOfWorld) MarkVolumeAsUnmounted(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 45.8K bytes
    - Viewed (0)
  5. pkg/volume/util/operationexecutor/operation_executor.go

    	MarkVolumeAsDetached(volumeName v1.UniqueVolumeName, nodeName types.NodeName)
    
    	// Marks desire to detach the specified volume (remove the volume from the node's
    	// volumesToReportAsAttached list)
    	RemoveVolumeFromReportAsAttached(volumeName v1.UniqueVolumeName, nodeName types.NodeName) error
    
    	// Unmarks the desire to detach for the specified volume (add the volume back to
    	// the node's volumesToReportAsAttached list)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  6. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    	time.Sleep(100 * time.Millisecond)
    	reconciliationLoopFunc(ctx)
    	// Right before detach operation is performed, the volume will be first removed from being reported
    	// as attached on node status (RemoveVolumeFromReportAsAttached). After UpdateNodeStatus operation which is expected to fail,
    	// controller then added the volume back as attached.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
Back to top