Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for offlineDisks (0.07 sec)

  1. cmd/erasure.go

    	}
    
    	return
    }
    
    func getOnlineOfflineDisksStats(disksInfo []madmin.Disk) (onlineDisks, offlineDisks madmin.BackendDisks) {
    	onlineDisks = make(madmin.BackendDisks)
    	offlineDisks = make(madmin.BackendDisks)
    
    	for _, disk := range disksInfo {
    		ep := disk.Endpoint
    		if _, ok := offlineDisks[ep]; !ok {
    			offlineDisks[ep] = 0
    		}
    		if _, ok := onlineDisks[ep]; !ok {
    			onlineDisks[ep] = 0
    		}
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  2. cmd/notification.go

    func getOfflineDisks(offlineHost string, endpoints EndpointServerPools) []madmin.Disk {
    	var offlineDisks []madmin.Disk
    	for _, pool := range endpoints {
    		for _, ep := range pool.Endpoints {
    			if offlineHost == "" && ep.IsLocal || offlineHost == ep.Host {
    				offlineDisks = append(offlineDisks, madmin.Disk{
    					Endpoint:  ep.String(),
    					State:     string(madmin.ItemOffline),
    					PoolIndex: ep.PoolIdx,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    		for _, s := range servers {
    			allDisks = append(allDisks, s.Disks...)
    		}
    		onlineDisks, offlineDisks := getOnlineOfflineDisksStats(allDisks)
    
    		backend = madmin.ErasureBackend{
    			Type:             madmin.ErasureType,
    			OnlineDisks:      onlineDisks.Sum(),
    			OfflineDisks:     offlineDisks.Sum(),
    			StandardSCParity: backendInfo.StandardSCParity,
    			RRSCParity:       backendInfo.RRSCParity,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  4. cmd/erasure-encode_test.go

    	content := make([]byte, size)
    
    	for i := range dataDown {
    		disks[i] = OfflineDisk
    	}
    	for i := data; i < data+parityDown; i++ {
    		disks[i] = OfflineDisk
    	}
    
    	b.SetBytes(size)
    	b.ReportAllocs()
    	for b.Loop() {
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  5. cmd/erasure-decode_test.go

    			}
    		}
    
    		for i, r := range bitrotReaders {
    			if r == nil {
    				disks[i] = OfflineDisk
    			}
    		}
    		if err == nil && !test.shouldFail {
    			bitrotReaders = make([]io.ReaderAt, len(disks))
    			for index, disk := range disks {
    				if disk == OfflineDisk {
    					continue
    				}
    				tillOffset := erasure.ShardFileOffset(test.offset, test.length, test.data)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21K bytes
    - Viewed (0)
  6. cmd/erasure-healing.go

    			readers := make([]io.ReaderAt, len(latestDisks))
    			prefer := make([]bool, len(latestDisks))
    			checksumAlgo := erasureInfo.GetChecksumInfo(partNumber).Algorithm
    			for i, disk := range latestDisks {
    				if disk == OfflineDisk {
    					continue
    				}
    				thisPartErrs := shuffleCheckParts(dataErrsByPart[partIndex], latestMeta.Erasure.Distribution)
    				if thisPartErrs[i] != checkPartSuccess {
    					continue
    				}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  7. cmd/erasure-sets.go

    	s.erasureDisksMu.RLock()
    	defer s.erasureDisksMu.RUnlock()
    
    	for i := range s.setCount {
    		for j := 0; j < s.setDriveCount; j++ {
    			disk := s.erasureDisks[i][j]
    			if disk == OfflineDisk {
    				continue
    			}
    			if !disk.IsOnline() {
    				continue
    			}
    			diskMap[disk.Endpoint()] = disk
    		}
    	}
    	return diskMap
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  8. cmd/erasure-server-pool.go

    		idMap[id] = struct{}{}
    	}
    	res := make([]StorageAPI, 0, len(idMap))
    	for _, s := range z.serverPools {
    		for _, set := range s.sets {
    			for _, disk := range set.getDisks() {
    				if disk == OfflineDisk {
    					continue
    				}
    				if id, _ := disk.GetDiskID(); id != "" {
    					if _, ok := idMap[id]; ok {
    						res = append(res, disk)
    					}
    				}
    			}
    		}
    	}
    	return res
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    		// Get the checksums of the current part.
    		readers := make([]io.ReaderAt, len(onlineDisks))
    		prefer := make([]bool, len(onlineDisks))
    		for index, disk := range onlineDisks {
    			if disk == OfflineDisk {
    				continue
    			}
    			if !metaArr[index].IsValid() {
    				continue
    			}
    			if !metaArr[index].Erasure.Equal(fi.Erasure) {
    				continue
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
Back to top