Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for chain (0.16 sec)

  1. pkg/kubelet/kubelet.go

    //     containers have failed health checks
    func (kl *Kubelet) syncLoopIteration(ctx context.Context, configCh <-chan kubetypes.PodUpdate, handler SyncHandler,
    	syncCh <-chan time.Time, housekeepingCh <-chan time.Time, plegCh <-chan *pleg.PodLifecycleEvent) bool {
    	select {
    	case u, open := <-configCh:
    		// Update from a config source; dispatch it to the right handler
    		// callback.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  2. src/net/http/server.go

    		ctx, cancelCtx = context.WithTimeout(r.Context(), h.dt)
    		defer cancelCtx()
    	}
    	r = r.WithContext(ctx)
    	done := make(chan struct{})
    	tw := &timeoutWriter{
    		w:   w,
    		h:   make(Header),
    		req: r,
    	}
    	panicChan := make(chan any, 1)
    	go func() {
    		defer func() {
    			if p := recover(); p != nil {
    				panicChan <- p
    			}
    		}()
    		h.handler.ServeHTTP(tw, r)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 123.4K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller_test.go

    	manager.podStoreSynced = alwaysReady
    	manager.jobStoreSynced = alwaysReady
    
    	var testJob batch.Job
    	received := make(chan struct{})
    
    	// The update sent through the fakeWatcher should make its way into the workqueue,
    	// and eventually into the syncHandler.
    	manager.syncHandler = func(ctx context.Context, key string) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    				Spec:       example.PodSpec{NodeName: "machine"},
    			},
    			deleted: true,
    		},
    	}
    
    	for _, test := range tests {
    		ready := make(chan struct{})
    		updated := make(chan struct{})
    		var readyOnce, updatedOnce sync.Once
    		var called int
    		deleteValidation := func(ctx context.Context, obj runtime.Object) error {
    			readyOnce.Do(func() {
    				close(ready)
    			})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  5. src/cmd/go/internal/work/exec.go

    				fmt.Fprintf(os.Stderr, "go: writing action graph: %v\n", err)
    				base.SetExitStatus(1)
    			}
    		}
    	}
    	writeActionGraph()
    
    	b.readySema = make(chan bool, len(all))
    
    	// Initialize per-action execution state.
    	for _, a := range all {
    		for _, a1 := range a.Deps {
    			a1.triggers = append(a1.triggers, a)
    		}
    		a.pending = len(a.Deps)
    		if a.pending == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 14:46:37 UTC 2024
    - 105.6K bytes
    - Viewed (0)
  6. src/cmd/link/internal/ld/data.go

    // blocks, waiting on the writes to complete. Note that we use the sem parameter
    // to limit the number of concurrent writes taking place.
    func writeBlocks(ctxt *Link, out *OutBuf, sem chan int, ldr *loader.Loader, syms []loader.Sym, addr, size int64, pad []byte) {
    	for i, s := range syms {
    		if ldr.SymValue(s) >= addr && !ldr.AttrSubSymbol(s) {
    			syms = syms[i:]
    			break
    		}
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 12 15:10:50 UTC 2024
    - 100.5K bytes
    - Viewed (0)
Back to top