Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for RLock (0.03 sec)

  1. 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()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  2. cmd/batch-handlers.go

    	case batchReplVersionV1:
    	default:
    		return fmt.Errorf("unexpected batch %s meta version: %d", ri.JobType, ri.Version)
    	}
    
    	return nil
    }
    
    func (ri *batchJobInfo) clone() *batchJobInfo {
    	ri.mu.RLock()
    	defer ri.mu.RUnlock()
    
    	return &batchJobInfo{
    		Version:          ri.Version,
    		JobID:            ri.JobID,
    		JobType:          ri.JobType,
    		RetryAttempts:    ri.RetryAttempts,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    		return nil, errCorruptedBackend
    	}
    	return fi, nil
    }
    
    // GetDiskID - returns the cached disk uuid
    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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K 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()
    
    	openidConfig, err := openid.LookupConfig(s,
    		NewHTTPTransport(), xhttp.DrainBody, globalSite.Region())
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top