Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for onlineDisks (0.22 sec)

  1. cmd/erasure-object.go

    	if dataDir == "" {
    		return nil
    	}
    	g := errgroup.WithNErrs(len(onlineDisks))
    	for index := range onlineDisks {
    		index := index
    		g.Go(func() error {
    			if onlineDisks[index] == nil {
    				return nil
    			}
    			return onlineDisks[index].Delete(ctx, bucket, pathJoin(object, dataDir), DeleteOptions{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  2. cmd/erasure-healing-common.go

    				if partsMetadata[index].IsValid() && e == etag {
    					onlineDisks[index] = disks[index]
    				} else {
    					onlineDisks[index] = nil
    				}
    			}
    			return onlineDisks, modTime, etag
    		}
    	}
    
    	// Create a new online disks slice, which have common uuid.
    	for index, t := range modTimes {
    		if partsMetadata[index].IsValid() && t.Equal(modTime) {
    			onlineDisks[index] = disks[index]
    		} else {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    		// Check if there is any offline disk and add it to the MRF list
    		for _, disk := range onlineDisks {
    			if disk != nil && disk.IsOnline() {
    				continue
    			}
    			er.addPartial(bucket, object, fi.VersionID)
    			break
    		}
    	}
    
    	for i := 0; i < len(onlineDisks); i++ {
    		if onlineDisks[i] != nil && onlineDisks[i].IsOnline() {
    			// Object info is the same in all disks, so we can pick
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  4. cmd/erasure.go

    }
    
    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
    		}
    	}
    
    	// Wait for the routines.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  5. cmd/erasure-healing-common_test.go

    			rQuorum := len(errs) - z.serverPools[0].sets[0].defaultParityCount
    			onlineDisks, modTime, _ := listOnlineDisks(erasureDisks, partsMetadata, test.errs, rQuorum)
    			if !modTime.Equal(test.expectedTime) {
    				t.Fatalf("Expected modTime to be equal to %v but was found to be %v",
    					test.expectedTime, modTime)
    			}
    			availableDisks, newErrs, _ := disksWithAllParts(ctx, onlineDisks, partsMetadata,
    				test.errs, fi, bucket, object, madmin.HealDeepScan)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 23K bytes
    - Viewed (1)
  6. cmd/server-startup-msg.go

    	var msg string
    	var mcMessage string
    	onlineDisks, offlineDisks := getOnlineOfflineDisksStats(storageInfo.Disks)
    	if storageInfo.Backend.Type == madmin.Erasure {
    		if offlineDisks.Sum() > 0 {
    			mcMessage = "Use `mc admin info` to look for latest server/drive info\n"
    		}
    
    		diskInfo := fmt.Sprintf(" %d Online, %d Offline. ", onlineDisks.Sum(), offlineDisks.Sum())
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 03:07:08 GMT 2024
    - 6.8K bytes
    - Viewed (0)
  7. cmd/metrics.go

    	if objLayer == nil {
    		return
    	}
    
    	server := getLocalServerProperty(globalEndpoints, &http.Request{
    		Host: globalLocalNodeName,
    	}, true)
    
    	onlineDisks, offlineDisks := getOnlineOfflineDisksStats(server.Disks)
    	totalDisks := offlineDisks.Merge(onlineDisks)
    
    	// Report total capacity
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    			prometheus.BuildFQName(minioNamespace, "capacity_raw", "total"),
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  8. cmd/metacache-set.go

    				time.Sleep(retryDelay)
    			} else {
    				time.Sleep(retryDelay250)
    			}
    		}
    		// Load first part metadata...
    		// Read metadata associated with the object from all disks.
    		fi, metaArr, onlineDisks, err := er.getObjectFileInfo(ctx, minioMetaBucket, o.objectPath(0), ObjectOptions{}, true)
    		if err != nil {
    			switch toObjectErr(err, minioMetaBucket, o.objectPath(0)).(type) {
    			case ObjectNotFound, InsufficientReadQuorum:
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  9. cmd/erasure-healing.go

    	}
    
    	result.ParityBlocks = result.DiskCount - readQuorum
    	result.DataBlocks = readQuorum
    
    	// List of disks having latest version of the object xl.meta
    	// (by modtime).
    	onlineDisks, modTime, etag := listOnlineDisks(storageDisks, partsMetadata, errs, readQuorum)
    
    	// Latest FileInfo for reference. If a valid metadata is not
    	// present, it is as good as object not found.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  10. cmd/admin-handlers.go

    		var allDisks []madmin.Disk
    		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,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
Back to top