Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for volumesNeedUpdateFromNodeStatus (0.39 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top