- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 105 for DiskID (0.18 sec)
-
cmd/metacache-walk_gen.go
return } case "Limit": z.Limit, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Limit") return } case "DiskID": z.DiskID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "DiskID") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 7K bytes - Viewed (0) -
cmd/storage-rest-common_gen.go
zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "id": z.DiskID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "DiskID") return } case "m": z.ScanMode, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "ScanMode") return } case "c":
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 7.9K bytes - Viewed (0) -
cmd/storage-rest-client.go
defer xioutil.SafeClose(updates) st, err := storageNSScannerRPC.Call(ctx, client.gridConn, &nsScannerOptions{ DiskID: *client.diskID.Load(), ScanMode: int(scanMode), Cache: &cache, }) if err != nil { return cache, toStorageErr(err) } var final *dataUsageCache err = st.Results(func(resp *nsScannerResp) error {
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) -
cmd/storage-datatypes_gen.go
zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "id": z.DiskID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "DiskID") return } case "v": z.Volume, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Volume") return } case "fp":
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 127.5K bytes - Viewed (0) -
cmd/metacache-walk.go
FilterPrefix string // ForwardTo will forward to the given object path. ForwardTo string // Limit the number of returned objects if > 0. Limit int // DiskID contains the disk ID of the disk. // Leave empty to not check disk ID. DiskID string } // supported FS for Nlink optimization in readdir. const ( xfs = "XFS" ext4 = "EXT4" )
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/storage-datatypes.go
// CheckPartsHandlerParams are parameters for CheckPartsHandler type CheckPartsHandlerParams struct { DiskID string `msg:"id"` Volume string `msg:"v"` FilePath string `msg:"fp"` FI FileInfo `msg:"fi"` } // DeleteFileHandlerParams are parameters for DeleteFileHandler type DeleteFileHandlerParams struct { DiskID string `msg:"id"` Volume string `msg:"v"` FilePath string `msg:"fp"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cmd/storage-rest-server.go
if !s.IsAuthValid(w, r) { return false } if err := r.ParseForm(); err != nil { s.writeErrorResponse(w, err) return false } diskID := r.Form.Get(storageRESTDiskID) if diskID == "" { // 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 }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
} h.disk = disk h.ID = diskID h.mu = &sync.RWMutex{} return &h, nil } // newHealingTracker will create a new healing tracker for the disk. func newHealingTracker() *healingTracker { return &healingTracker{ mu: &sync.RWMutex{}, } } func initHealingTracker(disk StorageAPI, healID string) *healingTracker { h := newHealingTracker() diskID, _ := disk.GetDiskID()
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) -
cmd/xl-storage.go
func (s *xlStorage) GetDiskID() (string, error) { s.RLock() diskID := s.diskID fileInfo := s.formatFileInfo lastCheck := s.formatLastCheck // check if we have a valid disk ID that is less than 1 seconds old. if fileInfo != nil && diskID != "" && time.Since(lastCheck) <= 1*time.Second { s.RUnlock() return diskID, nil } s.RUnlock() fi, err := s.checkFormatJSON() if err != nil {
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) -
cmd/xl-storage-disk-id-check.go
} 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 { // For empty disk-id we allow the call as the server might be // coming up and trying to read format.json or create format.json return nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0)