- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 301 for waitc (0.04 sec)
-
src/os/pidfd_linux.go
handle, status := p.handleTransientAcquire() switch status { case statusDone: // Process already completed Wait, or was not found by // pidfdFind. Return ECHILD for consistency with what the wait // syscall would return. return nil, NewSyscallError("wait", syscall.ECHILD) case statusReleased: return nil, syscall.EINVAL } defer p.handleTransientRelease() var (
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 4.2K bytes - Viewed (0) -
operator/pkg/util/progress/progress.go
comps := make([]string, 0, len(p.components)) wait := make([]string, 0, len(p.components)) for c, l := range p.components { comps = append(comps, name.UserFacingComponentName(name.ComponentName(c))) wait = append(wait, l.waitingResources()...) } sort.Strings(comps) sort.Strings(wait) msg := fmt.Sprintf(`Processing resources for %s.`, strings.Join(comps, ", ")) if len(wait) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
} return nil } // ExpectError waits until an error is received and returns it func (a *DeltaAdsTest) ExpectError() error { a.t.Helper() select { case <-time.After(a.timeout): a.t.Fatalf("did not get error in time") case err := <-a.error: return err } return nil } // ExpectNoResponse waits a short period of time and ensures no response is received
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
src/net/tcpsock_unix_test.go
t.Errorf("#%d: %v", i, err) } } c.Close() }(i) } ln.Close() wg.Wait() } // Issue 19289. // Test that a canceled Dial does not cause a subsequent Dial to succeed. func TestTCPSpuriousConnSetupCompletionWithCancel(t *testing.T) { mustHaveExternalNetwork(t) defer dnsWaitGroup.Wait() t.Parallel() const tries = 10000 var wg sync.WaitGroup wg.Add(tries * 2)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2.3K bytes - Viewed (0) -
src/runtime/stubs2.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
go func() { defer waitGroup.Done() wait.Until(c.runWorker, time.Second, ctx.Done()) }() } klog.Infof("Started %v workers for %v", c.options.Workers, c.options.Name) // Wait for context cancel. <-ctx.Done() // Forcefully shutdown workqueue. Drop any enqueued items. c.queue.ShutDown() // Workqueue shutdown signals for workers to stop. Wait for all workers to // clean up waitGroup.Wait()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager_test.go
} } func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { backoff := wait.Backoff{ Duration: initialDuration, Factor: 3, Jitter: 0, Steps: 6, } return wait.ExponentialBackoff(backoff, fn) } func TestPluginRegistration(t *testing.T) { defer cleanup(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 4.4K bytes - Viewed (0) -
src/runtime/runtime-gdb_unix_test.go
t.Fatalf("error starting test binary: %v", err) } pid := cmd.Process.Pid err = cmd.Wait() t.Logf("child output:\n%s", output.String()) if err == nil { t.Fatalf("Wait succeeded, want SIGABRT") } ee, ok := err.(*exec.ExitError) if !ok { t.Fatalf("Wait err got %T %v, want exec.ExitError", ee, ee) } ws, ok := ee.Sys().(syscall.WaitStatus) if !ok {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 17 19:05:30 UTC 2024 - 9.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/health.go
if client.Discovery().RESTClient() == nil { fmt.Printf("[upgrade/health] Would create the Job with the prefix %q in namespace %q and wait until it completes\n", prefix, ns) return nil } // Check if there is at least one Node where a Job's Pod can schedule. If not, skip this preflight check. err = wait.PollUntilContextTimeout(ctx, time.Second*1, timeout, true, func(_ context.Context) (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 09:18:02 UTC 2024 - 8.8K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/integTest/groovy/org/gradle/internal/work/ProjectLockStatisticsIntegrationTest.groovy
createDirs("child") settingsFile << """ include ':child' """ buildFile << """ apply plugin: "java" task wait { doLast { sleep 2000 } } project(':child') { configurations { foo }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 1.8K bytes - Viewed (0)