- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 191 for RUnlock (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)