- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 461 for race (0.06 sec)
-
pkg/kubelet/cm/devicemanager/manager_test.go
}{ { description: "GetTopologyHints data race when update device", count: 10, devices: devs, testfunc: func(manager *wrappedManagerImpl) { manager.GetTopologyHints(testPod, &testPod.Spec.Containers[0]) }, }, { description: "GetPodTopologyHints data race when update device", count: 10, devices: devs,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
guava/src/com/google/common/base/Suppliers.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 15.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/start.go
return false } // There's a possible race here where two processes check the // token file and see that it's older than the period, then the // first one removes it and creates another, and then a second one // removes the newly created file and creates yet another // file. Then both processes would act as though they had the token. // This is very rare, but it's also okay because we're only grabbing
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 14:52:56 UTC 2024 - 10.8K bytes - Viewed (0) -
src/runtime/proc.go
// CAS and event emission to appear atomic to the tracer. trace := traceAcquire() if trace.ok() { trace.GoPark(traceBlockPreempted, 0) } casfrom_Gscanstatus(gp, _Gscan|_Gpreempted, _Gpreempted) if trace.ok() { traceRelease(trace) } schedule() } // goyield is like Gosched, but it: // - emits a GoPreempt trace event instead of a GoSched trace event
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
src/cmd/compile/internal/types2/validtype.go
func (check *Checker) validType0(pos syntax.Pos, typ Type, nest, path []*Named) bool { typ = Unalias(typ) if check.conf.Trace { if t, _ := typ.(*Named); t != nil && t.obj != nil /* obj should always exist but be conservative */ { pos = t.obj.pos } check.indent++ check.trace(pos, "validType(%s) nest %v, path %v", typ, pathString(makeObjList(nest)), pathString(makeObjList(path))) defer func() { check.indent--
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 15 13:22:37 UTC 2024 - 10.2K bytes - Viewed (0) -
src/go/types/validtype.go
// different in the first place) must be from the current package; // they cannot have been imported. // Therefore it is safe to change their underlying types; there is // no chance for a race condition (the types of the current package // are not yet available to other goroutines). assert(t.obj.pkg == check.pkg) assert(t.Origin().obj.pkg == check.pkg) t.underlying = Typ[Invalid]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 18:48:38 UTC 2024 - 10.3K bytes - Viewed (0) -
src/net/http/httptest/server.go
// requests) and new connections (those which connected // but never sent a request). StateNew connections are // super rare and have only been seen (in // previously-flaky tests) in the case of // socket-late-binding races from the http Client // dialing this server and then getting an idle // connection before the dial completed. There is thus
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
src/runtime/lockrank_on.go
// after effectively any lock (anywhere we might panic), which // the partial order doesn't cover. // // raceFiniLock is held while exiting when running // the race detector. Don't do lock rank recording for it, // since we are exiting. lock2(l) return } if rank == 0 { rank = lockRankLeafRank } gp := getg() // Log the new class. systemstack(func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 10.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
panic("--- registry has been run twice ---") } rr.running.Store(true) <-stop } func expectRunningOrFail(t *testing.T, ctrl *Controller, want bool) { // running gets flipped in a goroutine, retry to avoid race retry.UntilSuccessOrFail(t, func() error { for _, registry := range ctrl.registries { if running := registry.Instance.(*RunnableRegistry).running.Load(); running != want {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/kube/kclient/client.go
// AddEventHandler is safe to call under the lock. This will *enqueue* all existing items, but not block on processing them, // so the timing is quick. // If we do this outside the lock, we can hit a subtle race condition where we have started processing items before they // are registered (in n.registeredHandlers); this can cause the dynamic filtering to miss events reg, err := n.informer.AddEventHandler(fh) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0)