- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,297 for waitc (0.05 sec)
-
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/os/wait_unimp.go
// aix, darwin, js/wasm, openbsd, solaris and wasip1/wasm don't implement // waitid/wait6. //go:build aix || darwin || (js && wasm) || openbsd || solaris || wasip1 package os // blockUntilWaitable attempts to block until a call to p.Wait will // succeed immediately, and reports whether it has done so. // It does not actually call p.Wait. // This version is used on systems that do not implement waitid,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 13:16:52 UTC 2023 - 831 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) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_context.go
// initialization signals. type InitializationSignal interface { // Signal notifies the dispatcher about finished initialization. Signal() // Wait waits for the initialization signal. Wait() } type initializationSignal struct { once sync.Once done chan struct{} } func NewInitializationSignal() InitializationSignal { return &initializationSignal{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 14 14:39:15 UTC 2021 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/poll.go
// wait: user specified WaitFunc function that controls at what interval the condition // function should be invoked periodically and whether it is bound by a timeout. // condition: user specified ConditionWithContextFunc function. // // Deprecated: will be removed in favor of loopConditionUntilContext.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 06:13:35 UTC 2023 - 14K bytes - Viewed (0) -
src/os/wait_wait6.go
package os import ( "runtime" "syscall" ) // blockUntilWaitable attempts to block until a call to p.Wait will // succeed immediately, and reports whether it has done so. // It does not actually call p.Wait. func (p *Process) blockUntilWaitable() (bool, error) { var errno syscall.Errno for { _, errno = wait6(_P_PID, p.Pid, syscall.WEXITED|syscall.WNOWAIT) if errno != syscall.EINTR { break } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 13 21:25:45 UTC 2022 - 781 bytes - Viewed (0) -
src/runtime/rwmutex_test.go
var cunlock atomic.Bool cdone := make(chan bool) for i := 0; i < numReaders; i++ { go parallelReader(&m, clocked, &cunlock, cdone) } // Wait for all parallel RLock()s to succeed. for i := 0; i < numReaders; i++ { <-clocked } cunlock.Store(true) // Wait for the goroutines to finish. for i := 0; i < numReaders; i++ { <-cdone } } func TestParallelRWMutexReaders(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 15 22:00:45 UTC 2023 - 4.2K bytes - Viewed (0) -
src/runtime/lock_sema.go
// to the caller. // This reduces the nosplit footprint of notetsleep_internal. gp = getg() // Register for wakeup on n->waitm. if !atomic.Casuintptr(&n.key, 0, uintptr(unsafe.Pointer(gp.m))) { // Must be locked (got wakeup). if n.key != locked { throw("notetsleep - waitm out of sync") } return true } if ns < 0 { // Queued. Sleep. gp.m.blocked = true if *cgo_yield == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0)