Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 241 for probing (0.13 sec)

  1. src/cmd/go/internal/modload/edit.go

    					// To ensure that this algorithm terminates, don't try it again.
    					continue
    				}
    				pruning := rootPruning
    				if pruning == pruned {
    					if summary, err := mg.loadCache.Get(m); err == nil {
    						pruning = summary.pruning
    					}
    				}
    				if t.check(prev, pruning).isDisqualified() {
    					// We found a problem with prev this round that would also disqualify
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 15 21:46:32 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/examples/stateful/stateful.go

    	mp.mu.Lock()
    	defer mp.mu.Unlock()
    	mp.executionPoints = nil
    }
    
    // PreBind is the function invoked by the framework at "prebind" extension
    // point.
    func (mp *MultipointExample) PreBind(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status {
    	// PreBind could be called concurrently for different pods.
    	mp.mu.Lock()
    	defer mp.mu.Unlock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 09 03:43:17 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet.go

    		// there was an error killing the pod, so we return that error directly
    		utilruntime.HandleError(err)
    		return err
    	}
    
    	// Once the containers are stopped, we can stop probing for liveness and readiness.
    	// TODO: once a pod is terminal, certain probes (liveness exec) could be stopped immediately after
    	//   the detection of a container shutdown or (for readiness) after the first failure. Tracked as
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  4. src/cmd/go/internal/modload/buildlist.go

    // If rs already has the given pruning, convertPruning returns rs unmodified.
    func convertPruning(ctx context.Context, rs *Requirements, pruning modPruning) (*Requirements, error) {
    	if rs.pruning == pruning {
    		return rs, nil
    	} else if rs.pruning == workspace || pruning == workspace {
    		panic("attempting to convert to/from workspace pruning and another pruning type")
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 16:04:44 UTC 2024
    - 53.8K bytes
    - Viewed (0)
  5. src/runtime/map_fast64.go

    	// If we hit the max load factor or we have too many overflow buckets,
    	// and we're not already in the middle of growing, start growing.
    	if !h.growing() && (overLoadFactor(h.count+1, h.B) || tooManyOverflowBuckets(h.noverflow, h.B)) {
    		hashGrow(t, h)
    		goto again // Growing the table invalidates everything, so try again
    	}
    
    	if insertb == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  6. pkg/scheduler/testing/framework/framework_helpers.go

    }
    
    // RegisterPreBindPlugin returns a function to register a PreBind Plugin to a given registry.
    func RegisterPreBindPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc {
    	return RegisterPluginAsExtensions(pluginName, pluginNewFunc, "PreBind")
    }
    
    // RegisterScorePlugin returns a function to register a Score Plugin to a given registry.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  7. src/runtime/map_fast32.go

    	// If we hit the max load factor or we have too many overflow buckets,
    	// and we're not already in the middle of growing, start growing.
    	if !h.growing() && (overLoadFactor(h.count+1, h.B) || tooManyOverflowBuckets(h.noverflow, h.B)) {
    		hashGrow(t, h)
    		goto again // Growing the table invalidates everything, so try again
    	}
    
    	if insertb == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    					}
    
    					initialObjects = testCtx.listAll(t)
    					initialObjects = testCtx.updateAPIServer(t, initialObjects, tc.prepare.prebind)
    					status := testCtx.p.PreBind(testCtx.ctx, testCtx.state, tc.pod, selectedNode.Node().Name)
    					t.Run("prebind", func(t *testing.T) {
    						testCtx.verify(t, tc.want.prebind, initialObjects, nil, status)
    					})
    
    					if tc.want.unreserveAfterBindFailure != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/examples/multipoint/multipoint.go

    		// resources. In this case, our clean up is simply deleting the key written
    		// in the Reserve operation.
    		state.Delete(framework.StateKey(pod.Name))
    	}
    }
    
    // PreBind is the function invoked by the framework at "prebind" extension point.
    func (mc CommunicatingPlugin) PreBind(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status {
    	if pod == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 09 03:43:17 UTC 2023
    - 3K bytes
    - Viewed (0)
  10. src/runtime/map_faststr.go

    	// If we hit the max load factor or we have too many overflow buckets,
    	// and we're not already in the middle of growing, start growing.
    	if !h.growing() && (overLoadFactor(h.count+1, h.B) || tooManyOverflowBuckets(h.noverflow, h.B)) {
    		hashGrow(t, h)
    		goto again // Growing the table invalidates everything, so try again
    	}
    
    	if insertb == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 15.3K bytes
    - Viewed (0)
Back to top