Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 44 for finishes (1.19 sec)

  1. CHANGELOG/CHANGELOG-1.28.md

      - If no QueueingHintFn returns QueueImmediately and more than one plugin returns QueueAfterBackoff, it queues Pod to backoffQ if Pod is backing off, or to activeQ if Pod's backoff has already finished.
      - If all QueueingHintFn return QueueSkip, it puts this pod back to the unschedulable pod pool
      
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 23:47:59 UTC 2024
    - 408.3K bytes
    - Viewed (0)
  2. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    	assert.NoError(t, result.Error())
    	verifyContainerStatuses(t, fakeRuntime, expected, "init container still running; do nothing")
    
    	// 3. should create all app containers because init container finished.
    	// Stop init container instance 0.
    	sandboxIDs, err := m.getSandboxIDByPodUID(ctx, pod.UID, nil)
    	require.NoError(t, err)
    	sandboxID := sandboxIDs[0]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_pods.go

    		if kl.containerManager.PodMightNeedToUnprepareResources(pod.UID) {
    			return true
    		}
    	}
    	return false
    }
    
    // PodIsFinished returns true if SyncTerminatedPod is finished, ie.
    // all required node-level resources that a pod was consuming have
    // been reclaimed by the kubelet.
    func (kl *Kubelet) PodIsFinished(pod *v1.Pod) bool {
    	return kl.podWorkers.ShouldPodBeFinished(pod.UID)
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    			if err != nil {
    				return err
    			}
    			diskVersions[index] = resp.Sign
    			dataDirs[index] = resp.OldDataDir
    			return nil
    		}, index)
    	}
    
    	// Wait for all renames to finish.
    	errs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    	if err != nil {
    		dg := errgroup.WithNErrs(len(disks))
    		for index, nerr := range errs {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    			},
    			{
    				Description: MetricDescription{
    					Namespace: nodeMetricNamespace,
    					Subsystem: scannerSubsystem,
    					Name:      "bucket_scans_finished",
    					Help:      "Total number of bucket scans finished since server uptime",
    					Type:      counterMetric,
    				},
    				Value: float64(globalScannerMetrics.lifetime(scannerMetricScanBucketDrive)),
    			},
    			{
    				Description: MetricDescription{
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:54 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.27.md

    - Kubectl explain should correctly work for all resources ([#118876](https://github.com/kubernetes/kubernetes/pull/118876), [@atiratree](https://github.com/atiratree)) [SIG CLI]
    - Only declare Job as finished after removing all Pod finalizers to avoid orphan Pods ([#119160](https://github.com/kubernetes/kubernetes/pull/119160), [@alculquicondor](https://github.com/alculquicondor)) [SIG Apps and Testing]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 23:01:06 UTC 2024
    - 455.3K bytes
    - Viewed (0)
  7. cmd/bucket-replication.go

    	for {
    		select {
    		case <-resyncTimer.C:
    			s.RLock()
    			for bucket, brs := range s.statusMap {
    				var updt bool
    				// Save the replication status if one resync to any bucket target is still not finished
    				for _, st := range brs.TargetsMap {
    					if st.LastUpdate.Equal(timeSentinel) {
    						updt = true
    						break
    					}
    				}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 114.4K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_test.go

    		MemoryThrottlingFactor:                    utilpointer.Float64(0),
    	}
    	var prober volume.DynamicPluginProber
    	tp := noopoteltrace.NewTracerProvider()
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    	cadvisor := cadvisortest.NewMockInterface(mockCtrl)
    	cadvisor.EXPECT().MachineInfo().Return(&cadvisorapi.MachineInfo{}, nil).AnyTimes()
    	cadvisor.EXPECT().ImagesFsInfo().Return(cadvisorapiv2.FsInfo{
    		Usage:     400,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  9. src/cmd/link/internal/ld/data.go

    			state.datsize += ldr.SymSize(s)
    		}
    		state.checkdatsize(sym.STLSBSS)
    
    		if sect != nil {
    			sect.Length = uint64(state.datsize)
    		}
    	}
    
    	/*
    	 * We finished data, begin read-only data.
    	 * Not all systems support a separate read-only non-executable data section.
    	 * ELF and Windows PE systems do.
    	 * OS X and Plan 9 do not.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 12 15:10:50 UTC 2024
    - 100.5K bytes
    - Viewed (0)
  10. pkg/scheduler/internal/queue/scheduling_queue_test.go

    			podInfo:   &framework.QueuedPodInfo{PodInfo: mustNewPodInfo(p), UnschedulablePlugins: sets.New("foo")},
    			hint:      queueHintReturnQueue,
    			duration:  DefaultPodInitialBackoffDuration, // backoff is finished
    			expectedQ: activeQ,
    		},
    		{
    			name:      "Skip queues pod to unschedulablePods",
    			podInfo:   &framework.QueuedPodInfo{PodInfo: mustNewPodInfo(p), UnschedulablePlugins: sets.New("foo")},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
Back to top