Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 178 for runlock (0.1 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/tier.go

    }
    
    func (config *TierConfigMgr) refreshedAt() time.Time {
    	config.RLock()
    	defer config.RUnlock()
    	return config.lastRefreshedAt
    }
    
    // IsTierValid returns true if there exists a remote tier by name tierName,
    // otherwise returns false.
    func (config *TierConfigMgr) IsTierValid(tierName string) bool {
    	config.RLock()
    	defer config.RUnlock()
    	_, valid := config.isTierNameInUse(tierName)
    	return valid
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  2. internal/logger/reqinfo.go

    func (r *ReqInfo) GetTags() []KeyVal {
    	if r == nil {
    		return nil
    	}
    	r.RLock()
    	defer r.RUnlock()
    	return append(make([]KeyVal, 0, len(r.tags)), r.tags...)
    }
    
    // GetTagsMap - returns the user defined tags in a map structure
    func (r *ReqInfo) GetTagsMap() map[string]string {
    	if r == nil {
    		return nil
    	}
    	r.RLock()
    	defer r.RUnlock()
    	m := make(map[string]string, len(r.tags))
    	for _, t := range r.tags {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  3. internal/config/callhome/callhome.go

    // Enabled - indicates if callhome is enabled or not
    func (c *Config) Enabled() bool {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	return c.Enable
    }
    
    // FrequencyDur - returns the currently configured callhome frequency
    func (c *Config) FrequencyDur() time.Duration {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	if c.Frequency == 0 {
    		return callhomeCycleDefault
    	}
    
    	return c.Frequency
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 2.6K bytes
    - Click Count (0)
  4. cmd/bucket-metadata-sys.go

    func (sys *BucketMetadataSys) Count() int {
    	sys.RLock()
    	defer sys.RUnlock()
    
    	return len(sys.metadataMap)
    }
    
    // Remove bucket metadata from memory.
    func (sys *BucketMetadataSys) Remove(buckets ...string) {
    	sys.Lock()
    	for _, bucket := range buckets {
    		sys.group.Forget(bucket)
    		delete(sys.metadataMap, bucket)
    		globalBucketMonitor.DeleteBucket(bucket)
    	}
    	sys.Unlock()
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  5. internal/lru/lru.go

    func (c *LRU[K, V]) Contains(key K) (ok bool) {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    	_, ok = c.items[key]
    	return ok
    }
    
    // Peek returns the key value (or undefined if not found) without updating
    // the "recently used"-ness of the key.
    func (c *LRU[K, V]) Peek(key K) (value V, ok bool) {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    	var ent *Entry[K, V]
    	if ent, ok = c.items[key]; ok {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 12.6K bytes
    - Click Count (0)
  6. internal/config/storageclass/storage-class.go

    func (sCfg *Config) AvailabilityOptimized() bool {
    	ConfigLock.RLock()
    	defer ConfigLock.RUnlock()
    	if !sCfg.initialized {
    		return true
    	}
    	return sCfg.Optimize == "availability" || sCfg.Optimize == ""
    }
    
    // Update update storage-class with new config
    func (sCfg *Config) Update(newCfg Config) {
    	ConfigLock.Lock()
    	defer ConfigLock.Unlock()
    	sCfg.RRS = newCfg.RRS
    	sCfg.Standard = newCfg.Standard
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  7. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Mar 05 02:50:24 GMT 2024
    - 1.3K bytes
    - Click Count (0)
  8. cmd/http-stats.go

    	if stats == nil {
    		return 0
    	}
    
    	stats.RLock()
    	defer stats.RUnlock()
    
    	val, ok := stats.apiStats[api]
    	if ok {
    		return val
    	}
    
    	return 0
    }
    
    // Load returns the recorded stats.
    func (stats *HTTPAPIStats) Load(toLower bool) map[string]int {
    	if stats == nil {
    		return map[string]int{}
    	}
    
    	stats.RLock()
    	defer stats.RUnlock()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Sep 24 17:13:00 GMT 2024
    - 11.4K bytes
    - Click Count (0)
  9. cmd/admin-heal-ops.go

    	var count int64
    	h.mutex.RLock()
    	defer h.mutex.RUnlock()
    
    	for _, v := range h.scannedItemsMap {
    		count += v
    	}
    	return count
    }
    
    // getScannedItemsMap - returns map of all scanned items against type
    func (h *healSequence) getScannedItemsMap() map[madmin.HealItemType]int64 {
    	h.mutex.RLock()
    	defer h.mutex.RUnlock()
    
    	// Make a copy before returning the value
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  10. internal/config/heal/heal.go

    // - '> 0' interval duration between cycles
    func (opts Config) BitrotScanCycle() (d time.Duration) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.cache.bitrotCycle
    }
    
    // Clone safely the heal configuration
    func (opts Config) Clone() (int, time.Duration, string) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.IOCount, opts.Sleep, opts.Bitrot
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Nov 04 19:06:02 GMT 2024
    - 4.9K bytes
    - Click Count (0)
Back to Top