Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for not_ready (0.14 sec)

  1. pkg/kubelet/nodestatus/setters.go

    		// NOTE(aaronlevy): NodeReady condition needs to be the last in the list of node conditions.
    		// This is due to an issue with version skewed kubelet and master components.
    		// ref: https://github.com/kubernetes/kubernetes/issues/16961
    		currentTime := metav1.NewTime(nowFunc())
    		newNodeReadyCondition := v1.NodeCondition{
    			Type:              v1.NodeReady,
    			Status:            v1.ConditionTrue,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  2. platforms/jvm/toolchains-jvm-shared/src/test/groovy/org/gradle/jvm/toolchain/internal/install/DefaultJdkCacheDirectoryTest.groovy

            new File(temporaryFolder, "jdks/jdk-mac-2/" + DefaultJdkCacheDirectory.MARKER_FILE).createNewFile()
    
            new File(temporaryFolder, "jdks/notReady").tap { mkdirs() }
    
            when:
            def homes = jdkCacheDirectory.listJavaHomes()
    
            then:
            homes == ([install1, install2] as Set)
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 09 06:41:24 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/cmd/phases/join/kubelet.go

    	node, err := bootstrapClient.CoreV1().Nodes().Get(context.TODO(), nodeName, metav1.GetOptions{})
    	if err != nil && !apierrors.IsNotFound(err) {
    		return errors.Wrapf(err, "cannot get Node %q", nodeName)
    	}
    	for _, cond := range node.Status.Conditions {
    		if cond.Type == v1.NodeReady && cond.Status == v1.ConditionTrue {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_node_status.go

    		return false
    	}
    
    	readyIdx, nodeReady := nodeutil.GetNodeCondition(&node.Status, v1.NodeReady)
    	if readyIdx == -1 {
    		klog.ErrorS(nil, "Node does not have NodeReady condition", "node", node)
    		return false
    	}
    
    	if nodeReady.Status == v1.ConditionFalse {
    		return false
    	}
    
    	klog.InfoS("Fast updating node status as it just became ready")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  5. src/internal/trace/oldtrace.go

    				// the states _Gidle or _Grunnable.
    				it.extra = append(it.extra, Event{
    					ctx: schedCtx{
    						// G: GoID(gid),
    						G: NoGoroutine,
    						P: NoProc,
    						M: NoThread,
    					},
    					table: it.evt,
    					base: baseEvent{
    						typ:  go122.EvGoStatus,
    						time: Time(ev.Ts),
    						args: timedEventArgs{uint64(gid), ^uint64(0), uint64(go122.GoRunnable)},
    					},
    				})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  6. cni/pkg/install/install.go

    	default:
    		// Valid configuration; set isReady to true and wait for modifications before checking again
    		setReady(in.isReady)
    		cniInstalls.With(resultLabel.Value(resultSuccess)).Increment()
    		// Pod set to "NotReady" before termination
    		return watcher.Wait(ctx)
    	}
    }
    
    // checkValidCNIConfig returns an error if an invalid CNI configuration is detected
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 21:45:18 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  7. src/internal/trace/testtrace/validation.go

    		tr := ev.StateTransition()
    		if tr.Resource.Kind != trace.ResourceGoroutine {
    			return false
    		}
    		from, to := tr.Goroutine()
    		return from == trace.GoUndetermined && to == trace.GoSyscall
    	}
    	if m == trace.NoThread && !lenient() {
    		e.Errorf("must have thread, but thread ID is none")
    		return nil
    	}
    	s, ok := v.ms[m]
    	if !ok {
    		s = &schedContext{M: m, P: trace.NoProc, G: trace.NoGoroutine}
    		v.ms[m] = s
    		return s
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  8. src/internal/trace/event.go

    //
    // Note that for thread state transitions this always refers to the
    // state before the transition. For example, if a thread is just
    // starting to run, then this will return NoThread.
    //
    // Note: tracking thread state is not currently supported, so this
    // will always return a valid thread ID. However thread state transitions
    // may be tracked in the future, and callers must be robust to this
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 12:39:00 UTC 2024
    - 28.9K bytes
    - Viewed (0)
  9. pkg/controller/endpointslice/endpointslice_controller.go

    	}
    	return endpointSlice
    }
    
    // isNodeReady returns true if a node is ready; false otherwise.
    func isNodeReady(node *v1.Node) bool {
    	for _, c := range node.Status.Conditions {
    		if c.Type == v1.NodeReady {
    			return c.Status == v1.ConditionTrue
    		}
    	}
    	return false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  10. pkg/controller/endpoint/endpoints_controller.go

    	return !ok
    }
    
    // truncateEndpoints by best effort will distribute the endpoints over the subsets based on the proportion
    // of endpoints per subset and will prioritize Ready Endpoints over NotReady Endpoints.
    func truncateEndpoints(endpoints *v1.Endpoints) bool {
    	totalReady := 0
    	totalNotReady := 0
    	for _, subset := range endpoints.Subsets {
    		totalReady += len(subset.Addresses)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 26.3K bytes
    - Viewed (0)
Back to top