Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetDiskLoc (0.21 sec)

  1. cmd/storage-interface.go

    	// Should be used for smaller payloads.
    	WriteAll(ctx context.Context, volume string, path string, b []byte) (err error)
    
    	// Read all.
    	ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error)
    	GetDiskLoc() (poolIdx, setIdx, diskIdx int) // Retrieve location indexes.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  2. 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) getLastUpdate() time.Time {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.LastUpdate
    }
    
    func (h healingTracker) getBucket() string {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  3. 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) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  4. 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) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
  5. 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) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  6. 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
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    	return true
    }
    
    func (s *xlStorage) LastConn() time.Time {
    	return time.Time{}
    }
    
    func (s *xlStorage) IsLocal() bool {
    	return true
    }
    
    // Retrieve location indexes.
    func (s *xlStorage) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    	return s.endpoint.PoolIdx, s.endpoint.SetIdx, s.endpoint.DiskIdx
    }
    
    func (s *xlStorage) Healing() *healingTracker {
    	healingFile := pathJoin(s.drivePath, minioMetaBucket,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
Back to top