- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,097 for unlock2 (0.11 sec)
-
cmd/lock-rest-client_test.go
if err == nil { t.Fatal("Expected for Lock to fail") } _, err = lkClient.RUnlock(context.Background(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for RUnlock to fail") } _, err = lkClient.Unlock(context.Background(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Unlock to fail") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/DefaultResourceLockCoordinationService.java
return tryLock(Arrays.asList(resourceLocks)); } /** * Unlocks the provided resource locks. */ public static InternalTransformer<ResourceLockState.Disposition, ResourceLockState> unlock(Iterable<? extends ResourceLock> resourceLocks) { return new ReleaseLocks(resourceLocks); } /** * Unlocks the provided resource locks. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 11.9K bytes - Viewed (0) -
src/syscall/env_unix.go
} envLock.Lock() defer envLock.Unlock() i, ok := env[key] kv := key + "=" + value if ok { envs[i] = kv } else { i = len(envs) envs = append(envs, kv) } env[key] = i runtimeSetenv(key, value) return nil } func Clearenv() { envOnce.Do(copyenv) // prevent copyenv in Getenv/Setenv envLock.Lock() defer envLock.Unlock() for k := range env {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 20:58:35 UTC 2023 - 2.7K bytes - Viewed (0) -
prepare_stmt.go
db.Mux.RUnlock() // wait for other goroutines prepared <-stmt.prepared if stmt.prepareErr != nil { return Stmt{}, stmt.prepareErr } return *stmt, nil } db.Mux.RUnlock() db.Mux.Lock() // double check if stmt, ok := db.Stmts[query]; ok && (!stmt.Transaction || isTransaction) { db.Mux.Unlock() // wait for other goroutines prepared <-stmt.prepared
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Thu Mar 28 08:47:39 UTC 2024 - 6.4K bytes - Viewed (0) -
operator/pkg/cache/cache.go
objectCachesMu.RLock() objectCache := objectCaches[name] objectCachesMu.RUnlock() if objectCache != nil { objectCache.Mu.Lock() delete(objectCache.Cache, objHash) objectCache.Mu.Unlock() } } // RemoveCache removes the object Cache with the give name. func RemoveCache(name string) { objectCachesMu.Lock() defer objectCachesMu.Unlock() delete(objectCaches, name)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 06 13:12:49 UTC 2023 - 2.4K bytes - Viewed (0) -
cmd/tier.go
} func (t *tierMetrics) logSuccess(tier string) { t.Lock() defer t.Unlock() stat := t.requestsCount[tier] stat.success++ t.requestsCount[tier] = stat } func (t *tierMetrics) logFailure(tier string) { t.Lock() defer t.Unlock() stat := t.requestsCount[tier] stat.failure++ t.requestsCount[tier] = stat } var (
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 08:44:07 UTC 2024 - 15.5K bytes - Viewed (0) -
pkg/filewatcher/worker.go
ft := wk.watchedFiles[path] if ft == nil { wk.mu.Unlock() return fmt.Errorf("path %s not found", path) } delete(wk.watchedFiles, path) wk.mu.Unlock() wk.retireTrackerCh <- ft return nil } func (wk *worker) eventChannel(path string) chan fsnotify.Event { wk.mu.RLock() defer wk.mu.RUnlock() if ft := wk.watchedFiles[path]; ft != nil { return ft.events }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 22:31:06 UTC 2024 - 5.2K bytes - Viewed (0) -
pilot/pkg/trustbundle/trustbundle.go
tb.endpointMutex.RLock() remoteEndpoints := tb.endpoints tb.endpointMutex.RUnlock() if slices.Equal(spiffeEndpoints, remoteEndpoints) { return } trustBundleLog.Infof("updated remote endpoints :%v", spiffeEndpoints) tb.endpointMutex.Lock() tb.endpoints = spiffeEndpoints tb.endpointMutex.Unlock() tb.endpointUpdateChan <- struct{}{} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
asw.Lock() defer asw.Unlock() volumeObj, ok := asw.attachedVolumes[volumeName] if ok { volumeObj.persistentVolumeSize = claimSize asw.attachedVolumes[volumeName] = volumeObj return true } return false } func (asw *actualStateOfWorld) MarkRemountRequired( podName volumetypes.UniquePodName) { asw.Lock() defer asw.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
pkg/kube/multicluster/component.go
m.mu.RLock() defer m.mu.RUnlock() t, f := m.clusters[clusterID] if !f { return nil } return &t } func (m *Component[T]) All() []T { m.mu.RLock() defer m.mu.RUnlock() return maps.Values(m.clusters) } func (m *Component[T]) clusterAdded(cluster *Cluster) ComponentConstraint { comp := m.constructor(cluster) m.mu.Lock() defer m.mu.Unlock() m.clusters[cluster.ID] = comp
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.4K bytes - Viewed (0)