- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 432 for unlock2 (0.2 sec)
-
pkg/kubelet/volumemanager/cache/desired_state_of_world.go
dsw.Lock() defer dsw.Unlock() if errs, found := dsw.podErrors[podName]; found { if errs.Len() <= maxPodErrors { errs.Insert(err) } return } dsw.podErrors[podName] = sets.New[string](err) } func (dsw *desiredStateOfWorld) PopPodErrors(podName types.UniquePodName) []string { dsw.Lock() defer dsw.Unlock() if errs, found := dsw.podErrors[podName]; found {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 27.1K bytes - Viewed (0) -
src/go/token/position.go
// => column is relative to alternative column column = alt.Column + (offset - alt.Offset) } } } } // TODO(mvdan): move Unlock back under Lock with a defer statement once // https://go.dev/issue/38471 is fixed to remove the performance penalty. f.mutex.Unlock() return } func (f *File) position(p Pos, adjusted bool) (pos Position) { offset := f.fixOffset(int(p) - f.base) pos.Offset = offset
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.7K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
func (e *EndpointIndex) DeleteServiceShard(shard ShardKey, serviceName, namespace string, preserveKeys bool) { e.mu.Lock() defer e.mu.Unlock() e.deleteServiceInner(shard, serviceName, namespace, preserveKeys) } func (e *EndpointIndex) DeleteShard(shardKey ShardKey) { e.mu.Lock() defer e.mu.Unlock() for svc, shardsByNamespace := range e.shardsBySvc { for ns := range shardsByNamespace {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/networking/core/accesslog.go
b.mutex.Lock() defer b.mutex.Unlock() b.listenerFileAccessLog = lal return lal } func (b *AccessLogBuilder) cachedFileAccessLog() *accesslog.AccessLog { b.mutex.RLock() defer b.mutex.RUnlock() return b.fileAccesslog } func (b *AccessLogBuilder) cachedListenerFileAccessLog() *accesslog.AccessLog { b.mutex.RLock() defer b.mutex.RUnlock() return b.listenerFileAccessLog }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
gb.stopCh = ctx.Done() gb.running = true gb.monitorLock.Unlock() // Start monitors and begin change processing until the stop channel is // closed. gb.startMonitors(logger) wait.Until(func() { gb.runProcessGraphChanges(logger) }, 1*time.Second, ctx.Done()) // Stop any running monitors. gb.monitorLock.Lock() defer gb.monitorLock.Unlock() monitors := gb.monitors stopped := 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
pilot/pkg/status/distribution/reporter.go
return } r.mu.Lock() defer r.mu.Unlock() r.inProgressResources[myRes.ToModelKey()] = &inProgressEntry{ Resource: myRes, completedIterations: 0, } } func (r *Reporter) DeleteInProgressResource(res config.Config) { tryLedgerDelete(r.ledger, res) if r.controller != nil { r.controller.configDeleted(res) } r.mu.Lock() defer r.mu.Unlock() delete(r.inProgressResources, res.Key())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 11.5K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
srQueueStats: newInQueueStats(r, "site"), } } func (q *queueCache) update() { q.Lock() defer q.Unlock() q.srQueueStats.update() for _, s := range q.bucketStats { s.update() } } func (q *queueCache) getBucketStats(bucket string) InQueueMetric { q.RLock() defer q.RUnlock() v, ok := q.bucketStats[bucket] if !ok { return InQueueMetric{} } return InQueueMetric{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 14.2K bytes - Viewed (0) -
security/pkg/nodeagent/cache/secretcache.go
s.mu.RLock() defer s.mu.RUnlock() return s.certRoot } // SetRoot sets root cert into cache. This method is thread safe. func (s *secretCache) SetRoot(rootCert []byte) { s.mu.Lock() defer s.mu.Unlock() s.certRoot = rootCert } func (s *secretCache) GetWorkload() *security.SecretItem { s.mu.RLock() defer s.mu.RUnlock() if s.workload == nil { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 04 08:29:46 UTC 2024 - 28.2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/pod_devices.go
pdev.RLock() defer pdev.RUnlock() ret := sets.New[string]() for k := range pdev.devs { ret.Insert(k) } return ret } func (pdev *podDevices) size() int { pdev.RLock() defer pdev.RUnlock() return len(pdev.devs) } func (pdev *podDevices) hasPod(podUID string) bool { pdev.RLock() defer pdev.RUnlock() _, podExists := pdev.devs[podUID] return podExists }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 16.7K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
if !update { z.poolMetaMutex.Lock() z.poolMeta = meta z.poolMetaMutex.Unlock() } else { newMeta := newPoolMeta(z, meta) if err = newMeta.save(ctx, z.serverPools); err != nil { return err } z.poolMetaMutex.Lock() z.poolMeta = newMeta z.poolMetaMutex.Unlock() } pools := meta.returnResumablePools() poolIndices := make([]int, 0, len(pools))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 14:30:43 UTC 2024 - 41.5K bytes - Viewed (1)