Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for GetDiskLoc (0.09 sec)

  1. cmd/background-newdisks-heal-ops.go

    	h.disk = disk
    	h.ID = diskID
    	h.HealID = healID
    	h.Path = disk.String()
    	h.Endpoint = disk.Endpoint().String()
    	h.Started = time.Now().UTC()
    	h.PoolIndex, h.SetIndex, h.DiskIndex = disk.GetDiskLoc()
    	return h
    }
    
    func (h *healingTracker) resetHealing() {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.ItemsHealed = 0
    	h.ItemsFailed = 0
    	h.BytesDone = 0
    	h.BytesFailed = 0
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. cmd/naughty-disk_test.go

    	d.mu.Lock()
    	defer d.mu.Unlock()
    	d.callNR++
    	if err, ok := d.errors[d.callNR]; ok {
    		return err
    	}
    	if d.defaultErr != nil {
    		return d.defaultErr
    	}
    	return nil
    }
    
    func (d *naughtyDisk) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    	return -1, -1, -1
    }
    
    func (d *naughtyDisk) GetDiskID() (string, error) {
    	return d.disk.GetDiskID()
    }
    
    func (d *naughtyDisk) SetDiskID(id string) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    	weSleep := func() bool {
    		return scannerIdleMode.Load() == 0
    	}
    
    	return p.storage.NSScanner(ctx, cache, updates, scanMode, weSleep)
    }
    
    func (p *xlStorageDiskIDCheck) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    	return p.storage.GetDiskLoc()
    }
    
    func (p *xlStorageDiskIDCheck) Close() error {
    	p.diskCancel()
    	return p.storage.Close()
    }
    
    func (p *xlStorageDiskIDCheck) GetDiskID() (string, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    	restClient *rest.Client
    	gridConn   *grid.Subroute
    	diskID     atomic.Pointer[string]
    
    	diskInfoCache *cachevalue.Cache[DiskInfo]
    }
    
    // Retrieve location indexes.
    func (client *storageRESTClient) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    	return client.endpoint.PoolIdx, client.endpoint.SetIdx, client.endpoint.DiskIdx
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. cmd/erasure-sets.go

    			// we verify that here based on LastConn(), however we make sure to avoid
    			// putting it back into the s.erasureDisks by re-placing the disk again.
    			_, setIndex, _ := cdisk.GetDiskLoc()
    			if setIndex != -1 {
    				continue
    			}
    		}
    		if cdisk != nil {
    			// Close previous offline disk.
    			cdisk.Close()
    		}
    
    		wg.Add(1)
    		go func(endpoint Endpoint) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
Back to top