| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/prober/ |
| H A D | prober_manager.go | 78 workerLock sync.RWMutex member
154 m.workerLock.Lock()
155 defer m.workerLock.Unlock()
200 m.workerLock.RLock()
201 defer m.workerLock.RUnlock()
216 m.workerLock.RLock()
217 defer m.workerLock.RUnlock()
274 m.workerLock.RLock()
282 m.workerLock.Lock()
283 defer m.workerLock.Unlock()
[all …]
|
| H A D | prober_manager_test.go | 370 m.workerLock.RLock()
371 defer m.workerLock.RUnlock()
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/swarm/storage/ |
| H A D | chunker.go | 110 workerLock sync.RWMutex // lock for the worker count member
210 tc.workerLock.Lock()
211 defer tc.workerLock.Unlock()
216 tc.workerLock.RLock()
217 defer tc.workerLock.RUnlock()
222 tc.workerLock.Lock()
223 defer tc.workerLock.Unlock()
|
| H A D | pyramid.go | 151 workerLock sync.RWMutex member
191 pc.workerLock.Lock()
192 defer pc.workerLock.Unlock()
197 pc.workerLock.Lock()
198 defer pc.workerLock.Unlock()
203 pc.workerLock.Lock()
204 defer pc.workerLock.Unlock()
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/garbagecollector/ |
| H A D | garbagecollector.go | 78 workerLock sync.RWMutex member
196 gc.workerLock.Lock()
197 defer gc.workerLock.Unlock()
304 gc.workerLock.RLock()
305 defer gc.workerLock.RUnlock()
649 gc.workerLock.RLock()
650 defer gc.workerLock.RUnlock()
|
| H A D | garbagecollector_test.go | 876 err = expectSyncNotBlocked(fakeDiscoveryClient, &gc.workerLock)
892 err = expectSyncNotBlocked(fakeDiscoveryClient, &gc.workerLock)
908 err = expectSyncNotBlocked(fakeDiscoveryClient, &gc.workerLock)
914 func expectSyncNotBlocked(fakeDiscoveryClient *fakeServerResources, workerLock *sync.RWMutex) error…
925 workerLock.Lock()
926 defer workerLock.Unlock()
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/resourcequota/ |
| H A D | resource_quota_controller.go | 101 workerLock sync.RWMutex member
246 rq.workerLock.RLock()
247 defer rq.workerLock.RUnlock()
430 rq.workerLock.Lock()
431 defer rq.workerLock.Unlock()
|
| H A D | resource_quota_controller_test.go | 1082 err = expectSyncNotBlocked(fakeDiscoveryClient, &qc.workerLock)
1098 err = expectSyncNotBlocked(fakeDiscoveryClient, &qc.workerLock)
1114 err = expectSyncNotBlocked(fakeDiscoveryClient, &qc.workerLock)
1129 func expectSyncNotBlocked(fakeDiscoveryClient *fakeServerResources, workerLock *sync.RWMutex) error…
1140 workerLock.Lock()
1141 defer workerLock.Unlock()
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.swt/examples/org.eclipse.swt.examples/src/org/eclipse/swt/examples/fileviewer/ |
| H A D | FileViewer.java | 141 private final Object workerLock = new Object(); field in FileViewer
1480 synchronized(workerLock) { in workerStop()
1483 workerLock.notifyAll(); in workerStop()
1501 synchronized(workerLock) { in workerUpdate()
1505 workerLock.notifyAll(); in workerUpdate()
1518 synchronized(workerLock) {
1523 synchronized(workerLock) {
1525 if ((!workerCancelled) && (workerStateDir == workerNextDir)) workerLock.wait();
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/dom/workers/ |
| H A D | WorkerThread.cpp | 275 MutexAutoLock workerLock(workerPrivate->mMutex); in Dispatch() local
|
| /dports/lang/spidermonkey60/firefox-60.9.0/dom/workers/ |
| H A D | WorkerThread.cpp | 265 MutexAutoLock workerLock(workerPrivate->mMutex); in Dispatch() local
|
| /dports/www/firefox-esr/firefox-91.8.0/dom/workers/ |
| H A D | WorkerThread.cpp | 299 MutexAutoLock workerLock(workerPrivate->mMutex); in Dispatch() local
|
| /dports/www/firefox/firefox-99.0/dom/workers/ |
| H A D | WorkerThread.cpp | 299 MutexAutoLock workerLock(workerPrivate->mMutex); in Dispatch() local
|
| /dports/mail/thunderbird/thunderbird-91.8.0/dom/workers/ |
| H A D | WorkerThread.cpp | 299 MutexAutoLock workerLock(workerPrivate->mMutex); in Dispatch() local
|
| /dports/lang/spidermonkey78/firefox-78.9.0/dom/workers/ |
| H A D | WorkerThread.cpp | 294 MutexAutoLock workerLock(workerPrivate->mMutex); in Dispatch() local
|
| /dports/games/0ad/0ad-0.0.23b-alpha/source/soundmanager/ |
| H A D | SoundManager.cpp | 129 CScopeLock workerLock(m_WorkerMutex); in Run() local
|