Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for SetDiskID (0.07 sec)

  1. cmd/naughty-disk_test.go

    	return -1, -1, -1
    }
    
    func (d *naughtyDisk) GetDiskID() (string, error) {
    	return d.disk.GetDiskID()
    }
    
    func (d *naughtyDisk) SetDiskID(id string) {
    	d.disk.SetDiskID(id)
    }
    
    func (d *naughtyDisk) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, weSleep func() bool) (info dataUsageCache, err error) {
    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/storage-interface.go

    	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,
    	// returns 'nil' once healing is complete or if the disk
    	// has never been replaced.
    	Healing() *healingTracker
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    	// function on a fresh disk or make sure to look at the error
    	// from a different networked call to validate the GetDiskID()
    	return *client.diskID.Load(), nil
    }
    
    func (client *storageRESTClient) SetDiskID(id string) {
    	client.diskID.Store(&id)
    }
    
    func (client *storageRESTClient) DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error) {
    	if !client.IsOnlineWS() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. cmd/format-erasure.go

    			if err != nil {
    				return err
    			}
    			formats[index] = format
    			if !heal {
    				// If no healing required, make the disks valid and
    				// online.
    				storageDisks[index].SetDiskID(format.Erasure.This)
    			}
    			return nil
    		}, index)
    	}
    
    	// Return all formats and errors if any.
    	return formats, g.Wait()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    	xl := xlStorageDiskIDCheck{
    		storage:      storage,
    		health:       newDiskHealthTracker(),
    		healthCheck:  healthCheck && globalDriveMonitoring,
    		metricsCache: cachevalue.New[DiskMetrics](),
    	}
    	xl.SetDiskID(emptyDiskID)
    
    	xl.totalWrites.Store(xl.storage.getWriteAttribute())
    	xl.totalDeletes.Store(xl.storage.getDeleteAttribute())
    	xl.diskCtx, xl.diskCancel = context.WithCancel(context.TODO())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  6. cmd/erasure-sets.go

    					printEndpointError(endpoint, err, false)
    					disk.Close()
    					s.erasureDisksMu.Unlock()
    					return
    				}
    				s.erasureDisks[setIndex][diskIndex].Close()
    			}
    
    			disk.SetDiskID(format.Erasure.This)
    			s.erasureDisks[setIndex][diskIndex] = disk
    
    			if disk.IsLocal() {
    				globalLocalDrivesMu.Lock()
    				if globalIsDistErasure {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  7. cmd/storage-rest-server.go

    						err = fmt.Errorf("major: %v: minor: %v: %w", xl.major, xl.minor, err)
    					}
    					logFatalErrs(err, endpoint, false)
    					return false
    				}
    				storage := newXLStorageDiskIDCheck(xl, true)
    				storage.SetDiskID(xl.diskID)
    				// We do not have to do SetFormatData() since 'xl'
    				// already captures formatData cached.
    
    				globalLocalDrivesMu.Lock()
    				defer globalLocalDrivesMu.Unlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  8. cmd/xl-storage_test.go

    		return nil, "", err
    	}
    
    	disk := newXLStorageDiskIDCheck(storage, false)
    	disk.SetDiskID("da017d62-70e3-45f1-8a1a-587707e69ad1")
    	return disk, diskPath, nil
    }
    
    // createPermDeniedFile - creates temporary directory and file with path '/mybucket/myobject'
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    	s.formatFileInfo = fi
    	s.formatData = b
    	s.formatLastCheck = time.Now()
    	s.Unlock()
    	return diskID, nil
    }
    
    // Make a volume entry.
    func (s *xlStorage) SetDiskID(id string) {
    	// NO-OP for xlStorage as it is handled either by xlStorageDiskIDCheck{} for local disks or
    	// storage rest server for remote disks.
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top