Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for addVolumeToReportAsAttached (0.26 sec)

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

    	defer asw.Unlock()
    	return asw.removeVolumeFromReportAsAttached(volumeName, nodeName)
    }
    
    func (asw *actualStateOfWorld) AddVolumeToReportAsAttached(
    	logger klog.Logger,
    	volumeName v1.UniqueVolumeName, nodeName types.NodeName) {
    	asw.Lock()
    	defer asw.Unlock()
    	asw.addVolumeToReportAsAttached(logger, volumeName, nodeName)
    }
    
    func (asw *actualStateOfWorld) AddVolumeNode(
    	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)
  2. pkg/controller/volume/attachdetach/reconciler/reconciler.go

    				// It is needed here too because DetachVolume is not call actually and we keep the data consistency for every reconcile.
    				rc.actualStateOfWorld.AddVolumeToReportAsAttached(logger, attachedVolume.VolumeName, attachedVolume.NodeName)
    				continue
    			}
    
    			// Trigger detach volume which requires verifying safe to detach step
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 21:02:38 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  3. pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go

    	}
    
    }
    
    // Populates data struct with one volume/node entry.
    // Calls RemoveVolumeFromReportAsAttached
    // Calls AddVolumeToReportAsAttached to add volume back as attached
    // Verifies there is one volume as reported as attached
    func Test_RemoveVolumeFromReportAsAttached_AddVolumeToReportAsAttached_Positive(t *testing.T) {
    	// Arrange
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 07:35:17 UTC 2024
    - 66.1K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/cache/actual_state_of_world.go

    }
    
    func (asw *actualStateOfWorld) MarkVolumeAsMounted(markVolumeOpts operationexecutor.MarkVolumeOpts) error {
    	return asw.AddPodToVolume(markVolumeOpts)
    }
    
    func (asw *actualStateOfWorld) AddVolumeToReportAsAttached(logger klog.Logger, volumeName v1.UniqueVolumeName, nodeName types.NodeName) {
    	// no operation for kubelet side
    }
    
    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

    	// Unmarks the desire to detach for the specified volume (add the volume back to
    	// the node's volumesToReportAsAttached list)
    	AddVolumeToReportAsAttached(logger klog.Logger, volumeName v1.UniqueVolumeName, nodeName types.NodeName)
    
    	// InitializeClaimSize sets pvc claim size by reading pvc.Status.Capacity
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 42.6K bytes
    - Viewed (0)
Back to top