Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 111 for Await (0.07 sec)

  1. pkg/controller/job/job_controller_test.go

    	if err != nil {
    		t.Fatalf("Creating job: %v", err)
    	}
    
    	// Await for the Job to appear in the jobLister to ensure so that Job Pod gets tracked correctly.
    	if err := wait.PollUntilContextTimeout(ctx, 10*time.Millisecond, wait.ForeverTestTimeout, false, func(ctx context.Context) (bool, error) {
    		job, _ := manager.jobLister.Jobs(job.GetNamespace()).Get(job.Name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller.go

    	if !cache.WaitForNamedCacheSync("job", ctx.Done(), jm.podStoreSynced, jm.jobStoreSynced) {
    		return
    	}
    
    	for i := 0; i < workers; i++ {
    		go wait.UntilWithContext(ctx, jm.worker, time.Second)
    	}
    
    	go wait.UntilWithContext(ctx, jm.orphanWorker, time.Second)
    
    	<-ctx.Done()
    }
    
    // getPodJobs returns a list of Jobs that potentially match a Pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  3. src/sync/waitgroup.go

    // goroutines to wait for. Then each of the goroutines
    // runs and calls [WaitGroup.Done] when finished. At the same time,
    // [WaitGroup.Wait] can be used to block until all goroutines have finished.
    //
    // A WaitGroup must not be copied after first use.
    //
    // In the terminology of [the Go memory model], a call to [WaitGroup.Done]
    // “synchronizes before” the return of any Wait call that it unblocks.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. src/sync/cond.go

    func NewCond(l Locker) *Cond {
    	return &Cond{L: l}
    }
    
    // Wait atomically unlocks c.L and suspends execution
    // of the calling goroutine. After later resuming execution,
    // Wait locks c.L before returning. Unlike in other systems,
    // Wait cannot return unless awoken by [Cond.Broadcast] or [Cond.Signal].
    //
    // Because c.L is not locked while Wait is waiting, the caller
    // typically cannot assume that the condition is true when
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  5. src/os/exec.go

    	}
    
    	// Both Release and successful Wait will deactivate the PID. Only one
    	// of those should win, so nothing left to do here if the compare
    	// fails.
    	//
    	// N.B. This means that results can be inconsistent. e.g., with a
    	// racing Release and Wait, Wait may successfully wait on the process,
    	// returning the wait status, while future calls error with "process
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  6. src/os/exec/exec_test.go

    	var wg sync.WaitGroup
    	wg.Add(1)
    	defer wg.Wait()
    	go func() {
    		defer wg.Done()
    
    		_, err := io.Copy(stdin, strings.NewReader(stdinCloseTestString))
    		check("Copy", err)
    
    		// Before the fix, this next line would race with cmd.Wait.
    		if err := stdin.Close(); err != nil && !errors.Is(err, os.ErrClosed) {
    			t.Errorf("Close: %v", err)
    		}
    	}()
    
    	check("Wait", cmd.Wait())
    }
    
    // Issue 17647.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:53 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  7. src/os/exec_unix.go

    	}
    }
    
    func (p *Process) pidWait() (*ProcessState, error) {
    	// TODO(go.dev/issue/67642): When there are concurrent Wait calls, one
    	// may wait on the wrong process if the PID is reused after the
    	// completes its wait.
    	//
    	// Checking for statusDone here would not be a complete fix, as the PID
    	// could still be waited on and reused prior to blockUntilWaitable.
    	switch p.pidStatus() {
    	case statusReleased:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  8. docs/en/docs/release-notes.md

    * Fix typos in Async docs. PR [#1423](https://github.com/tiangolo/fastapi/pull/1423).
    
    ## 0.54.2
    
    * Add translation to Spanish for [Concurrency and async / await - Concurrencia y async / await](https://fastapi.tiangolo.com/es/async/). PR [#1290](https://github.com/tiangolo/fastapi/pull/1290) by [@alvaropernas](https://github.com/alvaropernas).
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Fri Jun 14 15:07:37 UTC 2024
    - 395.4K bytes
    - Viewed (0)
  9. src/os/exec_unix_test.go

    		// Solaris/Illumos have a lower limit, above which wait returns
    		// EINVAL (see waitid in usr/src/uts/common/os/exit.c in
    		// illumos). This is configurable via sysconf(_SC_MAXPID), but
    		// we'll just take the default.
    		pid = 30000-1
    	}
    
    	p, err := FindProcess(pid)
    	if err != nil {
    		t.Fatalf("FindProcess(math.MaxInt32) got err %v, want nil", err)
    	}
    
    	if ps, err := p.Wait(); !errors.Is(err, syscall.ECHILD) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 18:08:44 UTC 2024
    - 2K bytes
    - Viewed (0)
  10. src/os/pidfd_linux_test.go

    	}
    	if err := proc.Signal(os.Kill); err != os.ErrProcessDone {
    		t.Errorf("Signal: got %v, want %v", err, os.ErrProcessDone)
    	}
    	if _, err := proc.Wait(); !errors.Is(err, syscall.ECHILD) {
    		t.Errorf("Wait: got %v, want %v", err, os.ErrProcessDone)
    	}
    	// Release never returns errors on Unix.
    	if err := proc.Release(); err != nil {
    		t.Fatalf("Release: got %v, want <nil>", err)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 18:08:44 UTC 2024
    - 1.6K bytes
    - Viewed (0)
Back to top