- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,091 for unlock2 (0.14 sec)
-
pilot/pkg/config/memory/store.go
} } return out } func (cr *store) Delete(kind config.GroupVersionKind, name, namespace string, resourceVersion *string) error { cr.mutex.Lock() defer cr.mutex.Unlock() data, ok := cr.data[kind] if !ok { return fmt.Errorf("unknown type %v", kind) } ns, exists := data[namespace] if !exists { return errNotFound } _, exists = ns[name]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 26 01:14:27 UTC 2023 - 6.3K 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) -
security/pkg/credentialfetcher/plugin/mock.go
ms.mutex.Lock() defer ms.mutex.Unlock() ms.numGetTokenCall = 0 ms.credential = "" } func (ms *MetadataServer) getToken(w http.ResponseWriter, req *http.Request) { ms.mutex.Lock() defer ms.mutex.Unlock() ms.numGetTokenCall++ token := fmt.Sprintf("%s%d", fakeTokenPrefix, ms.numGetTokenCall) if ms.credential != "" { token = ms.credential } fmt.Fprint(w, token) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3K 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) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/caching_object.go
func (o *cachingObject) conditionalSet(isNoop func() bool, set func()) { if fastPath := func() bool { o.lock.RLock() defer o.lock.RUnlock() return isNoop() }(); fastPath { return } o.lock.Lock() defer o.lock.Unlock() if isNoop() { return } if !o.deepCopied { o.object = o.object.DeepCopyObject().(metaRuntimeInterface) o.deepCopied = true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 18:03:48 UTC 2023 - 12.6K bytes - Viewed (0) -
pkg/config/mesh/networks_watcher.go
} w.mutex.Unlock() // Notify the handlers of the change. for _, h := range handlers { h.handler() } } // AddNetworksHandler registers a callback handler for changes to the mesh network config. func (w *internalNetworkWatcher) AddNetworksHandler(h func()) *WatcherHandlerRegistration { w.mutex.Lock() defer w.mutex.Unlock() handler := &WatcherHandlerRegistration{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 4.9K bytes - Viewed (0) -
cmd/iam-store.go
// concurrently reading and writing the IAM storage. The (r)lock() // functions return the iamCache. The cache can be safely written to // only when returned by `lock()`. lock() *iamCache unlock() rlock() *iamCache runlock() getUsersSysType() UsersSysType loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/index.go
} // Empty implements Index. func (i *index) Empty() bool { i.mu.RLock() defer i.mu.RUnlock() return len(i.keyToInstance) == 0 } // ForEach iterates over all workload instances in the index. func (i *index) ForEach(fn func(*model.WorkloadInstance)) { i.mu.RLock() defer i.mu.RUnlock() for _, instance := range i.keyToInstance { fn(instance) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 16 05:45:36 UTC 2023 - 4.1K bytes - Viewed (0) -
internal/logger/reqinfo.go
if r == nil { return nil } r.Lock() defer r.Unlock() r.tags = append(r.tags, KeyVal{key, val}) return r } // SetTags - sets key/val to ReqInfo.tags func (r *ReqInfo) SetTags(key string, val interface{}) *ReqInfo { if r == nil { return nil } r.Lock() defer r.Unlock() // Search of tag key already exists in tags var updated bool for _, tag := range r.tags {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/max_seats.go
func (m *maxSeatsTracker) GetMaxSeats(plName string) uint64 { m.RLock() defer m.RUnlock() return m.maxSeats[plName] } func (m *maxSeatsTracker) SetMaxSeats(plName string, maxSeats uint64) { m.Lock() defer m.Unlock() m.maxSeats[plName] = maxSeats } func (m *maxSeatsTracker) ForgetPriorityLevel(plName string) { m.Lock() defer m.Unlock() delete(m.maxSeats, plName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 1.7K bytes - Viewed (0)