Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for GetDiskID (0.22 sec)

  1. cmd/naughty-disk_test.go

    		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) {
    	d.disk.SetDiskID(id)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. cmd/background-newdisks-heal-ops.go

    func loadHealingTracker(ctx context.Context, disk StorageAPI) (*healingTracker, error) {
    	if disk == nil {
    		return nil, errors.New("loadHealingTracker: nil drive given")
    	}
    	diskID, err := disk.GetDiskID()
    	if err != nil {
    		return nil, err
    	}
    	b, err := disk.ReadAll(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename))
    	if err != nil {
    		return nil, err
    	}
    	var h healingTracker
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. cmd/storage-interface.go

    	// Returns the entire endpoint.
    	Endpoint() Endpoint
    
    	// Close the disk, mark it purposefully closed, only implemented for remote disks.
    	Close() error
    
    	// Returns the unique 'uuid' of this disk.
    	GetDiskID() (string, error)
    
    	// Set a unique 'uuid' for this disk, only used when
    	// disk is replaced and formatted.
    	SetDiskID(id string)
    
    	// Returns healing information for a newly replaced disk,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    	return p.storage.GetDiskLoc()
    }
    
    func (p *xlStorageDiskIDCheck) Close() error {
    	p.diskCancel()
    	return p.storage.Close()
    }
    
    func (p *xlStorageDiskIDCheck) GetDiskID() (string, error) {
    	return p.storage.GetDiskID()
    }
    
    func (p *xlStorageDiskIDCheck) SetDiskID(id string) {
    	p.diskID.Store(&id)
    }
    
    func (p *xlStorageDiskIDCheck) checkDiskStale() error {
    	if *p.diskID.Load() == emptyDiskID {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    	})
    	if err != nil {
    		return cache, toStorageErr(err)
    	}
    	if final == nil {
    		return cache, errors.New("no final cache")
    	}
    	return *final, nil
    }
    
    func (client *storageRESTClient) GetDiskID() (string, error) {
    	if !client.IsOnlineWS() {
    		// make sure to check if the disk is offline, since the underlying
    		// value is cached we should attempt to invalidate it if such calls
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  6. cmd/storage-rest-server.go

    		// Request sent empty disk-id, we allow the request
    		// as the peer might be coming up and trying to read format.json
    		// or create format.json
    		return true
    	}
    
    	storedDiskID, err := s.getStorage().GetDiskID()
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return false
    	}
    
    	if diskID != storedDiskID {
    		s.writeErrorResponse(w, errDiskStale)
    		return false
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    		}
    		storageLogOnceIf(GlobalContext, err, "check-format-json") // log unexpected errors
    		return nil, errCorruptedBackend
    	}
    	return fi, nil
    }
    
    // GetDiskID - returns the cached disk uuid
    func (s *xlStorage) GetDiskID() (string, error) {
    	s.RLock()
    	diskID := s.diskID
    	fileInfo := s.formatFileInfo
    	lastCheck := s.formatLastCheck
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  8. cmd/erasure-sets.go

    					}
    					disk.Close()
    					disk = ldisk
    					globalLocalDrivesMu.RUnlock()
    				}
    
    				innerWg.Add(1)
    				go func(disk StorageAPI, i, j int) {
    					defer innerWg.Done()
    					diskID, err := disk.GetDiskID()
    					if err != nil {
    						if !errors.Is(err, errUnformattedDisk) {
    							bootLogIf(ctx, err)
    						}
    						return
    					}
    					if diskID == "" {
    						return
    					}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  9. cmd/erasure-server-pool.go

    	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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top