- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 22 for lock1 (0.07 sec)
-
src/cmd/vendor/rsc.io/markdown/emoji.go
"clinking_glasses": "\U0001f942", "clipboard": "\U0001f4cb", "clipperton_island": "\U0001f1e8\U0001f1f5", "clock1": "\U0001f550", "clock10": "\U0001f559", "clock1030": "\U0001f565", "clock11": "\U0001f55a",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 107.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
_, err := registry.DeleteCollection(ctx, func(ctx context.Context, obj runtime.Object) error { lock.Lock() defer lock.Unlock() if called { t.Errorf("Delete called more than once, so context cancellation didn't work") } else { cancel() called = true } return nil }, nil, &metainternalversion.ListOptions{}) if err != context.Canceled {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
return } if rt.parallelLock.TryLock() { // lock acquired: we are the only or the first concurrent request // initialize the next set of parallel requests rt.parallelRequests = 1 } else { // lock is held by other requests // now wait for the lock to increase the parallelRequests rt.parallelLock.Lock() rt.parallelRequests++ } defer rt.parallelLock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
src/cmd/go/internal/work/exec.go
if cfg.BuildN { sh.ShowCmd(b.WorkDir, "%s || true", joinUnambiguously(cmdArgs)) return false } // gccCompilerID acquires b.exec, so do before acquiring lock. compilerID, cacheOK := b.gccCompilerID(compiler[0]) b.exec.Lock() defer b.exec.Unlock() if b, ok := b.flagCache[key]; ok { return b } if b.flagCache == nil { b.flagCache = make(map[[2]string]bool) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 14:46:37 UTC 2024 - 105.6K bytes - Viewed (0) -
doc/go1.17_spec.html
of an interface type or of elements of a composite type remains unchanged: </p> <pre> // A Mutex is a data type with two methods, Lock and Unlock. type Mutex struct { /* Mutex fields */ } func (m *Mutex) Lock() { /* Lock implementation */ } func (m *Mutex) Unlock() { /* Unlock implementation */ } // NewMutex has the same composition as Mutex but its method set is empty.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 11 20:22:45 UTC 2024 - 211.6K bytes - Viewed (0) -
cmd/object-handlers_test.go
{"enc-mp-2", []int64{5487701, 5487799, 3}, mapCopy(metaWithSSEC)}, {"enc-mp-3", []int64{10499807, 10499963, 7}, mapCopy(metaWithSSEC)}, } // SSEC can't be used with compression globalCompressConfigMu.Lock() globalCompressEnabled := globalCompressConfig.Enabled globalCompressConfigMu.Unlock() if globalCompressEnabled { objectInputs = objectInputs[0:8] }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 161.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/validation_test.go
warnings []string } // AddWarning adds a warning to recorder. func (r *warningRecorder) AddWarning(agent, text string) { r.mu.Lock() defer r.mu.Unlock() r.warnings = append(r.warnings, text) } func (r *warningRecorder) Warnings() []string { r.mu.Lock() defer r.mu.Unlock() warnings := make([]string, len(r.warnings)) copy(warnings, r.warnings) return warnings }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 17:14:10 UTC 2024 - 159.9K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
proxy, cb.req.Push, "outbound|8080|v1|foo.com", model.TrafficDirectionOutbound, "v1", "foo.com", 8080, service, dr, ) eps := eb.FromServiceEndpoints() mu.Lock() actual = eps mu.Unlock() wg.Done() }() } wg.Wait() sortEndpoints(actual) if v := cmp.Diff(expected, actual, protocmp.Transform()); v != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
src/reflect/all_test.go
func runSelect(cases []SelectCase, info []caseInfo) (chosen int, recv Value, recvOK bool, panicErr any) { defer func() { panicErr = recover() selectWatch.Lock() selectWatch.info = nil selectWatch.Unlock() }() selectWatch.Lock() selectWatch.now = time.Now() selectWatch.info = info selectWatch.Unlock() chosen, recv, recvOK = Select(cases) return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 218.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
kubelet.HandlePodCleanups(ctx) kubelet.HandlePodCleanups(ctx) destroyCount := 0 err := wait.Poll(100*time.Millisecond, 10*time.Second, func() (bool, error) { fakeContainerManager.PodContainerManager.Lock() defer fakeContainerManager.PodContainerManager.Unlock() destroyCount = 0 for _, functionName := range fakeContainerManager.PodContainerManager.CalledFunctions { if functionName == "Destroy" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0)