- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 432 for unlock2 (0.17 sec)
-
cmd/http-stats.go
if stats == nil { return } stats.Lock() defer stats.Unlock() if stats.apiStats == nil { stats.apiStats = make(map[string]int) } stats.apiStats[api]++ } // Dec increments the api stats counter. func (stats *HTTPAPIStats) Dec(api string) { if stats == nil { return } stats.Lock() defer stats.Unlock() if val, ok := stats.apiStats[api]; ok && val > 0 { stats.apiStats[api]--
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 06:25:13 UTC 2024 - 11.5K bytes - Viewed (0) -
src/runtime/time.go
func (t *timer) lock() { lock(&t.mu) t.trace("lock") } // unlock updates t.astate and unlocks the timer. func (t *timer) unlock() { t.trace("unlock") // Let heap fast paths know whether heap[i].when is accurate. // Also let maybeRunChan know whether channel is in heap. t.astate.Store(t.state) unlock(&t.mu) } // hchan returns the channel in t.arg. // t must be a timer with a channel.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 14:36:24 UTC 2024 - 37.5K 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) -
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/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) -
cmd/local-locker.go
return s + strconv.Itoa(idx) } func (l *localLocker) Unlock(_ context.Context, args dsync.LockArgs) (reply bool, err error) { if len(args.Resources) > maxDeleteList { return false, fmt.Errorf("internal error: localLocker.Unlock called with more than %d resources", maxDeleteList) } l.mutex.Lock() defer l.mutex.Unlock() err = nil for _, resource := range args.Resources {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 10.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world.go
func (dsw *desiredStateOfWorld) NodeExists(nodeName k8stypes.NodeName) bool { dsw.RLock() defer dsw.RUnlock() _, nodeExists := dsw.nodesManaged[nodeName] return nodeExists } func (dsw *desiredStateOfWorld) VolumeExists( volumeName v1.UniqueVolumeName, nodeName k8stypes.NodeName) bool { dsw.RLock() defer dsw.RUnlock() nodeObj, nodeExists := dsw.nodesManaged[nodeName] if nodeExists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
nw := ns.Labels[label.TopologyNetwork.Name] n.Lock() defer n.Unlock() oldDefaultNetwork := n.network n.network = network.ID(nw) return oldDefaultNetwork != n.network } func (n *networkManager) networkFromSystemNamespace() network.ID { n.RLock() defer n.RUnlock() return n.network } func (n *networkManager) networkFromMeshNetworks(endpointIP string) network.ID {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
if r == nil { return } r.Lock() defer r.Unlock() delete(r.Cache, bucket) } // UpdateReplicaStat updates in-memory replica statistics with new values. func (r *ReplicationStats) UpdateReplicaStat(bucket string, n int64) { if r == nil { return } r.Lock() defer r.Unlock() bs, ok := r.Cache[bucket] if !ok { bs = newBucketReplicationStats() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go
w.mu.Lock() defer w.mu.Unlock() if w.hijacked { klog.Errorf("Write called after hijack") return 0, http.ErrHijacked } w.written = true return w.w.Write(p) } // WriteHeader is delegated to the stored "http.ResponseWriter". func (w *tunnelingResponseWriter) WriteHeader(statusCode int) { w.mu.Lock() defer w.mu.Unlock() if w.written {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.7K bytes - Viewed (0)