- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,377 for waitc (0.07 sec)
-
src/cmd/cgo/internal/test/issue9400_linux.go
} // Disable GC for the duration of the test. // This avoids a potential GC deadlock when spinning in uninterruptible ASM below #49695. defer debug.SetGCPercent(debug.SetGCPercent(-1)) // SetGCPercent waits until the mark phase is over, but the runtime // also preempts at the start of the sweep phase, so make sure that's // done too. See #49695. runtime.GC() // Temporarily rewind the stack and trigger SIGSETXID
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 1.7K bytes - Viewed (0) -
src/os/exec_unix.go
} // If we can block until Wait4 will succeed immediately, do so. ready, err := p.blockUntilWaitable() if err != nil { return nil, err } if ready { // Mark the process done now, before the call to Wait4, // so that Process.pidSignal will not send a signal. p.pidDeactivate(statusDone) // Acquire a write lock on sigMu to wait for any // active call to the signal method to complete. p.sigMu.Lock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 4.1K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/plan/edges/NodeDependencySetTest.groovy
class NodeDependencySetTest extends Specification { def node = Stub(Node) def set = new DependencySuccessorsOnlyNodeSet() def "does not wait when the set is empty"() { expect: set.getState(node) == Node.DependenciesState.COMPLETE_AND_SUCCESSFUL } def "waits until all dependencies have completed successfully"() { def dep1 = Stub(Node) def dep2 = Stub(Node) given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 12 20:17:10 UTC 2022 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/storage/objectreader.go
waitCh := time.After(timeout) for { storage, err := s.GetStoredCustomResource(ns, name) if err != nil { return err } if storage.GetObjectKind().GroupVersionKind().Version == version { return nil } select { case <-waitCh:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go
err := wait.PollImmediate(500*time.Millisecond, 30*time.Second, func() (bool, error) { exists, err := existsInDiscoveryV1(crd, apiExtensionsClient, version) return !exists, err }) if err != nil { return err } } return nil } // DeleteV1CustomResourceDefinitions deletes all CRD matching the provided deleteListOpts and waits until all the CRDs disappear from discovery.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 02:01:40 UTC 2021 - 21.4K bytes - Viewed (0) -
src/context/example_test.go
// This example uses AfterFunc to define a function which waits on a sync.Cond, // stopping the wait when a context is canceled. func ExampleAfterFunc_cond() { waitOnCond := func(ctx context.Context, cond *sync.Cond, conditionMet func() bool) error { stopf := context.AfterFunc(ctx, func() { // We need to acquire cond.L here to be sure that the Broadcast // below won't occur before the call to Wait, which would result
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 21 20:24:28 UTC 2023 - 6.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException; /** * Waits for the {@link Service} to reach the {@linkplain State#TERMINATED terminated state}. * * @throws IllegalStateException if the service {@linkplain State#FAILED fails}. * @since 15.0 */ void awaitTerminated(); /** * Waits for the {@link Service} to reach a terminal state (either {@link Service.State#TERMINATED
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v1beta1/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 pollErr := wait.PollImmediate(1*time.Second, wait.ForeverTestTimeout, func() (bool, error) { _, gRPCErr = plugin.Encrypt(context.Background(), &kmsapi.EncryptRequest{Plain: []byte("foo")})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 5.2K bytes - Viewed (0) -
src/os/exec/exec.go
// // If any of c.Stdin, c.Stdout or c.Stderr are not an [*os.File], Wait also waits // for the respective I/O loop copying to or from the process to complete. // // Wait releases any resources associated with the [Cmd]. func (c *Cmd) Wait() error { if c.Process == nil { return errors.New("exec: not started") } if c.ProcessState != nil { return errors.New("exec: Wait was already called") } state, err := c.Process.Wait()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
// TODO(user): Consider scaling by number of mutator threads, // e.g. using Thread#activeCount() return Math.max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L)); } /** * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector * as necessary to try to ensure that this will happen. * * @throws RuntimeException if timed out or interrupted while waiting
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.6K bytes - Viewed (0)