- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 84 for RLock (0.16 sec)
-
cmd/peer-s3-server.go
peerS3BucketForceDelete = "force-delete" ) func healBucketLocal(ctx context.Context, bucket string, opts madmin.HealOpts) (res madmin.HealResultItem, err error) { globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrives) globalLocalDrivesMu.RUnlock() // Initialize sync waitgroup. g := errgroup.WithNErrs(len(localDrives)) // Disk states slices
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 8.4K bytes - Viewed (0) -
cmd/lock-rest-client_test.go
lkClient := newlockRESTClient(endpoint) if lkClient.IsOnline() { t.Fatalf("unexpected result. connection was online") } // Attempt all calls. _, err = lkClient.RLock(context.Background(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Rlock to fail") } _, err = lkClient.Lock(context.Background(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Lock to fail") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
} // GetReport gets the report for all bucket bandwidth details. func (m *Monitor) GetReport(selectBucket SelectionFunction) *BucketBandwidthReport { m.mlock.RLock() defer m.mlock.RUnlock() return m.getReport(selectBucket) } func (m *Monitor) getReport(selectBucket SelectionFunction) *BucketBandwidthReport { report := &BucketBandwidthReport{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6K bytes - Viewed (0) -
internal/dsync/drwmutex.go
isReadLock := false return dm.lockBlocking(ctx, cancel, id, source, isReadLock, opts) } // RLock holds a read lock on dm. // // If one or more read locks are already in use, it will grant another lock. // Otherwise the calling go routine blocks until the mutex is available. func (dm *DRWMutex) RLock(id, source string) { isReadLock := true dm.lockBlocking(context.Background(), nil, id, source, isReadLock, Options{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K 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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Dec 06 09:09:22 GMT 2023 - 4.7K bytes - Viewed (0) -
cmd/iam-store.go
cache := store.rlock() defer store.runlock() u, ok := cache.iamUsersMap[user] if !ok { // Check the sts map u, ok = cache.iamSTSAccountsMap[user] } return u, ok } // GetMappedPolicy - fetches mapped policy from memory. func (store *IAMStoreSys) GetMappedPolicy(name string, isGroup bool) (MappedPolicy, bool) { cache := store.rlock() defer store.runlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.6K bytes - Viewed (0) -
cmd/ilm-config.go
}, } type ilmConfig struct { mu sync.RWMutex cfg ilm.Config } 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()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 05 02:50:24 GMT 2024 - 1.3K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
objAPI ObjectLayer sync.RWMutex initialized bool metadataMap map[string]BucketMetadata } // Count returns number of bucket metadata map entries. 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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
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)