Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 432 for unlock2 (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top