Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for HasAddedPods (0.13 sec)

  1. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go

    	// Wait for the completion of a loop that started after sources are all ready, then set hasAddedPods accordingly
    	klog.InfoS("Desired state populator starts to run")
    	wait.PollUntil(dswp.loopSleepDuration, func() (bool, error) {
    		done := sourcesReady.AllReady()
    		dswp.populatorLoop()
    		return done, nil
    	}, stopCh)
    	dswp.hasAddedPodsLock.Lock()
    	if !dswp.hasAddedPods {
    		klog.InfoS("Finished populating initial desired state of world")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  2. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go

    		{
    			desc:          "HasAddedPods is false, ShouldPodRuntimeBeRemoved is false, ShouldPodContainerBeTerminating is true",
    			hasAddedPods:  false,
    			podState:      Terminating,
    			expectedFound: true, // Pod should be added to DSW
    		},
    		{
    			desc:          "HasAddedPods is false, other condition",
    			hasAddedPods:  false,
    			podState:      Other,
    			expectedFound: true, // Pod should be added to DSW
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.4K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/reconciler/reconciler_test.go

    	nodeName                     = k8stypes.NodeName("mynodename")
    	kubeletPodsDir               = "fake-dir"
    	testOperationBackOffDuration = 100 * time.Millisecond
    	reconcilerSyncWaitDuration   = 10 * time.Second
    )
    
    func hasAddedPods() bool { return true }
    
    // Calls Run()
    // Verifies there are no calls to attach, detach, mount, unmount, etc.
    func Test_Run_Positive_DoNothing(t *testing.T) {
    	// Arrange
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/volume_manager.go

    		kubeClient,
    		controllerAttachDetachEnabled,
    		reconcilerLoopSleepPeriod,
    		waitForAttachTimeout,
    		nodeName,
    		vm.desiredStateOfWorld,
    		vm.actualStateOfWorld,
    		vm.desiredStateOfWorldPopulator.HasAddedPods,
    		vm.operationExecutor,
    		mounter,
    		hostutil,
    		volumePluginMgr,
    		kubeletPodsDir)
    
    	return vm
    }
    
    // volumeManager implements the VolumeManager interface
    type volumeManager struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 21.5K bytes
    - Viewed (0)
Back to top