- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 1,377 for waitc (0.05 sec)
-
src/cmd/go/internal/par/work.go
if w.waiting == w.running { // All done. w.wait.Broadcast() w.mu.Unlock() return } w.wait.Wait() w.waiting-- } // Pick something to do at random, // to eliminate pathological contention // in case items added at about the same time // are most likely to contend. i := rand.Intn(len(w.todo)) item := w.todo[i] w.todo[i] = w.todo[len(w.todo)-1] w.todo = w.todo[:len(w.todo)-1]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 15:54:54 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
// DesiredStateOfWorldPopulatorLoopSleepPeriod is the amount of time the // DesiredStateOfWorldPopulator loop waits between successive executions DesiredStateOfWorldPopulatorLoopSleepPeriod time.Duration // DesiredStateOfWorldPopulatorListPodsRetryDuration is the amount of // time the DesiredStateOfWorldPopulator loop waits between list pods // calls. DesiredStateOfWorldPopulatorListPodsRetryDuration time.Duration }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
src/cmd/dist/util.go
bgwork <- func() { defer wg.Done() run(dir, CheckExit|ShowOutput|Background, cmd...) } } // bgwait waits for pending bgruns to finish. // bgwait must be called from only a single goroutine at a time. func bgwait(wg *sync.WaitGroup) { done := make(chan struct{}) go func() { wg.Wait() close(done) }() select { case <-done: case <-dying:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 23 17:50:29 UTC 2023 - 11.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
require.ErrorIs(t, stopReason, context.Canceled) }() // Wait for controller and informer to start up require.True(t, cache.WaitForCacheSync(testContext.Done(), myController.HasSynced)) // Stop the controller and informer testCancel() // Wait for controller and informer to stop wg.Wait() // Ensure the event handler was cleaned up require.Empty(t, informer.registrations)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
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) -
src/runtime/semasleep_test.go
if waiting { <-doneCh } else { cmd.Wait() } }) // Wait for After1 to close its stdout so that we know the runtime's SIGIO // handler is registered. b, err := io.ReadAll(stdout) if len(b) > 0 { t.Logf("read from testprog stdout: %s", b) } if err != nil { t.Fatalf("error reading from testprog: %v", err) } // Wait for child exit. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 17:48:24 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager.go
// registration/deregistration AddHandler(pluginType string, pluginHandler cache.PluginHandler) } const ( // loopSleepDuration is the amount of time the reconciler loop waits // between successive executions loopSleepDuration = 1 * time.Second ) // NewPluginManager returns a new concrete instance implementing the // PluginManager interface. func NewPluginManager( sockDir string,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 01 05:56:33 UTC 2022 - 4.3K bytes - Viewed (0) -
src/internal/singleflight/singleflight.go
Err error Shared bool } // Do executes and returns the results of the given function, making // sure that only one execution is in-flight for a given key at a // time. If a duplicate comes in, the duplicate caller waits for the // original to complete and receives the same results. // The return value shared indicates whether v was given to multiple callers. func (g *Group) Do(key string, fn func() (any, error)) (v any, err error, shared bool) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 30 20:49:56 UTC 2022 - 3.1K bytes - Viewed (0) -
pkg/kube/multicluster/cluster.go
Update ) func (a ACTION) String() string { switch a { case Add: return "Add" case Update: return "Update" } return "Unknown" } // Run starts the cluster's informers and waits for caches to sync. Once caches are synced, we mark the cluster synced. // This should be called after each of the handlers have registered informers, and should be run in a goroutine.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/test/framework/resource/config/apply/option.go
var CleanupConditionally Option = OptionFunc(func(opts *Options) { opts.Cleanup = cleanup.Conditionally }) // Wait configures the Options to wait for configuration to propagate. // This method currently does nothing, due to https://github.com/istio/istio/issues/37148 var Wait Option = OptionFunc(func(opts *Options) { // opts.Wait = true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 17 02:49:07 UTC 2022 - 1.5K bytes - Viewed (0)