- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 205 for runlock (0.16 sec)
-
cmd/bucket-replication.go
p.mu.RLock() workers := min(len(p.workers)+1, maxWorkers) existing := len(p.workers) p.mu.RUnlock() p.ResizeWorkers(workers, existing) } maxMRFWorkers := min(maxWorkers, MRFWorkerMaxLimit) if p.ActiveMRFWorkers() < maxMRFWorkers { p.mu.RLock() workers := min(p.mrfWorkerSize+1, maxMRFWorkers) p.mu.RUnlock() p.ResizeFailedWorkers(workers)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/iam-etcd-store.go
usersSysType: usersSysType, } } func (ies *IAMEtcdStore) rlock() *iamCache { ies.RLock() return ies.iamCache } func (ies *IAMEtcdStore) runlock() { ies.RUnlock() } func (ies *IAMEtcdStore) lock() *iamCache { ies.Lock() return ies.iamCache } func (ies *IAMEtcdStore) unlock() { ies.Unlock() } func (ies *IAMEtcdStore) getUsersSysType() UsersSysType {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
srQueueStats: newInQueueStats(r, "site"), } } func (q *queueCache) update() { q.Lock() defer q.Unlock() q.srQueueStats.update() for _, s := range q.bucketStats { s.update() } } func (q *queueCache) getBucketStats(bucket string) InQueueMetric { q.RLock() defer q.RUnlock() v, ok := q.bucketStats[bucket] if !ok { return InQueueMetric{} } return InQueueMetric{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/config/subnet/subnet.go
} r.Header.Add("Content-Type", writer.FormDataContentType()) return c.submitPost(r) } func (c Config) submitPost(r *http.Request) (string, error) { configLock.RLock() r.Header.Set(xhttp.SubnetAPIKey, c.APIKey) configLock.RUnlock() r.Header.Set(xhttp.MinioDeploymentID, xhttp.GlobalDeploymentID) client := &http.Client{ Timeout: 10 * time.Second, Transport: c.transport, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 27 16:35:36 GMT 2023 - 2.9K bytes - Viewed (0) -
internal/config/drive/drive.go
func (c *Config) Update(new Config) error { configLk.Lock() defer configLk.Unlock() c.MaxTimeout = getMaxTimeout(new.MaxTimeout) return nil } // GetMaxTimeout - returns the max timeout value. func (c *Config) GetMaxTimeout() time.Duration { configLk.RLock() defer configLk.RUnlock() return getMaxTimeout(c.MaxTimeout) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/metrics-resource.go
} updateDriveIOStats(dm.IOStats, latestStats, labels) latestDriveStats[d] = dm.IOStats } lastDriveStatsRefresh = time.Now().UTC() latestDriveStatsMu.Unlock() globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrives) globalLocalDrivesMu.RUnlock() for _, d := range localDrives { di, err := d.DiskInfo(GlobalContext, DiskInfoOptions{}) labels := map[string]string{"drive": di.Endpoint}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
cmd/erasure-multipart.go
lkctx, err := lk.GetRLock(ctx, globalOperationTimeout) if err != nil { return nil, err } rctx := lkctx.Context() obj, err := er.getObjectInfo(rctx, bucket, object, opts) lk.RUnlock(lkctx) if err != nil && !isErrVersionNotFound(err) && !isErrObjectNotFound(err) { return nil, err } if opts.CheckPrecondFn(obj) { return nil, PreConditionFailed{} } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
internal/config/identity/openid/jwt.go
} pk.add(key.Kid, pkey) } 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 {
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) -
cmd/perf-tests.go
} } func (n *netPerfRX) ActiveConnections() uint64 { n.RLock() defer n.RUnlock() return n.activeConnections } func (n *netPerfRX) Reset() { n.Lock() defer n.Unlock() n.RX = 0 n.RXSample = 0 n.lastToConnect = time.Time{} n.firstToDisconnect = time.Time{} } // Reader to read random data. type netperfReader struct { n uint64 eof chan struct{} buf []byte }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/xl-storage.go
func (s *xlStorage) GetDiskID() (string, error) { s.RLock() diskID := s.diskID fileInfo := s.formatFileInfo lastCheck := s.formatLastCheck // check if we have a valid disk ID that is less than 1 seconds old. if fileInfo != nil && diskID != "" && time.Since(lastCheck) <= 1*time.Second { s.RUnlock() return diskID, nil } s.RUnlock() fi, err := s.checkFormatJSON() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0)