- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for volumesNeedUpdateFromNodeStatus (0.39 sec)
-
pkg/kubelet/volumemanager/reconciler/reconciler.go
rc.unmountDetachDevices() // Clean up any orphan volumes that failed reconstruction. rc.cleanOrphanVolumes() } 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.
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/kubelet/volumemanager/reconciler/reconstruct.go
if !rc.populatorHasAddedPods() { return false } // Allow unmount only when ASW device paths were corrected from node.status to prevent // calling unmount with a wrong devicePath. if len(rc.volumesNeedUpdateFromNodeStatus) != 0 { return false } return true } // reconstructVolumes tries to reconstruct the actual state of world by scanning all pods' volume
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/reconciler/reconstruct_test.go
expectedVolumes[i] = v1.UniqueVolumeName(tc.expectedVolumesNeedDevicePath[i]) } if !reflect.DeepEqual(expectedVolumes, rcInstance.volumesNeedUpdateFromNodeStatus) { t.Errorf("Expected expectedVolumesNeedDevicePath:\n%v\n got:\n%v", expectedVolumes, rcInstance.volumesNeedUpdateFromNodeStatus) } volumesFailedReconstruction := sets.New[string]() for _, vol := range rcInstance.volumesFailedReconstruction {
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/reconciler_common.go
volumePluginMgr: volumePluginMgr, kubeletPodsDir: kubeletPodsDir, timeOfLastSync: time.Time{}, volumesFailedReconstruction: make([]podVolume, 0), volumesNeedUpdateFromNodeStatus: make([]v1.UniqueVolumeName, 0), } } type reconciler struct { kubeClient clientset.Interface controllerAttachDetachEnabled bool loopSleepDuration time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
assert.False(t, reconciler.StatesHasBeenSynced()) reconciler.volumesNeedUpdateFromNodeStatus = append(reconciler.volumesNeedUpdateFromNodeStatus, volumeName1, volumeName2) // Act - run reconcile loop just once. // "volumesNeedUpdateFromNodeStatus" is not empty, so no unmount will be triggered. reconciler.reconcile() // Assert
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0)