- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 749 for Uncertain (0.22 sec)
-
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
rcInstance.reconstructVolumes() // Assert 1 - the volume is Uncertain mountedPods := rcInstance.actualStateOfWorld.GetMountedVolumes() if len(mountedPods) != 0 { t.Errorf("expected 0 mounted volumes, got %+v", mountedPods) } allPods := rcInstance.actualStateOfWorld.GetAllMountedVolumes() if len(allPods) != 1 { t.Errorf("expected 1 uncertain volume in asw, got %+v", allPods) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct.go
} seLinuxMountContext = volume.seLinuxMountContext klog.V(2).InfoS("Volume is marked as uncertain and added into the actual state", "pod", klog.KObj(volume.pod), "podName", volume.podName, "volumeName", volume.volumeName, "seLinuxMountContext", volume.seLinuxMountContext) } // If the volume has device to mount, we mark its device as uncertain. if gvl.deviceMounter != nil || gvl.blockVolumeMapper != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
volumeName) } podObj, podExists := volumeObj.mountedPods[podName] updateUncertainVolume := false if podExists { // Update uncertain volumes - the new markVolumeOpts may have updated information. // Especially reconstructed volumes (marked as uncertain during reconstruction) need // an update.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler.go
} if len(rc.volumesNeedUpdateFromNodeStatus) != 0 { rc.updateReconstructedFromNodeStatus() } if len(rc.volumesNeedUpdateFromNodeStatus) == 0 { // ASW is fully populated only after both devicePaths and uncertain volume attach-ability // were reconstructed from the API server. // This will start reconciliation of node.status.volumesInUse. rc.updateLastSyncTime() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
if actualStateOfWorld.IsVolumeDeviceReconstructed(volumeToMount.VolumeName) { klog.V(2).InfoS("MountVolume.markDeviceErrorState leaving volume uncertain", "volumeName", volumeToMount.VolumeName) return } // Only devices which were uncertain can be marked as unmounted markDeviceUnmountError := actualStateOfWorld.MarkDeviceAsUnmounted(volumeToMount.VolumeName) if markDeviceUnmountError != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
if !attachable { t.Errorf("ASW reports %s as not-attachable, when %s was expected", volumeToCheck, expected) } // ASW does not have any special difference between False and Uncertain. // Uncertain only allows to be changed to True / False. case volumeAttachabilityUncertain, volumeAttachabilityFalse: if attachable { t.Errorf("ASW reports %s as attachable, when %s was expected", volumeToCheck, expected)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
unmountDeviceCallCount int volumeName string supportRemount bool }{ { name: "timed out operations should result in device marked as uncertain", deviceState: operationexecutor.DeviceMountUncertain, unmountDeviceCallCount: 1, volumeName: volumetesting.TimeoutOnMountDeviceVolumeName, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
// GetPossiblyMountedVolumesForPod returns a VolumeMap containing the volumes // referenced by the specified pod that are either successfully attached // and mounted or are "uncertain", i.e. a volume plugin may be mounting // them right now. The key in the map is the OuterVolumeSpecName (i.e. // pod.Spec.Volumes[x].Name). It returns an empty VolumeMap if pod has no // volumes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes.go
} return volumesToReturn, len(volumesToReturn) > 0 } // podVolumesExist checks with the volume manager and returns true any of the // pods for the specified volume are mounted or are uncertain. func (kl *Kubelet) podVolumesExist(podUID types.UID) bool { if mountedVolumes := kl.volumeManager.GetPossiblyMountedVolumesForPod( volumetypes.UniquePodName(podUID)); len(mountedVolumes) > 0 { return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world.go
// the underlying store indicating the specified volume is attached to the // specified node, AttachStateDetached if the combo does not exist, or // AttachStateUncertain if the attached state is marked as uncertain. GetAttachState(volumeName v1.UniqueVolumeName, nodeName types.NodeName) AttachState // GetAttachedVolumes generates and returns a list of volumes/node pairs
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 28.7K bytes - Viewed (0)