Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for updateRuntimeUp (0.15 sec)

  1. pkg/kubelet/kubelet_node_status_test.go

    	clock.SetTime(time.Now().Add(-maxWaitForContainerRuntime))
    	kubelet.updateRuntimeUp()
    	checkNodeStatus(v1.ConditionFalse, "KubeletNotReady")
    
    	// Should report kubelet ready if the runtime check is updated
    	clock.SetTime(time.Now())
    	kubelet.updateRuntimeUp()
    	checkNodeStatus(v1.ConditionTrue, "KubeletReady")
    
    	// Should report kubelet not ready if the runtime check is out of date
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_node_status.go

    	kl.syncNodeStatusMux.Lock()
    	defer func() {
    		kl.syncNodeStatusMux.Unlock()
    
    		if completed {
    			// containerRuntimeReadyExpected is read by updateRuntimeUp().
    			// Not going for a more granular mutex as this path runs only once.
    			kl.updateRuntimeMux.Lock()
    			defer kl.updateRuntimeMux.Unlock()
    			kl.containerRuntimeReadyExpected = true
    		}
    	}()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet.go

    	}
    	return val.(time.Time)
    }
    
    // updateRuntimeUp calls the container runtime status callback, initializing
    // the runtime dependent modules when the container runtime first comes up,
    // and returns an error if the status check fails.  If the status check is OK,
    // update the container runtime uptime in the kubelet runtimeState.
    func (kl *Kubelet) updateRuntimeUp() {
    	kl.updateRuntimeMux.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top