Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 191 for RUnlock (0.05 sec)

  1. internal/config/browser/browser.go

    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
    }
    
    // IsHSTSIncludeSubdomains - is HSTS 'includeSubdomains' directive enabled
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jun 21 00:58:58 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. internal/event/targetlist.go

    func (list *TargetList) List() []TargetID {
    	list.RLock()
    	defer list.RUnlock()
    
    	keys := []TargetID{}
    	for k := range list.targets {
    		keys = append(keys, k)
    	}
    
    	return keys
    }
    
    func (list *TargetList) get(id TargetID) (Target, bool) {
    	list.RLock()
    	defer list.RUnlock()
    
    	target, ok := list.targets[id]
    	return target, ok
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  3. internal/store/queuestore.go

    }
    
    // Del - Deletes an entry from the store.
    func (store *QueueStore[_]) Del(key Key) error {
    	store.Lock()
    	defer store.Unlock()
    	return store.del(key)
    }
    
    // Len returns the entry count.
    func (store *QueueStore[_]) Len() int {
    	store.RLock()
    	l := len(store.entries)
    	defer store.RUnlock()
    	return l
    }
    
    // lockless call
    func (store *QueueStore[_]) del(key Key) error {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  4. internal/config/batch/batch.go

    func (opts Config) ExpirationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return opts.ExpirationWorkersWait
    }
    
    // ReplicationWait returns the duration for which a batch replication worker
    // would wait before working on next object.
    func (opts Config) ReplicationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return opts.ReplicationWorkersWait
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. internal/dsync/dsync-server_test.go

    	return reply, nil
    }
    
    func (l *lockServer) RUnlock(args *LockArgs) (reply bool, err error) {
    	if d := atomic.LoadInt64(&l.responseDelay); d != 0 {
    		time.Sleep(time.Duration(d))
    	}
    
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	var locksHeld int64
    	if locksHeld, reply = l.lockMap[args.Resources[0]]; !reply { // No lock is held on the given name
    		return false, fmt.Errorf("RUnlock attempted on an unlocked entity: %s", args.Resources[0])
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  6. internal/logger/reqinfo.go

    	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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 4.4K bytes
    - Viewed (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
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Mar 05 02:50:24 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  8. cmd/http-stats.go

    		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()
    
    	apiStats := make(map[string]int, len(stats.apiStats))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  9. cmd/admin-heal-ops.go

    			select {
    			// Check after a second
    			case <-time.After(time.Second):
    				h.mutex.Unlock()
    				continue
    
    			case <-h.ctx.Done():
    				h.mutex.Unlock()
    				// discard result and return.
    				return errHealStopSignalled
    
    			// Timeout if no results consumed for too long.
    			case <-unconsumedTimer.C:
    				h.mutex.Unlock()
    				return errHealIdleTimeout
    			}
    		}
    		break
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  10. cmd/background-newdisks-heal-ops.go

    }
    
    func (h *healingTracker) getLastUpdate() time.Time {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.LastUpdate
    }
    
    func (h *healingTracker) getBucket() string {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.Bucket
    }
    
    func (h *healingTracker) setBucket(bucket string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Bucket = bucket
    }
    
    func (h *healingTracker) getObject() string {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
Back to top