- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 1,948 for waits (0.1 sec)
-
testing/performance/src/templates/native-dependents-resources/googleTest/libs/googleTest/1.7.0/include/gtest/gtest-death-test.h
// // 2. The parent process clone()s a sub-process and runs the death // test in it; the sub-process exits with code 0 at the end of the // death test, if it hasn't exited already. // // 3. The parent process waits for the sub-process to terminate. // // 4. The parent process checks the exit code and error message of // the sub-process. // // Examples: //
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 11.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go
} // a) we will allow the request to wait in the queue for one // fourth of the time of its allotted deadline. // b) if the request context does not have any deadline // then we default to 'defaultRequestWaitLimit' // in any case, the wait limit for any request must not // exceed the hard limit of 1m // // request has deadline: // wait-limit = min(remaining deadline / 4, 1m) // request has no deadline:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.3K bytes - Viewed (0) -
pkg/volume/csi/csi_block_test.go
if err != nil { t.Fatalf("Failed to create a fakeDriver: %v", err) } // after the driver is created, create the plugin. newTestPlugin waits for the informer to sync, // such that csiMapper.SetUpDevice below sees the VolumeAttachment object in the lister. plug, tmpDir := newTestPlugin(t, fakeClient) defer os.RemoveAll(tmpDir)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 26.5K bytes - Viewed (0) -
src/os/exec.go
return p.kill() } // Wait waits for the [Process] to exit, and then returns a // ProcessState describing its status and an error, if any. // Wait releases any resources associated with the Process. // On most operating systems, the Process must be a child // of the current process or an error will be returned. func (p *Process) Wait() (*ProcessState, error) { return p.wait() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 12.8K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultCacheCoordinator.java
} finally { releaseOwnership(); } } finally { stateLock.unlock(); } } } /** * Waits until the current thread can take ownership. * Must be called while holding the lock. */ private void takeOwnership() { while (owner != null && owner != Thread.currentThread()) { try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 01 12:21:15 UTC 2024 - 20.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
} /** * Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application * is complete. It does so by using daemon threads and adding a shutdown hook to wait for their * completion. * * <p>This method waits 120 seconds before continuing with JVM termination, even if the executor * has not finished its work. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 39K 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) -
pkg/adsc/adsc.go
} continue case <-t.C: return fmt.Errorf("timeout, still waiting for update for %v", want) } } } // Wait for an updates for all the specified types // If updates is empty, this will wait for any update func (a *ADSC) Wait(to time.Duration, updates ...string) ([]string, error) { t := time.NewTimer(to) want := sets.New[string](updates...) got := make([]string, 0, len(updates))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
src/cmd/go/internal/vcweb/vcweb.go
// with its current contents. // // If the script completed successfully, HandleScript invokes f on the handler // with the script's result still read-locked, and waits for it to return. (That // ensures that cache invalidation does not race with an in-flight handler.) // // Otherwise, HandleScript returns the (cached) error from executing the script.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 12.1K bytes - Viewed (0) -
src/crypto/tls/tls.go
} c.handshakeFn = c.clientHandshake return c } // A listener implements a network listener (net.Listener) for TLS connections. type listener struct { net.Listener config *Config } // Accept waits for and returns the next incoming TLS connection. // The returned connection is of type *Conn. func (l *listener) Accept() (net.Conn, error) { c, err := l.Listener.Accept() if err != nil { return nil, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 12.2K bytes - Viewed (0)