- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,230 for unlock2 (0.11 sec)
-
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) -
pkg/kubelet/cm/dra/plugin/plugins_store.go
func (s *pluginsStore) get(pluginName string) *plugin { s.RLock() defer s.RUnlock() return s.store[pluginName] } // Set lets you save a DRA Plugin to the list and give it a specific name. // This method is protected by a mutex. func (s *pluginsStore) add(pluginName string, p *plugin) { s.Lock() defer s.Unlock() if s.store == nil { s.store = make(map[string]*plugin) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 13:11:27 UTC 2023 - 1.7K 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) -
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) -
cmd/ilm-config.go
} func (c *ilmConfig) getExpirationWorkers() int { c.mu.RLock() defer c.mu.RUnlock() return c.cfg.ExpirationWorkers } func (c *ilmConfig) getTransitionWorkers() int { c.mu.RLock() defer c.mu.RUnlock() return c.cfg.TransitionWorkers } func (c *ilmConfig) update(cfg ilm.Config) { c.mu.Lock() defer c.mu.Unlock() c.cfg = cfg
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Mar 05 02:50:24 UTC 2024 - 1.3K bytes - Viewed (0) -
internal/grid/muxclient.go
} if m.subroute != nil { msg.Flags |= FlagSubroute } ch := make(chan Response, 1) m.respMu.Lock() if m.closed { m.respMu.Unlock() return nil, ErrDisconnected } m.respWait = ch m.respMu.Unlock() ctx := m.ctx // Add deadline if none. if msg.DeadlineMS == 0 { msg.DeadlineMS = uint32(defaultSingleRequestTimeout / time.Millisecond)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
} } func (pm *basicManager) GetPods() []*v1.Pod { pm.lock.RLock() defer pm.lock.RUnlock() return podsMapToPods(pm.podByUID) } func (pm *basicManager) GetPodsAndMirrorPods() (allPods []*v1.Pod, allMirrorPods []*v1.Pod, orphanedMirrorPodFullnames []string) { pm.lock.RLock() defer pm.lock.RUnlock() allPods = podsMapToPods(pm.podByUID) allMirrorPods = mirrorPodsMapToMirrorPods(pm.mirrorPodByUID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
// lock current snapshot pod map p.mu.RLock() defer p.mu.RUnlock() if info, f := p.currentPodCache[uid]; f { return info.Netns } return nil } // make sure uid is in the cache, even if we don't have a netns func (p *podNetnsCache) Ensure(uid string) { p.mu.Lock() defer p.mu.Unlock() if _, ok := p.currentPodCache[uid]; !ok { p.currentPodCache[uid] = WorkloadInfo{} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 17:18:11 UTC 2024 - 4.3K 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)