Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for globalLocalDrivesMap (0.25 sec)

  1. cmd/globals.go

    	// List of local drives to this node, this is only set during server startup,
    	// and is only mutated by HealFormat. Hold globalLocalDrivesMu to access.
    	globalLocalDrives    []StorageAPI
    	globalLocalDrivesMap = make(map[string]StorageAPI)
    	globalLocalDrivesMu  sync.RWMutex
    
    	globalDriveMonitoring = env.Get("_MINIO_DRIVE_ACTIVE_MONITORING", config.EnableOn) == config.EnableOn
    
    	// Is MINIO_CI_CD set?
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  2. 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]
    }
    
    func (s *storageRESTServer) getStorage() StorageAPI {
    	return getStorageViaEndpoint(s.endpoint)
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    				localDrives = append(localDrives, storageDisk)
    			}
    		}
    	}
    
    	if !globalIsDistErasure {
    		globalLocalDrivesMu.Lock()
    		globalLocalDrives = localDrives
    		for _, drive := range localDrives {
    			globalLocalDrivesMap[drive.Endpoint().String()] = drive
    		}
    		globalLocalDrivesMu.Unlock()
    	}
    
    	z.decommissionCancelers = make([]context.CancelFunc, len(z.serverPools))
    
    	// Initialize the pool meta, but set it to not save.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 82.5K bytes
    - Viewed (0)
Back to top