Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for IsVolumeReconstructed (0.27 sec)

  1. pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go

    func verifyVolumeFoundInReconstruction(t *testing.T, podToCheck volumetypes.UniquePodName, volumeToCheck v1.UniqueVolumeName, asw ActualStateOfWorld) {
    	isRecontructed := asw.IsVolumeReconstructed(volumeToCheck, podToCheck)
    	if !isRecontructed {
    		t.Fatalf("ASW IsVolumeReconstructed result invalid. expected <true> Actual <false>")
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  2. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    					return fmt.Errorf("expected 1 uncertain volume in asw got %d", len(volumes))
    				}
    				// The volume should be marked as reconstructed in ASW
    				if reconstructed := rcInstance.actualStateOfWorld.IsVolumeReconstructed("fake-plugin/pvc-abcdef", "pod1"); !reconstructed {
    					t.Errorf("expected volume to be marked as reconstructed, got %v", reconstructed)
    				}
    				return nil
    			},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  3. pkg/volume/util/operationexecutor/operation_executor.go

    	CheckAndMarkDeviceUncertainViaReconstruction(volumeName v1.UniqueVolumeName, deviceMountPath string) bool
    
    	// IsVolumeReconstructed returns true if volume currently added to actual state of the world
    	// was found during reconstruction.
    	IsVolumeReconstructed(volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName) bool
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/cache/actual_state_of_world.go

    	return nil
    }
    
    func (asw *actualStateOfWorld) MarkVolumeAsDetached(
    	volumeName v1.UniqueVolumeName, nodeName types.NodeName) {
    	asw.DeleteVolume(volumeName)
    }
    
    func (asw *actualStateOfWorld) IsVolumeReconstructed(volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName) bool {
    	volumeState := asw.GetVolumeMountState(volumeName, podName)
    
    	// only uncertain volumes are reconstructed
    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_generator.go

    		// if volume was previously reconstructed we are not going to change its state as unmounted even
    		// if mount operation fails.
    		if actualStateOfWorld.IsVolumeReconstructed(volumeToMount.VolumeName, volumeToMount.PodName) {
    			klog.V(3).InfoS("MountVolume.markVolumeErrorState leaving volume uncertain", "volumeName", volumeToMount.VolumeName)
    			return
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
Back to top