- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 163 for race (0.04 sec)
-
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/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) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
assert.ChannelIsEmpty(t, writes) defaultGateway.Annotations["foo"] = "bar" gws.Update(defaultGateway) expectReconciled() // We should not be updating the version, its already set. Setting it introduces a possible race condition // since we use SSA so there is no conflict checks. assert.ChannelIsEmpty(t, writes) // Somehow the annotation is removed - it should be added back defaultGateway.Annotations = map[string]string{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
thread.join(); // It's possible to race and suspend the thread just before the park call actually takes effect, // causing the thread to be suspended for 3.5 seconds, and then park itself for 2 seconds after // being resumed. To avoid a flake in this scenario, calculate how long that thread actually // waited and assert based on that time. Empirically, the race where the thread ends up waiting
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
src/go/types/instantiate.go
res = sig default: // only types and functions can be generic panic(fmt.Sprintf("%v: cannot instantiate %v", pos, orig)) } // Update all contexts; it's possible that we've lost a race. return updateContexts(res) } // validateTArgLen checks that the number of type arguments (got) matches the // number of type parameters (want); if they don't match an error is reported.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:01:18 UTC 2024 - 12.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
} // GetRegistries returns a copy of all registries func (c *Controller) GetRegistries() []serviceregistry.Instance { c.storeLock.RLock() defer c.storeLock.RUnlock() // copy registries to prevent race, no need to deep copy here. out := make([]serviceregistry.Instance, len(c.registries)) for i := range c.registries { out[i] = c.registries[i] } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
src/os/exec.go
// flags is the reason the handle is unavailable, which affects the // errors returned by concurrent calls. state atomic.Uint64 // Used only in modePID. sigMu sync.RWMutex // avoid race between wait and signal // handle is the OS handle for process actions, used only in // modeHandle. // // handle must be accessed only via the handleTransientAcquire method
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 12.8K bytes - Viewed (0)