- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 962 for waitc (0.03 sec)
-
src/syscall/exec_plan9.go
// If fork fails there is nothing to wait for. if ret.err != nil || ret.pid == 0 { forkc <- ret return } waitc := make(chan *waitErr, 1) // Mark that the process is running. procs.Lock() if procs.waits == nil { procs.waits = make(map[int]chan *waitErr) } procs.waits[ret.pid] = waitc procs.Unlock() forkc <- ret var w waitErr
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
// WaitForAPI waits for the API Server's /healthz endpoint to become "ok" // TODO: remove WaitForAPI once WaitForAllControlPlaneComponents goes GA: // https://github.com/kubernetes/kubeadm/issues/2907 WaitForAPI() error // WaitForPodsWithLabel waits for Pods in the kube-system namespace to become Ready WaitForPodsWithLabel(kvLabel string) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
const pollInterval = time.Second // Cmd represents the wait command func Cmd(cliCtx cli.Context) *cobra.Command { namespace := cliCtx.Namespace() var opts clioptions.ControlPlaneOptions cmd := &cobra.Command{ Use: "wait [flags] <type> <name>[.<namespace>]", Short: "Wait for an Istio resource", Long: `Waits for the specified condition to be true of an Istio resource.`,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 12:24:17 UTC 2024 - 10.1K bytes - Viewed (0) -
operator/pkg/helmreconciler/wait.go
"k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/kubernetes" kctldeployment "k8s.io/kubectl/pkg/util/deployment" "istio.io/istio/operator/pkg/name" "istio.io/istio/operator/pkg/object" "istio.io/istio/operator/pkg/util/progress" "istio.io/istio/pkg/kube" ) const ( // defaultWaitResourceTimeout is the maximum wait time for all resources(namespace/deployment/pod) to be created.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/wait-on-pipe.go
time.Sleep(100 * time.Millisecond) // Write to the pipe to unblock it. if _, err := syscall.Write(wfd, []byte{10}); err != nil { log.Fatalf("failed to write to pipe: %v", err) } // Wait for the goroutine to unblock and start running. // This is helpful to catch incorrect information written // down for the syscall-blocked goroutine, since it'll start // executing, and that execution information will be
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_termination_order.go
// sidecar containers need to wait on main containers, so we create a channel per main container // for them to wait on for _, c := range pod.Spec.Containers { channel := make(chan struct{}) to.terminated[c.Name] = channel mainContainerChannels = append(mainContainerChannels, channel) // if its not a running container, pre-close the channel so nothing waits on it
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 00:07:21 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go
makePVC("pvc-a", waitSC.Name).withBoundPV("pv-a").PersistentVolumeClaim, makePVC("pvc-b", waitSC.Name).withBoundPV("pv-b").PersistentVolumeClaim, }, pvs: []*v1.PersistentVolume{ makePV("pv-a", waitSC.Name).withPhase(v1.VolumeBound).withNodeAffinity(map[string][]string{ v1.LabelHostname: {"node-a"}, }).PersistentVolume,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 32K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/lockedfile_test.go
cmd.Env = append(os.Environ(), fmt.Sprintf("%s=%s", dirVar, dir)) qDone := make(chan struct{}) waitQ := mustBlock(t, "Edit A and B in subprocess", func() { out, err := cmd.CombinedOutput() if err != nil { t.Errorf("%v:\n%s", err, out) } close(qDone) }) // Wait until process Q has either failed or locked file B. // Otherwise, P.2 might not block on file B as intended. locked: for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 5.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v2/kms_plugin_mock.go
t.Fatalf("failed to start KMS plugin: err: %v", err) } return result } // waitForBase64PluginToBeUp waits until the plugin is ready to serve requests. func waitForBase64PluginToBeUp(plugin *Base64Plugin) error { var gRPCErr error var resp *kmsapi.StatusResponse pollErr := wait.PollImmediate(1*time.Second, wait.ForeverTestTimeout, func() (bool, error) { resp, gRPCErr = plugin.Status(context.Background(), &kmsapi.StatusRequest{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 6.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
try { return satisfied = guard.isSatisfied(); } finally { if (!satisfied) { lock.unlock(); } } } /** * Waits for the guard to be satisfied. Waits indefinitely, but may be interrupted. May be called * only by a thread currently occupying this monitor. * * @throws InterruptedException if interrupted while waiting */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 42.5K bytes - Viewed (0)