- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,074 for Unlock1 (0.15 sec)
-
pkg/kubelet/cm/fake_container_manager.go
cm.Lock() defer cm.Unlock() cm.CalledFunctions = append(cm.CalledFunctions, "QOSContainersInfo") return QOSContainersInfo{} } func (cm *FakeContainerManager) UpdateQOSCgroups() error { cm.Lock() defer cm.Unlock() cm.CalledFunctions = append(cm.CalledFunctions, "UpdateQOSCgroups") return nil } func (cm *FakeContainerManager) Status() Status { cm.Lock() defer cm.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:04 UTC 2023 - 7.4K bytes - Viewed (0) -
src/sync/cond_test.go
c.Wait() awake <- g } m.Unlock() }(i) } for i := 0; i < n; i++ { for i := 0; i < n; i++ { <-running // Will deadlock unless n are running. } if i == n-1 { m.Lock() exit = true m.Unlock() } select { case <-awake: t.Fatal("goroutine not asleep") default: } m.Lock() c.Broadcast() m.Unlock() seen := make([]bool, n)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 22 18:52:42 UTC 2023 - 5K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/ConcurrentBuildsIncrementalBuildIntegrationTest.groovy
outputFile = file('src.a.txt') } task block1 { dependsOn a doLast { ${server.callFromBuild("block1")} } } task block2 { dependsOn a doLast { ${server.callFromBuild("block2")} } } """ TestFile inputFile = file('src.txt') inputFile.text = 'content' def block1 = server.expectAndBlock("block1")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Mar 12 09:35:17 UTC 2020 - 5.7K bytes - Viewed (0) -
src/sync/map_reference_test.go
m.dirty = make(map[any]any) } previous, loaded = m.dirty[key] m.dirty[key] = value m.mu.Unlock() return } func (m *RWMutexMap) LoadAndDelete(key any) (value any, loaded bool) { m.mu.Lock() value, loaded = m.dirty[key] if !loaded { m.mu.Unlock() return nil, false } delete(m.dirty, key) m.mu.Unlock() return value, loaded } func (m *RWMutexMap) Delete(key any) { m.mu.Lock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 01 15:34:22 UTC 2024 - 5.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ConcurrentBuildsArtifactTransformIntegrationTest.groovy
given: // Run two builds where one build applies one transform and the other build the second buildFile << """ task block1 { doLast { ${server.callFromBuild("block1")} } } block1.mustRunAfter redThings blueThings.mustRunAfter block1 task block2 { doLast { ${server.callFromBuild("block2")} } } block2.mustRunAfter blueThings """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
f.Lock() defer f.Unlock() if !f.stopped { klog.V(4).Infof("Stopping fake watcher.") close(f.result) f.stopped = true } } func (f *FakeWatcher) IsStopped() bool { f.Lock() defer f.Unlock() return f.stopped } // Reset prepares the watcher to be reused. func (f *FakeWatcher) Reset() { f.Lock() defer f.Unlock() f.stopped = false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
src/runtime/race/testdata/rwmutex_test.go
go func() { mu1.Lock() defer mu1.Unlock() x = 1 ch <- true }() go func() { mu2.Lock() x = 2 mu2.Unlock() ch <- true }() <-ch <-ch } func TestNoRaceRWMutex(t *testing.T) { var mu sync.RWMutex var x, y int64 = 0, 1 _ = y ch := make(chan bool, 2) go func() { mu.Lock() defer mu.Unlock() x = 2 ch <- true }() go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 03 22:09:38 UTC 2017 - 2.1K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
defer func() { if recover() == nil { t.Fatalf("unlock of unlocked RWMutex did not panic") } }() mu := NewDRWMutex(ds, "test") mu.Unlock(context.Background()) } // Borrowed from rwmutex_test.go func TestUnlockPanic2(t *testing.T) { mu := NewDRWMutex(ds, "test-unlock-panic-2") defer func() { if recover() == nil { t.Fatalf("unlock of unlocked RWMutex did not panic") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
src/net/http/httputil/persist.go
sc.mu.Lock() sc.pipereq[req] = id sc.mu.Unlock() } }() sc.mu.Lock() if sc.we != nil { // no point receiving if write-side broken or closed defer sc.mu.Unlock() return nil, sc.we } if sc.re != nil { defer sc.mu.Unlock() return nil, sc.re } if sc.r == nil { // connection closed by user in the meantime defer sc.mu.Unlock() return nil, errClosed } r := sc.r
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0) -
src/sync/rwmutex_test.go
wlocked <- true } }() for i := 0; i < n; i++ { <-rlocked rl.Unlock() select { case <-wlocked: t.Fatal("RLocker() didn't read-lock it") default: } rl.Unlock() <-wlocked select { case <-rlocked: t.Fatal("RLocker() didn't respect the write lock") default: } wl.Unlock() } } func BenchmarkRWMutexUncontended(b *testing.B) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 29 17:13:13 UTC 2021 - 4.9K bytes - Viewed (0)