Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for diskfis (0.12 sec)

  1. cmd/erasure-common.go

    	// Based on the random shuffling return back randomized disks.
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	for _, i := range r.Perm(len(disks)) {
    		if disks[i] != nil && disks[i].IsLocal() {
    			newDisks = append(newDisks, disks[i])
    		}
    	}
    
    	return newDisks
    }
    
    func (er erasureObjects) getLocalDisks() (newDisks []StorageAPI) {
    	disks := er.getDisks()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. .gitignore

    docs/debugging/healing-bin/healing-bin
    docs/debugging/inspect/inspect
    docs/debugging/pprofgoparser/pprofgoparser
    docs/debugging/reorder-disks/reorder-disks
    docs/debugging/populate-hard-links/populate-hardlinks
    docs/debugging/xattr/xattr
    hash-set
    healing-bin
    inspect
    pprofgoparser
    reorder-disks
    s3-check-md5
    s3-verify
    xattr
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 802 bytes
    - Viewed (0)
  3. cmd/metrics-realtime.go

    	return m
    }
    
    func collectLocalDisksMetrics(disks map[string]struct{}) map[string]madmin.DiskMetric {
    	objLayer := newObjectLayerFn()
    	if objLayer == nil {
    		return nil
    	}
    
    	metrics := make(map[string]madmin.DiskMetric)
    	storageInfo := objLayer.LocalStorageInfo(GlobalContext, true)
    	for _, d := range storageInfo.Disks {
    		if len(disks) != 0 {
    			_, ok := disks[d.Endpoint]
    			if !ok {
    				continue
    			}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. cmd/mrf.go

    }
    
    // Add a partial S3 operation (put/delete) when one or more disks are offline.
    func (m *mrfState) addPartialOp(op partialOperation) {
    	if m == nil {
    		return
    	}
    
    	select {
    	case m.opCh <- op:
    	default:
    	}
    }
    
    var healSleeper = newDynamicSleeper(5, time.Second, false)
    
    // healRoutine listens to new disks reconnection events and
    // issues healing requests for queued objects belonging to the
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. cmd/peer-s3-server.go

    	g := errgroup.WithNErrs(len(localDrives))
    
    	// Disk states slices
    	beforeState := make([]string, len(localDrives))
    	afterState := make([]string, len(localDrives))
    
    	// Make a volume entry on all underlying storage disks.
    	for index := range localDrives {
    		index := index
    		g.Go(func() (serr error) {
    			if localDrives[index] == nil {
    				beforeState[index] = madmin.DriveStateOffline
    				afterState[index] = madmin.DriveStateOffline
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. cmd/admin-server-info.go

    	objLayer := newObjectLayerFn()
    	if objLayer != nil {
    		storageInfo := objLayer.LocalStorageInfo(GlobalContext, metrics)
    		props.State = string(madmin.ItemOnline)
    		props.Disks = storageInfo.Disks
    	} else {
    		props.State = string(madmin.ItemInitializing)
    		props.Disks = getOfflineDisks("", globalEndpoints)
    	}
    
    	return props
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  7. docs/debugging/reorder-disks/go.mod

    module github.com/minio/minio/docs/debugging/reorder-disks
    
    go 1.21
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 108 bytes
    - Viewed (0)
  8. cmd/storage-rest-common.go

    	storageRESTGlob          = "glob"
    	storageRESTMetrics       = "metrics"
    	storageRESTDriveQuorum   = "drive-quorum"
    	storageRESTOrigVolume    = "orig-volume"
    )
    
    type nsScannerOptions struct {
    	DiskID   string          `msg:"id"`
    	ScanMode int             `msg:"m"`
    	Cache    *dataUsageCache `msg:"c"`
    }
    
    type nsScannerResp struct {
    	Update *dataUsageEntry `msg:"u"`
    	Final  *dataUsageCache `msg:"f"`
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  9. cmd/speedtest.go

    			if globalEndpoints.NEndpoints() < concurrency {
    				concurrency = globalEndpoints.NEndpoints()
    			}
    
    			// Check if we have local disks per pool less than
    			// the concurrency make sure we choose only the "start"
    			// concurrency to be equal to the lowest number of
    			// local disks per server.
    			for _, localDiskCount := range globalEndpoints.NLocalDisksPathsPerPool() {
    				if localDiskCount < concurrency {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. .github/workflows/go-healing.yml

              sudo sysctl net.ipv6.conf.default.disable_ipv6=0
              make verify-healing
              make verify-healing-inconsistent-versions
              make verify-healing-with-root-disks
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 1.2K bytes
    - Viewed (0)
Back to top