- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 2,533 for happen (0.19 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
secondBarrier.await(); } } @Override protected ScheduledExecutorService executor() { // use a bunch of threads so that weird overlapping schedules are more likely to happen. return Executors.newScheduledThreadPool(10); } @Override protected Scheduler scheduler() { return new CustomScheduler() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 22.5K bytes - Viewed (0) -
src/os/exec.go
} for { state := p.state.Load() refs := state &^ processStatusMask status := processStatus(state & processStatusMask) if refs == 0 { // This should never happen because // handleTransientRelease is always paired with // handleTransientAcquire. panic("release of handle with refcount 0") } if refs == 1 && status == statusOK {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 12.8K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/elfexec/elfexec.go
return nil, err } notes = append(notes, elfNote{Name: name, Desc: desc, Type: typ}) // Drop padding bytes until the next note or the end of the section, // whichever comes first. for n := padding(len(desc)); n > 0; n-- { if _, err := r.ReadByte(); err == io.EOF { // We hit the end of the section before an alignment boundary. // This can happen if this section is at the end of the file or the next
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
// Idempotently add it to the containerMap incase it is missing. // This can happen after a kubelet restart, for example. m.containerMap.Add(string(pod.UID), container.Name, containerID) m.Unlock() cset := m.state.GetCPUSetOrDefault(string(pod.UID), container.Name) if cset.IsEmpty() { // NOTE: This should not happen outside of tests.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 19.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
// - It is an endpoint without an associated Pod. In this case, expectPod will be false. // - It is an endpoint with an associate Pod, but its not found. In this case, expectPod will be true. // this may happen due to eventually consistency issues, out of order events, etc. In this case, the caller // should not precede with the endpoint, or inaccurate information would be sent which may have impacts on // correctness and security.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
// // If a kubeClient is provided, then it synchronizes ResourceSlices // with the resource information provided by plugins. Without it, // the controller is inactive. This can happen when kubelet is run stand-alone // without an apiserver. In that case we can't and don't need to publish // ResourceSlices.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
platforms/software/antlr/src/main/java/org/gradle/api/plugins/antlr/internal/AntlrExecuter.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 14 14:52:10 UTC 2023 - 9.8K bytes - Viewed (0) -
src/runtime/HACKING.md
the locked region, reads do not need to be atomic, but the write does. Outside the locked region, reads need to be atomic. * Reads that only happen during STW, where no writes can happen during STW, do not need to be atomic. That said, the advice from the Go memory model stands: "Don't be [too] clever." The performance of the runtime matters, but its robustness matters more.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 13.9K bytes - Viewed (0) -
src/runtime/race.go
return int(n) } // RaceAcquire/RaceRelease/RaceReleaseMerge establish happens-before relations // between goroutines. These inform the race detector about actual synchronization // that it can't see for some reason (e.g. synchronization within RaceDisable/RaceEnable // sections of code). // RaceAcquire establishes a happens-before relation with the preceding
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:37:29 UTC 2024 - 20.4K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
Subscribed: sets.New(subs...), Unsubscribed: sets.New(req.ResourceNamesUnsubscribe...).Delete("*"), }, } // SidecarScope for the proxy may has not been updated based on this pushContext. // It can happen when `processRequest` comes after push context has been updated(s.initPushContext), // but before proxy's SidecarScope has been updated(s.updateProxy).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0)