- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for lock1 (0.1 sec)
-
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) -
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) -
src/crypto/x509/x509_test.go
t.Errorf("ParsePKCS1PublicKey = %+v, want %+v", pub, pub2) } // It's never been documented that asn1.Marshal/Unmarshal on rsa.PublicKey works, // but it does, and we know of code that depends on it. // Lock that in, even though we'd prefer that people use MarshalPKCS1PublicKey and ParsePKCS1PublicKey. derBytes2, err := asn1.Marshal(*pub) if err != nil { t.Errorf("Marshal(rsa.PublicKey): %v", err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:00:16 UTC 2024 - 163.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
kl := testKubelet.kubelet // convertToAPIContainerStatuses is purely transformative and shouldn't alter the state of the kubelet // as there are no synchronisation events in that function (no locks, no channels, ...) each test routine // should have its own vector clock increased independently. Golang race detector uses pure happens-before
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0)