Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 83 for RLock (0.04 sec)

  1. internal/rest/client.go

    func (c *Client) LastConn() time.Time {
    	return time.Unix(0, atomic.LoadInt64(&c.lastConn))
    }
    
    // LastError returns previous error
    func (c *Client) LastError() error {
    	c.RLock()
    	defer c.RUnlock()
    	return fmt.Errorf("[%s] %w", c.lastErrTime.Format(time.RFC3339), c.lastErr)
    }
    
    // computes the exponential backoff duration according to
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  2. internal/config/config.go

    	siteLK.Unlock()
    }
    
    // Name returns currently configured site name
    func (s *Site) Name() string {
    	siteLK.RLock()
    	defer siteLK.RUnlock()
    
    	return s.name
    }
    
    // Region returns currently configured site region
    func (s *Site) Region() string {
    	siteLK.RLock()
    	defer siteLK.RUnlock()
    
    	return s.region
    }
    
    var validRegionRegex = regexp.MustCompile("^[a-zA-Z][a-zA-Z0-9-_-]+$")
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 37.7K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle.go

    	if _, ok := t.lastDayStats[tier]; !ok {
    		t.lastDayStats[tier] = &lastDayTierStats{}
    	}
    	t.lastDayStats[tier].addStats(ts)
    }
    
    func (t *transitionState) getDailyAllTierStats() DailyAllTierStats {
    	t.lastDayMu.RLock()
    	defer t.lastDayMu.RUnlock()
    
    	res := make(DailyAllTierStats, len(t.lastDayStats))
    	for tier, st := range t.lastDayStats {
    		res[tier] = st.clone()
    	}
    	return res
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  4. cmd/iam.go

    func (sys *IAMSys) Init(ctx context.Context, objAPI ObjectLayer, etcdClient *etcd.Client, iamRefreshInterval time.Duration) {
    	bootstrapTraceMsg("IAM initialization started")
    	globalServerConfigMu.RLock()
    	s := globalServerConfig
    	globalServerConfigMu.RUnlock()
    
    	sys.Lock()
    	sys.iamRefreshInterval = iamRefreshInterval
    	sys.Unlock()
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	var (
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Oct 15 17:00:45 UTC 2025
    - 76.5K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    // If the factor is updated the sleep will be done again with the new factor.
    func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) {
    	for {
    		// Grab current values
    		d.mu.RLock()
    		minWait, maxWait := d.minSleep, d.maxSleep
    		factor := d.factor
    		cycle := d.cycle
    		d.mu.RUnlock()
    		// Don't sleep for really small amount of time
    		wantSleep := time.Duration(float64(base) * factor)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  6. cmd/storage-rest-server.go

    )
    
    func getStorageViaEndpoint(endpoint Endpoint) StorageAPI {
    	globalLocalDrivesMu.RLock()
    	defer globalLocalDrivesMu.RUnlock()
    	if len(globalLocalSetDrives) == 0 {
    		return globalLocalDrivesMap[endpoint.String()]
    	}
    	return globalLocalSetDrives[endpoint.PoolIdx][endpoint.SetIdx][endpoint.DiskIdx]
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  7. cmd/peer-rest-server.go

    		s.writeErrorResponse(w, err)
    		return
    	}
    }
    
    var errUnsupportedSignal = fmt.Errorf("unsupported signal")
    
    func waitingDrivesNode() map[string]madmin.DiskMetrics {
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrivesMap)
    	globalLocalDrivesMu.RUnlock()
    
    	errs := make([]error, len(localDrives))
    	infos := make([]DiskInfo, len(localDrives))
    	for i, drive := range localDrives {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 53.6K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool.go

    		erasureSetUpCount[i] = make([]setInfo, len(z.serverPools[i].sets))
    	}
    
    	storageInfo := z.StorageInfo(ctx, false)
    
    	for _, disk := range storageInfo.Disks {
    		if opts.Maintenance {
    			globalLocalDrivesMu.RLock()
    			_, ok := globalLocalDrivesMap[disk.Endpoint]
    			globalLocalDrivesMu.RUnlock()
    			if ok {
    				continue
    			}
    		}
    
    		if disk.PoolIndex > -1 && disk.SetIndex > -1 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.11.md

    * Removed unsafe double RLock in cpumanager ([#62464](https://github.com/kubernetes/kubernetes/pull/62464), [@choury](https://github.com/choury))
    
    ## Non-user-facing changes
    
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Thu Feb 06 06:04:15 UTC 2020
    - 328.4K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.10.md

        * See https://istio.io/news/releases/0.x/announcing-0.6/ for full Isto release notes.
    * removed unsafe double RLock in cpumanager ([#62464](https://github.com/kubernetes/kubernetes/pull/62464), [@choury](https://github.com/choury))
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 341.8K bytes
    - Viewed (0)
Back to top