- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for waitRead (0.28 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonStopClient.java
} if (connection != null) { throw new GradleException(String.format("Timeout waiting for all daemons to stop. Waited %s.", timer.getElapsed())); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.2K bytes - Viewed (0) -
src/os/exec_unix.go
// may wait on the wrong process if the PID is reused after the // completes its wait. // // Checking for statusDone here would not be a complete fix, as the PID // could still be waited on and reused prior to blockUntilWaitable. switch p.pidStatus() { case statusReleased: return nil, syscall.EINVAL } // If we can block until Wait4 will succeed immediately, do so.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 4.1K bytes - Viewed (0) -
src/sync/waitgroup.go
// positive delta that start when the counter is greater than zero, may happen // at any time. // Typically this means the calls to Add should execute before the statement // creating the goroutine or other event to be waited for. // If a WaitGroup is reused to wait for several independent sets of events, // new Add calls must happen after all previous Wait calls have returned. // See the WaitGroup example. func (wg *WaitGroup) Add(delta int) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_termination_order_test.go
} return delay.(int64) } for _, tc := range []struct { containerName string expectedDelay int64 }{ { containerName: "sc1", // overall grace period limits the amount of time waited here expectedDelay: 2, }, { containerName: "sc2", expectedDelay: 2, }, { containerName: "sc3", expectedDelay: 1, }, { containerName: "main",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 00:07:21 UTC 2023 - 6.7K bytes - Viewed (0) -
cmd/metacache-manager.go
debug.PrintStack() } return b } m.mu.RUnlock() m.mu.Lock() defer m.mu.Unlock() // See if someone else fetched it while we waited for the lock. b, ok = m.buckets[bucket] if ok { if b.bucket != bucket { logger.Info("getBucket: newly cached bucket %s does not match this bucket %s", b.bucket, bucket) debug.PrintStack() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/finisher/finisher.go
metrics.RecordRequestPostTimeout(metrics.PostTimeoutSourceRestHandler, metrics.PostTimeoutHandlerPending) klog.Errorf("FinishRequest: post-timeout activity, waited for %s, child goroutine has not returned yet", time.Since(timedOutAt)) return } var status string switch { case r.reason != nil:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 07 14:20:33 UTC 2021 - 6K bytes - Viewed (0) -
src/sync/mutex.go
// the tail of the wait queue. // // If a waiter receives ownership of the mutex and sees that either // (1) it is the last waiter in the queue, or (2) it waited for less than 1 ms, // it switches mutex back to normal operation mode. // // Normal mode has considerably better performance as a goroutine can acquire // a mutex several times in a row even if there are blocked waiters.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0)