Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 84 for RLock (0.03 sec)

  1. internal/config/subnet/subnet.go

    	if e != nil {
    		return "", e
    	}
    	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,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 27 16:35:36 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom.go

    }
    
    func (z *erasureServerPools) decommissionInBackground(ctx context.Context, idx int) error {
    	pool := z.serverPools[idx]
    	z.poolMetaMutex.RLock()
    	pending := z.poolMeta.PendingBuckets(idx)
    	z.poolMetaMutex.RUnlock()
    
    	for _, bucket := range pending {
    		z.poolMetaMutex.RLock()
    		isDecommissioned := z.poolMeta.isBucketDecommissioned(idx, bucket.String())
    		z.poolMetaMutex.RUnlock()
    		if isDecommissioned {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  3. cmd/local-locker.go

    		}
    	}
    
    	// None found return false, perhaps entry removed in previous run.
    	return false
    }
    
    func (l *localLocker) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	if len(args.Resources) != 1 {
    		return false, fmt.Errorf("internal error: localLocker.RLock called with more than one resource")
    	}
    
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	resource := args.Resources[0]
    	now := UTCNow()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  4. cmd/iam-etcd-store.go

    	return &IAMEtcdStore{
    		iamCache:     newIamCache(),
    		client:       client,
    		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
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  5. internal/logger/audit.go

    	auditTgts := AuditTargets()
    	if len(auditTgts) == 0 {
    		return
    	}
    
    	var entry audit.Entry
    	if w != nil && r != nil {
    		reqInfo := GetReqInfo(ctx)
    		if reqInfo == nil {
    			return
    		}
    		reqInfo.RLock()
    		defer reqInfo.RUnlock()
    
    		entry = internalAudit.ToEntry(w, r, reqClaims, xhttp.GlobalDeploymentID)
    		// indicates all requests for this API call are inbound
    		entry.Trigger = "incoming"
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. cmd/metrics-resource.go

    			continue
    		}
    		updateDriveIOStats(dm.IOStats, latestStats, labels)
    		latestDriveStats[d] = dm.IOStats
    	}
    	lastDriveStatsRefresh = time.Now().UTC()
    	latestDriveStatsMu.Unlock()
    
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrivesMap)
    	globalLocalDrivesMu.RUnlock()
    
    	for _, d := range localDrives {
    		di, err := d.DiskInfo(GlobalContext, DiskInfoOptions{})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    }
    
    const (
    	rebalMetaName = "rebalance.bin"
    	rebalMetaFmt  = 1
    	rebalMetaVer  = 1
    )
    
    func (z *erasureServerPools) nextRebalBucket(poolIdx int) (string, bool) {
    	z.rebalMu.RLock()
    	defer z.rebalMu.RUnlock()
    
    	r := z.rebalMeta
    	if r == nil {
    		return "", false
    	}
    
    	ps := r.PoolStats[poolIdx]
    	if ps == nil {
    		return "", false
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    			if p.ActiveWorkers() < maxWorkers {
    				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()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  9. cmd/metacache-bucket.go

    	b.updated = true
    	return existing, nil
    }
    
    // cloneCaches will return a clone of all current caches.
    func (b *bucketMetacache) cloneCaches() (map[string]metacache, map[string][]string) {
    	b.mu.RLock()
    	defer b.mu.RUnlock()
    	dst := make(map[string]metacache, len(b.caches))
    	for k, v := range b.caches {
    		dst[k] = v
    	}
    	// Copy indexes
    	dst2 := make(map[string][]string, len(b.cachesRoot))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. prepare_stmt.go

    				_ = s.Close()
    			}
    		}(stmt)
    	}
    	sdb.Stmts = make(map[string]*Stmt)
    }
    
    func (db *PreparedStmtDB) prepare(ctx context.Context, conn ConnPool, isTransaction bool, query string) (Stmt, error) {
    	db.Mux.RLock()
    	if stmt, ok := db.Stmts[query]; ok && (!stmt.Transaction || isTransaction) {
    		db.Mux.RUnlock()
    		// wait for other goroutines prepared
    		<-stmt.prepared
    		if stmt.prepareErr != nil {
    			return Stmt{}, stmt.prepareErr
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top