- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 454 for wait4 (0.06 sec)
-
src/internal/trace/testdata/testprog/iter-pull.go
} }() go func() { defer wg.Done() for i := range iterChans[1] { _, ok := i.next() if !ok { close(iterChans[0]) break } iterChans[0] <- i } }() wg.Wait() // End of traced execution. trace.Stop() } func pullRange(n int) intIter { next, stop := iter.Pull(func(yield func(v int) bool) { for i := range n { yield(i) } })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.4K bytes - Viewed (0) -
src/net/http/httptest/server.go
nconn := len(s.conns) ch := make(chan struct{}, nconn) for c := range s.conns { go s.closeConnChan(c, ch) } s.mu.Unlock() // Wait for outstanding closes to finish. // // Out of paranoia for making a late change in Go 1.6, we // bound how long this can wait, since golang.org/issue/14291 // isn't fully understood yet. At least this should only be used // in tests. timer := time.NewTimer(5 * time.Second)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
cmd/handler-api.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 08:13:12 UTC 2024 - 10.4K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/futile-wakeup.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.8K bytes - Viewed (0) -
cmd/batch-rotate.go
if success { break } if delay > 0 { time.Sleep(delay + time.Duration(rnd.Float64()*float64(delay))) } } if wait := globalBatchConfig.KeyRotationWait(); wait > 0 { time.Sleep(wait) } }() } wk.Wait() ri.Complete = !failed && ri.ObjectsFailed == 0 ri.Failed = failed || ri.ObjectsFailed > 0 globalBatchJobsMetrics.save(job.ID, ri)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/test/framework/components/istio/configmap.go
scopes.Framework.Debugf("cleanup patched %s injection configmap:\n%s", c.Name(), cfgMap.Data["config"]) return nil }) } if err := errG.Wait().ErrorOrNil(); err != nil { scopes.Framework.Errorf("failed cleaning up cluster-local config: %v", err) } }) return errG.Wait().ErrorOrNil() } func (ic *injectConfig) ValuesConfig() (*inject.ValuesConfig, error) { ic.mu.Lock() myic := ic.values ic.mu.Unlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12.8K bytes - Viewed (0) -
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) -
cmd/format-erasure.go
if formats[index] == nil { return errDiskNotFound } return saveFormatErasure(storageDisks[index], formats[index], "") }, index) } // Wait for the routines to finish. return reduceWriteQuorumErrs(ctx, g.Wait(), nil, len(storageDisks)) } // relinquishes the underlying connection for all storage disks. func closeStorageDisks(storageDisks ...StorageAPI) { var wg sync.WaitGroup
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
}) if err != nil { t.Fatal(err) } s.ScheduleOne(ctx) // Wait for pod to succeed or fail scheduling select { case <-eventChan: case <-time.After(wait.ForeverTestTimeout): t.Fatalf("scheduling timeout after %v", wait.ForeverTestTimeout) } stopFunc() // Wait for scheduling to return an error or succeed binding. var ( gotErr error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
pkg/probe/exec/exec.go
var dataBuffer bytes.Buffer writer := ioutils.LimitWriter(&dataBuffer, maxReadLength) e.SetStderr(writer) e.SetStdout(writer) err := e.Start() if err == nil { err = e.Wait() } data := dataBuffer.Bytes() klog.V(4).Infof("Exec probe response: %q", string(data)) if err != nil { exit, ok := err.(exec.ExitError) if ok { if exit.ExitStatus() == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 2.2K bytes - Viewed (0)