Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 76 for RLock (0.14 sec)

  1. internal/config/lambda/event/targetlist.go

    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := make([]Target, 0, len(list.targets))
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // Empty returns true if targetList is empty.
    func (list *TargetList) Empty() bool {
    	list.RLock()
    	defer list.RUnlock()
    
    	return len(list.targets) == 0
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  2. cmd/bucket-targets.go

    }
    
    // isOffline returns current liveness result of remote target. Add endpoint to
    // healthCheck map if missing and default to online status
    func (sys *BucketTargetSys) isOffline(ep *url.URL) bool {
    	sys.hMutex.RLock()
    	defer sys.hMutex.RUnlock()
    	if h, ok := sys.hc[ep.Host]; ok {
    		return !h.Online
    	}
    	go sys.initHC(ep)
    	return false
    }
    
    // markOffline sets endpoint to offline if network i/o timeout seen.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  3. internal/config/browser/browser.go

    }
    
    // GetCSPolicy - Get the Content security Policy
    func (browseCfg *Config) GetCSPolicy() string {
    	configLock.RLock()
    	defer configLock.RUnlock()
    	return browseCfg.CSPPolicy
    }
    
    // GetHSTSSeconds - Get the Content security Policy
    func (browseCfg *Config) GetHSTSSeconds() int {
    	configLock.RLock()
    	defer configLock.RUnlock()
    	return browseCfg.HSTSSeconds
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  4. internal/logger/targets.go

    // Returned slice may not be modified in any way.
    func SystemTargets() []Target {
    	swapSystemMuRW.RLock()
    	defer swapSystemMuRW.RUnlock()
    
    	res := systemTargets
    	return res
    }
    
    // AuditTargets returns active audit targets.
    // Returned slice may not be modified in any way.
    func AuditTargets() []Target {
    	swapAuditMuRW.RLock()
    	defer swapAuditMuRW.RUnlock()
    
    	res := auditTargets
    	return res
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    }
    
    func (z *erasureServerPools) IsRebalanceStarted() bool {
    	z.rebalMu.RLock()
    	defer z.rebalMu.RUnlock()
    
    	if r := z.rebalMeta; r != nil {
    		if r.StoppedAt.IsZero() {
    			return true
    		}
    	}
    	return false
    }
    
    func (z *erasureServerPools) IsPoolRebalancing(poolIndex int) bool {
    	z.rebalMu.RLock()
    	defer z.rebalMu.RUnlock()
    
    	if r := z.rebalMeta; r != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  6. internal/config/identity/openid/jwt.go

    	}
    
    	return nil
    }
    
    func (pk *publicKeys) add(keyID string, key interface{}) {
    	pk.Lock()
    	defer pk.Unlock()
    
    	pk.pkMap[keyID] = key
    }
    
    func (pk *publicKeys) get(kid string) interface{} {
    	pk.RLock()
    	defer pk.RUnlock()
    	return pk.pkMap[kid]
    }
    
    // PopulatePublicKey - populates a new publickey from the JWKS URL.
    func (r *Config) PopulatePublicKey(arn arn.ARN) error {
    	pCfg := r.arnProviderCfgsMap[arn]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 8.3K bytes
    - Viewed (5)
  7. internal/event/targetlist.go

    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := []Target{}
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // List - returns available target IDs.
    func (list *TargetList) List() []TargetID {
    	list.RLock()
    	defer list.RUnlock()
    
    	keys := []TargetID{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  8. internal/lsync/lrwmutex.go

    	const isWriteLock = true
    	return lm.lockLoop(ctx, id, source, timeout, isWriteLock)
    }
    
    // RLock holds a read lock on lm.
    //
    // If one or more read lock are already in use, it will grant another lock.
    // Otherwise the calling go routine blocks until the mutex is available.
    func (lm *LRWMutex) RLock() {
    	const isWriteLock = false
    	lm.lockLoop(context.Background(), lm.id, lm.source, 1<<63-1, isWriteLock)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.8K bytes
    - Viewed (0)
  9. cmd/tier.go

    	return metrics
    }
    
    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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  10. internal/config/cache/cache.go

    func (c *Config) Enabled() bool {
    	return c.Enable && c.Endpoint != ""
    }
    
    // MatchesSize verifies if input 'size' falls under cacheable threshold
    func (c Config) MatchesSize(size int64) bool {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	return c.Enable && c.BlockSize > 0 && size <= c.BlockSize
    }
    
    // Update updates new cache frequency
    func (c *Config) Update(ncfg Config) {
    	configLock.Lock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.6K bytes
    - Viewed (0)
Back to top